Home
last modified time | relevance | path

Searched refs:dbQuery (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dquery_helper.cpp39 return dbQuery; in StringToDbQuery()
44 return dbQuery; in StringToDbQuery()
57 return dbQuery; in StringToDbQuery()
84 return dbQuery; in StringToDbQuery()
419 dbQuery.And(); in HandleAnd()
426 dbQuery.Or(); in HandleOr()
476 dbQuery.Limit(number, offset); in HandleLimit()
483 dbQuery.BeginGroup(); in HandleBeginGroup()
490 dbQuery.EndGroup(); in HandleEndGroup()
528 dbQuery.InKeys(inDbKeys); in HandleInKeys()
[all …]
H A Dquery_helper.h34 …static bool Handle(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
35 …c bool HandleExtra(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
36 …bool HandleEqualTo(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
41 const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
43 … bool HandleIsNull(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
45 …atic bool HandleIn(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
46 …c bool HandleNotIn(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
47 …ic bool HandleLike(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
49 …tic bool HandleAnd(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
50 …atic bool HandleOr(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
[all …]
H A Dkvdb_general_store.cpp402 DistributedDB::Query dbQuery; in Sync() local
404 dbQuery = kvQuery->GetDBQuery(); in Sync()
409 … = delegate_->SubscribeRemoteQuery(devices, GetDBSyncCompleteCB(std::move(async)), dbQuery, false); in Sync()
412 … delegate_->UnSubscribeRemoteQuery(devices, GetDBSyncCompleteCB(std::move(async)), dbQuery, false); in Sync()
417 …dbStatus = delegate_->Sync(devices, dbMode, GetDBSyncCompleteCB(std::move(async)), dbQuery, false); in Sync()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_test.cpp435 DistributedDB::Query dbQuery; variable
436 EXPECT_FALSE(queryHelper->Handle(words, pointer, end, dbQuery));
452 EXPECT_FALSE(queryHelper->Handle(words, pointer, end, dbQuery));
484 DistributedDB::Query dbQuery; variable
491 EXPECT_TRUE(queryHelper->HandleLike(words, pointer, ends, dbQuery));
527 DistributedDB::Query dbQuery; variable
528 EXPECT_FALSE(queryHelper->HandleIn(words, pointer, ends, dbQuery));
529 EXPECT_FALSE(queryHelper->HandleIn(words, pointer, end, dbQuery));
530 EXPECT_FALSE(queryHelper->HandleIn(wordss, pointer, end, dbQuery));
531 EXPECT_TRUE(queryHelper->HandleIn(wordss, pointer, ends, dbQuery));
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dconvertor.cpp48 DBQuery dbQuery = *(query.query_); in GetDBQuery() local
50 dbQuery.PrefixKey(GetPrefix(query)); in GetDBQuery()
58 dbQuery.InKeys(keys); in GetDBQuery()
60 return dbQuery; in GetDBQuery()
H A Dsingle_store_impl.cpp411 DBQuery dbQuery = DBQuery::Select(); in GetEntries() local
412 dbQuery.PrefixKey(dbPrefix); in GetEntries()
413 auto status = GetEntries(dbQuery, entries); in GetEntries()
423 DBQuery dbQuery = convertor_.GetDBQuery(query); in GetEntries() local
424 auto status = GetEntries(dbQuery, entries); in GetEntries()
441 DBQuery dbQuery = DistributedDB::Query::Select(); in GetResultSet() local
442 dbQuery.PrefixKey(dbPrefix); in GetResultSet()
443 auto status = GetResultSet(dbQuery, resultSet); in GetResultSet()
493 DBQuery dbQuery = convertor_.GetDBQuery(query); in GetResultSet() local
494 auto status = GetResultSet(dbQuery, resultSet); in GetResultSet()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/
H A Dsingle_store_impl.cpp242 DBQuery dbQuery = DBQuery::Select(); in GetEntries() local
243 dbQuery.PrefixKey(dbPrefix); in GetEntries()
244 auto status = GetEntries(dbQuery, entries); in GetEntries()
253 DBQuery dbQuery = convertor_.GetDBQuery(query); in GetEntries() local
254 auto status = GetEntries(dbQuery, entries); in GetEntries()
270 DBQuery dbQuery = DistributedDB::Query::Select(); in GetResultSet() local
271 dbQuery.PrefixKey(dbPrefix); in GetResultSet()
272 auto status = GetResultSet(dbQuery, resultSet); in GetResultSet()
281 DBQuery dbQuery = convertor_.GetDBQuery(query); in GetResultSet() local
282 auto status = GetResultSet(dbQuery, resultSet); in GetResultSet()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/
H A Druntime_store.cpp473 Query dbQuery = Query::Select(); in GetEntries() local
475 dbQuery.PrefixKey(prefix); in GetEntries()
476 dbQuery.OrderByWriteTime(true); in GetEntries()
477 DBStatus status = kvStore_->GetEntries(dbQuery, entries); in GetEntries()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_general_store.cpp520 DistributedDB::Query dbQuery; in Sync() local
525 dbQuery.FromTable(GetIntersection(query.GetTables(), GetTables())); in Sync()
527 dbQuery = rdbQuery->GetQuery(); in Sync()
543 …dbStatus = delegate_->Sync(devices, dbMode, dbQuery, GetDBBriefCB(std::move(async)), syncParam.wai… in Sync()
550 dbStatus = delegate_->Sync({ devices, dbMode, dbQuery, syncParam.wait, in Sync()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_manager.cpp887 DistributedDB::Query dbQuery = DistributedDB::Query::Select(); in SyncOnStore() local
888 dbQuery.PrefixKey(std::vector<uint8_t>(prefix.begin(), prefix.end())); in SyncOnStore()
898 }, dbQuery, false); in SyncOnStore()