Searched refs:queryNodes (Results 1 - 7 of 7) sorted by relevance
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | virtual_cloud_db.cpp | 310 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 D | virtual_cloud_db.h | 115 bool IsCloudGidMatching(const std::vector<QueryNode> &queryNodes, VBucket &extend);
119 bool IsPrimaryKeyMatching(const std::vector<QueryNode> &queryNodes, VBucket &record);
|
| H A D | distributeddb_cloud_kv_syncer_test.cpp | 537 std::vector<QueryNode> queryNodes; in HWTEST_F() local
538 syncObject.ParserQueryNodes(bytes, queryNodes); in HWTEST_F()
539 ASSERT_EQ(queryNodes[0].type, QueryNodeType::IN); in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_cloud.cpp | 235 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()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | query_sync_object.h | 65 static int ParserQueryNodes(const Bytes &bytes, std::vector<QueryNode> &queryNodes);
|
| H A D | query_sync_object.cpp | 432 int QuerySyncObject::ParserQueryNodes(const Bytes &bytes, std::vector<QueryNode> &queryNodes) in ParserQueryNodes() argument
447 queryNodes.push_back(std::move(node)); in ParserQueryNodes()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_check_sync_test.cpp | 1067 auto queryNodes = RelationalStoreManager::ParserQueryNodes(bytes, status); in HWTEST_F()
1069 ASSERT_EQ(queryNodes.size(), 1u); in HWTEST_F()
1070 EXPECT_EQ(queryNodes[0].type, QueryNodeType::IN); in HWTEST_F()
1071 EXPECT_EQ(queryNodes[0].fieldName, "id"); in HWTEST_F()
1072 ASSERT_EQ(queryNodes[0].fieldValue.size(), idValue.size()); in HWTEST_F()
1074 std::string val = std::get<std::string>(queryNodes[0].fieldValue[i]); in HWTEST_F()
1491 auto queryNodes = RelationalStoreManager::ParserQueryNodes(bytes, status); in HWTEST_F()
1493 ASSERT_EQ(queryNodes.size(), 5u); // 5 is query nodes count in HWTEST_F()
|
Completed in 9 milliseconds