Home
last modified time | relevance | path

Searched refs:predicate (Results 1 - 25 of 51) sorted by relevance

123

/foundation/multimedia/media_library/frameworks/innerkitsimpl/medialibrary_data_extension/src/
H A Dmedialibrary_vision_operations.cpp103 DataSharePredicates predicate; in UpdateAnalysisTotal() local
104 predicate.SetWhereClause(selection); in UpdateAnalysisTotal()
109 return MediaLibraryDataManager::GetInstance()->Update(cmdTotal, valueBucket, predicate); in UpdateAnalysisTotal()
124 DataSharePredicates predicate; in DeleteFromVisionTables() local
125 predicate.EqualTo(FILE_ID, fileId); in DeleteFromVisionTables()
127 return MediaLibraryDataManager::GetInstance()->Delete(cmdTable, predicate); in DeleteFromVisionTables()
134 DataSharePredicates predicate; in DeleteFromVisionTablesForVideo() local
135 predicate.EqualTo(FILE_ID, fileId); in DeleteFromVisionTablesForVideo()
137 return MediaLibraryDataManager::GetInstance()->Delete(cmdTable, predicate); in DeleteFromVisionTablesForVideo()
/foundation/multimedia/media_library/frameworks/services/media_distributed/src/database_manage/
H A Dmedialibrary_sync_operation.cpp270 NativeRdb::AbsRdbPredicates predicate(syncOpts.table); in SyncPullTable()
271 predicate.InDevices(onlineDevices); in SyncPullTable()
273 predicate.EqualTo(MEDIA_DATA_DB_TIME_PENDING, to_string(0))->And()->EqualTo(MEDIA_DATA_DB_ID, syncOpts.row); in SyncPullTable()
275 predicate.EqualTo(MEDIA_DATA_DB_TIME_PENDING, to_string(0)); in SyncPullTable()
277 predicate.EqualTo(MEDIA_DATA_DB_ID, syncOpts.row); in SyncPullTable()
291 ret = syncOpts.rdbStore->Sync(option, predicate, callback); in SyncPullTable()
380 NativeRdb::AbsRdbPredicates predicate(syncOpts.table); in SyncPushTable()
381 predicate.InDevices(onlineDevices); in SyncPushTable()
383 predicate.EqualTo(MEDIA_DATA_DB_TIME_PENDING, to_string(0))->And()->EqualTo(MEDIA_DATA_DB_ID, syncOpts.row); in SyncPushTable()
385 predicate in SyncPushTable()
[all...]
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/
H A Ddata_share_service_proxy.h31 int Update(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate,
34 int Delete(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate) override;
85 std::pair<int32_t, int32_t> UpdateEx(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate,
89 const DataSharePredicates &predicate) override;
/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/
H A Drelational_store.cpp460 auto predicate = RelationalPredicate::GetSelf(predicates); in OH_Rdb_Update() local
462 if (rdbStore == nullptr || predicate == nullptr || bucket == nullptr) { in OH_Rdb_Update()
466 rdbStore->GetStore()->Update(updatedRows, bucket->Get(), predicate->Get()); in OH_Rdb_Update()
473 auto predicate = RelationalPredicate::GetSelf(predicates); in OH_Rdb_Delete() local
474 if (rdbStore == nullptr || predicate == nullptr) { in OH_Rdb_Delete()
478 rdbStore->GetStore()->Delete(deletedRows, predicate->Get()); in OH_Rdb_Delete()
485 auto predicate = RelationalPredicate::GetSelf(predicates); in OH_Rdb_Query() local
486 if (rdbStore == nullptr || predicate == nullptr) { in OH_Rdb_Query()
498 rdbStore->GetStore()->QueryByStep(predicate->Get(), columns); in OH_Rdb_Query()
925 auto predicate in OH_Rdb_LockRow() local
935 auto predicate = RelationalPredicate::GetSelf(predicates); OH_Rdb_UnlockRow() local
946 auto predicate = RelationalPredicate::GetSelf(predicates); OH_Rdb_QueryLockedRow() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
H A Ddata_share_service_stub.cpp63 DataSharePredicates predicate; in OnUpdateEx() local
65 if (!ITypesUtil::Unmarshal(data, uri, extUri, predicate, bucket.valuesMap)) { in OnUpdateEx()
70 auto [errCode, status] = UpdateEx(uri, extUri, predicate, bucket); in OnUpdateEx()
82 DataSharePredicates predicate; in OnDeleteEx() local
83 if (!ITypesUtil::Unmarshal(data, uri, extUri, predicate)) { in OnDeleteEx()
87 auto [errCode, status] = DeleteEx(uri, extUri, predicate); in OnDeleteEx()
99 DataSharePredicates predicate; in OnQuery() local
101 if (!ITypesUtil::Unmarshal(data, uri, extUri, predicate, columns)) { in OnQuery()
107 auto result = ISharedResultSet::WriteToParcel(Query(uri, extUri, predicate, columns, status), reply); in OnQuery()
H A Didata_share_service.h93 const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) = 0;
95 const DataSharePredicates &predicate) = 0;
/foundation/distributeddatamgr/relational_store/test/native/rdb/distributedtest/rdb_store_impl_test/
H A Ddistributed_test_agent.cpp124 AbsRdbPredicates predicate(tables[0]); in OnProcessMsg()
125 predicate.EqualTo("name", "zhangsan"); in OnProcessMsg()
126 predicate.InAllDevices(); in OnProcessMsg()
H A Ddistributed_test.cpp170 AbsRdbPredicates predicate(tables[0]); in HWTEST_F()
171 predicate.EqualTo("name", "zhangsan"); in HWTEST_F()
174 std::shared_ptr<ResultSet> resultSet = store_->RemoteQuery(deviceInfos_[0].networkId, predicate, columns, errCode); in HWTEST_F()
/foundation/multimedia/camera_framework/services/camera_service/include/avcodec/common/
H A Dfixed_size_list.h43 std::optional<T> find_if(const std::function<bool(const T&)>& predicate) in find_if() argument
47 if (predicate(data[i])) { in find_if()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
H A Drdb_delegate.h45 const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) override;
47 const DataSharePredicates &predicate) override;
H A Ddb_delegate.h49 const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) = 0;
51 const DataSharePredicates &predicate) = 0;
H A Drdb_delegate.cpp155 const std::string &tableName, const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) in UpdateEx()
163 RdbPredicates predicates = RdbDataShareAdapter::RdbUtils::ToPredicates(predicate, tableName); in UpdateEx()
178 std::pair<int64_t, int64_t> RdbDelegate::DeleteEx(const std::string &tableName, const DataSharePredicates &predicate) in DeleteEx() argument
185 RdbPredicates predicates = RdbDataShareAdapter::RdbUtils::ToPredicates(predicate, tableName); in DeleteEx()
154 UpdateEx( const std::string &tableName, const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) UpdateEx() argument
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_distributed_test.cpp247 AbsRdbPredicates predicate("employee"); in HWTEST_F()
251 errCode = rdbStore->Sync(option, predicate, OHOS::DistributedRdb::AsyncBrief()); in HWTEST_F()
257 errCode = rdbStore->Sync(option, predicate, OHOS::DistributedRdb::AsyncDetail()); in HWTEST_F()
267 errCode = store->Sync(option, predicate, OHOS::DistributedRdb::AsyncBrief()); in HWTEST_F()
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
H A Ddata_share_service_proxy.cpp46 const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) in Update()
48 auto [errCode, status] = UpdateEx(uri, extUri, predicate, valuesBucket); in Update()
58 int32_t DataShareServiceProxy::Delete(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate) in Delete() argument
60 auto [errCode, status] = DeleteEx(uri, extUri, predicate); in Delete()
103 const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) in UpdateEx()
111 if (!ITypesUtil::Marshal(data, uriStr, extUri.ToString(), predicate, valuesBucket)) { in UpdateEx()
135 const DataSharePredicates &predicate) in DeleteEx()
143 if (!ITypesUtil::Marshal(data, uriStr, extUri.ToString(), predicate)) { in DeleteEx()
45 Update(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) Update() argument
102 UpdateEx(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) UpdateEx() argument
134 DeleteEx(const Uri &uri, const Uri &extUri, const DataSharePredicates &predicate) DeleteEx() argument
/foundation/graphic/graphic_3d/lume/LumeEngine/src/
H A Dplugin_registry.cpp109 inline typename Container::const_iterator FindIf(const Container& container, Predicate&& predicate) in FindIf() argument
111 return std::find_if(container.cbegin(), container.cend(), BASE_NS::forward<Predicate>(predicate)); in FindIf()
115 inline bool NoneOf(const Container& container, Predicate&& predicate) in NoneOf() argument
117 return std::none_of(container.cbegin(), container.cend(), BASE_NS::forward<Predicate>(predicate)); in NoneOf()
121 inline bool AllOf(const Container& container, Predicate&& predicate) in AllOf() argument
123 return std::all_of(container.cbegin(), container.cend(), BASE_NS::forward<Predicate>(predicate)); in AllOf()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/data/
H A Dtemplate_data.cpp42 for (const auto &predicate: predicates) { in ToTemplate()
43 nodes.emplace_back(predicate.key, predicate.selectSql); in ToTemplate()
/foundation/distributeddatamgr/relational_store/test/js/rdb/unittest/src/
H A DRdbStoreDistributedJsunit.test.js176 let predicate = new dataRdb.RdbPredicates("employee");
177 predicate.equalTo("id", 1);
179 let rowId = await rdbStore.update(record, predicate);
187 console.log(TAG + "construct predicate failed");
/foundation/multimedia/media_library/frameworks/js/src/
H A Dmedialibrary_napi_utils.cpp322 shared_ptr<DataShareAbsPredicates> &predicate, const FetchOptionType &fetchOptType) in HandleSpecialPredicate()
327 auto &items = predicate->GetOperationList(); in HandleSpecialPredicate()
379 shared_ptr<DataShareAbsPredicates> &predicate) in GetLocationPredicate()
384 auto &items = predicate->GetOperationList(); in GetLocationPredicate()
436 CHECK_STATUS_RET(GetPredicate(env, arg, "predicates", context, fetchOptType), "invalid predicate"); in GetFetchOption()
447 CHECK_STATUS_RET(GetPredicate(env, arg, "predicates", context, fetchOptType), "invalid predicate"); in GetAlbumFetchOption()
467 shared_ptr<DataShareAbsPredicates> predicate = jsProxy->GetInstance(); in GetPredicate() local
468 CHECK_COND_RET(HandleSpecialPredicate(context, predicate, fetchOptType) == TRUE, napi_invalid_arg, in GetPredicate()
469 "invalid predicate"); in GetPredicate()
470 CHECK_COND_RET(GetLocationPredicate(context, predicate) in GetPredicate()
321 HandleSpecialPredicate(AsyncContext &context, shared_ptr<DataShareAbsPredicates> &predicate, const FetchOptionType &fetchOptType) HandleSpecialPredicate() argument
378 GetLocationPredicate(AsyncContext &context, shared_ptr<DataShareAbsPredicates> &predicate) GetLocationPredicate() argument
1606 shared_ptr<DataShareAbsPredicates> predicate = jsProxy->GetInstance(); ParsePredicates() local
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_store.cpp448 int RdbStore::Sync(const SyncOption &option, const AbsRdbPredicates &predicate, const AsyncBrief &async) in Sync() argument
451 (void)predicate; in Sync()
464 int RdbStore::Sync(const SyncOption &option, const AbsRdbPredicates &predicate, const AsyncDetail &async) in Sync() argument
467 (void)predicate; in Sync()
/foundation/multimedia/media_library/frameworks/js/src/sendable/
H A Dsendable_medialibrary_napi_utils.cpp233 shared_ptr<DataShareAbsPredicates> &predicate, const FetchOptionType &fetchOptType) in HandleSpecialPredicate()
238 auto &items = predicate->GetOperationList(); in HandleSpecialPredicate()
290 shared_ptr<DataShareAbsPredicates> &predicate) in GetLocationPredicate()
295 auto &items = predicate->GetOperationList(); in GetLocationPredicate()
347 CHECK_STATUS_RET(GetPredicate(env, arg, "predicates", context, fetchOptType), "invalid predicate"); in GetFetchOption()
358 CHECK_STATUS_RET(GetPredicate(env, arg, "predicates", context, fetchOptType), "invalid predicate"); in GetAlbumFetchOption()
378 shared_ptr<DataShareAbsPredicates> predicate = jsProxy->GetInstance(); in GetPredicate() local
379 CHECK_COND_RET(HandleSpecialPredicate(context, predicate, fetchOptType) == TRUE, napi_invalid_arg, in GetPredicate()
380 "invalid predicate"); in GetPredicate()
381 CHECK_COND_RET(GetLocationPredicate(context, predicate) in GetPredicate()
232 HandleSpecialPredicate(AsyncContext &context, shared_ptr<DataShareAbsPredicates> &predicate, const FetchOptionType &fetchOptType) HandleSpecialPredicate() argument
289 GetLocationPredicate(AsyncContext &context, shared_ptr<DataShareAbsPredicates> &predicate) GetLocationPredicate() argument
1276 shared_ptr<DataShareAbsPredicates> predicate = jsProxy->GetInstance(); ParsePredicates() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/
H A Drdb_subscriber_manager.cpp339 for (const auto &predicate : tpl.predicates_) { in Notify()
340 std::string result = delegate->Query(predicate.selectSql_); in Notify()
344 changeNode.data_.emplace_back("{\"" + predicate.key_ + "\":" + result + "}"); in Notify()
/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/
H A DRdbStoreDistributedJsunit.test.js178 let predicate = new data_relationalStore.RdbPredicates("employee");
179 predicate.equalTo("id", 1);
181 let rowId = await rdbStore.update(record, predicate);
189 console.log(TAG + "construct predicate failed");
/foundation/multimedia/media_library/frameworks/services/media_thumbnail/include/
H A Dthumbnail_generate_helper.h40 EXPORT static int32_t CreateAstcBatchOnDemand(ThumbRdbOpt &opts, NativeRdb::RdbPredicates &predicate,
/foundation/bundlemanager/app_domain_verify/test/unittest/mock/include/
H A Dmock_rdb.h239 int Sync(const SyncOption& option, const AbsRdbPredicates& predicate, const AsyncBrief& async) override
244 int Sync(const SyncOption& option, const AbsRdbPredicates& predicate, const AsyncDetail& async) override
/foundation/bundlemanager/bundle_framework/services/bundlemgr/test/mock/include/
H A Dmock_app_provision_info.h245 virtual int Sync(const SyncOption& option, const AbsRdbPredicates& predicate, const AsyncBrief& async) in Sync() argument
250 virtual int Sync(const SyncOption& option, const AbsRdbPredicates& predicate, const AsyncDetail& async) in Sync() argument

Completed in 20 milliseconds

123