| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/src/ |
| H A D | event_query_wrapper_builder.cpp | 177 BaseEventQueryWrapper::BaseEventQueryWrapper(std::shared_ptr<EventStore::SysEventQuery> query) in BaseEventQueryWrapper() argument 482 CreateQueryWrapperByArgument( const QueryArgument& argument, std::shared_ptr<EventStore::SysEventQuery> query) CreateQueryWrapperByArgument() argument [all...] |
| /foundation/communication/wifi/wifi/relation_services/wifi_hal_service/ |
| H A D | wifi_hal_p2p_struct.h | 114 char query[WIFI_P2P_SERVE_INFO_LENGTH]; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
| H A D | kv_store_nb_delegate_mock.cpp | 35 DBStatus KvStoreNbDelegateMock::GetEntries(const Query &query, std::vector<Entry> &entries) const
in GetEntries() argument 40 DBStatus KvStoreNbDelegateMock::GetEntries(const Query &query, KvStoreResultSet *&resultSet) const
in GetEntries() argument 45 DBStatus KvStoreNbDelegateMock::GetCount(const Query &query, int &count) const
in GetCount() argument 196 Sync(const std::vector<std::string> &devices, SyncMode mode, const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, const Query &query, bool wait) Sync() argument 219 SubscribeRemoteQuery(const std::vector<std::string> &devices, const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, const Query &query, bool wait) SubscribeRemoteQuery() argument 226 UnSubscribeRemoteQuery(const std::vector<std::string> &devices, const std::function<void(const std::map<std::string, DBStatus> &devicesMap)> &onComplete, const Query &query, bool wait) UnSubscribeRemoteQuery() argument
|
| H A D | db_store_mock.cpp | 37 DBStatus DBStoreMock::GetEntries(const Query &query, std::vector<Entry> &entries) const in GetEntries() argument 42 DBStatus DBStoreMock::GetEntries(const Query &query, KvStoreResultSet *&resultSet) const in GetEntries() argument 48 DBStatus DBStoreMock::GetCount(const Query &query, int &count) const in GetCount() argument 207 Sync(const std::vector<std::string> &devices, SyncMode mode, const std::function<void(const std::map<std::string, DBStatus> &)> &onComplete, const Query &query, bool wait) Sync() argument 227 SubscribeRemoteQuery(const std::vector<std::string> &devices, const std::function<void(const std::map<std::string, DBStatus> &)> &onComplete, const Query &query, bool wait) SubscribeRemoteQuery() argument 233 UnSubscribeRemoteQuery(const std::vector<std::string> &devices, const std::function<void(const std::map<std::string, DBStatus> &)> &onComplete, const Query &query, bool wait) UnSubscribeRemoteQuery() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_assets_operation_sync_test.cpp | 60 void BlockSync(const Query &query, RelationalStoreDelegate *delegate) in BlockSync() argument 375 Query query = Query::Select().FromTable({ tableName_ }); in HWTEST_F() local 394 Query query = Query::Select().FromTable({ tableName_ }); in HWTEST_F() local 431 Query query = Query::Select().FromTable({ tableName_ }); in HWTEST_F() local 466 Query query in HWTEST_F() local 509 Query query = Query::Select().FromTable({tableName_}); HWTEST_F() local 565 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 600 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 697 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 730 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 753 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 804 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 863 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 1010 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 1098 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 1123 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 1174 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local 1201 Query query = Query::Select().FromTable({ tableName_ }); HWTEST_F() local [all...] |
| H A D | distributeddb_cloud_reference_sync_test.cpp | 438 Query query = Query::Select().FromTable(tableNames); in HWTEST_F() local 464 Query query = Query::Select().FromTable(tableNames); in HWTEST_F() local 490 Query query = Query::Select().FromTable(tableNames); in HWTEST_F() local 521 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 568 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 609 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 638 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 677 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 750 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 806 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 881 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 937 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 989 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local 1015 Query query = Query::Select().FromTable(tableNames); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_general_store.cpp | 454 std::pair<int32_t, std::shared_ptr<Cursor>> RdbGeneralStore::Query(const std::string &table, GenQuery &query) in Query() argument 504 int32_t RdbGeneralStore::Sync(const Devices &devices, GenQuery &query, DetailAsync async, SyncParam &syncParam) in Sync() argument 553 std::pair<int32_t, std::shared_ptr<Cursor>> RdbGeneralStore::PreSharing(GenQuery &query) in PreSharing() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_single_ver_sync_db_Interface.cpp | 151 int VirtualSingleVerSyncDBInterface::GetUnSyncTotal(QueryObject &query, const SyncTimeRange &timeRange, in GetUnSyncTotal() argument 453 int VirtualSingleVerSyncDBInterface::GetSyncData(QueryObject &query, const SyncTimeRange &timeRange, in GetSyncData() argument 538 int VirtualSingleVerSyncDBInterface::PutSyncDataWithQuery(const QueryObject &query, in PutSyncDataWithQuery() argument 565 int VirtualSingleVerSyncDBInterface::AddSubscribe(const std::string &subscribeId, const QueryObject &query, in AddSubscribe() argument
|
| H A D | virtual_relational_ver_sync_db_interface.cpp | 72 int VirtualRelationalVerSyncDBInterface::PutSyncDataWithQuery(const QueryObject &query, in PutSyncDataWithQuery() argument 124 int VirtualRelationalVerSyncDBInterface::GetSyncData(QueryObject &query, in GetSyncData() argument
|
| H A D | distributeddb_single_ver_p2p_complex_sync_test.cpp | 441 Query query = Query::Select().PrefixKey({'k', '1'}); in HWTEST_F() local 674 Query query = Query::Select().PrefixKey({'k'}).OrderByWriteTime(true); in HWTEST_F() local 1058 Query query in HWTEST_F() local 1278 Query query = Query::Select().PrefixKey(prefixKey); HWTEST_F() local 1738 Query query = Query::Select().PrefixKey(key); HWTEST_F() local [all...] |
| H A D | distributeddb_single_ver_p2p_query_sync_test.cpp | 241 Query query = Query::Select().PrefixKey(key); in HWTEST_F() local 301 Query query = Query::Select().PrefixKey(key).Limit(limit, offset); in HWTEST_F() local 371 Query query = Query::Select().PrefixKey(key2); in HWTEST_F() local 446 Query query = Query::Select().PrefixKey(key2); HWTEST_F() local 491 Query query = Query::Select().InKeys({KEY_2, KEY_4}); HWTEST_F() local 591 Query query = Query::Select().PrefixKey(key); HWTEST_F() local 1750 Query query = Query::Select().EqualTo("$.field_name1", 1); HWTEST_F() local 1797 Query query = Query::Select().GreaterThan("field_name11", 10); HWTEST_F() local 1848 Query query = Query::Select().EqualTo("$.field_name1", 1).Limit(20, 0); HWTEST_F() local 1909 Query query = Query::Select().EqualTo("$.field_name1", 1); HWTEST_F() local [all...] |
| H A D | distributeddb_relational_multi_user_test.cpp | 205 Query query = Query::Select(g_tableName); in CheckSyncTest() local 287 Query query = Query::Select(g_tableName); in CheckSyncResult() local 718 Query query = Query::Select(g_tableName); in HWTEST_F() local 917 Query query = Query::Select(g_tableName); HWTEST_F() local 1062 Query query = Query::Select(g_tableName); HWTEST_F() local 1105 Query query = Query::Select(g_tableName); HWTEST_F() local 1147 Query query = Query::Select(g_tableName); HWTEST_F() local 1189 Query query = Query::Select(g_tableName); HWTEST_F() local 1231 Query query = Query::Select(g_tableName); HWTEST_F() local 1276 Query query = Query::Select(g_tableName); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
| H A D | js_util.cpp | 1084 napi_status JSUtil::GetValue(napi_env env, napi_value in, DataQuery &query) in GetValue() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_engine.cpp | 1107 void SQLiteSingleVerStorageEngine::CacheSubscribe(const std::string &subscribeId, const QueryObject &query) in CacheSubscribe() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_relational_sync_test.cpp | 226 Query query = Query::Select("sync_datb"); in HWTEST_F() local 245 Query query = Query::Select("sync_data").Like("value", "abc"); in HWTEST_F() local 264 Query query = Query::Select("sync_data").And().Or().EqualTo("flag", 2); in HWTEST_F() local 283 Query query in HWTEST_F() local 305 Query query = Query::Select("sync_data"); HWTEST_F() local 324 Query query = Query::Select(); HWTEST_F() local 349 Query query = Query::Select("student"); HWTEST_F() local 379 Query query = Query::Select("sync_data"); HWTEST_F() local 431 Query query = Query::Select("student").EqualTo("$id", 123); HWTEST_F() local 464 Query query = Query::Select("sync_data"); HWTEST_F() local 621 Query query = Query::Select("sync_data").Limit(4500, 100); HWTEST_F() local 647 Query query = Query::Select("sync_data").Limit(5000, 2000); HWTEST_F() local 673 Query query = Query::Select("sync_data").OrderBy("timestamp").Limit(4500, 1500); HWTEST_F() local 699 Query query = Query::Select("sync_data").OrderBy("timestamp"); HWTEST_F() local 725 Query query = Query::Select("sTudENT_1"); HWTEST_F() local 785 Query query = Query::Select("sTudENT_1"); HWTEST_F() local 824 Query query = Query::Select("sTudENT_1").EqualTo("ID", 1001); // 1001 : id HWTEST_F() local 873 Query query = Query::Select("sTudENT_1").EqualTo("ID", 1001); // 1001 id HWTEST_F() local 919 Query query = Query::Select("tbl_all_type"); HWTEST_F() local 1012 Query query = Query::Select("tbl_all_type"); HWTEST_F() local 1086 Query query = Query::Select("sync_data").Range({}, {}); HWTEST_F() local 1118 Query query = Query::Select("t2"); HWTEST_F() local [all...] |
| H A D | distributeddb_interfaces_data_operation_test.cpp | 1020 Query query = Query::Select(); in HWTEST_F() local 1114 Query query = Query::Select(); HWTEST_F() local 1160 Query query = Query::Select(); HWTEST_F() local 1199 Query query = Query::Select(); HWTEST_F() local 1252 Query query = Query::Select().IsNotNull("$.field_name1"); HWTEST_F() local 1306 Query query = Query::Select().PrefixKey({'a', 'c'}); HWTEST_F() local 1388 Query query = Query::Select().PrefixKey({'a', 'c'}).PrefixKey({}); HWTEST_F() local 1450 Query query = Query::Select().PrefixKey({'c'}); HWTEST_F() local 1498 Query query = Query::Select().LessThan("$.field_name1", 4).And().EqualTo("$.field_name1", 4). HWTEST_F() local 1576 Query query = Query::Select().BeginGroup().LessThan("$.field_name1", 4).And().BeginGroup(). HWTEST_F() local 1649 Query query = Query::Select().BeginGroup().LessThan("$.field_name1", 5).And().BeginGroup(). HWTEST_F() local 1694 Query query = Query::Select().PrefixKey({}).OrderBy("$.field_name1").OrderBy("$.field_name1"); HWTEST_F() local 1739 Query query = Query::Select().PrefixKey({}).OrderBy("$.field_name1", false); HWTEST_F() local 2485 Query query = Query::Select().BeginGroup().LessThan("$.field_name1", 5).OrderByWriteTime(false); HWTEST_F() local [all...] |
| H A D | distributeddb_cloud_interfaces_set_cloud_schema_test.cpp | 335 void DistributedDBCloudInterfacesSetCloudSchemaTest::BlockSync(const Query &query, in BlockSync() argument 1203 Query query = Query::Select().FromTable({ g_sharedTableName2 }); in HWTEST_F() local 1238 Query query = Query::Select().FromTable({ g_sharedTableName1 }); in HWTEST_F() local 1272 Query query in HWTEST_F() local 1339 Query query = Query::Select().FromTable({ g_sharedTableName5 }); HWTEST_F() local 1368 Query query = Query::Select().FromTable({ g_sharedTableName1 }); HWTEST_F() local 1546 Query query = Query::Select().FromTable({ g_tableName2, g_sharedTableName1 }); HWTEST_F() local 1579 Query query = Query::Select().FromTable({ g_tableName2, g_sharedTableName1 }); HWTEST_F() local 1642 Query query = Query::Select().FromTable(tables); HWTEST_F() local 1705 Query query = Query::Select().FromTable({ g_tableName2, g_sharedTableName1 }); HWTEST_F() local 1762 Query query = Query::Select().FromTable(tables); HWTEST_F() local 1817 Query query = Query::Select().FromTable({ g_sharedTableName1 }); HWTEST_F() local 1860 Query query = Query::Select().FromTable(tables); HWTEST_F() local 1915 Query query = Query::Select().FromTable({ g_tableName2, g_sharedTableName1 }); HWTEST_F() local 1967 Query query = Query::Select().FromTable({ g_tableName2, g_sharedTableName1 }); HWTEST_F() local 2043 Query query = Query::Select().FromTable({ g_tableName2, g_sharedTableName1 }); HWTEST_F() local 2108 Query query = Query::Select().FromTable({ g_tableName2, g_sharedTableName1 }); HWTEST_F() local 2180 Query query = Query::Select().FromTable({ g_tableName2 }); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_get_data_test.cpp | 613 Query query = Query::Select(g_tableName).NotEqualTo("key", 10).And().NotEqualTo("value", 20).OrderBy("key", false); HWTEST_F() local 1593 Query query = Query::Select().OrderBy("errDevice", false); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/test/unittest/api/ |
| H A D | documentdb_find_test.cpp | 149 Query query = { filter, "{}" }; in HWTEST_F() local 181 Query query = { filter, "{}" }; in HWTEST_F() local 209 Query query = { filter, "{}" }; in HWTEST_F() local 301 Query query = { filter, "{}" }; in HWTEST_F() local 317 Query query in HWTEST_F() local 341 Query query = { filter, "{}" }; HWTEST_F() local 378 Query query = { filter, "{}" }; HWTEST_F() local 426 Query query = { filter, projectionInfo }; HWTEST_F() local 493 Query query = { filter, projectionInfo }; HWTEST_F() local 545 Query query = { filter, projectionInfo }; HWTEST_F() local 598 Query query = { filter, projectionInfo }; HWTEST_F() local 620 Query query = { filter, projectionInfo }; HWTEST_F() local 664 Query query = { filter, projectionInfo }; HWTEST_F() local 709 Query query = { filter, projectionInfo }; HWTEST_F() local 770 Query query = { filter, projectionInfo }; HWTEST_F() local 816 Query query = { filter, projectionInfo }; HWTEST_F() local 885 Query query = { filter, "{}" }; HWTEST_F() local 916 Query query = { filter, "{}" }; HWTEST_F() local 937 Query query = { filter, projectionInfo }; HWTEST_F() local 1007 Query query = { filter, projectionInfo }; HWTEST_F() local 1050 Query query = { filter, projectionInfo }; HWTEST_F() local 1091 Query query = { filter, projectionInfo }; HWTEST_F() local 1129 Query query = { filter, projectionInfo }; HWTEST_F() local 1170 Query query = { filter, projectionInfo }; HWTEST_F() local 1196 Query query = { filter, "{}" }; HWTEST_F() local 1223 Query query = { filter, "{}" }; HWTEST_F() local 1251 Query query = { filter, projectionInfo }; HWTEST_F() local 1283 Query query = { filter, projectionInfo }; HWTEST_F() local 1321 Query query = { filter.c_str(), projectionInfo }; HWTEST_F() local 1350 Query query = { filter, "{}" }; HWTEST_F() local 1381 Query query = { filter, projection }; HWTEST_F() local 1412 Query query = { filter, projection }; HWTEST_F() local 1421 Query query = { filter, projection }; HWTEST_F() local 1438 Query query = { filter, projection }; HWTEST_F() local 1465 Query query = { filter, projection }; HWTEST_F() local 1494 Query query = { filter, projection }; HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync_utils.cpp | 343 bool SingleVerDataSyncUtils::IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) in IsNeedTriggerQueryAutoSync() argument
|
| H A D | single_ver_data_packet.cpp | 274 void DataRequestPacket::SetQuery(const QuerySyncObject &query) in SetQuery() argument 472 void ControlRequestPacket::SetQuery(const QuerySyncObject &query) in SetQuery() argument 491 void SubscribeRequest::SetQuery(const QuerySyncObject &query) in SetQuery() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | cloud_syncer_test.h | 291 void SetQuerySyncObject(TaskId taskId, const QuerySyncObject &query) in SetQuerySyncObject() argument
|
| H A D | cloud_db_sync_utils_test.cpp | 64 Query query = Query::Select().FromTable(g_tables); in InitSyncUtils() local 251 Query query = Query::Select().FromTable(tableNames); in callSync() local
|
| /foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | single_store_impl.cpp | 251 Status SingleStoreImpl::GetEntries(const DataQuery &query, std::vector<Entry> &entries) const in GetEntries() argument 279 Status SingleStoreImpl::GetResultSet(const DataQuery &query, std::shared_ptr<ResultSet> &resultSet) const in GetResultSet() argument 304 Status SingleStoreImpl::GetCount(const DataQuery &query, int &result) const in GetCount() argument 393 GetResultSet(const DBQuery &query, std::shared_ptr<ResultSet> &resultSet) const GetResultSet() argument 410 GetEntries(const DBQuery &query, std::vector<Entry> &entries) const GetEntries() argument 440 Sync(const std::vector<std::string> &devices, SyncMode mode, const DataQuery &query, std::shared_ptr<SyncCallback> syncCallback, uint32_t delay) Sync() argument 476 SubscribeWithQuery(const std::vector<std::string> &devices, const DataQuery &query) SubscribeWithQuery() argument 480 UnsubscribeWithQuery(const std::vector<std::string> &devices, const DataQuery &query) UnsubscribeWithQuery() argument [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/ |
| H A D | udmf_service_impl.cpp | 163 int32_t UdmfServiceImpl::GetData(const QueryOption &query, UnifiedData &unifiedData) in GetData() argument 193 int32_t UdmfServiceImpl::RetrieveData(const QueryOption &query, UnifiedData &unifiedData) in RetrieveData() argument 248 IsPermissionInCache(const QueryOption &query) IsPermissionInCache() argument 257 IsReadAndKeep(const std::vector<Privilege> &privileges, const QueryOption &query) IsReadAndKeep() argument 273 ProcessUri(const QueryOption &query, UnifiedData &unifiedData) ProcessUri() argument 324 SetRemoteUri(const QueryOption &query, std::vector<std::shared_ptr<UnifiedRecord>> &records) SetRemoteUri() argument 339 GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) GetBatchData() argument 360 UpdateData(const QueryOption &query, UnifiedData &unifiedData) UpdateData() argument 409 DeleteData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) DeleteData() argument 447 GetSummary(const QueryOption &query, Summary &summary) GetSummary() argument 469 AddPrivilege(const QueryOption &query, Privilege &privilege) AddPrivilege() argument 523 Sync(const QueryOption &query, const std::vector<std::string> &devices) Sync() argument 568 IsRemoteData(const QueryOption &query, bool &result) IsRemoteData() argument 697 QueryDataCommon( const QueryOption &query, std::vector<UnifiedData> &dataSet, std::shared_ptr<Store> &store) QueryDataCommon() argument [all...] |