| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 73 key != CloudDbConstant::CREATE_FIELD && in RemoveDataExceptExtendInfo()
186 cloudLogInfo.wTimestamp = (Timestamp)std::get<int64_t>(datum[CloudDbConstant::CREATE_FIELD]); in GetCloudLogInfo()
266 if (extendData.empty() || extendData.find(CloudDbConstant::CREATE_FIELD) == extendData.end()) { in GetWaterMarkAndUpdateTime()
267 LOGE("[CloudSyncer] VBucket is empty or CREATE_FIELD doesn't exist."); in GetWaterMarkAndUpdateTime()
270 if (TYPE_INDEX<int64_t> != extendData.at(CloudDbConstant::CREATE_FIELD).index()) { in GetWaterMarkAndUpdateTime()
271 LOGE("[CloudSyncer] VBucket's CREATE_FIELD doesn't fit int64_t."); in GetWaterMarkAndUpdateTime()
278 std::get<int64_t>(extendData.at(CloudDbConstant::CREATE_FIELD)) / CloudDbConstant::TEN_THOUSAND; in GetWaterMarkAndUpdateTime()
280 extendData.insert_or_assign(CloudDbConstant::CREATE_FIELD, createTime); in GetWaterMarkAndUpdateTime()
297 int64_t createTime = std::get<int64_t>(data[CloudDbConstant::CREATE_FIELD]) * CloudDbConstant::TEN_THOUSAND; in ModifyCloudDataTime()
299 data[CloudDbConstant::CREATE_FIELD] in ModifyCloudDataTime()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_constant.h | 27 static constexpr const char *CREATE_FIELD = "#_createTime"; member in DistributedDB::CloudDbConstant
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | schema_meta.h | 55 static constexpr const char *CREATE_FIELD = "#_createTime"; member in OHOS::DistributedData::final
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/ |
| H A D | cloud_db.rs | 18 Database, RawValueBucket, Value, CREATE_FIELD, GID_FIELD, MODIFY_FIELD,
255 let create_field = match ext.get(CREATE_FIELD) { in upload()
|
| H A D | types.rs | 21 pub(crate) const CREATE_FIELD: &str = "#_createTime";
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_cursor_impl.cpp | 26 { DistributedData::SchemaMeta::CREATE_FIELD, "createTime" },
165 entry[DBSchemaMeta::CREATE_FIELD] = GetExtend(vBucket, CREATE_TIME_KEY); in GetEntry()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_db_sync_utils_test.cpp | 98 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, in InsertCloudTableRecord()
129 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, in UpdateCloudTableRecord()
|
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 226 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in GenerateDataRecords()
293 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND + i); in DeleteCloudDBData()
421 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in UpdateCloudAssets()
|
| H A D | distributeddb_cloud_syncer_download_test.cpp | 96 data.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)i); in GetRetCloudData()
140 data.insert_or_assign(CloudDbConstant::CREATE_FIELD, (Bytes)i); in GetInvalidTypeCloudData()
174 data.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)i); in GetInvalidFieldCloudData()
|
| H A D | cloud_syncer_test.h | 201 std::pair<std::string, int64_t>(CloudDbConstant::CREATE_FIELD, 1), in initFullCloudSyncData()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 479 if (item.find(CloudDbConstant::CREATE_FIELD) == item.end()) { in FillTimestamp()
480 item[CloudDbConstant::CREATE_FIELD] = static_cast<int64_t>(rawSystemTime); in FillTimestamp()
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 156 logInfo.insert_or_assign(CloudDbConstant::CREATE_FIELD, in GetCloudLog()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 234 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in InsertRecordWithoutPk2LocalAndCloud()
270 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND + i); in InsertCloudTableRecord()
399 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in UpdateDiffType()
956 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in UpdateCloudAssetForDownloadAssetTest003()
1022 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in InsertCloudForCloudProcessNotify001()
1574 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in HWTEST_F()
1577 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in HWTEST_F()
|
| H A D | distributeddb_cloud_reference_sync_test.cpp | 287 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, in InsertCloudSharedTableRecord()
324 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, in UpdateCloudSharedTableRecord()
|
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 817 vBucket[CloudDbConstant::CREATE_FIELD] = cTime; in ConstructDownloadData()
1035 vBucket[CloudDbConstant::CREATE_FIELD] = cTime; in ConstructMultiDownloadData()
|
| H A D | distributeddb_cloud_check_sync_test.cpp | 370 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, static_cast<int64_t>( in InsertCloudTableRecord()
2409 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, static_cast<int64_t>( in HWTEST_F()
|
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 272 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, static_cast<int64_t>( in UpdateCloudTableRecord()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_cloud_syncable_storage_test.cpp | 261 vBucket[CloudDbConstant::CREATE_FIELD] = mTime; in ConstructMultiDownloadData()
754 bucket2.insert_or_assign(CloudDbConstant::CREATE_FIELD, 2L); // 2L is random field in HWTEST_F()
773 bucket2.insert_or_assign(CloudDbConstant::CREATE_FIELD, std::string("2")); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/ |
| H A D | cloudsync_fuzzer.cpp | 228 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, in InsertCloudTableRecord()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 315 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND + i); in InsertCloudTableRecord()
410 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND + i); in DeleteCloudTableRecord()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1837 recordCopy[CloudDbConstant::CREATE_FIELD] = static_cast<int64_t>(currentTime); in UpsertDataInTransaction()
1843 recordCopy[CloudDbConstant::CREATE_FIELD] = static_cast<int64_t>(dataInfoWithLog.logInfo.wTimestamp); in UpsertDataInTransaction()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_multi_sub_user_test.cpp | 327 log.insert_or_assign(CloudDbConstant::CREATE_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in GenerateDataRecords()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 582 logInfo.insert_or_assign(CloudDbConstant::CREATE_FIELD, in GetCloudLog()
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 855 errCode = CloudStorageUtils::GetValueFromVBucket<int64_t>(CloudDbConstant::CREATE_FIELD, vBucket, val); in BindValueToInsertLogStatement()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_tools_unit_test.cpp | 1424 log.insert_or_assign(DistributedDB::CloudDbConstant::CREATE_FIELD, static_cast<int64_t>( in InsertCloudRecord()
|