/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
H A D | sqlite_query_helper.h | 105 const bool &isCloudForcePush, bool isCompensatedTask, CloudWaterType mode); 107 …std::string GetCountRelationalCloudQuerySql(bool isCloudForcePush, bool isCompensatedTask, CloudWa… 109 … std::string GetGidRelationalCloudQuerySql(const std::vector<Field> &fields, bool isCloudForcePush, 162 …void AppendCloudQuery(bool isCloudForcePush, bool isCompensatedTask, std::string &sql, CloudWaterT… 164 void AppendCloudGidQuery(bool isCloudForcePush, bool isCompensatedTask, std::string &sql);
|
H A D | sqlite_cloud_kv_store.h | 46 …int GetUploadCount(const QuerySyncObject &query, const Timestamp ×tamp, bool isCloudForcePush, 50 bool isCloudForcePush, bool isCompensatedTask, int64_t &count) override; 57 …dGid(const TableSchema &tableSchema, const QuerySyncObject &querySyncObject, bool isCloudForcePush,
|
H A D | sqlite_query_helper.cpp | 1153 const bool &isCloudForcePush, bool isCompensatedTask, CloudWaterType mode) in GetRelationalCloudQuerySql() argument 1156 AppendCloudQuery(isCloudForcePush, isCompensatedTask, sql, mode); in GetRelationalCloudQuerySql() 1161 std::string SqliteQueryHelper::GetCountRelationalCloudQuerySql(bool isCloudForcePush, bool isCompen… in GetCountRelationalCloudQuerySql() argument 1165 AppendCloudQuery(isCloudForcePush, isCompensatedTask, sql, mode); in GetCountRelationalCloudQuerySql() 1170 bool isCloudForcePush, bool isCompensatedTask) in GetGidRelationalCloudQuerySql() argument 1173 AppendCloudGidQuery(isCloudForcePush, isCompensatedTask, sql); in GetGidRelationalCloudQuerySql() 1177 void SqliteQueryHelper::AppendCloudQuery(bool isCloudForcePush, bool isCompensatedTask, std::string… in AppendCloudQuery() argument 1193 if (isCloudForcePush) { in AppendCloudQuery() 1226 void SqliteQueryHelper::AppendCloudGidQuery(bool isCloudForcePush, bool isCompensatedTask, std::str… in AppendCloudGidQuery() argument 1235 …sql += isCloudForcePush ? " (b.flag & 0x04 != 0x04) AND (b.cloud_gid != '') " : " (b.cloud_gid != … in AppendCloudGidQuery()
|
H A D | sqlite_cloud_kv_store.cpp | 149 const Timestamp ×tamp, bool isCloudForcePush, [[gnu::unused]] bool isCompensatedTask, 159 isCloudForcePush); 164 …const std::vector<Timestamp> ×tampVec, bool isCloudForcePush, [[gnu::unused]] bool isCompensa… 175 isCloudForcePush, queryObj); 349 bool isCloudForcePush, bool isCompensatedTask, std::vector<std::string> &cloudGid) in GetCloudGid() argument
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
H A D | storage_proxy.h | 60 …tUploadCount(const std::string &tableName, const Timestamp ×tamp, const bool isCloudForcePush, 63 …int GetUploadCount(const QuerySyncObject &query, const bool isCloudForcePush, bool isCompensatedTa… 66 …int GetUploadCount(const QuerySyncObject &query, const Timestamp &localMark, bool isCloudForcePush, 77 int GetCloudGid(const QuerySyncObject &querySyncObject, bool isCloudForcePush,
|
H A D | icloud_sync_storage_interface.h | 112 …int GetUploadCount(const QuerySyncObject &query, const Timestamp ×tamp, bool isCloudForcePush, 116 bool isCloudForcePush, bool isCompensatedTask, int64_t &count) = 0; 124 bool isCloudForcePush, bool isCompensatedTask, std::vector<std::string> &cloudGid) = 0;
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
H A D | storage_proxy.cpp | 165 int StorageProxy::GetUploadCount(const QuerySyncObject &query, const bool isCloudForcePush, in GetUploadCount() argument 189 … return store_->GetAllUploadCount(query, timeStampVec, isCloudForcePush, isCompensatedTask, count); in GetUploadCount() 193 const bool isCloudForcePush, int64_t &count) in GetUploadCount() argument 205 return store_->GetUploadCount(query, localMark, isCloudForcePush, false, count); in GetUploadCount() 209 bool isCloudForcePush, bool isCompensatedTask, int64_t &count) in GetUploadCount() argument 219 return store_->GetUploadCount(query, localMark, isCloudForcePush, isCompensatedTask, count); in GetUploadCount() 262 int StorageProxy::GetCloudGid(const QuerySyncObject &querySyncObject, bool isCloudForcePush, in GetCloudGid() argument 274 …return store_->GetCloudGid(tableSchema, querySyncObject, isCloudForcePush, isCompensatedTask, clou… in GetCloudGid()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
H A D | relational_sync_able_storage.h | 143 …int GetUploadCount(const QuerySyncObject &query, const Timestamp ×tamp, bool isCloudForcePush, 147 bool isCloudForcePush, bool isCompensatedTask, int64_t &count) override; 154 …dGid(const TableSchema &tableSchema, const QuerySyncObject &querySyncObject, bool isCloudForcePush,
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
H A D | relational_sync_able_storage.cpp | 1069 …const std::vector<Timestamp> ×tampVec, bool isCloudForcePush, bool isCompensatedTask, int64_t… in GetAllUploadCount() argument 1078 …errCode = handle->GetAllUploadCount(timestampVec, isCloudForcePush, isCompensatedTask, queryObj, c… in GetAllUploadCount() 1086 bool isCloudForcePush, bool isCompensatedTask, int64_t &count) in GetUploadCount() argument 1095 … errCode = handle->GetUploadCount(timestamp, isCloudForcePush, isCompensatedTask, queryObj, count); in GetUploadCount() 1157 bool isCloudForcePush, bool isCompensatedTask, std::vector<std::string> &cloudGid) in GetCloudGid() argument 1169 …errCode = handle->GetSyncCloudGid(query, syncTimeRange, isCloudForcePush, isCompensatedTask, cloud… in GetCloudGid()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
H A D | sqlite_single_ver_relational_storage_executor.h | 115 int GetUploadCount(const Timestamp ×tamp, bool isCloudForcePush, bool isCompensatedTask, 118 …int GetAllUploadCount(const std::vector<Timestamp> ×tampVec, bool isCloudForcePush, bool isCo…
|
H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 1432 …ngleVerRelationalStorageExecutor::GetUploadCount(const Timestamp ×tamp, bool isCloudForcePush, in GetUploadCount() argument 1440 std::string sql = helper.GetCountRelationalCloudQuerySql(isCloudForcePush, isCompensatedTask, in GetUploadCount() 1446 bool isCloudForcePush, bool isCompensatedTask, QuerySyncObject &query, int64_t &count) in GetAllUploadCount() argument 1459 …std::string sql = helper.GetCountRelationalCloudQuerySql(isCloudForcePush, isCompensatedTask, type… in GetAllUploadCount()
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
H A D | cloud_syncer_extend.cpp | 107 bool isCloudForcePush = cloudTaskInfos_[taskId].mode == SYNC_MODE_CLOUD_FORCE_PUSH; in GetCloudGid() local 108 …int errCode = storageProxy_->GetCloudGid(obj, isCloudForcePush, IsCompensatedTask(taskId), cloudGi… in GetCloudGid()
|