/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
H A D | query.cpp | 17 Query::Query(const std::string &tableName) in Query() function in DistributedDB::Query 21 Query Query::Select() in Select() 23 Query query; in Select() 27 Query Query::Select(const std::string &tableName) in Select() 29 Query query(tableName); in Select() 34 Query &Query [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/query_fuzzer/ |
H A D | query_fuzzer.cpp | 30 Query query = Query::Select().EqualTo(rawString, static_cast<int>(size)); in FuzzEqualTo() 36 Query query = Query::Select().NotEqualTo(TEST_FIELD_NAME, rawString); in FuzzNotEqualTo() 42 Query query = Query::Select().GreaterThan(rawString, static_cast<int>(QueryFuzzer::U32_AT(data))); in FuzzGreaterThan() 48 Query query = Query::Select().LessThan(TEST_FIELD_NAME, rawString); in FuzzLessThan() 54 Query query = Query in FuzzGreaterThanOrEqualTo() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/ |
H A D | distributeddb_nb_predicate_query_test.cpp | 124 bool CheckSchemaQuery(KvStoreNbDelegate *&delegate, Query &queryNeedCheck, vector<Entry> &expectEntry, in CheckSchemaQuery() 166 bool CheckSchemaQueryForOrderBy(KvStoreNbDelegate *&delegate, Query &queryNeedCheck, vector<Entry> &expectEntry, in CheckSchemaQueryForOrderBy() 211 vector<Query> queries1, queries2, queries3; in CheckSchemaNotExist() 263 * @tc.name: Query 001 264 * @tc.desc: check valid schema of String type and construct valid query object and traverse all function of Query. 282 * @tc.steps: step2. test the Query interface of EqualTo/NotEqualTo/In/NotIn/GreaterThan/LessThan/ in HWTEST_F() 286 Query query1 = Query::Select().EqualTo("$.field1", "bxz"); in HWTEST_F() 289 Query query5 = Query in HWTEST_F() [all...] |
H A D | distributeddb_nb_predicate_query_expand_test.cpp | 131 * @tc.steps: step2. test the Query without brackets and check the result with GetEntries. in HWTEST_F() 134 Query query1 = Query::Select().EqualTo("$.field2.field3", true).And().LessThanOrEqualTo("$.field2.field4.field5", in HWTEST_F() 143 * @tc.steps: step3. test the Query with brackets appear in pairs and check the result with GetEntries. in HWTEST_F() 146 Query query2 = Query::Select().BeginGroup().EqualTo("$.field2.field3", true).And(). in HWTEST_F() 155 * @tc.steps: step4. test the Query with brackets appear in pairs and check the result with GetCount. in HWTEST_F() 158 Query query3 = Query::Select().BeginGroup().EqualTo("$.field2.field3", true).And(). in HWTEST_F() 191 * @tc.steps: step2. test the Query withou in HWTEST_F() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/include/ |
H A D | query.h | 29 class Query { class 33 DB_API static Query Select(); 34 DB_API static Query Select(const std::string &tableName); 36 DB_API Query &FromTable(const std::vector<std::string> &tableNames); 38 DB_API Query &From(const std::string &tableName); 41 DB_API Query &EqualTo(const std::string &field, const T &value) in EqualTo() 50 DB_API Query &NotEqualTo(const std::string &field, const T &value) in NotEqualTo() 59 DB_API Query &GreaterThan(const std::string &field, const T &value) in GreaterThan() 68 DB_API Query &LessThan(const std::string &field, const T &value) in LessThan() 77 DB_API Query [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
H A D | distributeddb_interfaces_query_test.cpp | 29 bool CheckQueryContainer(Query &query, std::list<QueryObjNode> &checkList) in CheckQueryContainer() 81 Query query1 = Query::Select().NotEqualTo(TEST_FIELD_NAME, 123); // random test data in CheckQueryCompareOper() 85 Query query2 = Query::Select().EqualTo(TEST_FIELD_NAME, true); in CheckQueryCompareOper() 90 Query query3 = Query::Select().GreaterThan(TEST_FIELD_NAME, 0); in CheckQueryCompareOper() 95 Query query4 = Query::Select().LessThan(TEST_FIELD_NAME, INT_MAX); in CheckQueryCompareOper() 100 Query query in CheckQueryCompareOper() [all...] |
H A D | distributeddb_interfaces_data_operation_test.cpp | 1020 Query query = Query::Select(); in HWTEST_F() 1047 Query invalidQuery1 = Query::Select().EqualTo("$.field_name1", true).And().Or(); in HWTEST_F() 1054 Query invalidQuery2 = Query::Select().And(); in HWTEST_F() 1061 Query invalidQuery3 = Query::Select().Limit(10, 0).EqualTo("$.field_name1", true); in HWTEST_F() 1068 Query invalidQuery4 = Query in HWTEST_F() [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() 118 Query query1 = Query::Select().NotEqualTo(TEST_FIELD_NAME, 123); // random test data in HWTEST_F() 121 Query query2 = Query::Select().EqualTo(TEST_FIELD_NAME, true); in HWTEST_F() 124 Query query3 = Query::Select().GreaterThan(TEST_FIELD_NAME, 0); in HWTEST_F() 127 Query query4 = Query::Select().LessThan(TEST_FIELD_NAME, INT_MAX); in HWTEST_F() 130 Query query in HWTEST_F() [all...] |
H A D | distributeddb_storage_query_sync_test.cpp | 170 g_schemaConnect->GetEntries(option, Query::Select(), entries); in SetUp() 213 Query query = Query::Select().PrefixKey(key); in HWTEST_F() 253 Query query = Query::Select().PrefixKey(PREFIX_KEY); in HWTEST_F() 322 Query query = Query::Select().PrefixKey(PREFIX_KEY); in HWTEST_F() 385 Query query = Query::Select().PrefixKey(PREFIX_KEY); in HWTEST_F() 449 Query quer in HWTEST_F() [all...] |
H A D | distributeddb_storage_subscribe_query_test.cpp | 237 Query query1 = Query::Select().PrefixKey({}); in HWTEST_F() 246 Query query2 = Query::Select().GreaterThan("field_name3", 10); in HWTEST_F() 255 Query query3 = Query::Select().GreaterThan("field_name11", 10); in HWTEST_F() 264 Query query4 = Query::Select().GreaterThan("field_name3", 10).And().BeginGroup(). in HWTEST_F() 303 Query query1 = Query in HWTEST_F() [all...] |
/foundation/ability/ability_base/interfaces/inner_api/base/include/ |
H A D | base_interfaces.h | 31 inline static IInterface *Query(IInterface * object) /* [in] */ in Query() function 36 return object->Query(g_IID_IInterface); in Query() 43 virtual IInterface *Query(const InterfaceID &iid) = 0; /* [in] */ 52 inline static IBoolean *Query(IInterface * object) /* [in] */ in INTERFACE() function 57 return static_cast<IBoolean *>(object->Query(g_IID_IBoolean)); in INTERFACE() 65 inline static IChar *Query(IInterface * object) /* [in] */ in INTERFACE() function 70 return static_cast<IChar *>(object->Query(g_IID_IChar)); in INTERFACE() 78 inline static IByte *Query(IInterface * object) /* [in] */ in INTERFACE() function 83 return static_cast<IByte *>(object->Query(g_IID_IByte)); in INTERFACE() 91 inline static IShort *Query(IInterfac in INTERFACE() function 104 inline static IInteger *Query(IInterface * object) /* [in] */ INTERFACE() function 117 inline static ILong *Query(IInterface * object) /* [in] */ INTERFACE() function 130 inline static IFloat *Query(IInterface * object) /* [in] */ INTERFACE() function 143 inline static IDouble *Query(IInterface * object) /* [in] */ INTERFACE() function 156 inline static IString *Query(IInterface * object) /* [in] */ INTERFACE() function 169 inline static IArray *Query(IInterface * object) /* [in] */ INTERFACE() function 190 inline static IPacMap *Query(IInterface * object) INTERFACE() function 203 inline static IUserObject *Query(IInterface * object) INTERFACE() function 216 inline static IRemoteObjectWrap *Query(IInterface * object) INTERFACE() function [all...] |
H A D | base_obj.h | 25 inline static IObject *Query(IInterface & object) /* [in] */ in INTERFACE() function 27 return static_cast<IObject *>(object.Query(g_IID_IObject)); in INTERFACE() 41 inline static IWeakReference *Query(IInterface * object) /* [in] */ in INTERFACE() function 46 return static_cast<IWeakReference *>(object->Query(g_IID_IWeakReference)); in INTERFACE() 55 inline static IWeakReferenceSource *Query(IInterface * object) /* [in] */ in INTERFACE() function 60 return static_cast<IWeakReferenceSource *>(object->Query(g_IID_IWeakReferenceSource)); in INTERFACE() 72 IInterface *Query(const InterfaceID &iid) override; /* [in] */
|
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
H A D | rdb_predicates_test.cpp | 587 std::shared_ptr<ResultSet> allDataTypes = RdbStorePredicateTest::store->Query(predicates, columns);
in HWTEST_F() 595 std::shared_ptr<AbsSharedResultSet> resultSet = RdbStorePredicateTest::store->Query(predicates, columns);
in HWTEST_F() 614 std::shared_ptr<ResultSet> allDataTypes = RdbStorePredicateTest::store->Query(predicates2, columns);
in HWTEST_F() 664 std::shared_ptr<ResultSet> allPerson = RdbStorePredicateTest::store->Query(predicates, columns);
in HWTEST_F() 669 allPerson = RdbStorePredicateTest::store->Query(predicates1, columns);
in HWTEST_F() 683 std::shared_ptr<ResultSet> allDataTypes9 = RdbStorePredicateTest::store->Query(predicates1, columns);
in CalendarTest() 694 std::shared_ptr<ResultSet> allDataTypes1 = RdbStorePredicateTest::store->Query(predicates1, columns);
in BasicDataTypeTest() 699 std::shared_ptr<ResultSet> allDataTypes2 = RdbStorePredicateTest::store->Query(predicates1, columns);
in BasicDataTypeTest() 704 std::shared_ptr<ResultSet> allDataTypes3 = RdbStorePredicateTest::store->Query(predicates1, columns);
in BasicDataTypeTest() 711 std::shared_ptr<ResultSet> allDataTypes4 = RdbStorePredicateTest::store->Query(predicates in BasicDataTypeTest() [all...] |
/foundation/ability/ability_base/interfaces/kits/native/want/src/ |
H A D | want_params.cpp | 122 return static_cast<Boolean *>(IBoolean::Query(iIt))->ToString(); in GetStringByType() 124 return static_cast<Byte *>(IByte::Query(iIt))->ToString(); in GetStringByType() 126 return static_cast<Char *>(IChar::Query(iIt))->ToString(); in GetStringByType() 128 return static_cast<Short *>(IShort::Query(iIt))->ToString(); in GetStringByType() 130 return static_cast<Integer *>(IInteger::Query(iIt))->ToString(); in GetStringByType() 132 return static_cast<Long *>(ILong::Query(iIt))->ToString(); in GetStringByType() 134 return static_cast<Float *>(IFloat::Query(iIt))->ToString(); in GetStringByType() 136 return static_cast<Double *>(IDouble::Query(iIt))->ToString(); in GetStringByType() 138 return static_cast<String *>(IString::Query(iIt))->ToString(); in GetStringByType() 140 return static_cast<Array *>(IArray::Query(iI in GetStringByType() [all...] |
H A D | pac_map.cpp | 74 if (id::Query(it->second.GetRefPtr()) != nullptr) { \ 75 sptr<id> idValue = id::Query(it->second.GetRefPtr()); \ 88 if (id::Query((it)->second.GetRefPtr()) != nullptr) { \ 89 sptr<id> idValue = id::Query(it->second.GetRefPtr()); \ 113 if (IArray::Query(it->second.GetRefPtr()) != nullptr) { \ 114 if (Array::Is##id##Array(IArray::Query(it->second.GetRefPtr()))) { \ 116 if (I##id::Query(object) != nullptr) { \ 117 (value).push_back(id::Unbox(I##id::Query(object))); \ 120 Array::ForEach(IArray::Query(it->second.GetRefPtr()), func); \ 129 IClassName *data = IClassName::Query(baseOb in GetBaseDataValue() [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
H A D | distributeddb_cloud_check_sync_test.cpp | 69 void PrepareOption(CloudSyncOption &option, const Query &query, bool isPriorityTask, bool isCompensatedSyncOnly = false) in PrepareOption() 79 void BlockSync(const Query &query, RelationalStoreDelegate *delegate, std::vector<DBStatus> &actualDBStatus, in BlockSync() 110 void BlockPrioritySync(const Query &query, RelationalStoreDelegate *delegate, bool isPriority, DBStatus expectResult, in BlockPrioritySync() 138 void BlockCompensatedSync(const Query &query, RelationalStoreDelegate *delegate, DBStatus expectResult, in BlockCompensatedSync() 208 void PriorityAndNormalSync(const Query &normalQuery, const Query &priorityQuery, 427 virtualCloudDb_->Query(tableName, extend, data); in CheckCloudTableCount() 501 void DistributedDBCloudCheckSyncTest::PriorityAndNormalSync(const Query &normalQuery, const Query &priorityQuery, in PriorityAndNormalSync() 595 Query quer in InitLogicDeleteDataEnv() [all...] |
/foundation/ability/dmsfwk/services/dtbschedmgr/src/distributedWant/ |
H A D | distributed_want_params.cpp | 170 AAFwk::IBoolean* obj = AAFwk::IBoolean::Query(iIt); in BooleanQueryToStr() 176 AAFwk::IByte* obj = AAFwk::IByte::Query(iIt); in ByteQueryToStr() 182 AAFwk::IChar* obj = AAFwk::IChar::Query(iIt); in CharQueryToStr() 188 AAFwk::IShort* obj = AAFwk::IShort::Query(iIt); in ShortQueryToStr() 194 AAFwk::IInteger* obj = AAFwk::IInteger::Query(iIt); in IntegerQueryToStr() 200 AAFwk::ILong* obj = AAFwk::ILong::Query(iIt); in LongQueryToStr() 206 AAFwk::IFloat* obj = AAFwk::IFloat::Query(iIt); in FloatQueryToStr() 212 AAFwk::IDouble* obj = AAFwk::IDouble::Query(iIt); in DoubleQueryToStr() 218 AAFwk::IString* obj = AAFwk::IString::Query(iIt); in StringQueryToStr() 224 AAFwk::IArray* obj = AAFwk::IArray::Query(iI in ArrayQueryToStr() [all...] |
/foundation/ability/ability_base/interfaces/inner_api/base/src/ |
H A D | base_object.cpp | 48 IInterface *Query(const InterfaceID &iid) override; 69 IInterface *WeakReferenceImpl::Query(const InterfaceID &iid) in Query() function in OHOS::AAFwk::WeakReferenceImpl 90 *object = object_->Query(iid); in Resolve() 110 IInterface *Object::Query(const InterfaceID &iid) in Query() function in OHOS::AAFwk::Object 180 if (IInterface::Query(&obj1) == IInterface::Query(&obj2)) { in Equals() 184 IObject *o1 = IObject::Query(obj1); in Equals() 188 return o1->Equals(*(IObject::Query(obj2))); in Equals() 193 IObject *obj = IObject::Query(object); in ToString()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/include/ |
H A D | distributeddb_nb_test_tools.h | 292 typedef DistributedDB::Query&(DistributedDB::Query::*FP_COMP)(const std::string& field, const ParaType& value); 293 typedef DistributedDB::Query&(DistributedDB::Query::*FP_LIKE)(const std::string& field, const std::string& value); 294 typedef DistributedDB::Query&(DistributedDB::Query::*FP_IN)(const std::string& field, 303 void GenerateQueryComp(std::vector<DistributedDB::Query> &queries, const bool (&funcFilter)[FP_COMP_SIZE], in GenerateQueryComp() 310 queries.push_back((DistributedDB::Query::Select().*(compFunc_[i]))(field, value)); in GenerateQueryComp() 314 void GenerateQueryLike(std::vector<DistributedDB::Query> &queries, const bool (&funcFilter)[FP_LIKE_SIZE], in GenerateQueryLike() 321 queries.push_back((DistributedDB::Query in GenerateQueryLike() [all...] |
H A D | distributeddb_schema_test_tools.h | 278 const DistributedDB::Query &query, std::vector<DistributedDB::Entry> &expectEntry, 283 std::vector<DistributedDB::Query> &queries) in ConstructInvalidQuery() 286 DistributedDB::Query::Select().EqualTo(field, value), in ConstructInvalidQuery() 287 DistributedDB::Query::Select().NotEqualTo(field, value), in ConstructInvalidQuery() 288 DistributedDB::Query::Select().GreaterThan(field, value), in ConstructInvalidQuery() 289 DistributedDB::Query::Select().GreaterThanOrEqualTo(field, value), in ConstructInvalidQuery() 290 DistributedDB::Query::Select().LessThan(field, value), in ConstructInvalidQuery() 291 DistributedDB::Query::Select().LessThanOrEqualTo(field, value), in ConstructInvalidQuery() 292 DistributedDB::Query::Select().In(field, scope), in ConstructInvalidQuery() 293 DistributedDB::Query in ConstructInvalidQuery() [all...] |
/foundation/ability/ability_runtime/frameworks/js/napi/mission_manager/ |
H A D | js_mission_info_utils.cpp | 74 if (AAFwk::IString::Query(iter->second) != nullptr) { in CreateJsWantParams() 77 } else if (AAFwk::IBoolean::Query(iter->second) != nullptr) { in CreateJsWantParams() 80 } else if (AAFwk::IShort::Query(iter->second) != nullptr) { in CreateJsWantParams() 83 } else if (AAFwk::IInteger::Query(iter->second) != nullptr) { in CreateJsWantParams() 86 } else if (AAFwk::ILong::Query(iter->second) != nullptr) { in CreateJsWantParams() 89 } else if (AAFwk::IFloat::Query(iter->second) != nullptr) { in CreateJsWantParams() 92 } else if (AAFwk::IDouble::Query(iter->second) != nullptr) { in CreateJsWantParams() 95 } else if (AAFwk::IChar::Query(iter->second) != nullptr) { in CreateJsWantParams() 98 } else if (AAFwk::IByte::Query(iter->second) != nullptr) { in CreateJsWantParams() 101 } else if (AAFwk::IArray::Query(ite in CreateJsWantParams() [all...] |
/foundation/ability/ability_runtime/frameworks/js/napi/js_mission_manager/ |
H A D | js_mission_info_utils.cpp | 76 if (AAFwk::IString::Query(iter->second) != nullptr) { in CreateJsWantParams() 79 } else if (AAFwk::IBoolean::Query(iter->second) != nullptr) { in CreateJsWantParams() 82 } else if (AAFwk::IShort::Query(iter->second) != nullptr) { in CreateJsWantParams() 85 } else if (AAFwk::IInteger::Query(iter->second) != nullptr) { in CreateJsWantParams() 88 } else if (AAFwk::ILong::Query(iter->second) != nullptr) { in CreateJsWantParams() 91 } else if (AAFwk::IFloat::Query(iter->second) != nullptr) { in CreateJsWantParams() 94 } else if (AAFwk::IDouble::Query(iter->second) != nullptr) { in CreateJsWantParams() 97 } else if (AAFwk::IChar::Query(iter->second) != nullptr) { in CreateJsWantParams() 100 } else if (AAFwk::IByte::Query(iter->second) != nullptr) { in CreateJsWantParams() 103 } else if (AAFwk::IArray::Query(ite in CreateJsWantParams() [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() 181 Query query = { filter, "{}" }; in HWTEST_F() 209 Query query = { filter, "{}" }; in HWTEST_F() 238 Query query1 = { filter1, "{}" }; in HWTEST_F() 248 Query query2 = { filter2, "{}" }; in HWTEST_F() 257 Query query3 = { filter3, "{}" }; in HWTEST_F() 266 Query query4 = { filter4, "{}" }; in HWTEST_F() 275 Query query5 = { filter5, "{}" }; in HWTEST_F() 284 Query query6 = { filter6, "{}" }; in HWTEST_F() 301 Query quer in HWTEST_F() [all...] |
/foundation/ability/ability_base/test/unittest/base/ |
H A D | base_object_test.cpp | 59 * @tc.name: Query
60 * @tc.desc: test Query function and iid == g_IID_IWeakReferenceSource.
68 EXPECT_TRUE(object.Query(iid));
in HWTEST_F() 73 * @tc.name: Query
74 * @tc.desc: test Query function and iid == g_IID_IInterface.
82 EXPECT_TRUE(object.Query(iid));
in HWTEST_F() 96 EXPECT_EQ(iid, object.GetInterfaceID(object.Query(iid)));
in HWTEST_F() 110 EXPECT_EQ(iid, object.GetInterfaceID(object.Query(iid)));
in HWTEST_F() 124 EXPECT_EQ(InterfaceID::Empty, object.GetInterfaceID(object.Query(iid)));
in HWTEST_F() 176 EXPECT_EQ(false, object->Equals(*(object1.Query(ii in HWTEST_F() [all...] |
/foundation/distributeddatamgr/relational_store/test/native/rdb/fuzztest/rdbstore_fuzzer/ |
H A D | rdbstore_fuzzer.cpp | 345 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 349 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 353 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 357 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 361 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 365 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 369 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 373 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 377 store->Query(predicates, { vectorElem }); in RdbQueryFuzz1() 405 store->Query(predicate in RdbQueryFuzz2() [all...] |