Home
last modified time | relevance | path

Searched refs:DistributedRdb (Results 1 – 25 of 132) sorted by relevance

123456

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Drdb_query_test.cpp25 using namespace OHOS::DistributedRdb;
60 DistributedRdb::PredicatesMemo predicates;
82 DistributedRdb::PredicatesMemo predicates;
110 DistributedRdb::PredicatesMemo predicates;
121 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::LIKE, "test", values);
122 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::GLOB, "test", values);
148 DistributedRdb::PredicatesMemo predicates;
155 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::AND, "test", values);
156 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::OR, "test", values);
161 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::IN, "test", values);
[all …]
H A Drdb_asset_loader_test.cpp28 using namespace OHOS::DistributedRdb;
86 DistributedRdb::RdbAssetLoader rdbAssetLoader(cloudAssetLoader, &bindAssets);
107 DistributedRdb::RdbAssetLoader rdbAssetLoader(cloudAssetLoader, &bindAssets);
126 DistributedRdb::RdbAssetLoader rdbAssetLoader(assetLoader, &bindAssets);
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dabs_rdb_predicates.cpp193 predicates_.AddOperation(DistributedRdb::AND, "", ""); in And()
199 predicates_.AddOperation(DistributedRdb::OR, "", ""); in Or()
219 predicates_.AddOperation(DistributedRdb::BEGIN_GROUP, {}, ""); in BeginWrap()
225 predicates_.AddOperation(DistributedRdb::END_GROUP, {}, ""); in EndWrap()
240 predicates_.AddOperation(DistributedRdb::IN, field, vals); in In()
246 predicates_.AddOperation(DistributedRdb::IN, field, values); in In()
274 predicates_.AddOperation(DistributedRdb::IS_NULL, field, ""); in IsNull()
284 predicates_.AddOperation(DistributedRdb::LIKE, field, value); in Like()
294 predicates_.AddOperation(DistributedRdb::GLOB, field, value); in Glob()
299 predicates_.AddOperation(DistributedRdb::DISTINCT, "", ""); in Distinct()
[all …]
H A Ddelay_notify.cpp33 DistributedRdb::RdbNotifyConfig rdbNotifyConfig; in ~DelayNotify()
43 void DelayNotify::UpdateNotify(const DistributedRdb::RdbChangedData &changedData, bool isFull) in UpdateNotify()
77 DistributedRdb::RdbChangedData changedData; in StartTimer()
115 DistributedRdb::RdbNotifyConfig rdbNotifyConfig; in StartTimer()
133 DistributedRdb::RdbChangedData changedData; in ExecuteTask()
145 DistributedRdb::RdbNotifyConfig rdbNotifyConfig; in ExecuteTask()
H A Drdb_store_manager.cpp169 DistributedRdb::RdbSyncerParam RdbStoreManager::GetSyncParam(const RdbStoreConfig &config) in GetSyncParam()
171 DistributedRdb::RdbSyncerParam syncerParam; in GetSyncParam()
186 int32_t RdbStoreManager::GetParamFromService(DistributedRdb::RdbSyncerParam &param) in GetParamFromService()
189 auto [err, service] = DistributedRdb::RdbManagerImpl::GetInstance().GetRdbService(param); in GetParamFromService()
198 if (err != DistributedRdb::RDB_OK && err != DistributedRdb::RDB_NO_META) { in GetParamFromService()
276 DistributedRdb::RdbSyncerParam param; in Delete()
279 auto [err, service] = DistributedRdb::RdbManagerImpl::GetInstance().GetRdbService(param); in Delete()
308 auto [err, service] = DistributedRdb::RdbManagerImpl::GetInstance().GetRdbService(param); in Collector()
H A Drdb_manager_impl.cpp29 namespace OHOS::DistributedRdb { namespace
31 using RdbServiceProxy = DistributedRdb::RdbServiceProxy;
33 using namespace OHOS::DistributedRdb::RelationalStore;
112 … auto remote = distributedDataMgr_->GetFeatureInterface(DistributedRdb::RdbService::SERVICE_NAME); in GetRdbService()
152 auto [errCode, service] = DistributedRdb::RdbManagerImpl::GetInstance().GetRdbService(param_); in OnRemoteDied()
171 : IRemoteProxy<DistributedRdb::IKvStoreDataService>(impl) in RdbStoreDataServiceProxy()
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Drdb_types_util.h27 using SubOption = DistributedRdb::SubscribeOption;
28 using SyncerParam = DistributedRdb::RdbSyncerParam;
29 using NotifyConfig = DistributedRdb::RdbNotifyConfig;
30 using Option = DistributedRdb::RdbService::Option;
31 using RdbPredicates = DistributedRdb::PredicatesMemo;
37 using TableDetail = DistributedRdb::TableDetail;
38 using Statistic = DistributedRdb::Statistic;
39 using Observer = DistributedRdb::RdbStoreObserver;
40 using Origin = DistributedRdb::Origin;
46 using Reference = DistributedRdb::Reference;
[all …]
H A Ddelay_notify.h29 …using Task = std::function<int(const DistributedRdb::RdbChangedData &, const DistributedRdb::RdbNo…
35 void UpdateNotify(const DistributedRdb::RdbChangedData &changedData, bool isFull = false);
51 DistributedRdb::RdbChangedData changedData_;
H A Drdb_store_impl.h47 …explicit RdbStoreLocalObserver(DistributedRdb::RdbStoreObserver *observer) : observer_(observer){}; in RdbStoreLocalObserver()
53 DistributedRdb::RdbStoreObserver *getObserver() in getObserver()
59 DistributedRdb::RdbStoreObserver *observer_ = nullptr;
64 …explicit RdbStoreLocalSharedObserver(DistributedRdb::RdbStoreObserver *observer) : observer_(obser… in RdbStoreLocalSharedObserver()
70 DistributedRdb::RdbStoreObserver *getObserver() in getObserver()
76 DistributedRdb::RdbStoreObserver *observer_ = nullptr;
120 const DistributedRdb::DistributedConfig &distributedConfig) override;
160 using RdbParam = DistributedRdb::RdbSyncerParam;
161 using Options = DistributedRdb::RdbService::Option;
162 using Memo = DistributedRdb::PredicatesMemo;
[all …]
H A Drdb_store_manager.h45 using Param = DistributedRdb::RdbSyncerParam;
46 using Info = DistributedRdb::RdbDebugInfo;
50 int32_t GetParamFromService(DistributedRdb::RdbSyncerParam &param);
/ohos5.0/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/
H A Drelational_store_impl.h28 class NDKDetailProgressObserver : public DistributedRdb::DetailProgressObserver {
31 void ProgressNotification(const DistributedRdb::Details &details);
38 class NDKStoreObserver : public OHOS::DistributedRdb::RdbStoreObserver {
40 using Origin = DistributedRdb::Origin;
41 using RdbStoreObserver = OHOS::DistributedRdb::RdbStoreObserver;
48 void OnChange(const OHOS::DistributedRdb::Origin &origin, const PrimaryFields &fields,
85 static OHOS::DistributedRdb::SyncMode TransformMode(Rdb_SyncMode &mode);
86 static OHOS::DistributedRdb::SubscribeMode GetSubscribeType(Rdb_SubscribeType &type);
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/src/
H A Dnapi_rdb_const_properties.cpp24 using OHOS::DistributedRdb::SyncMode;
25 using OHOS::DistributedRdb::SubscribeMode;
30 using OHOS::DistributedRdb::ProgressCode;
31 using OHOS::DistributedRdb::DistributedTableType;
85 SET_NAPI_PROPERTY(progress, "SYNC_BEGIN", int32_t(DistributedRdb::Progress::SYNC_BEGIN)); in ExportProgress()
87 SET_NAPI_PROPERTY(progress, "SYNC_FINISH", int32_t(DistributedRdb::Progress::SYNC_FINISH)); in ExportProgress()
126 SET_NAPI_PROPERTY(field, "CURSOR_FIELD", std::string(DistributedRdb::Field::CURSOR_FIELD)); in ExportField()
127 SET_NAPI_PROPERTY(field, "ORIGIN_FIELD", std::string(DistributedRdb::Field::ORIGIN_FIELD)); in ExportField()
130 SET_NAPI_PROPERTY(field, "OWNER_FIELD", std::string(DistributedRdb::Field::OWNER_FIELD)); in ExportField()
153 SET_NAPI_PROPERTY(changeType, "DATA_CHANGE", int32_t(DistributedRdb::Origin::BASIC_DATA)); in ExportChangeType()
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/include/
H A Dnapi_rdb_js_utils.h37 using Date = OHOS::DistributedRdb::Date;
39 using PRIKey = OHOS::DistributedRdb::RdbStoreObserver::PrimaryKey;
44 using SqlExecInfo = DistributedRdb::SqlObserver::SqlExecutionInfo;
86 int32_t Convert2Value(napi_env env, napi_value jsValue, DistributedRdb::Reference &output);
89 int32_t Convert2Value(napi_env env, napi_value jsValue, DistributedRdb::DistributedConfig &output);
116 napi_value Convert2JSValue(napi_env env, const DistributedRdb::Statistic &value);
118 napi_value Convert2JSValue(napi_env env, const DistributedRdb::TableDetail &value);
121 napi_value Convert2JSValue(napi_env env, const DistributedRdb::ProgressDetail &value);
123 napi_value Convert2JSValue(napi_env env, const DistributedRdb::Details &details);
H A Dnapi_rdb_store_observer.h25 class NapiRdbStoreObserver : public DistributedRdb::RdbStoreObserver,
28 using Origin = DistributedRdb::Origin;
38 int32_t mode = DistributedRdb::REMOTE);
52 int32_t mode_ = DistributedRdb::REMOTE;
H A Dnapi_rdb_context.h66 DistributedRdb::DistributedConfig distributedConfig;
69 DistributedRdb::SyncResult syncResult;
78 distributedType(DistributedRdb::DistributedTableType::DISTRIBUTED_DEVICE), in RdbStoreContext()
79 … syncMode(DistributedRdb::SyncMode::PUSH), conflictResolution(ConflictResolution::ON_CONFLICT_NONE) in RdbStoreContext()
H A Dnapi_rdb_store.h104 …napi_value OnLocal(napi_env env, const DistributedRdb::SubscribeOption &option, napi_value callbac…
105 napi_value RegisteredObserver(napi_env env, const DistributedRdb::SubscribeOption &option,
109 …napi_value OffLocal(napi_env env, const DistributedRdb::SubscribeOption &option, napi_value callba…
110 napi_value UnRegisteredObserver(napi_env env, const DistributedRdb::SubscribeOption &option,
114 …: public DistributedRdb::DetailProgressObserver, public std::enable_shared_from_this<SyncObserver>…
120 void ProgressNotification(const DistributedRdb::Details &details) override;
129 …: public DistributedRdb::SqlObserver, public std::enable_shared_from_this<NapiStatisticsObserver> {
167 std::list<std::shared_ptr<NapiRdbStoreObserver>> observers_[DistributedRdb::SUBSCRIBE_MODE_MAX];
/ohos5.0/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/
H A Drdb_store.h42 using SyncOption = DistributedRdb::SyncOption;
47 using Briefs = DistributedRdb::Briefs;
48 using AsyncBrief = DistributedRdb::AsyncBrief;
53 using Details = DistributedRdb::Details;
54 using AsyncDetail = DistributedRdb::AsyncDetail;
59 using SubscribeMode = DistributedRdb::SubscribeMode;
64 using SubscribeOption = DistributedRdb::SubscribeOption;
69 using DropOption = DistributedRdb::DropOption;
74 using RdbStoreObserver = DistributedRdb::RdbStoreObserver;
80 using DetailProgressObserver = DistributedRdb::DetailProgressObserver;
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/cj/src/
H A Drelational_store_impl_rdbstore.cpp143 DistributedRdb::DistributedConfig &distributedConfig) in SetDistributedTables()
229 DistributedRdb::SyncOption option; in Sync()
230 option.mode = static_cast<DistributedRdb::SyncMode>(mode); in Sync()
232 DistributedRdb::SyncResult resMap; in Sync()
274 DistributedRdb::SubscribeOption option; in RegisterObserver()
277 DistributedRdb::SubscribeMode::LOCAL; in RegisterObserver()
314 DistributedRdb::SubscribeOption option, in RegisteredObserver()
341 DistributedRdb::SubscribeOption option; in UnRegisterObserver()
344 DistributedRdb::SubscribeMode::LOCAL; in UnRegisterObserver()
380 DistributedRdb::SubscribeOption option; in UnRegisterAllObserver()
[all …]
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dmake_query_event.h23 namespace DistributedRdb {
30 MakeQueryEvent(StoreInfo storeInfo, std::shared_ptr<DistributedRdb::PredicatesMemo> predicates,
33 std::shared_ptr<DistributedRdb::PredicatesMemo> GetPredicates() const;
38 std::shared_ptr<DistributedRdb::PredicatesMemo> predicates_;
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/cj/include/
H A Drelational_store_impl_rdbstore.h33 class RdbStoreObserverImpl : public OHOS::DistributedRdb::RdbStoreObserver {
42 void OnChange(const DistributedRdb::Origin &origin, const PrimaryFields &fields, in OnChange()
69 DistributedRdb::DistributedConfig &distributedConfig);
88 int32_t RegisteredObserver(DistributedRdb::SubscribeOption option, std::map<std::string,
95 int32_t UnRegisteredObserver(DistributedRdb::SubscribeOption option, std::map<std::string,
98 … int32_t UnRegisteredAllObserver(DistributedRdb::SubscribeOption option, std::map<std::string,
/ohos5.0/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_distributed_test.cpp213 OHOS::DistributedRdb::DistributedConfig distributedConfig;
245 OHOS::DistributedRdb::SyncOption option = { OHOS::DistributedRdb::TIME_FIRST, false };
250 errCode = rdbStore->Sync(option, predicate, OHOS::DistributedRdb::AsyncBrief());
253 errCode = rdbStore->Sync(option, tables, OHOS::DistributedRdb::AsyncDetail());
256 errCode = rdbStore->Sync(option, predicate, OHOS::DistributedRdb::AsyncDetail());
266 errCode = store->Sync(option, predicate, OHOS::DistributedRdb::AsyncBrief());
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/
H A Drdb_store_manager.h45 using Param = DistributedRdb::RdbSyncerParam;
46 using Info = DistributedRdb::RdbDebugInfo;
50 int32_t GetParamFromService(DistributedRdb::RdbSyncerParam &param);
/ohos5.0/foundation/multimedia/media_library/frameworks/services/media_distributed/src/database_manage/
H A Dmedialibrary_sync_operation.cpp261 DistributedRdb::SyncOption option; in SyncPullTable()
262 option.mode = DistributedRdb::SyncMode::PULL; in SyncPullTable()
281 … DistributedRdb::SyncCallback callback = [syncOpts](const DistributedRdb::SyncResult &syncResult) { in SyncPullTable()
372 DistributedRdb::SyncOption option; in SyncPushTable()
373 option.mode = DistributedRdb::SyncMode::PUSH; in SyncPushTable()
391 … DistributedRdb::SyncCallback callback = [syncOpts](const DistributedRdb::SyncResult& syncResult) { in SyncPushTable()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dmake_query_event.cpp20 …std::shared_ptr<DistributedRdb::PredicatesMemo> predicates, const std::vector<std::string>& column… in MakeQueryEvent()
26 std::shared_ptr<DistributedRdb::PredicatesMemo> MakeQueryEvent::GetPredicates() const in GetPredicates()
/ohos5.0/foundation/distributeddatamgr/relational_store/test/native/rdb/distributedtest/rdb_store_impl_test/
H A Ddistributed_test_agent.cpp34 using namespace OHOS::DistributedRdb;
52 using SyncOption = DistributedRdb::SyncOption;
53 using SyncCallback = DistributedRdb::AsyncBrief;

123456