| /ohos5.0/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/ |
| H A D | store_observer.h | 35 std::vector<std::vector<Type>> primaryData[OP_BUTT]; member
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 132 return changedData.primaryData[ChangeType::OP_INSERT].empty() || in IsChangeDataEmpty()
133 changedData.primaryData[ChangeType::OP_UPDATE].empty() || in IsChangeDataEmpty()
134 changedData.primaryData[ChangeType::OP_DELETE].empty(); in IsChangeDataEmpty()
394 param.changedData.primaryData[ChangeType::OP_UPDATE].size()); in SaveChangedData()
570 for (auto &changePkValList : changedData.primaryData) { in InsertOrReplaceChangedDataByType()
577 changedData.primaryData[type].emplace_back(std::move(pkVal)); in InsertOrReplaceChangedDataByType()
|
| H A D | cloud_syncer.cpp | 510 param.changedData.primaryData[ChangeType::OP_INSERT].push_back(primaryValues); in UpdateChangedData()
523 size_t size = param.changedData.primaryData[ChangeType::OP_UPDATE].size(); in UpdateChangedData()
528 if (param.changedData.primaryData[ChangeType::OP_UPDATE][updateIndex].empty()) { in UpdateChangedData()
533 param.changedData.primaryData[ChangeType::OP_UPDATE][updateIndex][0] = in UpdateChangedData()
947 if (changedData.primaryData[OP_INSERT].empty() && changedData.primaryData[OP_UPDATE].empty() && in NeedNotifyChangedData()
948 changedData.primaryData[OP_DELETE].empty()) { in NeedNotifyChangedData()
1996 … changedAssets.primaryData[CloudSyncUtils::OpTypeToChangeType(downloadItem.strategy)].push_back( in DownloadOneAssetRecord()
1999 … changedAssets.primaryData[ChangeType::OP_UPDATE].push_back(downloadItem.primaryKeyValList); in DownloadOneAssetRecord()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | meta_data_manager.cpp | 114 HandleChanges(MetaDataManager::INSERT, data.primaryData[MetaDataManager::INSERT]); in OnChange()
115 HandleChanges(MetaDataManager::UPDATE, data.primaryData[MetaDataManager::UPDATE]); in OnChange()
116 HandleChanges(MetaDataManager::DELETE, data.primaryData[MetaDataManager::DELETE]); in OnChange()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | store_observer.h | 41 std::vector<std::vector<Type>> primaryData[OP_BUTT]; member
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_local_db_observer.cpp | 47 for (const auto &primary : dataInfo.primaryData[changeType]) { in Convert()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_ext_test.cpp | 1514 for (size_t i = 1; i <= g_changedData[num].primaryData[ChangeType::OP_INSERT].size(); i++) { in CheckChangedData()
1515 … EXPECT_EQ(std::get<int64_t>(g_changedData[num].primaryData[ChangeType::OP_INSERT][i - 1][0]), in CheckChangedData()
1518 for (size_t i = 1; i <= g_changedData[num].primaryData[ChangeType::OP_DELETE].size(); i++) { in CheckChangedData()
1519 … EXPECT_EQ(std::get<int64_t>(g_changedData[num].primaryData[ChangeType::OP_DELETE][i - 1][0]), in CheckChangedData()
1524 for (size_t i = 1; i <= g_changedData[num].primaryData[ChangeType::OP_INSERT].size(); i++) { in CheckChangedData()
1525 … EXPECT_EQ(std::get<int64_t>(g_changedData[num].primaryData[ChangeType::OP_INSERT][i - 1][0]), in CheckChangedData()
1528 for (size_t i = 1; i <= g_changedData[num].primaryData[ChangeType::OP_UPDATE].size(); i++) { in CheckChangedData()
1529 … EXPECT_EQ(std::get<int64_t>(g_changedData[num].primaryData[ChangeType::OP_UPDATE][i - 1][0]), in CheckChangedData()
1532 for (size_t i = 1; i <= g_changedData[num].primaryData[ChangeType::OP_DELETE].size(); i++) { in CheckChangedData()
1533 … EXPECT_EQ(std::get<int64_t>(g_changedData[num].primaryData[ChangeType::OP_DELETE][i - 1][0]), in CheckChangedData()
|
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 1927 changedData.primaryData[ChangeType::OP_DELETE].push_back(dataVec);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_tools_unit_test.cpp | 855 for (size_t m = 0; m < input.primaryData[type].size(); m++) { in IsPrimaryDataEq()
856 if (m >= expected.primaryData[type].size()) { in IsPrimaryDataEq()
860 if (input.primaryData[type][m].size() != expected.primaryData[type][m].size()) { in IsPrimaryDataEq()
864 for (size_t k = 0; k < input.primaryData[type][m].size(); k++) { in IsPrimaryDataEq()
865 if (!IsPrimaryKeyEq(input.primaryData[type][m][k], expected.primaryData[type][m][k])) { in IsPrimaryDataEq()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_table_without_primary_key_sync_test.cpp | 87 changedDataForTable.primaryData[changeType].push_back({i}); in InitExpectChangedData()
101 changedDataForTable.primaryData[changeType].push_back({i}); in InitExpectChangedDataByDetailsType()
|
| H A D | distributeddb_cloud_db_proxy_test.cpp | 912 changedData.primaryData[OP_INSERT] = {{}};
914 changedData.primaryData[OP_UPDATE] = {{}};
916 changedData.primaryData[OP_DELETE] = {{}};
|
| H A D | distributeddb_cloud_table_compound_primary_key_sync_test.cpp | 81 changedDataForTable.primaryData[changeType].push_back({i + 1, in InitExpectChangedData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 1172 … changedDataForTable1.primaryData[ChangeType::OP_INSERT].push_back({"Cloud" + std::to_string(i)});
1173 changedDataForTable2.primaryData[ChangeType::OP_INSERT].push_back({(int64_t)i + 10});
1339 … changedDataForTable1.primaryData[ChangeType::OP_INSERT].push_back({"Cloud" + std::to_string(i)});
1340 changedDataForTable2.primaryData[ChangeType::OP_INSERT].push_back({(int64_t)i + 10});
1877 … changedDataForTable1.primaryData[ChangeType::OP_UPDATE].push_back({"Local" + std::to_string(0)});
|
| H A D | distributeddb_cloud_check_sync_test.cpp | 1857 expectData.primaryData[ChangeType::OP_DELETE].push_back({std::to_string(i)});
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 323 for (auto &changeValList : changedData.primaryData) { in TriggerObserverAction()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_sqlite_ext.cpp | 728 itTable->primaryData[option].push_back(dataVec); in SaveChangedData()
735 changedData.primaryData[option].push_back(dataVec); in SaveChangedData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1327 changedData.primaryData[ChangeType::OP_DELETE].push_back(dataVec); in CleanCloudData()
1519 changedData.primaryData[i].clear(); in FilterChangeDataByDetailsType()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_general_store.cpp | 632 for (auto &priData : data.primaryData[i]) { in OnChange()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.cpp | 1053 for (auto &priData : data.primaryData[i]) { in OnChange()
|