/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
H A D | single_kvstore_client_query_test.cpp | 82 DataQuery query; in HWTEST_F() local 83 EXPECT_TRUE(query.ToString().length() == 0); in HWTEST_F() 85 query.EqualTo("$.test_field_name", str); in HWTEST_F() 86 EXPECT_TRUE(query.ToString().length() > 0); in HWTEST_F() 87 query.Reset(); in HWTEST_F() 88 EXPECT_TRUE(query.ToString().length() == 0); in HWTEST_F() 100 DataQuery query; in HWTEST_F() local 101 query.EqualTo("", 100); in HWTEST_F() 102 EXPECT_TRUE(query.ToString().length() == 0); in HWTEST_F() 103 query in HWTEST_F() 132 DataQuery query; HWTEST_F() local 159 DataQuery query; HWTEST_F() local 191 DataQuery query; HWTEST_F() local 218 DataQuery query; HWTEST_F() local 246 DataQuery query; HWTEST_F() local 269 DataQuery query; HWTEST_F() local 297 DataQuery query; HWTEST_F() local 320 DataQuery query; HWTEST_F() local 348 DataQuery query; HWTEST_F() local 371 DataQuery query; HWTEST_F() local 399 DataQuery query; HWTEST_F() local 422 DataQuery query; HWTEST_F() local 438 DataQuery query; HWTEST_F() local 452 DataQuery query; HWTEST_F() local 484 DataQuery query; HWTEST_F() local 511 DataQuery query; HWTEST_F() local 543 DataQuery query; HWTEST_F() local 570 DataQuery query; HWTEST_F() local 586 DataQuery query; HWTEST_F() local 600 DataQuery query; HWTEST_F() local 616 DataQuery query; HWTEST_F() local 630 DataQuery query; HWTEST_F() local 646 DataQuery query; HWTEST_F() local 662 DataQuery query; HWTEST_F() local 678 DataQuery query; HWTEST_F() local 692 DataQuery query; HWTEST_F() local 708 DataQuery query; HWTEST_F() local 722 DataQuery query; HWTEST_F() local 738 DataQuery query; HWTEST_F() local 766 DataQuery query; HWTEST_F() local 831 DataQuery query; HWTEST_F() local 884 DataQuery query; HWTEST_F() local 908 DataQuery query; HWTEST_F() local 927 DataQuery query; HWTEST_F() local 943 DataQuery query; HWTEST_F() local 957 DataQuery query; HWTEST_F() local 979 DataQuery query; HWTEST_F() local 997 DataQuery query; HWTEST_F() local 1034 DataQuery query; 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 150 EXPECT_EQ(GRD_FindDoc(g_db, COLLECTION_NAME, query, 1, &resultSet), GRD_OK); in HWTEST_F() 181 Query query = { filter, "{}" }; in HWTEST_F() local 182 EXPECT_EQ(GRD_FindDoc(g_db, COLLECTION_NAME, query, 1, &resultSet), GRD_OK); in HWTEST_F() 209 Query query = { filter, "{}" }; in HWTEST_F() local 210 EXPECT_EQ(GRD_FindDoc(g_db, COLLECTION_NAME, query, 1, &resultSet), GRD_OK); in HWTEST_F() 301 Query query = { filter, "{}" }; in HWTEST_F() local 302 EXPECT_EQ(GRD_FindDoc(g_db, colName1, query, 1, &resultSet), GRD_INVALID_FORMAT); in HWTEST_F() 303 EXPECT_EQ(GRD_FindDoc(g_db, colName2, query, 1, &resultSet), GRD_INVALID_FORMAT); in HWTEST_F() 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/udmf/framework/innerkitsimpl/service/ |
H A D | udmf_service_client.cpp | 125 int32_t UdmfServiceClient::GetData(const QueryOption &query, UnifiedData &unifiedData) in GetData() argument 127 LOG_DEBUG(UDMF_SERVICE, "start, tag: %{public}s", query.key.c_str()); in GetData() 128 UnifiedKey key(query.key); in GetData() 134 auto err = udmfProxy_->GetData(query, unifiedData); in GetData() 146 int32_t UdmfServiceClient::GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) in GetBatchData() argument 148 LOG_DEBUG(UDMF_SERVICE, "start, tag: intention = %{public}d, key = %{public}s", query.intention, query.key.c_str()); in GetBatchData() 149 auto find = UD_INTENTION_MAP.find(query.intention); in GetBatchData() 151 if (!UnifiedDataUtils::IsValidOptions(query.key, intention)) { in GetBatchData() 152 LOG_ERROR(UDMF_SERVICE, "invalid option, query in GetBatchData() 173 UpdateData(const QueryOption &query, UnifiedData &unifiedData) UpdateData() argument 195 DeleteData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) DeleteData() argument 208 GetSummary(const QueryOption &query, Summary &summary) GetSummary() argument 219 AddPrivilege(const QueryOption &query, Privilege &privilege) AddPrivilege() argument 230 Sync(const QueryOption &query, const std::vector<std::string> &devices) Sync() argument 241 IsRemoteData(const QueryOption &query, bool &result) IsRemoteData() argument [all...] |
H A D | udmf_service_proxy.cpp | 70 int32_t UdmfServiceProxy::GetData(const QueryOption &query, UnifiedData &unifiedData) in GetData() argument 73 int32_t status = IPC_SEND(UdmfServiceInterfaceCode::GET_DATA, reply, query); in GetData() 75 LOG_ERROR(UDMF_SERVICE, "status:0x%{public}x, key:%{public}s!", status, query.key.c_str()); in GetData() 85 int32_t UdmfServiceProxy::GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) in GetBatchData() argument 88 int32_t status = IPC_SEND(UdmfServiceInterfaceCode::GET_BATCH_DATA, reply, query); in GetBatchData() 91 query.key.c_str(), query.intention); in GetBatchData() 101 int32_t UdmfServiceProxy::UpdateData(const QueryOption &query, UnifiedData &unifiedData) in UpdateData() argument 105 int32_t status = IPC_SEND(UdmfServiceInterfaceCode::UPDATE_DATA, reply, query, unifiedData); in UpdateData() 113 int32_t UdmfServiceProxy::DeleteData(const QueryOption &query, st argument 130 GetSummary(const QueryOption &query, Summary &summary) GetSummary() argument 146 AddPrivilege(const QueryOption &query, Privilege &privilege) AddPrivilege() argument 157 Sync(const QueryOption &query, const std::vector<std::string> &devices) Sync() argument 168 IsRemoteData(const QueryOption &query, bool &result) IsRemoteData() argument [all...] |
H A D | udmf_service.h | 41 virtual int32_t GetData(const QueryOption &query, UnifiedData &unifiedData) = 0; 42 virtual int32_t GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) = 0; 43 virtual int32_t UpdateData(const QueryOption &query, UnifiedData &unifiedData) = 0; 44 virtual int32_t DeleteData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) = 0; 45 virtual int32_t GetSummary(const QueryOption &query, Summary &summary) = 0; 46 virtual int32_t AddPrivilege(const QueryOption &query, Privilege &privilege) = 0; 47 virtual int32_t Sync(const QueryOption &query, const std::vector<std::string> &devices) = 0; 48 virtual int32_t IsRemoteData(const QueryOption &query, bool &result) = 0;
|
H A D | udmf_service_client.h | 36 int32_t GetData(const QueryOption &query, UnifiedData &unifiedData) override; 37 int32_t GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) override; 38 int32_t UpdateData(const QueryOption &query, UnifiedData &unifiedData) override; 39 int32_t DeleteData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) override; 40 int32_t GetSummary(const QueryOption &query, Summary &summary) override; 41 int32_t AddPrivilege(const QueryOption &query, Privilege &privilege) override; 42 int32_t Sync(const QueryOption &query, const std::vector<std::string> &devices) override; 43 int32_t IsRemoteData(const QueryOption &query, bool &result) override;
|
H A D | udmf_service_proxy.h | 39 int32_t GetData(const QueryOption &query, UnifiedData &unifiedData) override; 40 int32_t GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) override; 41 int32_t UpdateData(const QueryOption &query, UnifiedData &unifiedData) override; 42 int32_t DeleteData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) override; 43 int32_t GetSummary(const QueryOption &query, Summary &summary) override; 44 int32_t AddPrivilege(const QueryOption &query, Privilege &privilege) override; 45 int32_t Sync(const QueryOption &query, const std::vector<std::string> &devices) override; 46 int32_t IsRemoteData(const QueryOption &query, bool &result) override;
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/ |
H A D | udmf_service_stub.cpp | 77 QueryOption query; in OnGetData() local 78 if (!ITypesUtil::Unmarshal(data, query)) { in OnGetData() 83 query.tokenId = token; in OnGetData() 85 int32_t status = GetData(query, unifiedData); in OnGetData() 97 QueryOption query; in OnGetBatchData() local 98 if (!ITypesUtil::Unmarshal(data, query)) { in OnGetBatchData() 103 query.tokenId = token; in OnGetBatchData() 105 int32_t status = GetBatchData(query, unifiedDataSet); in OnGetBatchData() 117 QueryOption query; in OnUpdateData() local 119 if (!ITypesUtil::Unmarshal(data, query, unifiedDat in OnUpdateData() 136 QueryOption query; OnDeleteData() local 156 QueryOption query; OnGetSummary() local 175 QueryOption query; OnAddPrivilege() local 194 QueryOption query; OnSync() local 212 QueryOption query; OnIsRemoteData() local [all...] |
H A D | udmf_service_impl.cpp | 163 int32_t UdmfServiceImpl::GetData(const QueryOption &query, UnifiedData &unifiedData) in GetData() argument 169 auto find = UD_INTENTION_MAP.find(query.intention); in GetData() 173 if (!PreProcessUtils::GetHapBundleNameByToken(query.tokenId, bundleName)) { in GetData() 178 res = RetrieveData(query, unifiedData); in GetData() 193 int32_t UdmfServiceImpl::RetrieveData(const QueryOption &query, UnifiedData &unifiedData) in RetrieveData() argument 195 UnifiedKey key(query.key); in RetrieveData() 197 ZLOGE("Unified key: %{public}s is invalid.", query.key.c_str()); in RetrieveData() 205 int32_t res = store->Get(query.key, unifiedData); in RetrieveData() 207 ZLOGE("Get data from store failed, res: %{public}d, key: %{public}s.", res, query.key.c_str()); in RetrieveData() 212 ZLOGE("Get data from DB is incomplete, key: %{public}s.", query in RetrieveData() 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...] |
H A D | udmf_service_impl.h | 41 int32_t GetData(const QueryOption &query, UnifiedData &unifiedData) override; 42 int32_t GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) override; 43 int32_t UpdateData(const QueryOption &query, UnifiedData &unifiedData) override; 44 int32_t DeleteData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) override; 45 int32_t GetSummary(const QueryOption &query, Summary &summary) override; 46 int32_t AddPrivilege(const QueryOption &query, Privilege &privilege) override; 47 int32_t Sync(const QueryOption &query, const std::vector<std::string> &devices) override; 48 int32_t IsRemoteData(const QueryOption &query, bool &result) override; 59 int32_t RetrieveData(const QueryOption &query, UnifiedData &unifiedData); 60 int32_t QueryDataCommon(const QueryOption &query, st [all...] |
/foundation/distributeddatamgr/udmf/framework/innerkitsimpl/test/unittest/mock/ |
H A D | udmf_service_client_mock.cpp | 47 int32_t UdmfServiceClient::GetData(const QueryOption &query, UnifiedData &unifiedData) in GetData() argument 52 return MUdmfServiceClient::udmfServiceClient->GetData(query, unifiedData); in GetData() 56 int32_t UdmfServiceClient::GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) in GetBatchData() argument 61 return MUdmfServiceClient::udmfServiceClient->GetBatchData(query, unifiedDataSet); in GetBatchData() 65 int32_t UdmfServiceClient::DeleteData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet) in DeleteData() argument 70 return MUdmfServiceClient::udmfServiceClient->DeleteData(query, unifiedDataSet); in DeleteData() 74 int32_t UdmfServiceClient::UpdateData(const QueryOption &query, UnifiedData &unifiedData) in UpdateData() argument 79 return MUdmfServiceClient::udmfServiceClient->UpdateData(query, unifiedData); in UpdateData() 83 int32_t UdmfServiceClient::GetSummary(const QueryOption &query, Summary &summary) in GetSummary() argument 88 return MUdmfServiceClient::udmfServiceClient->GetSummary(query, summar in GetSummary() 92 IsRemoteData(const QueryOption &query, bool &result) IsRemoteData() argument 101 Sync(const QueryOption &query, const std::vector<std::string> &devices) Sync() argument 138 AddPrivilege(const QueryOption &query, Privilege &privilege) AddPrivilege() argument [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/ |
H A D | js_query.cpp | 66 * var query = new ddm.JsQuery(); 74 JsQuery* query = new (std::nothrow) JsQuery(); in New() local 75 NAPI_ASSERT(env, query !=nullptr, "no memory for query"); in New() 78 ZLOGD("query finalize."); in New() 79 auto* query = reinterpret_cast<JsQuery*>(data); in New() 80 CHECK_RETURN_VOID(query != nullptr, "query is null!"); in New() 81 delete query; in New() 83 ASSERT_CALL(env, napi_wrap(env, ctxt->self, query, finaliz in New() 94 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Reset() local 125 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; EqualTo() local 150 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; NotEqualTo() local 175 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; GreaterThan() local 200 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; LessThan() local 225 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; GreaterThanOrEqualTo() local 250 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; LessThanOrEqualTo() local 281 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; IsNull() local 353 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; InNumber() local 383 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; InString() local 395 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; NotInNumber() local 425 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; NotInString() local 449 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Like() local 473 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Unlike() local 485 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; And() local 497 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Or() local 516 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; OrderByAsc() local 535 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; OrderByDesc() local 557 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Limit() local 576 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; IsNotNull() local 587 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; BeginGroup() local 599 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; EndGroup() local 617 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; PrefixKey() local 635 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; SetSuggestIndex() local 653 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; DeviceId() local 665 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; GetSqlLike() local [all...] |
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
H A D | wifi_p2p_upnp_service_info.cpp | 43 std::string query; in BuildWpaQuery() local 44 query.append("upnp "); in BuildWpaQuery() 49 query.append(std::string(version)); in BuildWpaQuery() 50 query.append(std::string("uuid:")); in BuildWpaQuery() 51 query.append(uuid); in BuildWpaQuery() 53 query.append(std::string("::")); in BuildWpaQuery() 54 query.append(data); in BuildWpaQuery() 57 query.append(std::string(";")); in BuildWpaQuery() 58 query.append(1, static_cast<unsigned char>(svrName.length())); in BuildWpaQuery() 59 query in BuildWpaQuery() [all...] |
H A D | wifi_p2p_upnp_service_request.cpp | 28 WifiP2pUpnpServiceRequest::WifiP2pUpnpServiceRequest(std::string query) in WifiP2pUpnpServiceRequest() argument 29 : WifiP2pServiceRequest(P2pServicerProtocolType::SERVICE_TYPE_UP_NP, query) in WifiP2pUpnpServiceRequest() 39 std::string query; in Create() local 49 query.append(std::string(version)); in Create() 50 query.append(WifiP2pServiceInfo::Bin2HexStr(searchTarget)); in Create() 51 WifiP2pUpnpServiceRequest ret(query); in Create()
|
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
H A D | convertor.cpp | 41 std::vector<uint8_t> Convertor::GetPrefix(const DataQuery &query) const in GetPrefix() 43 return Convertor::GetPrefix(Key(query.prefix_)); in GetPrefix() 46 Convertor::DBQuery Convertor::GetDBQuery(const DataQuery &query) const in GetDBQuery() 48 DBQuery dbQuery = *(query.query_); in GetDBQuery() 49 if (query.hasPrefix_) { in GetDBQuery() 50 dbQuery.PrefixKey(GetPrefix(query)); in GetDBQuery() 53 if (query.hasKeys_) { in GetDBQuery() 55 for (auto &key : query.keys_) { in GetDBQuery() 56 keys.insert(ToWholeDBKey(GetRealKey(key, query))); in GetDBQuery() 63 std::string Convertor::GetRealKey(const std::string &key, const DataQuery &query) cons [all...] |
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
H A D | kv_utils.h | 42 API_EXPORT static Status ToQuery(const DataShare::DataShareAbsPredicates &predicates, DataQuery &query) 49 static void NoSupport(const DataShare::OperationItem &oper, DataQuery &query); 50 static void EqualTo(const DataShare::OperationItem &oper, DataQuery &query); 51 static void NotEqualTo(const DataShare::OperationItem &oper, DataQuery &query); 52 static void GreaterThan(const DataShare::OperationItem &oper, DataQuery &query); 53 static void LessThan(const DataShare::OperationItem &oper, DataQuery &query); 54 static void GreaterThanOrEqualTo(const DataShare::OperationItem &oper, DataQuery &query); 55 static void LessThanOrEqualTo(const DataShare::OperationItem &oper, DataQuery &query); 56 static void And(const DataShare::OperationItem &oper, DataQuery &query); 57 static void Or(const DataShare::OperationItem &oper, DataQuery &query); [all...] |
/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 48 (*HANDLERS[oper.operation])(oper, query); in ToQuery() 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 182 query.InKeys(*val); in InKeys() 185 void KvUtils::KeyPrefix(const OperationItem &oper, DataQuery &query) in KeyPrefix() argument 187 query.KeyPrefix(oper.GetSingle(0)); in KeyPrefix() 190 void KvUtils::EqualTo(const OperationItem &oper, DataQuery &query) in EqualTo() argument 192 Querys equal(&query, QueryType::EQUAL); in EqualTo() 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/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
H A D | kv_utils.cpp | 42 Status KvUtils::ToQuery(const DataShareAbsPredicates &predicates, DataQuery &query) in ToQuery() argument 50 (*HANDLERS[oper.operation])(oper, query); in ToQuery() 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 184 query.InKeys(*val); in InKeys() 187 void KvUtils::KeyPrefix(const OperationItem &oper, DataQuery &query) in KeyPrefix() argument 189 query.KeyPrefix(oper.GetSingle(0)); in KeyPrefix() 192 void KvUtils::EqualTo(const OperationItem &oper, DataQuery &query) in EqualTo() argument 194 Querys equal(&query, QueryType::EQUAL); in EqualTo() 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/relational_store/test/js/rdb/unittest/src/ |
H A D | RdbstorePredicatesJsunit.test.js | 129 let result = await rdbStore.query(predicates); 148 let result = await rdbStore.query(predicates); 167 let result = await rdbStore.query(predicates); 186 let result = await rdbStore.query(predicates); 205 let result = await rdbStore.query(predicates); 224 let result = await rdbStore.query(predicates); 243 let result = await rdbStore.query(predicates); 262 let result = await rdbStore.query(predicates); 284 let result1 = await rdbStore.query(predicates1); 292 let result2 = await rdbStore.query(predicates [all...] |
/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/ |
H A D | RdbstorePredicatesJsunit.test.js | 138 let result = await rdbStore.query(predicates); 158 let result = await rdbStore.query(predicates); 178 let result = await rdbStore.query(predicates); 198 let result = await rdbStore.query(predicates); 218 let result = await rdbStore.query(predicates); 239 let result = await rdbStore.query(predicates); 260 let result = await rdbStore.query(predicates); 281 let result = await rdbStore.query(predicates); 304 let result1 = await rdbStore.query(predicates1); 312 let result2 = await rdbStore.query(predicates [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
H A D | single_store_impl_get_top_test.cpp | 101 DataQuery query; in HWTEST_F() local 102 query.KeyPrefix("1"); in HWTEST_F() 103 query.OrderByWriteTime(true); in HWTEST_F() 105 auto status = singleKvStore->GetEntries(query, output); in HWTEST_F() 134 DataQuery query; in HWTEST_F() local 135 query.KeyPrefix("1"); in HWTEST_F() 136 query.OrderByWriteTime(false); in HWTEST_F() 138 auto status = singleKvStore->GetEntries(query, output); in HWTEST_F() 168 DataQuery query; in HWTEST_F() local 169 query in HWTEST_F() 197 DataQuery query; HWTEST_F() local 238 DataQuery query; HWTEST_F() local 279 DataQuery query; HWTEST_F() local [all...] |
/foundation/distributeddatamgr/udmf/interfaces/innerkits/client/ |
H A D | udmf_client.h | 39 Status GetData(const QueryOption &query, UnifiedData &unifiedData); 40 Status GetDataAsync(const QueryOption &query, ObtainDataCallback callback); 41 Status GetBatchData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet); 42 Status UpdateData(const QueryOption &query, UnifiedData &unifiedData); 43 Status DeleteData(const QueryOption &query, std::vector<UnifiedData> &unifiedDataSet); 44 Status GetSummary(const QueryOption &query, Summary& summary); 45 Status AddPrivilege(const QueryOption &query, Privilege &privilege); 46 Status Sync(const QueryOption &query, const std::vector<std::string> &devices); 47 Status IsRemoteData(const QueryOption &query, bool &result);
|
/foundation/communication/dsoftbus/tests/core/bus_center/lnn/lane/src/ |
H A D | lnn_lane_query_test.cpp | 111 LaneQueryInfo query; in HWTEST_F() local 112 memset_s(&query, sizeof(LaneQueryInfo), 0, sizeof(LaneQueryInfo)); in HWTEST_F() 113 query.transType = LANE_T_BYTE; in HWTEST_F() 114 EXPECT_EQ(strncpy_s(query.networkId, NETWORK_ID_BUF_LEN, NODE_NETWORK_ID, strlen(NODE_NETWORK_ID)), EOK); in HWTEST_F() 116 ret = LnnQueryLaneResource(&query, &qosInfo); in HWTEST_F() 119 ret = LnnQueryLaneResource(&query, nullptr); in HWTEST_F() 122 ret = LnnQueryLaneResource(&query, &qosInfo); in HWTEST_F() 125 ret = LnnQueryLaneResource(&query, &qosInfo); in HWTEST_F() 143 LaneQueryInfo query; in HWTEST_F() local 144 query in HWTEST_F() 169 LaneQueryInfo query; HWTEST_F() local 193 LaneQueryInfo query; HWTEST_F() local 221 LaneQueryInfo query; HWTEST_F() local 249 LaneQueryInfo query; HWTEST_F() local 493 LaneQueryInfo query; HWTEST_F() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/ |
H A D | js_query.cpp | 68 * var query = new ddm.JsQuery(); 75 "Parameter error:param query must be object"); in New() 77 JsQuery* query = new (std::nothrow) JsQuery(); in New() local 78 ASSERT_ERR(env, query != nullptr, Status::INVALID_ARGUMENT, in New() 79 "Parameter error:query is null"); in New() 82 ZLOGD("query finalize."); in New() 83 auto* query = reinterpret_cast<JsQuery*>(data); in New() 84 ASSERT_VOID(query != nullptr, "query is null!"); in New() 85 delete query; in New() 97 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Reset() local 137 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; EqualTo() local 164 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; NotEqualTo() local 191 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; GreaterThan() local 218 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; LessThan() local 245 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; GreaterThanOrEqualTo() local 272 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; LessThanOrEqualTo() local 307 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; IsNull() local 385 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; InNumber() local 420 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; InString() local 434 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; NotInNumber() local 469 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; NotInString() local 498 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Like() local 527 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Unlike() local 539 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; And() local 551 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Or() local 574 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; OrderByAsc() local 597 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; OrderByDesc() local 625 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; Limit() local 648 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; IsNotNull() local 660 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; BeginGroup() local 672 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; EndGroup() local 694 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; PrefixKey() local 716 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; SetSuggestIndex() local 738 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; DeviceId() local 750 auto& query = reinterpret_cast<JsQuery*>(ctxt->native)->query_; GetSqlLike() local [all...] |
/foundation/distributeddatamgr/relational_store/test/js/dataability/unittest/src/ |
H A D | DataAbilityPredicatesJsunit.test.js | 144 let result = await rdbStore.query(predicates); 164 let result = await rdbStore.query(predicates); 184 let result = await rdbStore.query(predicates); 204 let result = await rdbStore.query(predicates); 224 let result = await rdbStore.query(predicates); 244 let result = await rdbStore.query(predicates); 264 let result = await rdbStore.query(predicates); 284 let result = await rdbStore.query(predicates); 305 let result = await rdbStore.query(predicates); 326 let result = await rdbStore.query(predicate [all...] |