| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_constant.h | 34 static constexpr const char *VERSION_FIELD = "#_version"; member in DistributedDB::CloudDbConstant
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | virtual_cloud_db.cpp | 94 extend[i][CloudDbConstant::VERSION_FIELD] = std::to_string(currentVersion_++); in InnerBatchInsert()
131 extend[i][CloudDbConstant::VERSION_FIELD] = std::to_string(currentVersion_++); in BatchInsertWithGid()
470 extend[i][CloudDbConstant::VERSION_FIELD] = std::to_string(currentVersion_++); in InnerUpdateWithoutLock()
503 if (cloudData.extend.find(CloudDbConstant::VERSION_FIELD) != cloudData.extend.end()) { in UpdateCloudData()
504 if (std::get<std::string>(data.extend[CloudDbConstant::VERSION_FIELD]) != in UpdateCloudData()
505 std::get<std::string>(cloudData.extend[CloudDbConstant::VERSION_FIELD])) { in UpdateCloudData()
509 cloudData.extend[CloudDbConstant::VERSION_FIELD] = std::to_string(currentVersion_ - 1); in UpdateCloudData()
|
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 280 entry[CloudDbConstant::VERSION_FIELD] = std::to_string(versionStart++); in UpdateCloudDBData()
425 log.insert_or_assign(CloudDbConstant::VERSION_FIELD, version); in UpdateCloudAssets()
593 CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, extend, localVersion); in HWTEST_F()
595 CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, cloudExtend, in HWTEST_F()
|
| H A D | distributeddb_cloud_syncer_download_assets_test.cpp | 250 entry[CloudDbConstant::VERSION_FIELD] = std::to_string(versionStart++); in UpdateCloudDBData()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | schema_meta.h | 59 static constexpr const char *VERSION_FIELD = "#_version"; member in OHOS::DistributedData::final
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 77 key != CloudDbConstant::VERSION_FIELD && in RemoveDataExceptExtendInfo()
192 (void)CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, in GetCloudLogInfo()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 270 downloadData.data[i].insert_or_assign(CloudDbConstant::VERSION_FIELD, std::string("11")); in AddVersionToDownloadData()
1380 extend1.insert_or_assign(CloudDbConstant::VERSION_FIELD, std::string("1")); in HWTEST_F()
1401 syncData.insData.extend[0].erase(CloudDbConstant::VERSION_FIELD); in HWTEST_F()
1485 downloadData.data[i].erase(CloudDbConstant::VERSION_FIELD); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 1097 } else if (colName == CloudDbConstant::VERSION_FIELD) { in BindUpdateLogStmtFromVBucket()
1363 GetStringFromCloudData(CloudDbConstant::VERSION_FIELD, data, dataItem.version); in GetDataItemFromCloudData()
1428 updateColName.push_back(CloudDbConstant::VERSION_FIELD); in AddUpdateColForShare()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 1236 extend.erase(CloudDbConstant::VERSION_FIELD); in HWTEST_F()
1242 if (extend.find(CloudDbConstant::VERSION_FIELD) != extend.end()) { in HWTEST_F()
1243 extend[CloudDbConstant::VERSION_FIELD] = ""; in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 603 logInfo.insert_or_assign(CloudDbConstant::VERSION_FIELD, version); in GetCloudLog()
1889 updateColName.push_back(CloudDbConstant::VERSION_FIELD); in GetUpdateLogRecordStatement()
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 260 if (CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, in BindUpdateVersionStatement()
1897 errCode = CloudStorageUtils::GetValueFromVBucket<std::string>(CloudDbConstant::VERSION_FIELD, vBucket, version); in BindShareValueToInsertLogStatement()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_executor_utils.cpp | 177 logInfo.insert_or_assign(CloudDbConstant::VERSION_FIELD, version); in GetCloudLog()
886 CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::VERSION_FIELD, data.extend[i], dataItem.version); in FillCloudGid()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_check_sync_test.cpp | 2414 log.insert_or_assign(CloudDbConstant::VERSION_FIELD, std::string("1")); in HWTEST_F()
2416 log.insert_or_assign(CloudDbConstant::VERSION_FIELD, std::string("2")); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1845 recordCopy[CloudDbConstant::VERSION_FIELD] = dataInfoWithLog.logInfo.version; in UpsertDataInTransaction()
|