Home
last modified time | relevance | path

Searched refs:queryNodes (Results 1 – 7 of 7) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Dvirtual_cloud_db.cpp310 std::vector<QueryNode> queryNodes; in GetCloudData() local
315 queryNodes = RelationalStoreManager::ParserQueryNodes(bytes, status); in GetCloudData()
320 if ((!queryNodes.empty()) && (!IsCloudGidMatching(queryNodes, tableData.extend)) && in GetCloudData()
321 (!IsPrimaryKeyMatching(queryNodes, tableData.record))) { in GetCloudData()
339 bool VirtualCloudDb::IsPrimaryKeyMatching(const std::vector<QueryNode> &queryNodes, VBucket &record) in IsPrimaryKeyMatching() argument
344 for (const auto &queryNode : queryNodes) { in IsPrimaryKeyMatching()
384 bool VirtualCloudDb::IsCloudGidMatching(const std::vector<QueryNode> &queryNodes, VBucket &extend) in IsCloudGidMatching() argument
386 for (const auto &queryNode : queryNodes) { in IsCloudGidMatching()
H A Dvirtual_cloud_db.h118 bool IsCloudGidMatching(const std::vector<QueryNode> &queryNodes, VBucket &extend);
122 bool IsPrimaryKeyMatching(const std::vector<QueryNode> &queryNodes, VBucket &record);
H A Ddistributeddb_cloud_kv_syncer_test.cpp515 std::vector<QueryNode> queryNodes; variable
516 syncObject.ParserQueryNodes(bytes, queryNodes);
517 ASSERT_EQ(queryNodes[0].type, QueryNodeType::IN);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_cloud.cpp235 QueryNodes queryNodes; in ConvertQuery() local
236 queryNodes.reserve(nodes.size()); in ConvertQuery()
264 queryNodes.emplace_back(std::move(queryNode)); in ConvertQuery()
266 return queryNodes; in ConvertQuery()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dquery_sync_object.h65 static int ParserQueryNodes(const Bytes &bytes, std::vector<QueryNode> &queryNodes);
H A Dquery_sync_object.cpp432 int QuerySyncObject::ParserQueryNodes(const Bytes &bytes, std::vector<QueryNode> &queryNodes) in ParserQueryNodes() argument
447 queryNodes.push_back(std::move(node)); in ParserQueryNodes()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_check_sync_test.cpp1071 auto queryNodes = RelationalStoreManager::ParserQueryNodes(bytes, status); in __anonc8f560be1302() local
1073 ASSERT_EQ(queryNodes.size(), 1u); in __anonc8f560be1302()
1074 EXPECT_EQ(queryNodes[0].type, QueryNodeType::IN); in __anonc8f560be1302()
1075 EXPECT_EQ(queryNodes[0].fieldName, "id"); in __anonc8f560be1302()
1076 ASSERT_EQ(queryNodes[0].fieldValue.size(), idValue.size()); in __anonc8f560be1302()
1078 std::string val = std::get<std::string>(queryNodes[0].fieldValue[i]); in __anonc8f560be1302()
1495 auto queryNodes = RelationalStoreManager::ParserQueryNodes(bytes, status); in __anonc8f560be1c02() local
1497 ASSERT_EQ(queryNodes.size(), 5u); // 5 is query nodes count in __anonc8f560be1c02()