Home
last modified time | relevance | path

Searched refs:QueryObject (Results 1 – 25 of 56) sorted by relevance

123

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dquery_object.cpp29 QueryObject::QueryObject() in QueryObject() function in DistributedDB::QueryObject
62 QueryObject::QueryObject(const Query &query) in QueryObject() function in DistributedDB::QueryObject
67 QueryObject::QueryObject(const QueryExpression &queryExpression) in QueryObject() function in DistributedDB::QueryObject
109 QueryObject::~QueryObject() in ~QueryObject()
112 int QueryObject::Init() in Init()
139 bool QueryObject::IsValid() in IsValid()
147 bool QueryObject::HasLimit() const in HasLimit()
177 void QueryObject::ClearNodesFlag() in ClearNodesFlag()
189 int QueryObject::Parse() in Parse()
441 bool QueryObject::Empty() const in Empty()
[all …]
H A Dquery_object.h27 class QueryObject {
29 QueryObject();
30 explicit QueryObject(const Query &query);
32 QueryObject(const std::list<QueryObjNode> &queryObjNodes, const std::vector<uint8_t> &prefixKey,
34 virtual ~QueryObject();
76 explicit QueryObject(const QueryExpression &queryExpression);
H A Dsqlite_single_ver_storage_executor.h49 int GetEntries(QueryObject &queryObj, std::vector<Entry> &entries) const;
51 int GetCount(QueryObject &queryObj, int &count) const;
88 int OpenResultSet(QueryObject &queryObj, int &count);
98 int ReloadResultSet(QueryObject &queryObj);
133 uint64_t recordVersion, const QueryObject &query);
163 int CheckQueryObjectLegal(QueryObject &queryObj) const;
169 int AddSubscribeTrigger(QueryObject &query, const std::string &subscribeId);
249 int InitResultSetCount(QueryObject &queryObj, sqlite3_stmt *&countStmt);
251 int InitResultSetContent(QueryObject &queryObj);
253 int InitResultSet(QueryObject &queryObj, sqlite3_stmt *&countStmt);
[all …]
H A Dsqlite_single_ver_natural_store.h83 …int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSi…
94 … int PutSyncDataWithQuery(const QueryObject &query, const std::vector<SingleVerKvEntry *> &entries,
178 int CheckAndInitQueryCondition(QueryObject &query) const override;
185 …int AddSubscribe(const std::string &subscribeId, const QueryObject &query, bool needCacheSubscribe…
246 …int SaveSyncDataItems(const QueryObject &query, std::vector<DataItem> &dataItems, const DeviceInfo…
281 …int SaveSyncDataToMain(const QueryObject &query, std::vector<DataItem> &dataItems, const DeviceInf…
285 …int SaveSyncItems(const QueryObject& query, std::vector<DataItem> &dataItems, const DeviceInfo &de…
288 int SaveSyncDataToCacheDB(const QueryObject &query, std::vector<DataItem> &dataItems,
291 int SaveSyncItemsInCacheMode(SQLiteSingleVerStorageExecutor *handle, const QueryObject &query,
H A Dsqlite_single_ver_continue_token.h31 SQLiteSingleVerContinueToken(const SyncTimeRange &timeRange, const QueryObject &queryObject);
62 QueryObject GetQuery() const;
78 std::map<DeviceID, QueryObject> queryObject_;
H A Dsqlite_single_ver_continue_token.cpp26 const SyncTimeRange &timeRange, const QueryObject &queryObject) in SQLiteSingleVerContinueToken()
27 : queryObject_(std::map<DeviceID, QueryObject>{{"", queryObject}}), in SQLiteSingleVerContinueToken()
109 QueryObject SQLiteSingleVerContinueToken::GetQuery() const in GetQuery()
114 return QueryObject{}; in GetQuery()
H A Dsqlite_single_ver_forward_cursor.h30 SQLiteSingleVerForwardCursor(SQLiteSingleVerNaturalStore *kvDB, const QueryObject &queryObj);
54 QueryObject queryObj_;
H A Dsqlite_single_ver_result_set.h43 …SQLiteSingleVerResultSet(SQLiteSingleVerNaturalStore *kvDB, const QueryObject &queryObj, const Opt…
103 …mutable QueryObject queryObj_; // Some QueryObject member function need to call is not a const fun…
H A Dsqlite_single_ver_storage_engine.h61 void CacheSubscribe(const std::string &subscribeId, const QueryObject &query);
132 std::map<std::string, QueryObject> subscribeQuery_;
H A Dsqlite_single_ver_storage_executor_subscribe.cpp26 int SQLiteSingleVerStorageExecutor::CheckQueryObjectLegal(QueryObject &queryObj) const in CheckQueryObjectLegal()
96 int SQLiteSingleVerStorageExecutor::CheckDataWithQuery(QueryObject query, std::vector<DataItem> &da… in CheckDataWithQuery()
149 int SQLiteSingleVerStorageExecutor::AddSubscribeTrigger(QueryObject &query, const std::string &subs… in AddSubscribeTrigger()
H A Dquery_sync_object.cpp93 : QueryObject(queryObjNodes, prefixKey, keys) in QuerySyncObject()
97 : QueryObject(query) in QuerySyncObject()
101 : QueryObject(expression) in QuerySyncObject()
425 const auto &expressions = QueryObject::GetQueryExpressions(query); in GetQuerySyncObject()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_subscribe_query_test.cpp238 QueryObject queryObject1(query1);
247 QueryObject queryObject2(query2);
400 QueryObject queryObj(query);
458 QueryObject queryObj(query);
515 QueryObject queryObj(query);
571 QueryObject queryObj(query);
662 QueryObject queryObj(query);
688 QueryObject queryObj(query);
738 QueryObject queryObj(query);
786 QueryObject queryObj(query);
[all …]
H A Ddistributeddb_relational_get_data_test.cpp267 QueryObject query(Query::Select(g_tableName)); in SetNextBeginTime001()
384 QueryObject query(Query::Select(g_tableName));
438 QueryObject query(Query::Select(g_tableName));
492 QueryObject query(Query::Select(tableName));
614 QueryObject queryObj(query);
635 queryObj = QueryObject(query);
702 QueryObject query(Query::Select(tableName));
788 QueryObject query(Query::Select(tableName));
862 QueryObject query(Query::Select(tableName));
1595 QueryObject queryObj1(query);
[all …]
H A Ddistributeddb_storage_query_sync_test.cpp214 QueryObject queryObj(query);
254 QueryObject queryObj(query);
323 QueryObject queryObj(query);
386 QueryObject queryObj(query);
450 QueryObject queryObj(query);
517 QueryObject queryObj(query);
565 QueryObject queryObj(query);
736 QueryObject queryObj(query);
1089 QueryObject queryObj(query);
1093 QueryObject queryObj1(query1);
[all …]
H A Ddistributeddb_storage_index_optimize_test.cpp261 QueryObject queryObject1(query1);
273 QueryObject queryObject2(query2);
285 QueryObject queryObject3(query3);
317 QueryObject queryObject1(query1);
367 QueryObject queryObject3(query3);
H A Ddistributeddb_query_object_helper_test.cpp49 QueryObject queryObj(query); in GetQuerySql()
171 QueryObject queryObj(query);
180 QueryObject queryObj1(query1);
186 QueryObject queryObj2(query2);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.h119 int OpenResultSet(QueryObject &queryObj, int &count);
138 uint64_t recordVersion, const QueryObject &query);
172 int CheckQueryObjectLegal(QueryObject &queryObj) const;
174 …int CheckDataWithQuery(QueryObject query, std::vector<DataItem> &dataItems, const DeviceInfo &devi…
178 int AddSubscribeTrigger(QueryObject &query, const std::string &subscribeId);
188 …int GetSyncDataWithQuery(const QueryObject &query, size_t appendLength, const DataSizeSpecInfo &da…
H A Drd_single_ver_storage_executor.cpp523 int RdSingleVerStorageExecutor::OpenResultSet(QueryObject &queryObj, int &count) in OpenResultSet()
570 Timestamp &maxStamp, uint64_t recordVersion, const QueryObject &query) in SaveSyncDataItemInCacheMode()
647 int RdSingleVerStorageExecutor::CheckQueryObjectLegal(QueryObject &queryObj) const in CheckQueryObjectLegal()
652 int RdSingleVerStorageExecutor::CheckDataWithQuery(QueryObject query, std::vector<DataItem> &dataIt… in CheckDataWithQuery()
663 int RdSingleVerStorageExecutor::AddSubscribeTrigger(QueryObject &query, const std::string &subscrib… in AddSubscribeTrigger()
688 int RdSingleVerStorageExecutor::GetSyncDataWithQuery(const QueryObject &query, size_t appendLength, in GetSyncDataWithQuery()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_ver_relational_continue_token.h29 …SQLiteSingleVerRelationalContinueToken(const SyncTimeRange &timeRange, const QueryObject &queryObj…
39 const QueryObject &GetQuery() const;
56 QueryObject queryObj_;
H A Dsqlite_single_ver_relational_continue_token.cpp21 const SyncTimeRange &timeRange, const QueryObject &queryObject) in SQLiteSingleVerRelationalContinueToken()
139 const QueryObject &SQLiteSingleVerRelationalContinueToken::GetQuery() const in GetQuery()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dsync_generic_interface.h48 virtual int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData()
102 …virtual int PutSyncDataWithQuery(const QueryObject &query, const std::vector<SingleVerKvEntry *> &… in PutSyncDataWithQuery()
108 virtual int CheckAndInitQueryCondition(QueryObject &query) const in CheckAndInitQueryCondition()
119 …virtual int AddSubscribe(const std::string &subscribeId, const QueryObject &query, bool needCacheS… in AddSubscribe()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_data_inserter.h46 … RelationalSyncDataInserter CreateInserter(const std::string &deviceName, const QueryObject &query,
58 void SetQuery(QueryObject query);
80 QueryObject query_;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_single_ver_sync_db_Interface.h86 …int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, const DataSizeSpecInfo &dataSi…
92 … int PutSyncDataWithQuery(const QueryObject &query, const std::vector<SingleVerKvEntry *> &entries,
119 int CheckAndInitQueryCondition(QueryObject &query) const override;
124 …int AddSubscribe(const std::string &subscribeId, const QueryObject &query, bool needCacheSubscribe…
H A Dvirtual_relational_ver_sync_db_interface.h43 … int PutSyncDataWithQuery(const QueryObject &query, const std::vector<SingleVerKvEntry *> &entries,
57 int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange,
98 int CheckAndInitQueryCondition(QueryObject &query) const override in CheckAndInitQueryCondition()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_sync_able_storage.h79 int GetSyncData(QueryObject &query, const SyncTimeRange &timeRange,
86 …int PutSyncDataWithQuery(const QueryObject &object, const std::vector<SingleVerKvEntry *> &entries,
107 int CheckAndInitQueryCondition(QueryObject &query) const override;
271 …int PutSyncData(const QueryObject &object, std::vector<DataItem> &dataItems, const std::string &de…
272 …int SaveSyncDataItems(const QueryObject &object, std::vector<DataItem> &dataItems, const std::stri…

123