Home
last modified time | relevance | path

Searched refs:DistributedRdb (Results 1 - 25 of 125) sorted by relevance

12345

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Drdb_query_test.cpp26 using namespace OHOS::DistributedRdb;
60 DistributedRdb::PredicatesMemo predicates; in HWTEST_F()
82 DistributedRdb::PredicatesMemo predicates; in HWTEST_F()
86 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::EQUAL_TO, "name", "John Doe"); in HWTEST_F()
87 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::GREATER_THAN, "age", "30"); in HWTEST_F()
88 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::OPERATOR_MAX, "too", "99"); in HWTEST_F()
110 DistributedRdb::PredicatesMemo predicates; in HWTEST_F()
115 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::EQUAL_TO, "test", values); in HWTEST_F()
116 predicates.AddOperation(DistributedRdb::RdbPredicateOperator::NOT_EQUAL_TO, "test", values); in HWTEST_F()
117 predicates.AddOperation(DistributedRdb in HWTEST_F()
[all...]
H A Drdb_asset_loader_test.cpp29 using namespace OHOS::DistributedRdb;
85 DistributedRdb::RdbAssetLoader rdbAssetLoader(cloudAssetLoader, &bindAssets); in HWTEST_F()
106 DistributedRdb::RdbAssetLoader rdbAssetLoader(cloudAssetLoader, &bindAssets); in HWTEST_F()
125 DistributedRdb::RdbAssetLoader rdbAssetLoader(assetLoader, &bindAssets); in HWTEST_F()
/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;
32 using RdbOperation = DistributedRdb::RdbPredicateOperation;
36 using ProgressDetail = DistributedRdb::ProgressDetail;
37 using TableDetail = DistributedRdb::TableDetail;
38 using Statistic = DistributedRdb::Statistic;
39 using Observer = DistributedRdb
[all...]
H A Ddelay_notify.h29 using Task = std::function<int(const DistributedRdb::RdbChangedData &, const DistributedRdb::RdbNotifyConfig &)>;
35 void UpdateNotify(const DistributedRdb::RdbChangedData &changedData, bool isFull = false);
51 DistributedRdb::RdbChangedData changedData_;
H A Drdb_store_manager.h45 using Param = DistributedRdb::RdbSyncerParam;
46 using Info = DistributedRdb::RdbDebugInfo;
50 int32_t GetParamFromService(DistributedRdb::RdbSyncerParam &param);
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_(observer){}; in RdbStoreLocalSharedObserver()
70 DistributedRdb::RdbStoreObserver *getObserver() in getObserver()
76 DistributedRdb::RdbStoreObserver *observer_ = nullptr;
120 const DistributedRdb::DistributedConfig &distributedConfig) override;
160 using RdbParam = DistributedRdb::RdbSyncerParam;
173 int InnerSync(const DistributedRdb::RdbService::Option &option, const DistributedRdb
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dabs_rdb_predicates.cpp165 const DistributedRdb::PredicatesMemo& AbsRdbPredicates::GetDistributedPredicates() const in GetDistributedPredicates()
169 predicates_.AddOperation(DistributedRdb::RdbPredicateOperator::LIMIT, in GetDistributedPredicates()
178 predicates_.AddOperation(DistributedRdb::EQUAL_TO, field, *pval); in EqualTo()
186 predicates_.AddOperation(DistributedRdb::NOT_EQUAL_TO, field, *pval); in NotEqualTo()
193 predicates_.AddOperation(DistributedRdb::AND, "", ""); in And()
199 predicates_.AddOperation(DistributedRdb::OR, "", ""); in Or()
206 predicates_.AddOperation(DistributedRdb::ORDER_BY, field, isAsc); in OrderByAsc()
213 predicates_.AddOperation(DistributedRdb::ORDER_BY, field, isAsc); in OrderByDesc()
219 predicates_.AddOperation(DistributedRdb::BEGIN_GROUP, {}, ""); in BeginWrap()
225 predicates_.AddOperation(DistributedRdb in EndWrap()
[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()
144 DistributedRdb::RdbNotifyConfig rdbNotifyConfig; in ExecuteTask()
H A Drdb_store_manager.cpp163 DistributedRdb::RdbSyncerParam RdbStoreManager::GetSyncParam(const RdbStoreConfig &config) in GetSyncParam()
165 DistributedRdb::RdbSyncerParam syncerParam; in GetSyncParam()
180 int32_t RdbStoreManager::GetParamFromService(DistributedRdb::RdbSyncerParam &param) in GetParamFromService()
183 auto [err, service] = DistributedRdb::RdbManagerImpl::GetInstance().GetRdbService(param); in GetParamFromService()
192 if (err != DistributedRdb::RDB_OK && err != DistributedRdb::RDB_NO_META) { in GetParamFromService()
270 DistributedRdb::RdbSyncerParam param; in Delete()
273 auto [err, service] = DistributedRdb::RdbManagerImpl::GetInstance().GetRdbService(param); in Delete()
302 auto [err, service] = DistributedRdb::RdbManagerImpl::GetInstance().GetRdbService(param); in Collector()
H A Drdb_manager_impl.cpp29 namespace OHOS::DistributedRdb { namespace in OHOS
31 using RdbServiceProxy = DistributedRdb::RdbServiceProxy;
33 using namespace OHOS::DistributedRdb::RelationalStore;
37 DECLARE_INTERFACE_DESCRIPTOR(u"OHOS.DistributedRdb.DeathStub");
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()
232 } // namespace OHOS::DistributedRdb
/foundation/distributeddatamgr/relational_store/frameworks/cj/include/
H A Drelational_store_impl_rdbstore.h33 class RdbStoreObserverImpl : public DistributedRdb::RdbStoreObserver {
41 RdbStoreObserverImpl(int64_t id, FuncType type, int32_t mode = DistributedRdb::REMOTE);
51 void OnChange(const DistributedRdb::Origin &origin, const PrimaryFields &fields,
52 DistributedRdb::RdbStoreObserver::ChangeInfo &&changeInfo) override
54 if (mode_ != DistributedRdb::CLOUD_DETAIL && mode_ != DistributedRdb::LOCAL_DETAIL) {
69 int32_t mode_ = DistributedRdb::REMOTE;
74 std::function<void(const DistributedRdb::Origin &origin, const PrimaryFields &fields,
75 DistributedRdb::RdbStoreObserver::ChangeInfo &&changeInfo)> changeInfoFunc;
78 class SyncObserverImpl : public DistributedRdb
[all...]
H A Drelational_store_utils.h142 CArrPRIKeyType VectorToCArrPRIKeyType(std::vector<DistributedRdb::RdbStoreObserver::PrimaryKey> arr);
144 RetChangeInfo ToRetChangeInfo(const DistributedRdb::Origin &origin,
145 DistributedRdb::RdbStoreObserver::ChangeInfo::iterator info);
147 CArrRetChangeInfo ToCArrRetChangeInfo(const DistributedRdb::Origin &origin,
148 const DistributedRdb::RdbStoreObserver::PrimaryFields &fields,
149 DistributedRdb::RdbStoreObserver::ChangeInfo &&changeInfo);
158 CStatistic ToStatistic(DistributedRdb::Statistic statistic);
165 CTableDetails ToCTableDetails(DistributedRdb::TableDetail detail);
173 CDetails ToCDetails(DistributedRdb::TableDetails details);
181 CProgressDetails ToCProgressDetails(const DistributedRdb
[all...]
/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);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dmake_query_event.h23 namespace DistributedRdb { namespace
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_;
/foundation/distributeddatamgr/relational_store/frameworks/js/napi/relationalstore/include/
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_js_utils.h37 using Date = OHOS::DistributedRdb::Date;
39 using PRIKey = OHOS::DistributedRdb::RdbStoreObserver::PrimaryKey;
44 using SqlExecInfo = DistributedRdb::SqlObserver::SqlExecutionInfo;
82 int32_t Convert2Value(napi_env env, napi_value jsValue, DistributedRdb::Reference &output);
85 int32_t Convert2Value(napi_env env, napi_value jsValue, DistributedRdb::DistributedConfig &output);
109 napi_value Convert2JSValue(napi_env env, const DistributedRdb::Statistic &value);
111 napi_value Convert2JSValue(napi_env env, const DistributedRdb::TableDetail &value);
114 napi_value Convert2JSValue(napi_env env, const DistributedRdb::ProgressDetail &value);
116 napi_value Convert2JSValue(napi_env env, const DistributedRdb::Details &details);
H A Dnapi_rdb_context.h65 DistributedRdb::DistributedConfig distributedConfig;
68 DistributedRdb::SyncResult syncResult;
77 distributedType(DistributedRdb::DistributedTableType::DISTRIBUTED_DEVICE), in RdbStoreContext()
78 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 callback);
105 napi_value RegisteredObserver(napi_env env, const DistributedRdb::SubscribeOption &option,
109 napi_value OffLocal(napi_env env, const DistributedRdb::SubscribeOption &option, napi_value callback);
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];
/foundation/distributeddatamgr/relational_store/frameworks/cj/src/
H A Drelational_store_impl_rdbstore.cpp65 changeInfoFunc = [ lambda = CJLambda::Create(cFunc)](const DistributedRdb::Origin &origin, in RdbStoreObserverImpl()
66 const PrimaryFields &fields, DistributedRdb::RdbStoreObserver::ChangeInfo &&changeInfo) -> in RdbStoreObserverImpl()
77 func = [ lambda = CJLambda::Create(cFunc)](const DistributedRdb::Details &details) -> in SyncObserverImpl()
166 return rdbStore_->SetDistributedTables(tablesVector, DistributedRdb::DISTRIBUTED_DEVICE, in SetDistributedTables()
167 DistributedRdb::DistributedConfig{false}); in SetDistributedTables()
176 return rdbStore_->SetDistributedTables(tablesVector, type, DistributedRdb::DistributedConfig{false}); in SetDistributedTables()
180 DistributedRdb::DistributedConfig &distributedConfig) in SetDistributedTables()
266 DistributedRdb::SyncOption option; in Sync()
267 option.mode = static_cast<DistributedRdb::SyncMode>(mode); in Sync()
269 DistributedRdb in Sync()
[all...]
H A Drelational_store_utils.cpp302 CArrPRIKeyType VectorToCArrPRIKeyType(std::vector<DistributedRdb::RdbStoreObserver::PrimaryKey> arr) in VectorToCArrPRIKeyType()
319 RetChangeInfo ToRetChangeInfo(const DistributedRdb::Origin &origin, in ToRetChangeInfo()
320 DistributedRdb::RdbStoreObserver::ChangeInfo::iterator info) in ToRetChangeInfo()
326 second[DistributedRdb::RdbStoreObserver::ChangeType::CHG_TYPE_INSERT]); in ToRetChangeInfo()
328 second[DistributedRdb::RdbStoreObserver::ChangeType::CHG_TYPE_UPDATE]); in ToRetChangeInfo()
330 second[DistributedRdb::RdbStoreObserver::ChangeType::CHG_TYPE_DELETE]); in ToRetChangeInfo()
334 CArrRetChangeInfo ToCArrRetChangeInfo(const DistributedRdb::Origin &origin, in ToCArrRetChangeInfo()
335 const DistributedRdb::RdbStoreObserver::PrimaryFields &fields, in ToCArrRetChangeInfo()
336 DistributedRdb::RdbStoreObserver::ChangeInfo &&changeInfo) in ToCArrRetChangeInfo()
355 CStatistic ToStatistic(DistributedRdb
[all...]
/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()
86 SET_NAPI_PROPERTY(progress, "SYNC_IN_PROGRESS", int32_t(DistributedRdb::Progress::SYNC_IN_PROGRESS)); 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()
128 SET_NAPI_PROPERTY(field, "DELETED_FLAG_FIELD", std::string(DistributedRdb in ExportField()
[all...]
/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/
H A Drdb_store.h40 * @brief Use SyncOption replace DistributedRdb::SyncOption namespace.
42 using SyncOption = DistributedRdb::SyncOption;
45 * @brief Use AsyncBrief replace DistributedRdb::AsyncBrief namespace.
47 using Briefs = DistributedRdb::Briefs;
48 using AsyncBrief = DistributedRdb::AsyncBrief;
51 * @brief Use AsyncBrief replace DistributedRdb::AsyncBrief namespace.
53 using Details = DistributedRdb::Details;
54 using AsyncDetail = DistributedRdb::AsyncDetail;
57 * @brief Use SubscribeMode replace DistributedRdb::SubscribeMode namespace.
59 using SubscribeMode = DistributedRdb
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dmake_query_event.cpp19 MakeQueryEvent::MakeQueryEvent(StoreInfo storeInfo, std::shared_ptr<DistributedRdb::PredicatesMemo> predicates, in MakeQueryEvent()
26 std::shared_ptr<DistributedRdb::PredicatesMemo> MakeQueryEvent::GetPredicates() const in GetPredicates()
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_distributed_test.cpp213 OHOS::DistributedRdb::DistributedConfig distributedConfig; in HWTEST_F()
246 OHOS::DistributedRdb::SyncOption option = { OHOS::DistributedRdb::TIME_FIRST, false }; in HWTEST_F()
251 errCode = rdbStore->Sync(option, predicate, OHOS::DistributedRdb::AsyncBrief()); in HWTEST_F()
254 errCode = rdbStore->Sync(option, tables, OHOS::DistributedRdb::AsyncDetail()); 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/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_watcher.cpp24 namespace OHOS::DistributedRdb { namespace in OHOS
35 DistributedRdb::Origin rdbOrigin; in OnChange()
67 } // namespace OHOS::DistributedRdb

Completed in 15 milliseconds

12345