| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_cloud_schema_mgr_test.cpp | 283 RelationalSchemaObject localSchema; variable
308 RelationalSchemaObject localSchema; variable
338 RelationalSchemaObject localSchema; variable
365 RelationalSchemaObject localSchema; variable
393 RelationalSchemaObject localSchema; variable
421 RelationalSchemaObject localSchema; variable
448 RelationalSchemaObject localSchema; variable
480 RelationalSchemaObject localSchema; variable
508 RelationalSchemaObject localSchema; variable
533 RelationalSchemaObject localSchema; variable
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | schema_negotiate.cpp | 64 errCode = localSchema.CompareAgainstSchemaObject(remoteSchemaObj); in MakeLocalSyncOpinion()
69 errCode = remoteSchemaObj.CompareAgainstSchemaObject(localSchema); in MakeLocalSyncOpinion()
102 for (const auto &it : localSchema.GetTables()) { in MakeOpinionEachTable()
129 SchemaType localType = localSchema.GetSchemaType(); in MakeLocalSyncOpinion()
142 if (!localSchema.IsSchemaValid()) { in MakeLocalSyncOpinion()
155 if (localSchema.GetSchemaVersion() != remoteSchemaObj.GetSchemaVersion()) { in MakeLocalSyncOpinion()
157 localSchema.GetSchemaVersion().c_str(), remoteSchemaObj.GetSchemaVersion().c_str()); in MakeLocalSyncOpinion()
161 if (localSchema.GetSchemaVersion() == SchemaConstant::SCHEMA_SUPPORT_VERSION_V2_1 && in MakeLocalSyncOpinion()
162 localSchema.GetTableMode() != remoteSchemaObj.GetTableMode()) { in MakeLocalSyncOpinion()
164 localSchema.GetTableMode(), remoteSchemaObj.GetTableMode()); in MakeLocalSyncOpinion()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/ |
| H A D | schema_negotiate.h | 42 …static SyncOpinion MakeLocalSyncOpinion(const SchemaObject &localSchema, const std::string &remote…
48 static RelationalSyncOpinion MakeLocalSyncOpinion(const RelationalSchemaObject &localSchema,
62 static RelationalSyncOpinion MakeOpinionEachTable(const RelationalSchemaObject &localSchema,
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_natural_store_extend.cpp | 332 const SchemaObject &localSchema = MyProp().GetSchemaConstRef(); in CheckAndInitQueryCondition() local
333 …if (localSchema.GetSchemaType() != SchemaType::NONE && localSchema.GetSchemaType() != SchemaType::… in CheckAndInitQueryCondition()
337 query.SetSchema(localSchema); in CheckAndInitQueryCondition()
396 const SchemaObject &localSchema = MyProp().GetSchemaConstRef(); in AddSubscribe() local
398 queryInner.SetSchema(localSchema); in AddSubscribe()
453 const SchemaObject &localSchema = MyProp().GetSchemaConstRef(); in IsSupportSubscribe() local
454 …if (localSchema.GetSchemaType() != SchemaType::NONE && localSchema.GetSchemaType() != SchemaType::… in IsSupportSubscribe()
|
| H A D | sqlite_single_ver_natural_store.cpp | 1570 const SchemaObject &localSchema = MyProp().GetSchemaConstRef(); in CheckCompatible() local
1571 … if (!localSchema.IsSchemaValid() || schema.empty() || ReadSchemaType(type) == SchemaType::NONE) { in CheckCompatible()
1573 … LOGI("IsLocalSchemaDb=%d, IsRemoteSchemaDb=%d.", localSchema.IsSchemaValid(), !schema.empty()); in CheckCompatible()
1585 errCode = localSchema.CompareAgainstSchemaObject(remoteSchema); in CheckCompatible()
1591 errCode = remoteSchema.CompareAgainstSchemaObject(localSchema); in CheckCompatible()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/ |
| H A D | schema_mgr.h | 32 void SetCloudDbSchema(const DataBaseSchema &schema, RelationalSchemaObject &localSchema);
35 int ChkSchema(const TableName &tableName, RelationalSchemaObject &localSchema);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | schema_mgr.cpp | 30 int SchemaMgr::ChkSchema(const TableName &tableName, RelationalSchemaObject &localSchema) in ChkSchema() argument
36 TableInfo tableInfo = localSchema.GetTable(tableName); in ChkSchema()
150 void SchemaMgr::SetCloudDbSchema(const DataBaseSchema &schema, RelationalSchemaObject &localSchema) in SetCloudDbSchema() argument
155 TableInfo tableInfo = localSchema.GetTable(tableName); in SetCloudDbSchema()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 52 …const QueryObject &query, const RelationalSchemaObject &localSchema, const std::vector<FieldInfo> … in CreateInserter() argument
59 TableInfo localTable = localSchema.GetTable(query.GetTableName()); in CreateInserter()
61 inserter.SetTableMode(localSchema.GetTableMode()); in CreateInserter()
62 if (localSchema.GetTableMode() == DistributedTableMode::COLLABORATION) { in CreateInserter()
|
| H A D | relational_sync_data_inserter.h | 47 const RelationalSchemaObject &localSchema, const std::vector<FieldInfo> &remoteFields,
|
| H A D | relational_sync_able_storage.cpp | 1219 RelationalSchemaObject localSchema = GetSchemaInfo(); in ChkSchema() local
1220 int errCode = schemaMgr_.ChkSchema(tableName, localSchema); in ChkSchema()
1237 RelationalSchemaObject localSchema = GetSchemaInfo(); in SetCloudDbSchema() local
1238 schemaMgr_.SetCloudDbSchema(schema, localSchema); in SetCloudDbSchema()
1265 RelationalSchemaObject localSchema = GetSchemaInfo(); in GetInfoByPrimaryKeyOrGidInner() local
1266 handle->SetLocalSchema(localSchema); in GetInfoByPrimaryKeyOrGidInner()
1288 RelationalSchemaObject localSchema = GetSchemaInfo(); in PutCloudSyncDataInner() local
1289 handle->SetLocalSchema(localSchema); in PutCloudSyncDataInner()
1305 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets) in CleanCloudData() argument
1313 …int errCode = transactionHandle_->DoCleanInner(mode, tableNameList, localSchema, assets, notifyTab… in CleanCloudData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_relational_store.cpp | 446 RelationalSchemaObject localSchema = sqliteStorageEngine_->GetSchema(); in CreateDistributedTable() local
447 TableInfo tableInfo = localSchema.GetTable(tableName); in CreateDistributedTable()
497 RelationalSchemaObject localSchema = sqliteStorageEngine_->GetSchema(); in CleanCloudData() local
498 TableInfoMap tables = localSchema.GetTables(); in CleanCloudData()
1031 RelationalSchemaObject localSchema = sqliteStorageEngine_->GetSchema(); in PrepareSharedTable() local
1032 TableInfoMap tableList = localSchema.GetTables(); in PrepareSharedTable()
1203 RelationalSchemaObject localSchema = sqliteStorageEngine_->GetSchema(); in CheckObjectValid() local
1221 TableInfo tableInfo = localSchema.GetTable(tableName); in CheckObjectValid()
1282 RelationalSchemaObject localSchema = sqliteStorageEngine_->GetSchema(); in SetTrackerTable() local
1283 TableInfo tableInfo = localSchema.GetTable(trackerSchema.tableName); in SetTrackerTable()
[all …]
|
| H A D | sqlite_single_ver_relational_storage_executor.h | 129 void SetLocalSchema(const RelationalSchemaObject &localSchema);
139 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets,
215 …leanLogs(const std::vector<std::string> &tableNameList, const RelationalSchemaObject &localSchema);
218 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets);
223 const RelationalSchemaObject &localSchema);
395 int DoCleanAssetId(const std::string &tableName, const RelationalSchemaObject &localSchema);
|
| H A D | sqlite_single_ver_relational_storage_executor_extend.cpp | 295 const std::vector<std::string> &tableNameList, const RelationalSchemaObject &localSchema, in DoCleanInner() argument
304 errCode = DoCleanLogs(tableNameList, localSchema); in DoCleanInner()
311 errCode = DoCleanLogAndData(tableNameList, localSchema, assets); in DoCleanInner()
333 const RelationalSchemaObject &localSchema) in DoCleanLogs() argument
340 errCode = DoCleanAssetId(tableName, localSchema); in DoCleanLogs()
452 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets) in DoCleanLogAndData() argument
465 std::vector<FieldInfo> fieldInfos = localSchema.GetTable(tableName).GetFieldInfos(); in DoCleanLogAndData()
474 errCode = CleanCloudDataAndLogOnUserTable(tableName, logTableName, localSchema); in DoCleanLogAndData()
|
| H A D | sqlite_single_relational_storage_engine.h | 109 RelationalSchemaObject &localSchema);
|
| H A D | sqlite_single_ver_relational_storage_executor.cpp | 1679 …SQLiteSingleVerRelationalStorageExecutor::SetLocalSchema(const RelationalSchemaObject &localSchema) in SetLocalSchema() argument
1681 localSchema_ = localSchema; in SetLocalSchema()
1726 const std::string &logTableName, const RelationalSchemaObject &localSchema) in CleanCloudDataAndLogOnUserTable() argument
1744 errCode = DoCleanAssetId(tableName, localSchema); in CleanCloudDataAndLogOnUserTable()
|
| H A D | sqlite_single_relational_storage_engine.cpp | 811 RelationalSchemaObject &localSchema) in DoUpdateSharedTable() argument
824 TableSyncType::CLOUD_COOPERATION, localSchema); in DoUpdateSharedTable()
|
| H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 1090 const RelationalSchemaObject &localSchema) in DoCleanAssetId() argument
1099 std::vector<FieldInfo> fieldInfos = localSchema.GetTable(tableName).GetFieldInfos(); in DoCleanAssetId()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | ability_sync.cpp | 1216 …SchemaObject localSchema = (static_cast<SingleVerKvDBSyncInterface *>(storageInterface_))->GetSche… in MakeKvSyncOpinion() local
1217 …SyncOpinion localSyncOpinion = SchemaNegotiate::MakeLocalSyncOpinion(localSchema, remoteSchema, re… in MakeKvSyncOpinion()
1219 localSchema.GetSchemaType(), remoteSchemaType)) { // LCOV_EXCL_BR_LINE in MakeKvSyncOpinion()
1233 …RelationalSchemaObject localSchema = (static_cast<RelationalDBSyncInterface *>(storageInterface_))… in MakeRelationSyncOpinion() local
1234 return SchemaNegotiate::MakeLocalSyncOpinion(localSchema, remoteSchema, remoteSchemaType); in MakeRelationSyncOpinion()
1245 …SchemaObject localSchema = (static_cast<SingleVerKvDBSyncInterface *>(storageInterface_))->GetSche… in HandleKvAckSchemaParam() local
1246 …SyncOpinion syncOpinion = SchemaNegotiate::MakeLocalSyncOpinion(localSchema, remoteSchema, remoteS… in HandleKvAckSchemaParam()
1258 localSchema.GetSchemaType(), remoteSchemaType)) { // LCOV_EXCL_BR_LINE in HandleKvAckSchemaParam()
1269 … auto localSchema = (static_cast<RelationalDBSyncInterface *>(storageInterface_))->GetSchemaInfo(); in HandleRelationAckSchemaParam() local
1270 …auto localOpinion = SchemaNegotiate::MakeLocalSyncOpinion(localSchema, remoteSchema, remoteSchemaT… in HandleRelationAckSchemaParam()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_meta_data_test.cpp | 258 const RelationalSchemaObject localSchema; variable
260 …EXPECT_EQ(proxyObj.CleanCloudData(ClearMode::DEFAULT, strVec, localSchema, assets), -E_INVALID_DB);
353 const RelationalSchemaObject localSchema; variable
354 … EXPECT_EQ(obj.CleanCloudData(ClearMode::DEFAULT, strVec, localSchema, assets), -E_INVALID_DB);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | mock_icloud_sync_storage_interface.h | 46 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets));
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | storage_proxy.h | 86 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets);
|
| H A D | icloud_sync_storage_interface.h | 134 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets) in CleanCloudData() argument
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_proxy.cpp | 324 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets) in CleanCloudData() argument
334 return store_->CleanCloudData(mode, tableNameList, localSchema, assets); in CleanCloudData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_sync_able_storage.h | 175 const RelationalSchemaObject &localSchema, std::vector<Asset> &assets) override;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_syncer.h | 59 const RelationalSchemaObject &localSchema);
|