| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | cloud_upload_recorder.h | 28 …void RecordUploadRecord(const std::string &table, const Bytes &hashKey, const CloudWaterType &type,
30 …bool IsIgnoreUploadRecord(const std::string &table, const Bytes &hashKey, const CloudWaterType &ty…
32 …void ReleaseUploadRecord(const std::string &table, const CloudWaterType &type, Timestamp localWate…
39 using TableUploadRecord = std::map<CloudWaterType, std::map<Bytes, int64_t>>;
|
| H A D | cloud_meta_data.h | 37 …int GetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp &localMark);
41 … int SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timestamp localMark);
|
| H A D | cloud_storage_utils.h | 119 …LogInfo &logInfo, const VBucket &uploadExtend = {}, const CloudWaterType &type = CloudWaterType::B…
121 …LogInfo &logInfo, const VBucket &uploadExtend = {}, const CloudWaterType &type = CloudWaterType::B…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_meta_data.cpp | 43 int CloudMetaData::GetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timesta… in GetLocalWaterMarkByType()
53 if (type == CloudWaterType::INSERT) { in GetLocalWaterMarkByType()
55 } else if (type == CloudWaterType::UPDATE) { in GetLocalWaterMarkByType()
57 } else if (type == CloudWaterType::DELETE) { in GetLocalWaterMarkByType()
101 int CloudMetaData::SetLocalWaterMarkByType(const TableName &tableName, CloudWaterType type, Timesta… in SetLocalWaterMarkByType()
110 if (type == CloudWaterType::DELETE) { in SetLocalWaterMarkByType()
112 } else if (type == CloudWaterType::UPDATE) { in SetLocalWaterMarkByType()
115 } else if (type == CloudWaterType::INSERT) { in SetLocalWaterMarkByType()
|
| H A D | cloud_upload_recorder.cpp | 19 …der::RecordUploadRecord(const std::string &table, const Bytes &hashKey, const CloudWaterType &type, in RecordUploadRecord()
27 const CloudWaterType &type, int64_t modifyTime) const in IsIgnoreUploadRecord()
46 void CloudUploadRecorder::ReleaseUploadRecord(const std::string &table, const CloudWaterType &type, in ReleaseUploadRecord()
|
| H A D | cloud_storage_utils.cpp | 1126 const LogInfo &logInfo, const VBucket &uploadExtend, const CloudWaterType &type) in GetUpdateRecordFlagSql()
1141 (type == CloudWaterType::UPDATE || type == CloudWaterType::DELETE)) { in GetUpdateRecordFlagSql()
1162 const LogInfo &logInfo, const VBucket &uploadExtend, const CloudWaterType &type) in GetUpdateRecordFlagSqlUpload()
1179 (type == CloudWaterType::UPDATE || type == CloudWaterType::DELETE)) { in GetUpdateRecordFlagSqlUpload()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_query_helper.h | 31 enum class CloudWaterType; variable
105 const bool &isCloudForcePush, bool isCompensatedTask, CloudWaterType mode);
107 …etCountRelationalCloudQuerySql(bool isCloudForcePush, bool isCompensatedTask, CloudWaterType mode);
117 …int GetCountKvCloudDataStatement(sqlite3 *db, bool forcePush, const CloudWaterType mode, sqlite3_s…
124 …ir<int, sqlite3_stmt *> GetKvCloudQueryStmt(sqlite3 *db, bool forcePush, const CloudWaterType mode,
129 …static void AppendCloudQueryToGetDiffData(std::string &sql, const CloudWaterType mode, bool isKv =…
162 …ndCloudQuery(bool isCloudForcePush, bool isCompensatedTask, std::string &sql, CloudWaterType mode);
|
| H A D | sqlite_query_helper.cpp | 1153 const bool &isCloudForcePush, bool isCompensatedTask, CloudWaterType mode) in GetRelationalCloudQuerySql()
1162 CloudWaterType mode) in GetCountRelationalCloudQuerySql()
1178 CloudWaterType mode) in AppendCloudQuery()
1183 if (mode == CloudWaterType::INSERT) { in AppendCloudQuery()
1187 if (isCompensatedTask && mode == CloudWaterType::DELETE) { in AppendCloudQuery()
1206 void SqliteQueryHelper::AppendCloudQueryToGetDiffData(std::string &sql, const CloudWaterType mode, … in AppendCloudQueryToGetDiffData()
1209 case DistributedDB::CloudWaterType::DELETE: in AppendCloudQueryToGetDiffData()
1213 case DistributedDB::CloudWaterType::UPDATE: in AppendCloudQueryToGetDiffData()
1217 case DistributedDB::CloudWaterType::INSERT: in AppendCloudQueryToGetDiffData()
1267 const CloudWaterType mode, int64_t timeStamp, const std::string &user) in GetKvCloudQueryStmt()
[all …]
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 76 case DistributedDB::CloudWaterType::DELETE: in UpdateBeginTimeForMemoryDB()
79 case DistributedDB::CloudWaterType::UPDATE: in UpdateBeginTimeForMemoryDB()
82 case DistributedDB::CloudWaterType::INSERT: in UpdateBeginTimeForMemoryDB()
85 case DistributedDB::CloudWaterType::BUTT: in UpdateBeginTimeForMemoryDB()
500 OpType SqliteCloudKvExecutorUtils::TransToOpType(const CloudWaterType type) in TransToOpType()
503 case CloudWaterType::INSERT: in TransToOpType()
505 case CloudWaterType::UPDATE: in TransToOpType()
507 case CloudWaterType::DELETE: in TransToOpType()
1057 std::vector<CloudWaterType> typeVec = DBCommon::GetWaterTypeVec(); in CountAllCloudData()
1418 (type == CloudWaterType::UPDATE || type == CloudWaterType::DELETE)) { in BindFillGidLogStmt()
[all …]
|
| H A D | sqlite_cloud_kv_executor_utils.h | 96 static OpType TransToOpType(const CloudWaterType type);
134 const CloudWaterType &type, CloudUploadRecorder &recorder);
159 const DataItem &dataItem, const VBucket &uploadExtend, const CloudWaterType &type);
|
| H A D | sqlite_single_ver_continue_token.h | 65 const CloudWaterType mode);
|
| H A D | sqlite_single_ver_continue_token.cpp | 145 bool &stepNext, const CloudWaterType mode) in GetCloudQueryStmt()
|
| H A D | sqlite_cloud_kv_store.h | 100 …void ReleaseUploadRecord(const std::string &tableName, const CloudWaterType &type, Timestamp local…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | db_common.h | 40 static inline const std::vector<CloudWaterType> GetWaterTypeVec() in GetWaterTypeVec()
42 return {CloudWaterType::DELETE, CloudWaterType::UPDATE, CloudWaterType::INSERT}; in GetWaterTypeVec()
136 static bool IsNeedCompensatedForUpload(const VBucket &uploadExtend, const CloudWaterType &type);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_types.h | 23 enum class CloudWaterType { enum
50 CloudWaterType mode;
53 …CloudSyncData(const std::string &_tableName, CloudWaterType _mode) : tableName(_tableName), mode(_… in CloudSyncData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | storage_proxy.h | 44 …int GetLocalWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMar…
48 int PutWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &localMark);
156 …void ReleaseUploadRecord(const std::string &table, const CloudWaterType &type, Timestamp localWate…
|
| H A D | icloud_sync_storage_interface.h | 233 [[gnu::unused]] const CloudWaterType &type, Timestamp localMark)
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_db_proxy.cpp | 316 context->SetInfo(CloudWaterType::INSERT, status); in DMLActionTask()
322 context->SetInfo(CloudWaterType::UPDATE, status); in DMLActionTask()
328 context->SetInfo(CloudWaterType::DELETE, status); in DMLActionTask()
600 void CloudDBProxy::CloudActionContext::SetInfo(const CloudWaterType &type, DBStatus status) in SetInfo()
613 if (IsRecordActionFail(extend, type == CloudWaterType::INSERT, status)) { in SetInfo()
|
| H A D | cloud_sync_utils.h | 88 static int FillAssetIdToAssets(CloudSyncBatch &data, int errorCode, const CloudWaterType &type);
|
| H A D | cloud_db_proxy.h | 113 void SetInfo(const CloudWaterType &type, DBStatus status);
|
| H A D | cloud_syncer.h | 116 CloudWaterType mode = CloudWaterType::DELETE;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_proxy.cpp | 68 int StorageProxy::GetLocalWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timest… in GetLocalWaterMarkByMode()
94 int StorageProxy::PutWaterMarkByMode(const std::string &tableName, CloudWaterType mode, Timestamp &… in PutWaterMarkByMode()
177 std::vector<CloudWaterType> waterTypeVec = DBCommon::GetWaterTypeVec(); in GetUploadCount()
685 void StorageProxy::ReleaseUploadRecord(const std::string &table, const CloudWaterType &type, Timest… in ReleaseUploadRecord()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_meta_data_test.cpp | 220 …EXPECT_EQ(proxyObj.GetLocalWaterMarkByMode(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark), -E…
222 …EXPECT_EQ(proxyObj.PutWaterMarkByMode(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark), -E_INVA…
223 proxyObj.ReleaseUploadRecord(TABLE_NAME_1, CloudWaterType::INSERT, retLocalMark);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 229 …void ReleaseUploadRecord(const std::string &tableName, const CloudWaterType &type, Timestamp local…
246 const CloudSyncBatch &updateData, const CloudWaterType &type, bool isLock = false);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | db_common.cpp | 729 bool DBCommon::IsNeedCompensatedForUpload(const VBucket &uploadExtend, const CloudWaterType &type) in IsNeedCompensatedForUpload()
731 … return (DBCommon::IsCloudRecordAlreadyExisted(uploadExtend) && type == CloudWaterType::INSERT) || in IsNeedCompensatedForUpload()
732 (DBCommon::IsCloudRecordNotFound(uploadExtend) && type == CloudWaterType::UPDATE); in IsNeedCompensatedForUpload()
|