Searched refs:syncDataPk (Results 1 – 3 of 3) sorted by relevance
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 596 std::vector<VBucket> syncDataPk; in GetCompensatedSyncQuery() local
599 syncDataPk, syncDataUserId); in GetCompensatedSyncQuery()
604 if (syncDataPk.empty()) { in GetCompensatedSyncQuery()
608 errCode = CloudStorageUtils::GetSyncQueryByPk(table.name, syncDataPk, true, syncObject); in GetCompensatedSyncQuery()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_kv_syncer_test.cpp | 499 std::vector<VBucket> syncDataPk; variable
502 syncDataPk.push_back(bucket);
504 ASSERT_EQ(CloudStorageUtils::GetSyncQueryByPk(tableName, syncDataPk, true, syncObject), E_OK);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 2019 std::vector<VBucket> syncDataPk; in GetCompensatedSyncQueryInner() local
2020 errCode = handle->GetWaitCompensatedSyncDataPk(table, syncDataPk); in GetCompensatedSyncQueryInner()
2026 if (syncDataPk.empty()) { in GetCompensatedSyncQueryInner()
2031 errCode = CloudStorageUtils::GetSyncQueryByPk(table.name, syncDataPk, false, syncObject); in GetCompensatedSyncQueryInner()
|