| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 74 key != CloudDbConstant::MODIFY_FIELD && in RemoveDataExceptExtendInfo()
185 cloudLogInfo.timestamp = (Timestamp)std::get<int64_t>(datum[CloudDbConstant::MODIFY_FIELD]); in GetCloudLogInfo()
258 … if (extendData.empty() || extendData.find(CloudDbConstant::MODIFY_FIELD) == extendData.end()) { in GetWaterMarkAndUpdateTime()
262 if (TYPE_INDEX<int64_t> != extendData.at(CloudDbConstant::MODIFY_FIELD).index()) { in GetWaterMarkAndUpdateTime()
274 …rk = std::max(int64_t(waterMark), std::get<int64_t>(extendData.at(CloudDbConstant::MODIFY_FIELD))); in GetWaterMarkAndUpdateTime()
276 … std::get<int64_t>(extendData.at(CloudDbConstant::MODIFY_FIELD)) / CloudDbConstant::TEN_THOUSAND; in GetWaterMarkAndUpdateTime()
279 extendData.insert_or_assign(CloudDbConstant::MODIFY_FIELD, modifyTime); in GetWaterMarkAndUpdateTime()
296 …int64_t modifyTime = std::get<int64_t>(data[CloudDbConstant::MODIFY_FIELD]) * CloudDbConstant::TEN… in ModifyCloudDataTime()
298 data[CloudDbConstant::MODIFY_FIELD] = modifyTime; in ModifyCloudDataTime()
|
| /ohos5.0/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,
128 let modify_field = match ext.get(MODIFY_FIELD) { in batch_delete()
260 let modify_field = match ext.get(MODIFY_FIELD) { in upload()
|
| H A D | types.rs | 22 pub(crate) const MODIFY_FIELD: &str = "#_modifyTime";
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/ |
| H A D | cloud_db_constant.h | 28 static constexpr const char *MODIFY_FIELD = "#_modifyTime"; variable
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/ |
| H A D | cloud_cursor_impl.cpp | 27 { DistributedData::SchemaMeta::MODIFY_FIELD, "modifyTime" }
166 entry[DBSchemaMeta::MODIFY_FIELD] = GetExtend(vBucket, MODIFY_TIME_KEY); in GetEntry()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | schema_meta.h | 56 static constexpr const char *MODIFY_FIELD = "#_modifyTime"; variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_save_cloud_data_test.cpp | 819 vBucket[CloudDbConstant::MODIFY_FIELD] = mTime; in ConstructDownloadData()
1037 vBucket[CloudDbConstant::MODIFY_FIELD] = mTime; in ConstructMultiDownloadData()
1157 vBucket[CloudDbConstant::MODIFY_FIELD] = BASE_MODIFY_TIME;
1192 vBucket[CloudDbConstant::MODIFY_FIELD] = BASE_MODIFY_TIME;
1257 vBucket[CloudDbConstant::MODIFY_FIELD] = BASE_MODIFY_TIME; in DeleteWithPkTest()
|
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 235 … log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in InsertRecordWithoutPk2LocalAndCloud()
271 …log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND +… in InsertCloudTableRecord()
400 … log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in UpdateDiffType()
957 … log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in UpdateCloudAssetForDownloadAssetTest003()
1023 … log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in InsertCloudForCloudProcessNotify001()
1575 … log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND);
|
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 275 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, static_cast<int64_t>( in UpdateCloudTableRecord()
657 log.insert_or_assign(DistributedDB::CloudDbConstant::MODIFY_FIELD, static_cast<int64_t>( in InsertCloudAssetData()
|
| H A D | distributeddb_cloud_reference_sync_test.cpp | 289 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in InsertCloudSharedTableRecord()
326 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in UpdateCloudSharedTableRecord()
|
| H A D | distributeddb_cloud_check_sync_test.cpp | 342 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, static_cast<int64_t>( in InsertCloudTableRecord()
2303 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, static_cast<int64_t>(
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_syncer_lock_test.cpp | 227 … log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in GenerateDataRecords()
294 …log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND +… in DeleteCloudDBData()
422 … log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in UpdateCloudAssets()
|
| H A D | cloud_db_sync_utils_test.cpp | 100 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in InsertCloudTableRecord()
131 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in UpdateCloudTableRecord()
|
| H A D | distributeddb_cloud_syncer_download_test.cpp | 97 data.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)i); in GetRetCloudData()
143 data.insert_or_assign(CloudDbConstant::MODIFY_FIELD, std::to_string(i)); in GetInvalidTypeCloudData()
177 data.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)i); in GetInvalidFieldCloudData()
|
| H A D | cloud_syncer_test.h | 200 VBucket tmp = { std::pair<std::string, int64_t>(CloudDbConstant::MODIFY_FIELD, 1), in initFullCloudSyncData()
|
| H A D | distributeddb_cloud_syncer_upload_test.cpp | 95 tmp = { pair<std::string, int64_t>(CloudDbConstant::MODIFY_FIELD, 1), in PrepareRecord()
401 VBucket tmp = {pair<std::string, int64_t>(CloudDbConstant::MODIFY_FIELD, 1)};
627 VBucket tmp = {pair<std::string, int64_t>(CloudDbConstant::MODIFY_FIELD, 1)};
|
| H A D | virtual_cloud_db.cpp | 30 const char *g_modifiedField = CloudDbConstant::MODIFY_FIELD;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_storage_utils.cpp | 1093 } else if (colName == CloudDbConstant::MODIFY_FIELD) { in BindUpdateLogStmtFromVBucket()
1231 … errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::MODIFY_FIELD, data, modifyTime); in BindStepConsistentFlagStmt()
1370 GetUInt64FromCloudData(CloudDbConstant::MODIFY_FIELD, data, dataItem.modifyTime); in GetDataItemFromCloudData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 607 logInfo.insert_or_assign(CloudDbConstant::MODIFY_FIELD, modifyTime); in GetCloudLog()
1857 updateColName.push_back(CloudDbConstant::MODIFY_FIELD); in GetUpdateLogRecordStatement()
1866 updateColName.push_back(CloudDbConstant::MODIFY_FIELD); in GetUpdateLogRecordStatement()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/ |
| H A D | cloudsync_fuzzer.cpp | 230 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in InsertCloudTableRecord()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 478 item[CloudDbConstant::MODIFY_FIELD] = static_cast<int64_t>(rawSystemTime); in FillTimestamp()
|
| H A D | sqlite_cloud_kv_executor_utils.cpp | 65 auto it = lastRecord.find(CloudDbConstant::MODIFY_FIELD); in GetMaxTimeStamp()
146 logInfo.insert_or_assign(CloudDbConstant::MODIFY_FIELD, modifyTime); in GetCloudLog()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 299 …log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND +… in InsertCloudTableRecord()
394 …log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND +… in DeleteCloudTableRecord()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_multi_sub_user_test.cpp | 328 … log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in GenerateDataRecords()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1833 recordCopy[CloudDbConstant::MODIFY_FIELD] = static_cast<int64_t>(currentTime); in UpsertDataInTransaction()
1839 …recordCopy[CloudDbConstant::MODIFY_FIELD] = static_cast<int64_t>(dataInfoWithLog.logInfo.timestamp… in UpsertDataInTransaction()
|