android/app/src/main/java/com/nextcloud/client/database/dao/UploadDao.kt at 26eb15a7b206e6acce814ee6981178f875723bf9 · nextcloud/android · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
/*
 * Nextcloud - Android Client
 *
 * SPDX-FileCopyrightText: 2025 Alper Ozturk <[email protected]>
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */

package com.nextcloud.client.database.dao

import androidx.room.Dao
import androidx.room.Insert
import androidx.room.OnConflictStrategy
import androidx.room.Query
import com.nextcloud.client.database.entity.UploadEntity
import com.owncloud.android.db.ProviderMeta.ProviderTableMeta

@Dao
interface UploadDao {
    @Query(
        "SELECT _id FROM " + ProviderTableMeta.UPLOADS_TABLE_NAME +
            " WHERE " + ProviderTableMeta.UPLOADS_STATUS + " = :status AND " +
            ProviderTableMeta.UPLOADS_ACCOUNT_NAME + " = :accountName AND _id IS NOT NULL"
    )
    fun getAllIds(status: Int, accountName: String): List<Int>

    @Query(
        "SELECT * FROM " + ProviderTableMeta.UPLOADS_TABLE_NAME +
            " WHERE " + ProviderTableMeta._ID + " IN (:ids) AND " +
            ProviderTableMeta.UPLOADS_ACCOUNT_NAME + " = :accountName"
    )
    fun getUploadsByIds(ids: LongArray, accountName: String): List<UploadEntity>

    @Query(
        "SELECT * FROM ${ProviderTableMeta.UPLOADS_TABLE_NAME} " +
            "WHERE ${ProviderTableMeta.UPLOADS_REMOTE_PATH} = :remotePath LIMIT 1"
    )
    fun getByRemotePath(remotePath: String): UploadEntity?

    @Query(
        "DELETE FROM ${ProviderTableMeta.UPLOADS_TABLE_NAME} " +
            "WHERE ${ProviderTableMeta.UPLOADS_ACCOUNT_NAME} = :accountName " +
            "AND ${ProviderTableMeta.UPLOADS_REMOTE_PATH} = :remotePath"
    )
    fun deleteByRemotePathAndAccountName(remotePath: String, accountName: String)

    @Query(
        """
    DELETE FROM ${ProviderTableMeta.UPLOADS_TABLE_NAME}
    WHERE ${ProviderTableMeta.UPLOADS_LOCAL_PATH} = :localPath
      AND ${ProviderTableMeta.UPLOADS_REMOTE_PATH} = :remotePath
"""
    )
    suspend fun deleteByLocalRemotePath(localPath: String, remotePath: String)

    @Query(
        "SELECT * FROM " + ProviderTableMeta.UPLOADS_TABLE_NAME +
            " WHERE " + ProviderTableMeta._ID + " = :id AND " +
            ProviderTableMeta.UPLOADS_ACCOUNT_NAME + " = :accountName " +
            "LIMIT 1"
    )
    fun getUploadById(id: Long, accountName: String): UploadEntity?

    @Insert(onConflict = OnConflictStrategy.REPLACE)
    fun insertOrReplace(entity: UploadEntity): Long

    @Query(
        "SELECT * FROM " + ProviderTableMeta.UPLOADS_TABLE_NAME +
            " WHERE " + ProviderTableMeta.UPLOADS_ACCOUNT_NAME + " = :accountName AND " +
            ProviderTableMeta.UPLOADS_LOCAL_PATH + " = :localPath AND " +
            ProviderTableMeta.UPLOADS_REMOTE_PATH + " = :remotePath " +
            "LIMIT 1"
    )
    fun getUploadByAccountAndPaths(accountName: String, localPath: String, remotePath: String): UploadEntity?

    @Query(
        "UPDATE ${ProviderTableMeta.UPLOADS_TABLE_NAME} " +
            "SET ${ProviderTableMeta.UPLOADS_STATUS} = :status " +
            "WHERE ${ProviderTableMeta.UPLOADS_REMOTE_PATH} = :remotePath " +
            "AND ${ProviderTableMeta.UPLOADS_ACCOUNT_NAME} = :accountName"
    )
    suspend fun updateStatus(remotePath: String, accountName: String, status: Int): Int

    @Query(
        """
    SELECT * FROM ${ProviderTableMeta.UPLOADS_TABLE_NAME}
    WHERE ${ProviderTableMeta.UPLOADS_STATUS} = :status
      AND (:nameCollisionPolicy IS NULL OR ${ProviderTableMeta.UPLOADS_NAME_COLLISION_POLICY} = :nameCollisionPolicy)
"""
    )
    suspend fun getUploadsByStatus(status: Int, nameCollisionPolicy: Int? = null): List<UploadEntity>

    @Query(
        """
    SELECT * FROM ${ProviderTableMeta.UPLOADS_TABLE_NAME}
    WHERE ${ProviderTableMeta.UPLOADS_ACCOUNT_NAME} = :accountName
      AND ${ProviderTableMeta.UPLOADS_STATUS} = :status
      AND (:nameCollisionPolicy IS NULL OR ${ProviderTableMeta.UPLOADS_NAME_COLLISION_POLICY} = :nameCollisionPolicy)
"""
    )
    suspend fun getUploadsByAccountNameAndStatus(
        accountName: String,
        status: Int,
        nameCollisionPolicy: Int? = null
    ): List<UploadEntity>
}