Home
last modified time | relevance | path

Searched refs:predicate (Results 1 – 25 of 34) sorted by relevance

12

/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/
Drelational_store.cpp152 auto predicate = RelationalPredicate::GetSelf(predicates); in OH_Rdb_Update() local
154 if (rdbStore == nullptr || predicate == nullptr || bucket == nullptr) { in OH_Rdb_Update()
158 rdbStore->GetStore()->Update(updatedRows, bucket->Get(), predicate->Get()); in OH_Rdb_Update()
165 auto predicate = RelationalPredicate::GetSelf(predicates); in OH_Rdb_Delete() local
166 if (rdbStore == nullptr || predicate == nullptr) { in OH_Rdb_Delete()
170 rdbStore->GetStore()->Delete(deletedRows, predicate->Get()); in OH_Rdb_Delete()
177 auto predicate = RelationalPredicate::GetSelf(predicates); in OH_Rdb_Query() local
178 if (rdbStore == nullptr || predicate == nullptr) { in OH_Rdb_Query()
190 rdbStore->GetStore()->QueryByStep(predicate->Get(), columns); in OH_Rdb_Query()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/
Ddata_share_service_stub.cpp60 DataSharePredicates predicate; in OnRemoteUpdate() local
62 if (!ITypesUtil::Unmarshal(data, uri, predicate, bucket.valuesMap)) { in OnRemoteUpdate()
67 int32_t status = Update(uri, predicate, bucket); in OnRemoteUpdate()
78 DataSharePredicates predicate; in OnRemoteDelete() local
79 if (!ITypesUtil::Unmarshal(data, uri, predicate)) { in OnRemoteDelete()
83 int32_t status = Delete(uri, predicate); in OnRemoteDelete()
94 DataSharePredicates predicate; in OnRemoteQuery() local
96 if (!ITypesUtil::Unmarshal(data, uri, predicate, columns)) { in OnRemoteQuery()
102 auto result = ISharedResultSet::WriteToParcel(Query(uri, predicate, columns, status), reply); in OnRemoteQuery()
Didata_share_service.h58 …const std::string &uri, const DataSharePredicates &predicate, const DataShareValuesBucket &valuesB…
59 virtual int32_t Delete(const std::string &uri, const DataSharePredicates &predicate) = 0;
Ddata_share_service_impl.h44 int32_t Update(const std::string &uri, const DataSharePredicates &predicate,
46 int32_t Delete(const std::string &uri, const DataSharePredicates &predicate) override;
Ddata_share_service_impl.cpp78 int32_t DataShareServiceImpl::Update(const std::string &uri, const DataSharePredicates &predicate, in Update() argument
83 auto ret = updateStrategy_.Execute(context, predicate, valuesBucket); in Update()
91 int32_t DataShareServiceImpl::Delete(const std::string &uri, const DataSharePredicates &predicate) in Delete() argument
95 auto ret = deleteStrategy_.Execute(context, predicate); in Delete()
/foundation/multimedia/media_library/frameworks/services/media_distributed/src/database_manage/
Dmedialibrary_sync_operation.cpp267 NativeRdb::AbsRdbPredicates predicate(syncOpts.table); in SyncPullTable() local
268 predicate.InDevices(onlineDevices); in SyncPullTable()
270 …predicate.EqualTo(MEDIA_DATA_DB_TIME_PENDING, to_string(0))->And()->EqualTo(MEDIA_DATA_DB_ID, sync… in SyncPullTable()
272 predicate.EqualTo(MEDIA_DATA_DB_TIME_PENDING, to_string(0)); in SyncPullTable()
274 predicate.EqualTo(MEDIA_DATA_DB_ID, syncOpts.row); in SyncPullTable()
288 ret = syncOpts.rdbStore->Sync(option, predicate, callback); in SyncPullTable()
377 NativeRdb::AbsRdbPredicates predicate(syncOpts.table); in SyncPushTable() local
378 predicate.InDevices(onlineDevices); in SyncPushTable()
380 …predicate.EqualTo(MEDIA_DATA_DB_TIME_PENDING, to_string(0))->And()->EqualTo(MEDIA_DATA_DB_ID, sync… in SyncPushTable()
382 predicate.EqualTo(MEDIA_DATA_DB_TIME_PENDING, to_string(0)); in SyncPushTable()
[all …]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/strategies/
Ddelete_strategy.cpp29 …4_t DeleteStrategy::Execute(std::shared_ptr<Context> context, const DataSharePredicates &predicate) in Execute() argument
45 return delegate->Delete(context->calledTableName, predicate); in Execute()
Dupdate_strategy.cpp29 …std::shared_ptr<Context> context, const DataSharePredicates &predicate, const DataShareValuesBucke… in Execute() argument
45 return delegate->Update(context->calledTableName, predicate, valuesBucket); in Execute()
Ddelete_strategy.h27 int64_t Execute(std::shared_ptr<Context> context, const DataSharePredicates &predicate);
Dupdate_strategy.h28 int64_t Execute(std::shared_ptr<Context> context, const DataSharePredicates &predicate,
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
Drdb_delegate.h36 int64_t Update(const std::string &tableName, const DataSharePredicates &predicate,
38 int64_t Delete(const std::string &tableName, const DataSharePredicates &predicate) override;
Drdb_delegate.cpp83 …const std::string &tableName, const DataSharePredicates &predicate, const DataShareValuesBucket &v… in Update() argument
91 RdbPredicates predicates = RdbDataShareAdapter::RdbUtils::ToPredicates(predicate, tableName); in Update()
98 int64_t RdbDelegate::Delete(const std::string &tableName, const DataSharePredicates &predicate) in Delete() argument
105 RdbPredicates predicates = RdbDataShareAdapter::RdbUtils::ToPredicates(predicate, tableName); in Delete()
Ddb_delegate.h35 virtual int64_t Update(const std::string &tableName, const DataSharePredicates &predicate,
37 virtual int64_t Delete(const std::string &tableName, const DataSharePredicates &predicate) = 0;
/foundation/distributeddatamgr/relational_store/test/native/rdb/distributedtest/rdb_store_impl_test/
Ddistributed_test_agent.cpp123 AbsRdbPredicates predicate(tables[0]); in OnProcessMsg() local
124 predicate.EqualTo("name", "zhangsan"); in OnProcessMsg()
125 predicate.InAllDevices(); in OnProcessMsg()
Ddistributed_test.cpp157 AbsRdbPredicates predicate(tables[0]);
158 predicate.EqualTo("name", "zhangsan");
161 …std::shared_ptr<ResultSet> resultSet = store_->RemoteQuery(deviceInfos_[0].networkId, predicate, c…
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/include/
Ddata_share_service_proxy.h31 int Update(const Uri &uri, const DataSharePredicates &predicate,
34 int Delete(const Uri &uri, const DataSharePredicates &predicate) override;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/data/
Dtemplate_data.cpp42 for (const auto &predicate: predicates) { in ToTemplate() local
43 nodes.emplace_back(predicate.key, predicate.selectSql); in ToTemplate()
/foundation/distributeddatamgr/relational_store/test/js/rdb/unittest/src/
DRdbStoreDistributedJsunit.test.js174 let predicate = new dataRdb.RdbPredicates("employee");
175 predicate.equalTo("id", 1);
177 let rowId = await rdbStore.update(record, predicate);
/foundation/distributeddatamgr/relational_store/test/js/relationalstore/unittest/src/
DRdbstoreDeleteJsunit.test.js345 var predicate = new dataSharePredicates.DataSharePredicates();
346 await rdbStore.delete("test", predicate);
DRdbStoreDistributedJsunit.test.js178 let predicate = new data_relationalStore.RdbPredicates("employee");
179 predicate.equalTo("id", 1);
181 let rowId = await rdbStore.update(record, predicate);
/foundation/distributeddatamgr/data_share/frameworks/native/proxy/src/
Ddata_share_service_proxy.cpp57 const DataSharePredicates &predicate, const DataShareValuesBucket &valuesBucket) in Update() argument
65 if (!ITypesUtil::Marshal(data, uriStr, predicate, valuesBucket)) { in Update()
81 int32_t DataShareServiceProxy::Delete(const Uri &uri, const DataSharePredicates &predicate) in Delete() argument
89 if (!ITypesUtil::Marshal(data, uriStr, predicate)) { in Delete()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/subscriber_managers/
Drdb_subscriber_manager.cpp309 for (const auto &predicate : tpl.predicates_) { in Notify() local
310 std::string result = delegate->Query(predicate.selectSql_); in Notify()
314 changeNode.data_.emplace_back("{\"" + predicate.key_ + "\":" + result + "}"); in Notify()
/foundation/multimedia/media_library/frameworks/js/src/
Dmedialibrary_napi_utils.cpp239 shared_ptr<DataShareAbsPredicates> &predicate, const FetchOptionType &fetchOptType) in HandleSpecialPredicate() argument
244 auto &items = predicate->GetOperationList(); in HandleSpecialPredicate()
315 …shared_ptr<DataShareAbsPredicates> predicate = DataSharePredicatesProxy::GetNativePredicates(env, … in GetPredicate() local
316 … CHECK_COND_RET(HandleSpecialPredicate(context, predicate, fetchOptType) == TRUE, napi_invalid_arg, in GetPredicate()
861 unique_ptr<MediaLibraryAsyncContext> &context, shared_ptr<DataShareAbsPredicates> &predicate,
865 unique_ptr<AlbumNapiAsyncContext> &context, shared_ptr<DataShareAbsPredicates> &predicate,
869 unique_ptr<SmartAlbumNapiAsyncContext> &context, shared_ptr<DataShareAbsPredicates> &predicate,
/foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/include/
Ddk_database.h83 DKPredicate predicate; member
/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/
Drdb_store.h456 const SyncOption &option, const AbsRdbPredicates &predicate, const AsyncBrief &async) = 0;

12