Searched refs:rdbQuery (Results 1 - 5 of 5) sorted by relevance
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | rdb_query_test.cpp | 47 RdbQuery rdbQuery;
in HWTEST_F() local
49 bool result = rdbQuery.IsEqual(tid);
in HWTEST_F()
51 std::vector<std::string> tables = rdbQuery.GetTables();
in HWTEST_F()
56 rdbQuery.MakeRemoteQuery(devices, sql, std::move(args));
in HWTEST_F()
57 EXPECT_TRUE(rdbQuery.IsRemoteQuery());
in HWTEST_F()
58 EXPECT_EQ(rdbQuery.GetDevices().size(), 1);
in HWTEST_F()
59 EXPECT_EQ(rdbQuery.GetDevices()[0], devices);
in HWTEST_F()
61 rdbQuery.MakeQuery(predicates);
in HWTEST_F()
62 rdbQuery.MakeCloudQuery(predicates);
in HWTEST_F()
77 RdbQuery rdbQuery;
in HWTEST_F() local
105 RdbQuery rdbQuery; HWTEST_F() local
143 RdbQuery rdbQuery; HWTEST_F() local
[all...] |
| H A D | cloud_data_test.cpp | 685 auto rdbQuery = std::make_shared<DistributedRdb::RdbQuery>(); in HWTEST_F()
686 rdbQuery->MakeQuery(*predicate); in HWTEST_F()
687 rdbQuery->SetColumns(evt.GetColumns()); in HWTEST_F()
688 callback(rdbQuery); in HWTEST_F()
902 auto rdbQuery = std::make_shared<DistributedRdb::RdbQuery>(); in HWTEST_F() local
903 auto event2 = std::make_unique<CloudShareEvent>(storeInfo, rdbQuery, nullptr); in HWTEST_F()
905 auto event3 = std::make_unique<CloudShareEvent>(storeInfo, rdbQuery, asyncCallback); in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.cpp | 456 RdbQuery *rdbQuery = nullptr; in Query() local
457 auto ret = query.QueryInterface(rdbQuery); in Query()
458 if (ret != GeneralError::E_OK || rdbQuery == nullptr) { in Query()
468 if (rdbQuery->IsRemoteQuery()) { in Query()
469 if (rdbQuery->GetDevices().size() != 1) { in Query()
470 ZLOGE("RemoteQuery: devices size error! size:%{public}zu", rdbQuery->GetDevices().size()); in Query()
473 return { GeneralError::E_OK, RemoteQuery(*rdbQuery->GetDevices().begin(), rdbQuery->GetRemoteCondition()) }; in Query()
507 RdbQuery *rdbQuery = nullptr; in Sync() local
509 auto ret = query.QueryInterface(rdbQuery); in Sync()
555 RdbQuery *rdbQuery = nullptr; PreSharing() local
[all...] |
| H A D | rdb_service_impl.cpp | 132 auto rdbQuery = std::make_shared<RdbQuery>(); in RdbServiceImpl()
133 rdbQuery->MakeQuery(*predicate); in RdbServiceImpl()
134 rdbQuery->SetColumns(evt.GetColumns()); in RdbServiceImpl()
135 callback(rdbQuery); in RdbServiceImpl()
404 RdbQuery rdbQuery;
405 rdbQuery.MakeRemoteQuery(DmAdapter::GetInstance().ToUUID(device), sql, ValueProxy::Convert(selectionArgs));
406 auto [errCode, cursor] = store->Query("", rdbQuery);
436 RdbQuery rdbQuery;
437 rdbQuery.MakeQuery(predicates);
438 auto devices = rdbQuery
[all...] |
| H A D | rdb_service_impl.h | 181 StoreInfo& storeInfo, std::shared_ptr<RdbQuery> rdbQuery);
|
Completed in 7 milliseconds