Home
last modified time | relevance | path

Searched refs:dataItems (Results 1 – 25 of 33) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.cpp36 for (const auto &item : dataItems) { in GetEntriesFromItems()
230 std::vector<VirtualDataItem> dataItems; in GetSyncData() local
255 std::vector<VirtualDataItem> dataItems; in GetSyncDataNext() local
287 dataItems.clear(); in GetSyncData()
321 for (auto iter = dataItems.begin(); iter != dataItems.end(); ++iter) { in PutSyncData()
417 std::vector<VirtualDataItem> dataItems; in GetSyncData() local
426 dataItems.push_back(data); in GetSyncData()
431 dataItems.push_back(data); in GetSyncData()
499 std::vector<VirtualDataItem> dataItems; in PutSyncDataWithQuery() local
509 dataItems.push_back(item); in PutSyncDataWithQuery()
[all …]
H A Dvirtual_single_ver_sync_db_Interface.h65 int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems,
68 int GetSyncDataNext(std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken,
154 std::vector<VirtualDataItem> &dataItems, ContinueToken &continueStmtToken) const;
156 int GetSyncDataNext(std::vector<VirtualDataItem>& dataItems,
159 int PutSyncData(std::vector<VirtualDataItem>& dataItems, const std::string &deviceName);
164 const DataSizeSpecInfo &dataSizeInfo, std::vector<VirtualDataItem> &dataItems) const;
H A Dvirtual_relational_ver_sync_db_interface.cpp26 …tEntriesFromItems(std::vector<SingleVerKvEntry *> &entries, const std::vector<DataItem> &dataItems) in GetEntriesFromItems() argument
29 for (const auto &item : dataItems) { in GetEntriesFromItems()
54 LOGD("[GetEntriesFromItems] size:%zu", dataItems.size()); in GetEntriesFromItems()
76 std::vector<DataItem> dataItems; in PutSyncDataWithQuery() local
88 dataItems.push_back(item); in PutSyncDataWithQuery()
93 … int errCode = DataTransformer::TransformDataItem(dataItems, localFieldInfo_, optTableDataWithLog); in PutSyncDataWithQuery()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_natural_store.cpp61 if (dataItems.empty()) { in ProcessContinueToken()
96 if (dataItems.empty()) { in ProcessContinueTokenForQuerySync()
138 for (auto &item : dataItems) { in GetKvEntriesByDataItems()
628 std::vector<DataItem> dataItems; in GetSyncData() local
635 for (auto &item : dataItems) { in GetSyncData()
680 dataItems.clear(); in GetSyncData()
710 std::vector<DataItem> dataItems; in GetSyncData() local
778 dataItems.clear(); in GetSyncDataForQuerySync()
1194 for (auto &item : dataItems) { in SaveSyncDataItems()
1269 for (auto &item: dataItems) { in SaveSyncItems()
[all …]
H A Dsqlite_single_ver_storage_executor.h79 … int GetSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t appendLength, Timestamp begin,
81 …int GetDeletedSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t appendLength, Timestamp…
141 std::vector<DataItem> &dataItems);
142 … int GetMinVersionCacheData(std::vector<DataItem> &dataItems, uint64_t &minVerIncurCacheDb) const;
180 const std::pair<Timestamp, Timestamp> &timeRange, std::vector<DataItem> &dataItems) const;
289 int GetAllDataItems(sqlite3_stmt *statement, std::vector<DataItem> &dataItems,
297 int ProcessTimestampForSyncDataInCacheDB(std::vector<DataItem> &dataItems);
313 int MigrateDataItems(std::vector<DataItem> &dataItems, NotifyMigrateSyncData &syncData);
328 int GetSyncDataItems(std::vector<DataItem> &dataItems, sqlite3_stmt *statement,
335 std::vector<DataItem> &dataItems);
[all …]
H A Dsqlite_single_ver_natural_store.h77 …int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, ContinueToken &c…
86 int GetSyncDataNext(std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken,
246 …int SaveSyncDataItems(const QueryObject &query, std::vector<DataItem> &dataItems, const DeviceInfo…
275 void CheckAmendValueContentForSyncProcedure(std::vector<DataItem> &dataItems) const;
281 …int SaveSyncDataToMain(const QueryObject &query, std::vector<DataItem> &dataItems, const DeviceInf…
285 …int SaveSyncItems(const QueryObject& query, std::vector<DataItem> &dataItems, const DeviceInfo &de…
288 int SaveSyncDataToCacheDB(const QueryObject &query, std::vector<DataItem> &dataItems,
292 … std::vector<DataItem> &dataItems, const DeviceInfo &deviceInfo, Timestamp &maxTimestamp) const;
294 …int GetSyncDataForQuerySync(std::vector<DataItem> &dataItems, SQLiteSingleVerContinueToken *&conti…
H A Dsqlite_single_ver_storage_executor_cache.cpp127 std::vector<DataItem> &dataItems, uint64_t &minVerIncurCacheDb) const in GetMinVersionCacheData() argument
306 for (auto &item : dataItems) { in CheckDataWithQuery()
339 syncData.isRemote = ((dataItems[0].flag & DataItem::LOCAL_FLAG) == 0); in MigrateDataItems()
341 (dataItems[0].flag & DataItem::REMOVE_DEVICE_DATA_NOTIFY_FLAG) != 0; in MigrateDataItems()
343 int errCode = CheckDataWithQuery(dataItems); in MigrateDataItems()
349 for (auto &item : dataItems) { in MigrateDataItems()
382 std::vector<DataItem> &dataItems) in MigrateSyncDataByVersion() argument
397 errCode = ProcessTimestampForSyncDataInCacheDB(dataItems); in MigrateSyncDataByVersion()
403 errCode = MigrateDataItems(dataItems, syncData); in MigrateSyncDataByVersion()
844 if (dataItems.empty()) { in ProcessTimestampForSyncDataInCacheDB()
[all …]
H A Dsqlite_single_ver_storage_executor.cpp526 if ((dataTotalSize > dataSizeInfo.blockSize && !dataItems.empty()) || in GetSyncDataItems()
527 dataItems.size() >= dataSizeInfo.packetSize) { in GetSyncDataItems()
531 dataItems.push_back(std::move(dataItem)); in GetSyncDataItems()
546 errCode = GetSyncDataItems(dataItems, statement, appendLength, dataSizeInfo); in GetSyncDataByTimestamp()
560 errCode = GetSyncDataItems(dataItems, statement, appendLength, dataSizeInfo); in GetDeletedSyncDataByTimestamp()
571 …if ((appendSize > dataSizeInfo.blockSize && !dataItems.empty()) || dataItems.size() >= dataSizeInf… in AppendDataItem()
574 dataItems.push_back(item); in AppendDataItem()
625 std::vector<DataItem> &dataItems) const in GetSyncDataWithQuery()
1966 dataItems.clear(); in GetAllDataItems()
1967 dataItems.shrink_to_fit(); in GetAllDataItems()
[all …]
H A Dsqlite_single_ver_storage_executor_subscribe.cpp75 const DeviceInfo &deviceInfo, std::vector<DataItem> &dataItems) in CheckMissQueryDataItems() argument
78 for (auto &item : dataItems) { in CheckMissQueryDataItems()
96 …teSingleVerStorageExecutor::CheckDataWithQuery(QueryObject query, std::vector<DataItem> &dataItems, in CheckDataWithQuery() argument
121 errCode = CheckMissQueryDataItems(stmt, helper, deviceInfo, dataItems); in CheckDataWithQuery()
H A Dsqlite_single_ver_storage_engine.cpp100 const std::vector<DataItem> &dataItems) in EraseDeviceWaterMark() argument
103 for (const auto &dataItem : dataItems) { in EraseDeviceWaterMark()
150 std::vector<DataItem> dataItems; in MigrateSyncDataByVersion() local
152 int errCode = handle->GetMinVersionCacheData(dataItems, minVerIncurCacheDb); in MigrateSyncDataByVersion()
168 errCode = EraseDeviceWaterMark(handle, dataItems); in MigrateSyncDataByVersion()
177 errCode = handle->MigrateSyncDataByVersion(curMigrateVer++, syncData, dataItems); in MigrateSyncDataByVersion()
H A Dsqlite_single_ver_natural_store_extend.cpp228 …ngleVerNaturalStore::CheckAmendValueContentForSyncProcedure(std::vector<DataItem> &dataItems) const in CheckAmendValueContentForSyncProcedure()
238 for (auto &eachItem : dataItems) { in CheckAmendValueContentForSyncProcedure()
257 dataItems.size(), deleteCount, amendCount, neglectCount); in CheckAmendValueContentForSyncProcedure()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_register_observer_test.cpp699 dataItems.push_back(dataItem); in PreSyncDataForRegisterObserver014()
703 dataItems.push_back(dataItem); in PreSyncDataForRegisterObserver014()
708 dataItems.push_back(dataItem); in PreSyncDataForRegisterObserver014()
712 dataItems.push_back(dataItem); in PreSyncDataForRegisterObserver014()
716 dataItems.push_back(dataItem); in PreSyncDataForRegisterObserver014()
720 dataItems.push_back(dataItem); in PreSyncDataForRegisterObserver014()
757 vector<DataItem> dataItems; variable
805 vector<DataItem> dataItems; variable
811 dataItems.push_back(std::move(item));
817 dataItems.clear();
[all …]
H A Ddistributeddb_storage_single_ver_natural_store_testcase.cpp191 std::vector<DataItem> dataItems; in GetSyncData004() local
193 …EXPECT_EQ(DistributedDBToolsUnitTest::GetSyncDataTest(inputArg, store, dataItems, token), -E_UNFIN… in GetSyncData004()
196 std::size_t countNum = dataItems.size(); in GetSyncData004()
205 dataItems.clear(); in GetSyncData004()
208 countNum += dataItems.size(); in GetSyncData004()
249 std::vector<DataItem> dataItems; in GetSyncData005() local
256 EXPECT_EQ(DistributedDBToolsUnitTest::GetSyncDataTest(inputArg, store, dataItems, token), E_OK); in GetSyncData005()
259 EXPECT_EQ(dataItems.size(), 10UL); in GetSyncData005()
285 std::vector<DataItem> dataItems; in GetSyncData006() local
293 EXPECT_EQ(DistributedDBToolsUnitTest::GetSyncDataTest(inputArg, store, dataItems, token), E_OK); in GetSyncData006()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.h97 … int GetSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t appendLength, Timestamp begin,
100 …int GetDeletedSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t appendLength, Timestamp…
147 std::vector<DataItem> &dataItems);
149 … int GetMinVersionCacheData(std::vector<DataItem> &dataItems, uint64_t &minVerIncurCacheDb) const;
174 …int CheckDataWithQuery(QueryObject query, std::vector<DataItem> &dataItems, const DeviceInfo &devi…
189 const std::pair<Timestamp, Timestamp> &timeRange, std::vector<DataItem> &dataItems) const;
H A Drd_single_ver_storage_executor.cpp506 int RdSingleVerStorageExecutor::GetSyncDataByTimestamp(std::vector<DataItem> &dataItems, size_t app… in GetSyncDataByTimestamp() argument
512 int RdSingleVerStorageExecutor::GetDeletedSyncDataByTimestamp(std::vector<DataItem> &dataItems, siz… in GetDeletedSyncDataByTimestamp() argument
591 std::vector<DataItem> &dataItems) in MigrateSyncDataByVersion() argument
596 int RdSingleVerStorageExecutor::GetMinVersionCacheData(std::vector<DataItem> &dataItems, in GetMinVersionCacheData() argument
652 …RdSingleVerStorageExecutor::CheckDataWithQuery(QueryObject query, std::vector<DataItem> &dataItems, in CheckDataWithQuery() argument
690 std::vector<DataItem> &dataItems) const in GetSyncDataWithQuery()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp343 for (auto &item : dataItems) { in GetKvEntriesByDataItems()
388 if (dataItems.empty()) { in ProcessContinueTokenForQuerySync()
395 token->SetNextBeginTime(dataItems.back()); in ProcessContinueTokenForQuerySync()
396 token->UpdateNextSyncOffset(dataItems.size()); in ProcessContinueTokenForQuerySync()
432 dataItems.clear(); in GetSyncDataForQuerySync()
475 std::vector<DataItem> dataItems; in GetSyncDataNext() local
495 std::vector<DataItem> dataItems; in ConvertEntries() local
507 dataItems.push_back(item); in ConvertEntries()
510 return dataItems; in ConvertEntries()
518 return PutSyncData(object, dataItems, deviceName); in PutSyncDataWithQuery()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dintercepted_data_impl.cpp64 InterceptedDataImpl::InterceptedDataImpl(std::vector<SingleVerKvEntry *> dataItems, in InterceptedDataImpl() argument
71 dataItems_(dataItems), in InterceptedDataImpl()
75 totalLength_ = GenericSingleVerKvEntry::CalculateLens(dataItems, SOFTWARE_VERSION_CURRENT); in InterceptedDataImpl()
H A Dintercepted_data_impl.h32 …InterceptedDataImpl(std::vector<SingleVerKvEntry *> dataItems, const std::function<int(const Value…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Ddata_transformer.cpp25 const std::vector<FieldInfo> &fieldInfoList, std::vector<DataItem> &dataItems) in TransformTableData() argument
36 dataItems.push_back(std::move(dataItem)); in TransformTableData()
41 int DataTransformer::TransformDataItem(const std::vector<DataItem> &dataItems, in TransformDataItem() argument
44 if (dataItems.empty()) { in TransformDataItem()
47 for (const DataItem &dataItem : dataItems) { in TransformDataItem()
H A Ddata_transformer.h91 const std::vector<FieldInfo> &fieldInfoList, std::vector<DataItem> &dataItems);
92 …static int TransformDataItem(const std::vector<DataItem> &dataItems, const std::vector<FieldInfo> …
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.h192 … std::vector<DistributedDB::DataItem> &dataItems, DistributedDB::ContinueToken &continueStmtToken);
195 … std::vector<DistributedDB::DataItem> &dataItems, DistributedDB::ContinueToken &continueStmtToken);
198 const std::vector<DistributedDB::DataItem> &dataItems, const std::string &deviceName);
201 const std::vector<DistributedDB::DataItem> &dataItems, const std::string &deviceName,
204 static int ConvertItemsToSingleVerEntry(const std::vector<DistributedDB::DataItem> &dataItems,
208 std::vector<DistributedDB::DataItem> &dataItems);
H A Ddistributeddb_tools_unit_test.cpp576 std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken) in GetSyncDataTest() argument
583 ConvertSingleVerEntryToItems(entries, dataItems); in GetSyncDataTest()
588 std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken) in GetSyncDataNextTest() argument
594 ConvertSingleVerEntryToItems(entries, dataItems); in GetSyncDataNextTest()
599 const std::vector<DataItem> &dataItems, const std::string &deviceName) in PutSyncDataTest() argument
602 return PutSyncDataTest(store, dataItems, deviceName, query); in PutSyncDataTest()
606 const std::vector<DataItem> &dataItems, const std::string &deviceName, const QueryObject &query) in PutSyncDataTest() argument
609 std::vector<DistributedDB::DataItem> items = dataItems; in PutSyncDataTest()
629 std::vector<DistributedDB::DataItem> items = dataItems; in ConvertItemsToSingleVerEntry()
643 std::vector<DistributedDB::DataItem> &dataItems) in ConvertSingleVerEntryToItems() argument
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h30 virtual int GetSyncData(Timestamp begin, Timestamp end, std::vector<DataItem> &dataItems, in GetSyncData() argument
55 virtual int GetSyncDataNext(std::vector<DataItem> &dataItems, ContinueToken &continueStmtToken, in GetSyncDataNext() argument
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h259 …int GetSyncDataForQuerySync(std::vector<DataItem> &dataItems, SQLiteSingleVerRelationalContinueTok…
271 …int PutSyncData(const QueryObject &object, std::vector<DataItem> &dataItems, const std::string &de…
272 …int SaveSyncDataItems(const QueryObject &object, std::vector<DataItem> &dataItems, const std::stri…
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_device_identifier_test.cpp495 std::vector<DataItem> dataItems; variable
497 EXPECT_EQ(errStore->GetSyncDataNext(dataItems, token, info), -E_INVALID_ARGS);
499 EXPECT_EQ(errStore->GetSyncDataNext(dataItems, token, info), -E_INVALID_ARGS);

12