Home
last modified time | relevance | path

Searched refs:MODIFY_FIELD (Results 1 - 25 of 32) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_sync_utils.cpp74 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()
259 LOGE("[CloudSyncer] VBucket is empty or MODIFY_FIELD doesn't exist."); in GetWaterMarkAndUpdateTime()
262 if (TYPE_INDEX<int64_t> != extendData.at(CloudDbConstant::MODIFY_FIELD).index()) { in GetWaterMarkAndUpdateTime()
263 LOGE("[CloudSyncer] VBucket's MODIFY_FIELD doesn't fit int64_t."); in GetWaterMarkAndUpdateTime()
274 waterMark = 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]) * CloudDbConstan in ModifyCloudDataTime()
[all...]
H A Dcloud_db_proxy.cpp77 int errCode = CloudStorageUtils::GetValueFromVBucket<int64_t>(CloudDbConstant::MODIFY_FIELD, data[0], first); in RecordSyncDataTimeStampLog()
84 errCode = CloudStorageUtils::GetValueFromVBucket<int64_t>(CloudDbConstant::MODIFY_FIELD, data[data.size() - 1], in RecordSyncDataTimeStampLog()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/
H A Dcloud_db_constant.h28 static constexpr const char *MODIFY_FIELD = "#_modifyTime"; member in DistributedDB::CloudDbConstant
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/
H A Dcloud_db.rs18 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 Dtypes.rs22 pub(crate) const MODIFY_FIELD: &str = "#_modifyTime";
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dschema_meta.h56 static constexpr const char *MODIFY_FIELD = "#_modifyTime"; member in OHOS::DistributedData::final
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dcloud_cursor_impl.cpp27 { DistributedData::SchemaMeta::MODIFY_FIELD, "modifyTime" }
166 entry[DBSchemaMeta::MODIFY_FIELD] = GetExtend(vBucket, MODIFY_TIME_KEY); in GetEntry()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dcloud_db_sync_utils_test.cpp100 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in InsertCloudTableRecord()
131 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in UpdateCloudTableRecord()
H A Ddistributeddb_cloud_syncer_lock_test.cpp227 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 + i); in DeleteCloudDBData()
422 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND); in UpdateCloudAssets()
H A Ddistributeddb_cloud_syncer_download_test.cpp97 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 Dcloud_syncer_test.h200 VBucket tmp = { std::pair<std::string, int64_t>(CloudDbConstant::MODIFY_FIELD, 1), in initFullCloudSyncData()
H A Ddistributeddb_cloud_syncer_upload_test.cpp95 tmp = { pair<std::string, int64_t>(CloudDbConstant::MODIFY_FIELD, 1), in PrepareRecord()
401 VBucket tmp = {pair<std::string, int64_t>(CloudDbConstant::MODIFY_FIELD, 1)}; in HWTEST_F()
627 VBucket tmp = {pair<std::string, int64_t>(CloudDbConstant::MODIFY_FIELD, 1)}; in HWTEST_F()
H A Dvirtual_cloud_db.cpp30 const char *g_modifiedField = CloudDbConstant::MODIFY_FIELD;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_save_cloud_data_test.cpp819 vBucket[CloudDbConstant::MODIFY_FIELD] = mTime; in ConstructDownloadData()
1037 vBucket[CloudDbConstant::MODIFY_FIELD] = mTime; in ConstructMultiDownloadData()
1157 vBucket[CloudDbConstant::MODIFY_FIELD] = BASE_MODIFY_TIME; in HWTEST_F()
1192 vBucket[CloudDbConstant::MODIFY_FIELD] = BASE_MODIFY_TIME; in HWTEST_F()
1257 vBucket[CloudDbConstant::MODIFY_FIELD] = BASE_MODIFY_TIME; in DeleteWithPkTest()
H A Ddistributeddb_cloud_interfaces_relational_sync_test.cpp235 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 + i); 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); in HWTEST_F()
H A Ddistributeddb_cloud_reference_sync_test.cpp289 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in InsertCloudSharedTableRecord()
326 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in UpdateCloudSharedTableRecord()
H A Ddistributeddb_cloud_check_sync_test.cpp372 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, static_cast<int64_t>( in InsertCloudTableRecord()
2411 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, static_cast<int64_t>( in HWTEST_F()
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp274 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, static_cast<int64_t>( in UpdateCloudTableRecord()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp581 logInfo.insert_or_assign(CloudDbConstant::MODIFY_FIELD, modifyTime); in GetCloudLog()
1881 updateColName.push_back(CloudDbConstant::MODIFY_FIELD); in GetUpdateLogRecordStatement()
1892 updateColName.push_back(CloudDbConstant::MODIFY_FIELD); in GetUpdateLogRecordStatement()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_storage_utils.cpp1091 } else if (colName == CloudDbConstant::MODIFY_FIELD) { in BindUpdateLogStmtFromVBucket()
1229 errCode = CloudStorageUtils::GetValueFromVBucket(CloudDbConstant::MODIFY_FIELD, data, modifyTime); in BindStepConsistentFlagStmt()
1368 GetUInt64FromCloudData(CloudDbConstant::MODIFY_FIELD, data, dataItem.modifyTime); in GetDataItemFromCloudData()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/
H A Dcloudsync_fuzzer.cpp230 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, in InsertCloudTableRecord()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_store.cpp478 item[CloudDbConstant::MODIFY_FIELD] = static_cast<int64_t>(rawSystemTime); in FillTimestamp()
H A Dsqlite_cloud_kv_executor_utils.cpp65 auto it = lastRecord.find(CloudDbConstant::MODIFY_FIELD); in GetMaxTimeStamp()
155 logInfo.insert_or_assign(CloudDbConstant::MODIFY_FIELD, modifyTime); in GetCloudLog()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_set_cloud_schema_test.cpp316 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND + i); in InsertCloudTableRecord()
411 log.insert_or_assign(CloudDbConstant::MODIFY_FIELD, (int64_t)now / CloudDbConstant::TEN_THOUSAND + i); in DeleteCloudTableRecord()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp1836 recordCopy[CloudDbConstant::MODIFY_FIELD] = static_cast<int64_t>(currentTime); in UpsertDataInTransaction()
1842 recordCopy[CloudDbConstant::MODIFY_FIELD] = static_cast<int64_t>(dataInfoWithLog.logInfo.timestamp); in UpsertDataInTransaction()

Completed in 45 milliseconds

12