| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_relational_syncer.cpp | 46 tablesQuery.push_back(param.syncQuery); in PrepareSync()
80 subParam.syncQuery = table; in GenerateEachSyncTask()
109 resMap_[syncId][item.first][param.syncQuery.GetRelationTableName()] = static_cast<int>(item.second); in DoOnSubSyncComplete()
181 QuerySyncObject query = param.syncQuery; in SyncConditionCheck()
195 if (!param.syncQuery.GetRelationTableNames().empty()) { in QuerySyncPreCheck()
206 if (param.syncQuery.GetRelationTableName().empty()) { in QuerySyncPreCheck()
|
| H A D | single_ver_kv_syncer.cpp | 175 QuerySyncObject query = param.syncQuery; in SyncConditionCheck()
212 param.syncQuery = query; in TriggerSubscribe()
284 param.syncQuery = query; in TriggerSubQuerySync()
|
| H A D | single_ver_data_sync_extend.cpp | 180 QuerySyncObject syncQuery = packet->GetQuery(); in SubscribeRequestRecvPre() local
183 errCode = storage_->CheckAndInitQueryCondition(syncQuery); in SubscribeRequestRecvPre()
|
| H A D | single_ver_data_sync_utils.cpp | 101 QuerySyncObject syncQuery = packet->GetQuery(); in RequestQueryCheck() local
102 int errCode = storage->CheckAndInitQueryCondition(syncQuery); in RequestQueryCheck()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | sync_types.h | 76 QuerySyncObject syncQuery; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include/ |
| H A D | isyncer.h | 46 QuerySyncObject syncQuery; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.h | 105 int GetCompensatedSyncQuery(std::vector<QuerySyncObject> &syncQuery, std::vector<std::string> &users) override;
|
| H A D | sqlite_cloud_kv_store.cpp | 578 int SqliteCloudKvStore::GetCompensatedSyncQuery(std::vector<QuerySyncObject> &syncQuery, in GetCompensatedSyncQuery() argument
613 syncQuery.push_back(syncObject); in GetCompensatedSyncQuery()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 212 int GetCompensatedSyncQuery(std::vector<QuerySyncObject> &syncQuery, std::vector<std::string> &users) override;
288 const std::vector<TableSchema> &tables, std::vector<QuerySyncObject> &syncQuery);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_meta_data_test.cpp | 285 std::vector<QuerySyncObject> syncQuery; in HWTEST_F() local
287 EXPECT_EQ(proxyObj.GetCompensatedSyncQuery(syncQuery, users), -E_INVALID_DB); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store_connection.cpp | 253 syncParam.syncQuery = QuerySyncObject(info.query); in SyncToDevice()
257 if (syncParam.syncQuery.GetSortType() != SortType::NONE) { in SyncToDevice()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | icloud_sync_storage_interface.h | 190 virtual int GetCompensatedSyncQuery([[gnu::unused]] std::vector<QuerySyncObject> &syncQuery, in GetCompensatedSyncQuery() argument
|
| H A D | storage_proxy.h | 127 int GetCompensatedSyncQuery(std::vector<QuerySyncObject> &syncQuery, std::vector<std::string> &users);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | generic_syncer.cpp | 168 syncParam.syncQuery = param.syncQuery; in Sync()
900 operation->SetQuery(param.syncQuery); in InitSyncOperation()
|
| H A D | sync_engine.cpp | 990 outParam.syncQuery = query; in GetSubscribeSyncParam()
999 outParam.syncQuery = query; in GetQueryAutoSyncParam()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_proxy.cpp | 571 int StorageProxy::GetCompensatedSyncQuery(std::vector<QuerySyncObject> &syncQuery, std::vector<std::string> &users) in GetCompensatedSyncQuery() argument
577 return store_->GetCompensatedSyncQuery(syncQuery, users); in GetCompensatedSyncQuery()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer_extend.cpp | 484 std::vector<QuerySyncObject> syncQuery; in GenerateCompensatedSync() local
486 int errCode = storageProxy_->GetCompensatedSyncQuery(syncQuery, users); in GenerateCompensatedSync()
491 if (syncQuery.empty()) { in GenerateCompensatedSync()
503 for (const auto &query : syncQuery) { in GenerateCompensatedSync()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 633 QuerySyncObject syncQuery(Query::Select().PrefixKey({'2'})); in HWTEST_F()
634 packet->SetQuery(syncQuery); in HWTEST_F()
635 packet->SetQueryId(syncQuery.GetIdentify()); in HWTEST_F()
674 EXPECT_EQ(outPacket->GetQueryId(), syncQuery.GetIdentify()); in HWTEST_F()
|
| H A D | distributeddb_single_ver_p2p_subscribe_sync_test.cpp | 277 QuerySyncObject syncQuery(query); in HWTEST_F()
278 packet->SetQuery(syncQuery); in HWTEST_F()
314 EXPECT_EQ(outPacket->GetQuery().GetIdentify(), syncQuery.GetIdentify()); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb_connection.cpp | 153 syncParam.syncQuery = syncParameter->query_; in PragmaSyncAction()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1933 int RelationalSyncAbleStorage::GetCompensatedSyncQuery(std::vector<QuerySyncObject> &syncQuery, in GetCompensatedSyncQuery() argument
1949 errCode = GetCompensatedSyncQueryInner(handle, tables, syncQuery); in GetCompensatedSyncQuery()
2010 const std::vector<TableSchema> &tables, std::vector<QuerySyncObject> &syncQuery) in GetCompensatedSyncQueryInner()
2040 syncQuery.push_back(syncObject); in GetCompensatedSyncQueryInner()
2009 GetCompensatedSyncQueryInner(SQLiteSingleVerRelationalStorageExecutor *handle, const std::vector<TableSchema> &tables, std::vector<QuerySyncObject> &syncQuery) GetCompensatedSyncQueryInner() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_test.cpp | 3397 std::vector<QuerySyncObject> syncQuery; in HWTEST_F() local
3399 EXPECT_EQ(kvStoreObj.GetCompensatedSyncQuery(syncQuery, users), E_OK); in HWTEST_F()
|