| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
| H A D | kvstore_datashare_bridge_test.cpp | 181 DataQuery query; in HWTEST_F() local
201 DataQuery query; in HWTEST_F() local
225 DataQuery query; in HWTEST_F() local
263 DataQuery query; in HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 95 void RelationalSyncDataInserter::SetQuery(QueryObject query) in SetQuery() argument
51 CreateInserter(const std::string &deviceName, const QueryObject &query, const RelationalSchemaObject &localSchema, const std::vector<FieldInfo> &remoteFields, const StoreInfo &info) CreateInserter() argument
|
| /foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | kv_utils.cpp | 40 Status KvUtils::ToQuery(const DataShareAbsPredicates &predicates, DataQuery &query) in ToQuery() argument
171 void KvUtils::NoSupport(const DataShare::OperationItem &oper, DataQuery &query) in NoSupport() argument
176 void KvUtils::InKeys(const OperationItem &oper, DataQuery &query) in InKeys() argument
185 void KvUtils::KeyPrefix(const OperationItem &oper, DataQuery &query) in KeyPrefix() argument
190 void KvUtils::EqualTo(const OperationItem &oper, DataQuery &query) in EqualTo() argument
196 void KvUtils::NotEqualTo(const OperationItem &oper, DataQuery &query) in NotEqualTo() argument
202 GreaterThan(const OperationItem &oper, DataQuery &query) GreaterThan() argument
208 LessThan(const OperationItem &oper, DataQuery &query) LessThan() argument
214 GreaterThanOrEqualTo(const OperationItem &oper, DataQuery &query) GreaterThanOrEqualTo() argument
220 LessThanOrEqualTo(const OperationItem &oper, DataQuery &query) LessThanOrEqualTo() argument
226 And(const OperationItem &oper, DataQuery &query) And() argument
231 Or(const OperationItem &oper, DataQuery &query) Or() argument
236 IsNull(const OperationItem &oper, DataQuery &query) IsNull() argument
241 IsNotNull(const OperationItem &oper, DataQuery &query) IsNotNull() argument
246 In(const OperationItem &oper, DataQuery &query) In() argument
252 NotIn(const OperationItem &oper, DataQuery &query) NotIn() argument
258 Like(const OperationItem &oper, DataQuery &query) Like() argument
263 Unlike(const OperationItem &oper, DataQuery &query) Unlike() argument
268 OrderByAsc(const OperationItem &oper, DataQuery &query) OrderByAsc() argument
273 OrderByDesc(const OperationItem &oper, DataQuery &query) OrderByDesc() argument
278 Limit(const OperationItem &oper, DataQuery &query) Limit() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
| H A D | general_store_mock.cpp | 67 std::pair<int32_t, std::shared_ptr<Cursor>> GeneralStoreMock::Query(const std::string &table, GenQuery &query) in Query() argument
72 int32_t GeneralStoreMock::Sync(const Devices &devices, GenQuery &query, DetailAsync async, SyncParam &syncParm) in Sync() argument
77 std::pair<int32_t, std::shared_ptr<Cursor>> GeneralStoreMock::PreSharing(GenQuery &query) in PreSharing() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoredelegate_fuzzer/ |
| H A D | relationalstoredelegate_fuzzer.cpp | 143 Query query = Query::Select(); in CombineTest() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_nb_delegate_schema_put_test.cpp | 355 Query query = Query::Select().EqualTo("$.field_name2", 1); in HWTEST_F() local
408 Query query = Query::Select().EqualTo("create", true); HWTEST_F() local
444 Query query = Query::Select().EqualTo("$.field_name2", 1); HWTEST_F() local
[all...] |
| H A D | distributeddb_interfaces_schema_database_upgrade_test.cpp | 228 Query query = Query::Select().EqualTo("field_2.field_3", "OpenHarmony"); in HWTEST_F() local
311 Query query = Query::Select().EqualTo("field_2.field_4", 88); // 88 is the default value in the testcase. in TestUpgradeFromSchema() local
|
| H A D | distributeddb_interfaces_query_test.cpp | 29 bool CheckQueryContainer(Query &query, std::list<QueryObjNode> &checkList) in CheckQueryContainer() argument
146 Query query = Query::Select(); in HWTEST_F() local
202 Query query = Query::Select().NotEqualTo(".test", testValue); in HWTEST_F() local
219 Query query in HWTEST_F() local
[all...] |
| H A D | distributeddb_interfaces_device_identifier_test.cpp | 752 Query query = Query::Select(); in HWTEST_F() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_single_kv_store.cpp | 115 JsQuery* query; member
294 JsQuery* query = nullptr; GetResultSize() member
[all...] |
| H A D | js_device_kv_store.cpp | 132 JsQuery* query; member
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor_extend.cpp | 373 int SQLiteSingleVerStorageExecutor::GetSyncTotalWithQuery(QueryObject &query, in GetSyncTotalWithQuery() argument
|
| H A D | query_object.cpp | 62 QueryObject::QueryObject(const Query &query) in QueryObject() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/common/ |
| H A D | distributeddb_tools_test.cpp | 133 SyncTestWithQuery(KvStoreNbDelegate* delegate, const std::vector<std::string>& devices, SyncMode mode, std::map<std::string, DBStatus>& statuses, const Query &query) SyncTestWithQuery() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | kv_utils.cpp | 42 Status KvUtils::ToQuery(const DataShareAbsPredicates &predicates, DataQuery &query) in ToQuery() argument
173 void KvUtils::NoSupport(const DataShare::OperationItem &oper, DataQuery &query) in NoSupport() argument
178 void KvUtils::InKeys(const OperationItem &oper, DataQuery &query) in InKeys() argument
187 void KvUtils::KeyPrefix(const OperationItem &oper, DataQuery &query) in KeyPrefix() argument
192 void KvUtils::EqualTo(const OperationItem &oper, DataQuery &query) in EqualTo() argument
198 void KvUtils::NotEqualTo(const OperationItem &oper, DataQuery &query) in NotEqualTo() argument
204 GreaterThan(const OperationItem &oper, DataQuery &query) GreaterThan() argument
210 LessThan(const OperationItem &oper, DataQuery &query) LessThan() argument
216 GreaterThanOrEqualTo(const OperationItem &oper, DataQuery &query) GreaterThanOrEqualTo() argument
222 LessThanOrEqualTo(const OperationItem &oper, DataQuery &query) LessThanOrEqualTo() argument
228 And(const OperationItem &oper, DataQuery &query) And() argument
233 Or(const OperationItem &oper, DataQuery &query) Or() argument
238 IsNull(const OperationItem &oper, DataQuery &query) IsNull() argument
243 IsNotNull(const OperationItem &oper, DataQuery &query) IsNotNull() argument
248 In(const OperationItem &oper, DataQuery &query) In() argument
254 NotIn(const OperationItem &oper, DataQuery &query) NotIn() argument
260 Like(const OperationItem &oper, DataQuery &query) Like() argument
265 Unlike(const OperationItem &oper, DataQuery &query) Unlike() argument
270 OrderByAsc(const OperationItem &oper, DataQuery &query) OrderByAsc() argument
275 OrderByDesc(const OperationItem &oper, DataQuery &query) OrderByDesc() argument
280 Limit(const OperationItem &oper, DataQuery &query) Limit() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_query_object_helper_test.cpp | 47 void GetQuerySql(const Query &query) in GetQuerySql() argument
170 Query query = Query::Select().NotEqualTo(".test", testValue); in HWTEST_F() local
201 Query query = Query::Select().EqualTo(TEST_FIELD_NAME, true).And().GreaterThan(TEST_FIELD_NAME, 1); in HWTEST_F() local
281 Query query in HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_cloud.cpp | 80 RdbQuery query; in Query() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 607 bool MultiVerSyncStateMachine::IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) in IsNeedTriggerQueryAutoSync() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/test/ |
| H A D | cloud_test.cpp | 479 MockQuery query; in HWTEST_F() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 98 void SyncManager::SyncInfo::SetQuery(std::shared_ptr<GenQuery> query) in SetQuery() argument
319 auto query = info.GenerateQuery(database.name, database.GetTableNames()); in GetPostEventTask() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | generic_virtual_device.cpp | 281 int GenericVirtualDevice::Sync(SyncMode mode, const Query &query, bool wait) in Sync() argument
286 int GenericVirtualDevice::Sync(SyncMode mode, const Query &query, in Sync() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/ |
| H A D | kv_delegate.cpp | 284 Query query;
in Get() local
332 Query query;
in GetBatch() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | generic_kvdb_connection.cpp | 235 int GenericKvDBConnection::GetEntries(const IOption &option, const Query &query, std::vector<Entry> &entries) const in GetEntries() argument
251 int GenericKvDBConnection::GetResultSet(const IOption &option, const Query &query, IKvDBResultSet *&resultSet) const in GetResultSet() argument
259 int GenericKvDBConnection::GetCount(const IOption &option, const Query &query, int &count) const in GetCount() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | subscribe_manager.cpp | 42 int SubscribeManager::ReserveRemoteSubscribeQuery(const std::string &device, const QuerySyncObject &query) in ReserveRemoteSubscribeQuery() argument
51 int SubscribeManager::ActiveRemoteSubscribeQuery(const std::string &device, const QuerySyncObject &query) in ActiveRemoteSubscribeQuery() argument
60 int SubscribeManager::ReserveLocalSubscribeQuery(const std::string &device, const QuerySyncObject &query) in ReserveLocalSubscribeQuery() argument
69 int SubscribeManager::ActiveLocalSubscribeQuery(const std::string &device, const QuerySyncObject &query) in ActiveLocalSubscribeQuery() argument
85 DeleteLocalSubscribeQuery(const std::string &device, const QuerySyncObject &query) DeleteLocalSubscribeQuery() argument
92 DeleteRemoteSubscribeQuery(const std::string &device, const QuerySyncObject &query) DeleteRemoteSubscribeQuery() argument
136 RemoveRemoteSubscribeQuery(const std::string &device, const QuerySyncObject &query) RemoveRemoteSubscribeQuery() argument
143 RemoveLocalSubscribeQuery(const std::string &device, const QuerySyncObject &query) RemoveLocalSubscribeQuery() argument
255 ReserveSubscribeQuery(const std::string &device, const QuerySyncObject &query, SubscribeMap &subscribeMap, SubscribedTotalMap &subscribedTotalMap) ReserveSubscribeQuery() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/sync_fuzzer/ |
| H A D | sync_fuzzer.cpp | 121 Query query = Query::Select().PrefixKey(tmpKey); in NormalSyncPush() local
154 Query query = Query::Select().PrefixKey(tmpKey); in NormalSyncPull() local
177 Query query = Query::Select().PrefixKey(tmpKey); in NormalSyncPushAndPull() local
201 Query query = Query::Select().InKeys(keys); in SubscribeOperation() local
|