| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | schema_mgr.cpp | 152 DataBaseSchema cloudSchema = schema; in SetCloudDbSchema() local
153 for (TableSchema &table : cloudSchema.tables) { in SetCloudDbSchema()
173 SetCloudDbSchema(cloudSchema); in SetCloudDbSchema()
178 DataBaseSchema cloudSchema = schema; in SetCloudDbSchema() local
180 for (const auto &tableSchema : cloudSchema.tables) { in SetCloudDbSchema()
194 cloudSchema.tables.push_back(sharedTableSchema); in SetCloudDbSchema()
196 cloudSchema_ = std::make_shared<DataBaseSchema>(cloudSchema); in SetCloudDbSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_relational_storage_engine.h | 58 …int UpgradeSharedTable(const DataBaseSchema &cloudSchema, const std::vector<std::string> &deleteTa…
100 const DataBaseSchema &cloudSchema, const std::vector<std::string> &deleteTableNames,
108 …nst std::map<std::string, std::vector<Field>> &updateTableNames, const DataBaseSchema &cloudSchema,
115 …const DataBaseSchema &cloudSchema, const std::map<std::string, std::vector<Field>> &updateTableNam…
121 …xistUserTable(SQLiteSingleVerRelationalStorageExecutor *&handle, const DataBaseSchema &cloudSchema,
|
| H A D | sqlite_single_relational_storage_engine.cpp | 709 int SQLiteSingleRelationalStorageEngine::UpgradeSharedTable(const DataBaseSchema &cloudSchema, in UpgradeSharedTable() argument
741 const DataBaseSchema &cloudSchema, const std::vector<std::string> &deleteTableNames, in UpgradeSharedTableInner() argument
751 errCode = DoUpdateSharedTable(handle, updateTableNames, cloudSchema, schema); in UpgradeSharedTableInner()
756 errCode = CheckIfExistUserTable(handle, cloudSchema, alterTableNames, schema); in UpgradeSharedTableInner()
766 errCode = DoCreateSharedTable(handle, cloudSchema, updateTableNames, alterTableNames, schema); in UpgradeSharedTableInner()
810 …nst std::map<std::string, std::vector<Field>> &updateTableNames, const DataBaseSchema &cloudSchema, in DoUpdateSharedTable() argument
821 for (const auto &tableSchema : cloudSchema.tables) { in DoUpdateSharedTable()
875 …const DataBaseSchema &cloudSchema, const std::map<std::string, std::vector<Field>> &updateTableNam… in DoCreateSharedTable() argument
878 for (auto const &tableSchema : cloudSchema.tables) { in DoCreateSharedTable()
939 const DataBaseSchema &cloudSchema, const std::map<std::string, std::string> &alterTableNames, in CheckIfExistUserTable() argument
[all …]
|
| H A D | sqlite_relational_store.cpp | 1571 std::shared_ptr<DataBaseSchema> cloudSchema; in CheckCloudSchema() local
1572 (void) storageEngine_->GetCloudDbSchema(cloudSchema); in CheckCloudSchema()
1585 if (cloudSchema == nullptr) { in CheckCloudSchema()
1588 for (const auto &oldSchema : cloudSchema->tables) { in CheckCloudSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_cloud_kv_store.cpp | 62 int SqliteCloudKvStore::GetCloudDbSchema(std::shared_ptr<DataBaseSchema> &cloudSchema) in GetCloudDbSchema() argument
65 cloudSchema = std::make_shared<DataBaseSchema>(schema_[user_]); in GetCloudDbSchema()
581 std::shared_ptr<DataBaseSchema> cloudSchema; in GetCompensatedSyncQuery() local
582 (void)GetCloudDbSchema(cloudSchema); in GetCompensatedSyncQuery()
583 if (cloudSchema == nullptr) { in GetCompensatedSyncQuery()
586 if (cloudSchema->tables.empty()) { in GetCompensatedSyncQuery()
595 for (const auto &table: cloudSchema->tables) { in GetCompensatedSyncQuery()
|
| H A D | sqlite_cloud_kv_store.h | 36 int GetCloudDbSchema(std::shared_ptr<DataBaseSchema> &cloudSchema) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer_extend.cpp | 747 std::shared_ptr<DataBaseSchema> cloudSchema; in TryToAddSyncTask() local
748 int errCode = storageProxy_->GetCloudDbSchema(cloudSchema); in TryToAddSyncTask()
770 if (!MergeTaskInfo(cloudSchema, taskId)) { in TryToAddSyncTask()
778 bool CloudSyncer::MergeTaskInfo(const std::shared_ptr<DataBaseSchema> &cloudSchema, TaskId taskId) in MergeTaskInfo() argument
787 std::tie(isMerge, checkTaskId) = TryMergeTask(cloudSchema, checkTaskId); in MergeTaskInfo()
793 …skId> CloudSyncer::TryMergeTask(const std::shared_ptr<DataBaseSchema> &cloudSchema, TaskId tryTask… in TryMergeTask() argument
825 AdjustTableBasedOnSchema(cloudSchema, cloudTaskInfos_[nextTryTask]); in TryMergeTask()
867 void CloudSyncer::AdjustTableBasedOnSchema(const std::shared_ptr<DataBaseSchema> &cloudSchema, in AdjustTableBasedOnSchema() argument
873 for (const auto &table : cloudSchema->tables) { in AdjustTableBasedOnSchema()
|
| H A D | cloud_syncer.h | 393 bool MergeTaskInfo(const std::shared_ptr<DataBaseSchema> &cloudSchema, TaskId taskId);
395 …std::pair<bool, TaskId> TryMergeTask(const std::shared_ptr<DataBaseSchema> &cloudSchema, TaskId tr…
403 …void AdjustTableBasedOnSchema(const std::shared_ptr<DataBaseSchema> &cloudSchema, CloudTaskInfo &t…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_delegate_impl.cpp | 249 DataBaseSchema cloudSchema = schema; in SetCloudDbSchema() local
250 if (!ParamCheckUtils::CheckSharedTableName(cloudSchema)) { in SetCloudDbSchema()
258 int errorCode = conn_->PrepareAndSetCloudDbSchema(cloudSchema); in SetCloudDbSchema()
|
| H A D | relational_sync_able_storage.h | 165 int GetCloudDbSchema(std::shared_ptr<DataBaseSchema> &cloudSchema) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1297 int RelationalSyncAbleStorage::GetCloudDbSchema(std::shared_ptr<DataBaseSchema> &cloudSchema) in GetCloudDbSchema() argument
1300 cloudSchema = schemaMgr_.GetCloudDbSchema(); in GetCloudDbSchema()
1662 std::shared_ptr<DataBaseSchema> cloudSchema; in GetSourceTableName() local
1663 (void) GetCloudDbSchema(cloudSchema); in GetSourceTableName()
1664 if (cloudSchema == nullptr) { in GetSourceTableName()
1668 for (const auto &table : cloudSchema->tables) { in GetSourceTableName()
1688 std::shared_ptr<DataBaseSchema> cloudSchema; in GetSharedTargetTableName() local
1689 (void) GetCloudDbSchema(cloudSchema); in GetSharedTargetTableName()
1690 if (cloudSchema == nullptr) { in GetSharedTargetTableName()
1694 for (const auto &table : cloudSchema->tables) { in GetSharedTargetTableName()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_meta_data_test.cpp | 292 std::shared_ptr<DataBaseSchema> cloudSchema; variable
293 EXPECT_EQ(proxyObj.GetCloudDbSchema(cloudSchema), -E_INVALID_DB);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | storage_proxy.h | 146 int GetCloudDbSchema(std::shared_ptr<DataBaseSchema> &cloudSchema);
|
| H A D | icloud_sync_storage_interface.h | 102 virtual int GetCloudDbSchema(std::shared_ptr<DataBaseSchema> &cloudSchema) = 0;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_proxy.cpp | 640 int StorageProxy::GetCloudDbSchema(std::shared_ptr<DataBaseSchema> &cloudSchema) in GetCloudDbSchema() argument
646 return store_->GetCloudDbSchema(cloudSchema); in GetCloudDbSchema()
|