Home
last modified time | relevance | path

Searched refs:queryObj (Results 1 – 25 of 29) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_subscribe_query_test.cpp400 QueryObject queryObj(query);
458 QueryObject queryObj(query);
515 QueryObject queryObj(query);
571 QueryObject queryObj(query);
626 QueryObject queryObj(query);
662 QueryObject queryObj(query);
665 errCode = store->AddSubscribe(SUBSCRIBE_ID, queryObj, false);
688 QueryObject queryObj(query);
738 QueryObject queryObj(query);
786 QueryObject queryObj(query);
[all …]
H A Ddistributeddb_storage_query_sync_test.cpp214 QueryObject queryObj(query);
254 QueryObject queryObj(query);
323 QueryObject queryObj(query);
364 queryObj};
386 QueryObject queryObj(query);
450 QueryObject queryObj(query);
517 QueryObject queryObj(query);
565 QueryObject queryObj(query);
736 QueryObject queryObj(query);
805 QuerySyncObject queryObj; variable
[all …]
H A Ddistributeddb_query_object_helper_test.cpp49 QueryObject queryObj(query); in GetQuerySql() local
53 queryObj.SetSchema(schema); in GetQuerySql()
56 SqliteQueryHelper helper = queryObj.GetQueryHelper(errCode); in GetQuerySql()
171 QueryObject queryObj(query);
174 queryObj.SetSchema(schema);
176 SqliteQueryHelper helper = queryObj.GetQueryHelper(errCode); // invalid field name
H A Ddistributeddb_relational_get_data_test.cpp614 QueryObject queryObj(query);
615 queryObj.SetSchema(store->GetSchemaInfo());
618 …EXPECT_EQ(store->GetSyncData(queryObj, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_O…
635 queryObj = QueryObject(query);
636 queryObj.SetSchema(store->GetSchemaInfo());
638 …EXPECT_EQ(store->GetSyncData(queryObj, SyncTimeRange {}, DataSizeSpecInfo {}, token, entries), E_O…
H A Ddistributeddb_storage_sqlite_single_ver_natural_executor_test.cpp1185 QueryObject queryObj(queryObjNodes, prefixKey, keys);
1186 int ret = g_handle->AddSubscribeTrigger(queryObj, "");
1188 ret = g_handle->ReloadResultSet(queryObj);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
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);
93 int OpenResultSetForCacheRowIdMode(QueryObject &queryObj, std::vector<int64_t> &rowIdCache,
98 int ReloadResultSet(QueryObject &queryObj);
103 int ReloadResultSetForCacheRowIdMode(QueryObject &queryObj, std::vector<int64_t> &rowIdCache,
163 int CheckQueryObjectLegal(QueryObject &queryObj) const;
249 int InitResultSetCount(QueryObject &queryObj, sqlite3_stmt *&countStmt);
251 int InitResultSetContent(QueryObject &queryObj);
253 int InitResultSet(QueryObject &queryObj, sqlite3_stmt *&countStmt);
H A Dsqlite_single_ver_natural_store_connection.cpp153 QueryObject queryObj(query); in GetEntries() local
154 if (((queryObj.GetSortType() != SortType::NONE) && !queryObj.IsQueryOnlyByKey()) in GetEntries()
155 || queryObj.IsQueryByRange()) { in GetEntries()
163 queryObj.SetSchema(schemaObjRef); in GetEntries()
203 QueryObject queryObj(query); in GetCount() local
204 if (((queryObj.GetSortType() != SortType::NONE) && !queryObj.IsQueryOnlyByKey()) in GetCount()
205 || queryObj.IsQueryByRange()) { in GetCount()
212 queryObj.SetSchema(schemaObjRef); in GetCount()
601 QueryObject queryObj(query); in GetResultSet() local
607 if (((queryObj.GetSortType() != SortType::NONE) && !queryObj.IsQueryOnlyByKey()) in GetResultSet()
[all …]
H A Dsqlite_single_ver_storage_executor.cpp346 SqliteQueryHelper helper = queryObj.GetQueryHelper(errCode); in GetEntries()
368 SqliteQueryHelper helper = queryObj.GetQueryHelper(errCode); in GetCount()
373 if (!queryObj.IsCountValid()) { in GetCount()
742 int errCode = InitResultSet(queryObj, countStatement); in OpenResultSet()
757 if (queryObj.HasLimit()) { in OpenResultSet()
760 queryObj.GetLimitVal(limit, offset); in OpenResultSet()
828 if (!queryObj.IsValid()) { in OpenResultSetForCacheRowIdMode()
871 if (!queryObj.IsValid()) { in ReloadResultSet()
1890 if (!queryObj.IsValid()) { in InitResultSet()
1894 errCode = InitResultSetCount(queryObj, countStmt); in InitResultSet()
[all …]
H A Dsqlite_single_ver_forward_cursor.cpp32 const QueryObject &queryObj) in SQLiteSingleVerForwardCursor() argument
34 queryObj_(queryObj), in SQLiteSingleVerForwardCursor()
H A Dsqlite_single_ver_forward_cursor.h30 SQLiteSingleVerForwardCursor(SQLiteSingleVerNaturalStore *kvDB, const QueryObject &queryObj);
H A Dsqlite_single_ver_result_set.h43 …SQLiteSingleVerResultSet(SQLiteSingleVerNaturalStore *kvDB, const QueryObject &queryObj, const Opt…
H A Dsqlite_single_ver_result_set.cpp35 …ResultSet::SQLiteSingleVerResultSet(SQLiteSingleVerNaturalStore *kvDB, const QueryObject &queryObj, in SQLiteSingleVerResultSet() argument
36 …const Option& option) : option_(option), type_(ResultSetType::QUERY), queryObj_(queryObj), kvDB_(k… in SQLiteSingleVerResultSet()
H A Dquery_sync_object.cpp296 int QuerySyncObject::DeSerializeData(Parcel &parcel, QuerySyncObject &queryObj) in DeSerializeData() argument
341 queryObj = QuerySyncObject(context.queryObjNodes, context.prefixKey, keys); in DeSerializeData()
343 queryObj.SetTableName(tableName); in DeSerializeData()
H A Dquery_sync_object.h50 static int DeSerializeData(Parcel &parcel, QuerySyncObject &queryObj);
H A Dsqlite_single_ver_storage_executor_subscribe.cpp26 int SQLiteSingleVerStorageExecutor::CheckQueryObjectLegal(QueryObject &queryObj) const in CheckQueryObjectLegal()
29 SqliteQueryHelper helper = queryObj.GetQueryHelper(errCode); in CheckQueryObjectLegal()
H A Dsqlite_cloud_kv_store.cpp173 QuerySyncObject queryObj = query; variable
175 isCloudForcePush, queryObj);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Drelational_db_sync_interface.h38 virtual int LocalDataChanged(int notifyEvent, std::vector<QuerySyncObject> &queryObj) = 0;
/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);
172 int CheckQueryObjectLegal(QueryObject &queryObj) const;
H A Drd_single_ver_storage_executor.cpp523 int RdSingleVerStorageExecutor::OpenResultSet(QueryObject &queryObj, int &count) in OpenResultSet() argument
647 int RdSingleVerStorageExecutor::CheckQueryObjectLegal(QueryObject &queryObj) const in CheckQueryObjectLegal()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_able_storage.cpp642 …elationalSyncAbleStorage::LocalDataChanged(int notifyEvent, std::vector<QuerySyncObject> &queryObj) in LocalDataChanged() argument
644 (void) queryObj; in LocalDataChanged()
1076 QuerySyncObject queryObj = query; in GetAllUploadCount() local
1077 queryObj.SetSchema(GetSchemaInfo()); in GetAllUploadCount()
1078 …errCode = handle->GetAllUploadCount(timestampVec, isCloudForcePush, isCompensatedTask, queryObj, c… in GetAllUploadCount()
1093 QuerySyncObject queryObj = query; in GetUploadCount() local
1094 queryObj.SetSchema(GetSchemaInfo()); in GetUploadCount()
1095 … errCode = handle->GetUploadCount(timestamp, isCloudForcePush, isCompensatedTask, queryObj, count); in GetUploadCount()
1471 QuerySyncObject queryObj = query; in CheckQueryValid() local
1472 queryObj.SetSchema(GetSchemaInfo()); in CheckQueryValid()
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.cpp279 QuerySyncObject queryObj = packet->GetQuery(); in DataPacketQuerySyncSerialization() local
287 errCode = queryObj.SerializeData(parcel, SOFTWARE_VERSION_CURRENT); in DataPacketQuerySyncSerialization()
702 QuerySyncObject queryObj = packet->GetQuery(); in SubscribeSerialization() local
703 errCode = queryObj.SerializeData(parcel, SOFTWARE_VERSION_CURRENT); in SubscribeSerialization()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dvirtual_relational_ver_sync_db_interface.h55 int LocalDataChanged(int notifyEvent, std::vector<QuerySyncObject> &queryObj) override;
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp712 QuerySyncObject queryObj(Query::Select().PrefixKey({'b'}));
713 EXPECT_EQ(subManager.ReserveLocalSubscribeQuery("test_dev", queryObj), E_OK);
714 subManager.DeleteLocalSubscribeQuery(DEVICE_A, queryObj);
716 EXPECT_EQ(subManager.ActiveLocalSubscribeQuery(DEVICE_B, queryObj), -E_INTERNAL_ERROR);
H A Dvirtual_relational_ver_sync_db_interface.cpp180 …tionalVerSyncDBInterface::LocalDataChanged(int notifyEvent, std::vector<QuerySyncObject> &queryObj) in LocalDataChanged() argument
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_device_identifier_test.cpp753 QueryObject queryObj(query);
755 EXPECT_EQ(g_store->AddSubscribe(sub, queryObj, true), E_OK);

12