Home
last modified time | relevance | path

Searched refs:dataItem (Results 1 – 25 of 47) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_executor_cache.cpp92 DataItem dataItem; in RemoveDeviceDataInCacheMode() local
93 dataItem.key = REMOVE_DEVICE_DATA_KEY; in RemoveDeviceDataInCacheMode()
94 dataItem.value = devVect; in RemoveDeviceDataInCacheMode()
177 if (!dataItem.value.empty()) { in MigrateRmDevData()
262 …int errCode = PutIntoConflictAndCommitForMigrateCache(dataItem, {dataItem.dev.empty(), dataItem.de… in MigrateDataItem()
286 …errCode = BindSavedSyncData(statement, dataItem, dataItem.hashKey, { dataItem.origDev, dataItem.de… in MigrateDataItem()
530 dataItem.writeTimestamp, dataItem.timestamp, dataItem.flag, recordVersion); in BindSyncDataInCacheMode()
542 return BindDevSyncDataInCacheMode(statement, dataItem.origDev, dataItem.dev); in BindSyncDataInCacheMode()
635 hashKey = dataItem.key; in SaveSyncDataItemInCacheMode()
652 if (((dataItem.flag & DataItem::LOCAL_FLAG) != 0) && dataItem.origDev.empty()) { in SaveSyncDataItemInCacheMode()
[all …]
H A Dsqlite_cloud_kv_executor_utils.cpp515 const DataItem &dataItem) in BindOnlyUpdateLogStmt() argument
583 const DataItem &dataItem) in BindInsertLogStmt() argument
613 const DataItem &dataItem) in BindUpdateStmt() argument
627 const DataItem &dataItem) in BindUpdateLogStmt() argument
658 DataItem &dataItem) in BindDeleteStmt() argument
660 dataItem.key = {}; in BindDeleteStmt()
661 dataItem.value = {}; in BindDeleteStmt()
861 DataItem dataItem; in FillCloudGid() local
986 if (dataItem.dev == dev) { in GetDataItem()
987 dataItem.dev = ""; in GetDataItem()
[all …]
H A Dsqlite_single_ver_storage_executor.h58 int SaveSyncDataItem(DataItem &dataItem, const DeviceInfo &deviceInfo,
130 int PutLocalDataToCacheDB(const LocalDataItem &dataItem) const;
231 DataOperStatus JudgeSyncSaveType(DataItem &dataItem, const DataItem &itemGet,
234 static std::string GetOriginDevName(const DataItem &dataItem, const std::string &origDevGet);
275 const DataItem &dataItem, const Key &hashKey, uint64_t recordVersion) const;
287 int GetOneRawDataItem(sqlite3_stmt *statement, DataItem &dataItem,
294 int BindLocalDataInCacheMode(sqlite3_stmt *statement, const LocalDataItem &dataItem) const;
306 int PrepareForNotifyConflictAndObserver(DataItem &dataItem, const DeviceInfo &deviceInfo,
315 int MigrateDataItem(DataItem &dataItem, const NotifyMigrateSyncData &syncData);
325 int MigrateRmDevData(const DataItem &dataItem) const;
[all …]
H A Dsqlite_single_ver_storage_executor.cpp480 dataItem.flag &= (~DataItem::LOCAL_FLAG); in GetDataItemForSync()
506 DataItem dataItem; in GetSyncDataItems() local
531 dataItems.push_back(std::move(dataItem)); in GetSyncDataItems()
1195 if (((dataItem.flag & DataItem::LOCAL_FLAG) != 0) && dataItem.origDev.empty()) { in GetOriginDevName()
1198 return dataItem.origDev; in GetOriginDevName()
1535 orgItemInfo.dataItem.key = origKey; in PutConflictData()
1543 newItemInfo.dataItem.key = origKey; in PutConflictData()
1758 static_cast<int64_t>(dataItem.flag)); in BindDevForSavedSyncData()
1968 DataItem dataItem; in GetAllDataItems() local
1977 dataItems.push_back(std::move(dataItem)); in GetAllDataItems()
[all …]
H A Dsqlite_cloud_kv_executor_utils.h98 …nt BindOnlyUpdateLogStmt(sqlite3_stmt *logStmt, const std::string &user, const DataItem &dataItem);
104 const DataItem &dataItem);
107 const DataItem &dataItem);
110 const DataItem &dataItem);
112 …ic int BindUpdateLogStmt(sqlite3_stmt *logStmt, const std::string &user, const DataItem &dataItem);
115 DataItem &dataItem);
117 static int BindDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, bool isInsert);
119 …static int BindSyncDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, bool isInsert, int &…
121 static int BindCloudDataStmt(sqlite3_stmt *dataStmt, const DataItem &dataItem, int &index);
159 const DataItem &dataItem, const VBucket &uploadExtend, const CloudWaterType &type);
H A Dsqlite_single_ver_natural_store_connection.cpp961 DataItem dataItem; in SaveEntry() local
962 dataItem.key = entry.key; in SaveEntry()
963 dataItem.value = entry.value; in SaveEntry()
964 dataItem.flag = DataItem::LOCAL_FLAG; in SaveEntry()
968 int errCode = CheckAmendValueContentForLocalProcedure(dataItem.value, dataItem.value); in SaveEntry()
990 LocalDataItem dataItem; in SaveLocalEntry() local
991 dataItem.key = entry.key; in SaveLocalEntry()
992 dataItem.value = entry.value; in SaveLocalEntry()
1003 return SaveLocalItem(dataItem); in SaveLocalEntry()
1011 …rCode = writeHandle_->PutKvData(SingleVerDataType::LOCAL_TYPE_SQLITE, dataItem.key, dataItem.value, in SaveLocalItem()
[all …]
H A Dsqlite_single_ver_natural_store_connection.h200 int SaveLocalItem(const LocalDataItem &dataItem) const;
201 int SaveLocalItemInCacheMode(const LocalDataItem &dataItem) const;
202 int SaveEntryNormally(DataItem &dataItem);
203 int SaveEntryInCacheMode(DataItem &dataItem, uint64_t recordVersion);
222 void RecordTimeIntoDataItem(Timestamp existCreateTime, DataItem &dataItem,
H A Dsqlite_cloud_kv_store.cpp437 auto [errCodeNext, dataItem] = CloudStorageUtils::GetDataItemFromCloudVersionData(data); in GetCloudVersion()
442 dataItem.dev = DBBase64Utils::DecodeIfNeed(dataItem.dev); in GetCloudVersion()
443 std::vector<uint8_t> blob = dataItem.value; in GetCloudVersion()
445 …std::string, std::string> versionPair = std::pair<std::string, std::string>(dataItem.dev, version); in GetCloudVersion()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dsingle_ver_natural_store_commit_notify_data.cpp113 DBCommon::CalcValueHash(itemInfo.dataItem.key, hashKey); in InsertConflictedItem()
123 auto iter = orgDataItem_.find(itemInfo.dataItem.key); in InsertConflictedItem()
126 orgDataItem_[itemInfo.dataItem.key] = itemInfo; in InsertConflictedItem()
222 if (orgItemInfo.dataItem.value == newItemInfo.dataItem.value && in PutIntoConflictData()
223 orgItemInfo.dataItem.origDev == newItemInfo.dataItem.origDev && in PutIntoConflictData()
224 orgItemInfo.dataItem.flag == newItemInfo.dataItem.flag && in PutIntoConflictData()
236 conflictData.type = ((newItemInfo.dataItem.origDev != orgItemInfo.dataItem.origDev) ? in PutIntoConflictData()
242 conflictData.oldData = {orgItemInfo.dataItem.value, isDeleted, true}; in PutIntoConflictData()
245 conflictData.newData = {newItemInfo.dataItem.value, isDeleted, newItemInfo.isLocal}; in PutIntoConflictData()
249 conflictData.key = isDeleted ? orgItemInfo.dataItem.key : newItemInfo.dataItem.key; in PutIntoConflictData()
[all …]
H A Ddata_transformer.cpp31 DataItem dataItem; in TransformTableData() local
66 dataItem.timestamp = logInfo.timestamp; in SerializeDataItem()
67 dataItem.dev = logInfo.device; in SerializeDataItem()
68 dataItem.origDev = logInfo.originDev; in SerializeDataItem()
70 dataItem.flag = logInfo.flag; in SerializeDataItem()
71 dataItem.hashKey = logInfo.hashKey; in SerializeDataItem()
87 logInfo.timestamp = dataItem.timestamp; in DeSerializeDataItem()
88 logInfo.device = dataItem.dev; in DeSerializeDataItem()
89 logInfo.originDev = dataItem.origDev; in DeSerializeDataItem()
91 logInfo.flag = dataItem.flag; in DeSerializeDataItem()
[all …]
H A Ddata_transformer.h96 DataItem &dataItem);
97 static int DeSerializeDataItem(const DataItem &dataItem, OptRowDataWithLog &data,
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_register_observer_test.cpp201 DataItem dataItem; in TestForOperation() local
202 dataItem.key = entry.key; in TestForOperation()
205 dataItem.writeTimestamp = dataItem.timestamp; in TestForOperation()
206 dataItem.flag = 0; in TestForOperation()
215 dataItem.timestamp++; in TestForOperation()
216 dataItem.writeTimestamp = dataItem.timestamp; in TestForOperation()
697 dataItem.writeTimestamp = dataItem.timestamp; in PreSyncDataForRegisterObserver014()
705 dataItem.key = g_entry3.key; in PreSyncDataForRegisterObserver014()
707 dataItem.flag = 0; in PreSyncDataForRegisterObserver014()
710 dataItem.key = g_entry4.key; in PreSyncDataForRegisterObserver014()
[all …]
H A Ddistributeddb_storage_sqlite_single_ver_natural_executor_test.cpp911 DataItem dataItem; variable
913 items.push_back(dataItem);
945 items.push_back(dataItem);
984 DataItem dataItem; variable
986 items.push_back(dataItem);
1015 DataItem dataItem; variable
1017 items.push_back(dataItem);
1083 DataItem dataItem; variable
1084 dataItem.flag = DataItem::REMOTE_DEVICE_DATA_MISS_QUERY;
1088 dataItem.key = KEY_1;
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_types_util.cpp50 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel) in Unmarshalling() argument
52 return ITypesUtil::Unmarshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Unmarshalling()
56 bool Marshalling(const PublishedDataItem &dataItem, MessageParcel &parcel) in Marshalling() argument
58 return ITypesUtil::Marshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Marshalling()
H A Ddata_share_types_util.h42 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel);
45 bool Marshalling(const PublishedDataItem &dataItem, MessageParcel &parcel);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.cpp215 dataItem.key = iter->key; in GetSyncData()
216 dataItem.value = iter->value; in GetSyncData()
217 dataItem.timestamp = iter->timestamp; in GetSyncData()
219 dataItem.flag = iter->flag; in GetSyncData()
220 dataItem.isLocal = iter->isLocal; in GetSyncData()
338 VirtualDataItem dataItem; in PutSyncData() local
339 dataItem.key = iter->key; in PutSyncData()
340 dataItem.value = iter->value; in PutSyncData()
343 dataItem.flag = iter->flag; in PutSyncData()
344 dataItem.isLocal = false; in PutSyncData()
[all …]
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/common/src/
H A Ddatashare_itypes_utils.cpp87 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel) in Unmarshalling() argument
89 return ITypesUtil::Unmarshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Unmarshalling()
93 bool Marshalling(const PublishedDataItem &dataItem, MessageParcel &parcel) in Marshalling() argument
95 return ITypesUtil::Marshal(parcel, dataItem.key_, dataItem.subscriberId_, dataItem.value_); in Marshalling()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_storage_executor.cpp814 const DataItem &dataItem, int64_t rowid) in SaveSyncLog() argument
817 int errCode = GetLogInfoPre(queryStmt, dataItem, logInfoGet); in SaveSyncLog()
819 logInfoBind.hashKey = dataItem.hashKey; in SaveSyncLog()
820 logInfoBind.device = dataItem.dev; in SaveSyncLog()
821 logInfoBind.timestamp = dataItem.timestamp; in SaveSyncLog()
822 logInfoBind.flag = dataItem.flag; in SaveSyncLog()
825 logInfoBind.wTimestamp = dataItem.writeTimestamp; in SaveSyncLog()
826 logInfoBind.originDev = dataItem.dev; in SaveSyncLog()
883 if ((dataItem.flag & DataItem::DELETE_FLAG) != 0) { in SaveSyncDataItem()
956 int errCode = GetLogInfoPre(queryStmt, dataItem, logInfoGet); in GetSyncDataPre()
[all …]
H A Dsqlite_single_ver_relational_storage_executor.h252 …int GetDataItemForSync(sqlite3_stmt *statement, DataItem &dataItem, bool isGettingDeletedData) con…
254 int GetSyncDataPre(const DataItem &dataItem, sqlite3_stmt *queryStmt, DataItem &itemGet);
260 …int SaveSyncDataItem(const DataItem &dataItem, SaveSyncDataStmt &saveStmt, RelationalSyncDataInser…
263 …int DeleteSyncDataItem(const DataItem &dataItem, RelationalSyncDataInserter &inserter, sqlite3_stm…
265 int GetLogInfoPre(sqlite3_stmt *queryStmt, const DataItem &dataItem, LogInfo &logInfoGet);
267 …int SaveSyncLog(sqlite3_stmt *statement, sqlite3_stmt *queryStmt, const DataItem &dataItem, int64_…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dcloud_storage_utils.cpp1361 auto &[errCode, dataItem] = res; in GetDataItemFromCloudData()
1364 GetStringFromCloudData(CloudDbConstant::GID_FIELD, data, dataItem.gid); in GetDataItemFromCloudData()
1368 dataItem.flag = static_cast<uint64_t>(LogInfoFlag::FLAG_CLOUD_WRITE); in GetDataItemFromCloudData()
1372 bool isSystemRecord = IsSystemRecord(dataItem.key); in GetDataItemFromCloudData()
1374 dataItem.hashKey = dataItem.key; in GetDataItemFromCloudData()
1376 } else if (!dataItem.key.empty()) { in GetDataItemFromCloudData()
1377 (void)DBCommon::CalcValueHash(dataItem.key, dataItem.hashKey); in GetDataItemFromCloudData()
1385 auto &[errCode, dataItem] = res; in GetDataItemFromCloudVersionData()
1444 auto &[errCode, dataItem] = res; in GetSystemRecordFromCloudData()
1449 dataItem.dev = ""; in GetSystemRecordFromCloudData()
[all …]
/ohos5.0/foundation/distributeddatamgr/preferences/frameworks/native/platform/src/
H A Dpreferences_db_adapter.cpp426 std::pair<std::vector<uint8_t>, std::vector<uint8_t>> dataItem; in GetAllInner() local
435 dataItem.first.resize(keySize); in GetAllInner()
436 dataItem.second.resize(valueSize); in GetAllInner()
437 ret = PreferenceDbAdapter::GetApiInstance().GetItemApi(resultSet, dataItem.first.data(), in GetAllInner()
438 dataItem.second.data()); in GetAllInner()
444 data.emplace_back(std::move(dataItem)); in GetAllInner()
/ohos5.0/foundation/distributeddatamgr/data_share/frameworks/native/common/include/
H A Ddatashare_itypes_utils.h69 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel);
72 bool Unmarshalling(PublishedDataItem &dataItem, MessageParcel &parcel);
/ohos5.0/base/customization/enterprise_device_management/services/edm_plugin/src/utils/
H A Darray_usb_device_id_serializer.cpp142 for (const auto &dataItem : data) { in MergePolicy() local
143 for (const auto &item : dataItem) { in MergePolicy()
H A Darray_usb_device_type_serializer.cpp148 for (const auto &dataItem : data) { in MergePolicy() local
149 for (const auto &item : dataItem) { in MergePolicy()
/ohos5.0/base/customization/enterprise_device_management/interfaces/inner_api/plugin_kits/include/
H A Dipolicy_serializer.h205 for (const auto &dataItem : data) { in MergePolicy() local
206 for (const auto &item : dataItem) { in MergePolicy()

12