Home
last modified time | relevance | path

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

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dquery_helper.cpp35 DBQuery dbQuery = DBQuery::Select(); in StringToDbQuery() local
39 return dbQuery; in StringToDbQuery()
44 return dbQuery; in StringToDbQuery()
57 return dbQuery; in StringToDbQuery()
65 isSuccess = HandleEqualTo(words, pointer, end, dbQuery); in StringToDbQuery()
67 isSuccess = HandleNotEqualTo(words, pointer, end, dbQuery); in StringToDbQuery()
69 isSuccess = HandleGreaterThan(words, pointer, end, dbQuery); in StringToDbQuery()
71 isSuccess = HandleLessThan(words, pointer, end, dbQuery); in StringToDbQuery()
73 isSuccess = HandleGreaterThanOrEqualTo(words, pointer, end, dbQuery); in StringToDbQuery()
75 isSuccess = HandleLessThanOrEqualTo(words, pointer, end, dbQuery); in StringToDbQuery()
87 Handle(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) Handle() argument
117 HandleExtra(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleExtra() argument
139 HandleEqualTo(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleEqualTo() argument
166 HandleNotEqualTo(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleNotEqualTo() argument
193 HandleGreaterThan(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleGreaterThan() argument
218 HandleLessThan(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleLessThan() argument
243 HandleGreaterThanOrEqualTo( const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleGreaterThanOrEqualTo() argument
269 HandleLessThanOrEqualTo( const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleLessThanOrEqualTo() argument
295 HandleIsNull(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleIsNull() argument
307 HandleIsNotNull(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleIsNotNull() argument
319 HandleIn(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleIn() argument
355 HandleNotIn(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleNotIn() argument
391 HandleLike(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleLike() argument
404 HandleNotLike(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleNotLike() argument
417 HandleAnd(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleAnd() argument
424 HandleOr(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleOr() argument
431 HandleOrderByAsc(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleOrderByAsc() argument
443 HandleOrderByDesc(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleOrderByDesc() argument
455 HandleOrderByWriteTime(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleOrderByWriteTime() argument
468 HandleLimit(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleLimit() argument
481 HandleBeginGroup(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleBeginGroup() argument
488 HandleEndGroup(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleEndGroup() argument
495 HandleKeyPrefix(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleKeyPrefix() argument
508 HandleInKeys(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleInKeys() argument
534 HandleSetSuggestIndex(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleSetSuggestIndex() argument
546 HandleDeviceId(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery) HandleDeviceId() argument
[all...]
H A Dquery_helper.h34 static bool Handle(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
35 static bool HandleExtra(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
36 static bool HandleEqualTo(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
37 static bool HandleNotEqualTo(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
38 static bool HandleGreaterThan(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
39 static bool HandleLessThan(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);
42 static bool HandleLessThanOrEqualTo(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
43 static bool HandleIsNull(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
44 static bool HandleIsNotNull(const std::vector<std::string> &words, int &pointer, int end, DBQuery &dbQuery);
[all...]
H A Dkvdb_general_store.cpp401 DistributedDB::Query dbQuery; in Sync() local
403 dbQuery = kvQuery->GetDBQuery(); in Sync()
408 dbStatus = delegate_->SubscribeRemoteQuery(devices, GetDBSyncCompleteCB(std::move(async)), dbQuery, false); in Sync()
411 delegate_->UnSubscribeRemoteQuery(devices, GetDBSyncCompleteCB(std::move(async)), dbQuery, false); in Sync()
416 dbStatus = delegate_->Sync(devices, dbMode, GetDBSyncCompleteCB(std::move(async)), dbQuery, false); in Sync()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_test.cpp436 DistributedDB::Query dbQuery; in HWTEST_F() local
437 EXPECT_FALSE(queryHelper->Handle(words, pointer, end, dbQuery)); in HWTEST_F()
438 EXPECT_FALSE(queryHelper->HandleExtra(words, pointer, end, dbQuery)); in HWTEST_F()
439 EXPECT_FALSE(queryHelper->HandleEqualTo(words, pointer, end, dbQuery)); in HWTEST_F()
440 EXPECT_FALSE(queryHelper->HandleNotEqualTo(words, pointer, end, dbQuery)); in HWTEST_F()
441 EXPECT_FALSE(queryHelper->HandleNotEqualTo(words, pointer, ends, dbQuery)); in HWTEST_F()
442 EXPECT_FALSE(queryHelper->HandleGreaterThan(words, pointer, ends, dbQuery)); in HWTEST_F()
443 EXPECT_FALSE(queryHelper->HandleGreaterThan(words, pointer, end, dbQuery)); in HWTEST_F()
444 EXPECT_FALSE(queryHelper->HandleLessThan(words, pointer, ends, dbQuery)); in HWTEST_F()
445 EXPECT_FALSE(queryHelper->HandleLessThan(words, pointer, end, dbQuery)); in HWTEST_F()
485 DistributedDB::Query dbQuery; HWTEST_F() local
528 DistributedDB::Query dbQuery; HWTEST_F() local
554 DistributedDB::Query dbQuery; HWTEST_F() local
[all...]
/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, resultSe in GetResultSet()
526 DBQuery dbQuery = convertor_.GetDBQuery(query); GetCount() local
[all...]
/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, resultSe in GetResultSet()
312 DBQuery dbQuery = convertor_.GetDBQuery(query); GetCount() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/
H A Druntime_store.cpp530 Query dbQuery = Query::Select(); in GetEntries() local
532 dbQuery.PrefixKey(prefix); in GetEntries()
533 dbQuery.OrderByWriteTime(true); in GetEntries()
534 DBStatus status = kvStore_->GetEntries(dbQuery, entries); in GetEntries()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_general_store.cpp506 DistributedDB::Query dbQuery; in Sync() local
511 dbQuery.FromTable(GetIntersection(query.GetTables(), GetTables())); in Sync()
513 dbQuery = rdbQuery->GetQuery(); in Sync()
529 dbStatus = delegate_->Sync(devices, dbMode, dbQuery, GetDBBriefCB(std::move(async)), syncParam.wait != 0); in Sync()
536 dbStatus = delegate_->Sync({ devices, dbMode, dbQuery, syncParam.wait, in Sync()
/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()

Completed in 12 milliseconds