Home
last modified time | relevance | path

Searched refs:GetTable (Results 1 – 19 of 19) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_relational_schema_object_test.cpp299 EXPECT_EQ(schemaObj.GetTable("FIRST").GetUniqueDefine().size(), 2u);
595 TableInfo table1 = schemaObj.GetTable("FIRST");
596 TableInfo table2 = schemaObj.GetTable("FIRST");
602 TableInfo table3 = schemaObj.GetTable("SECOND");
605 TableInfo table4 = schemaObj.GetTable("FIRST");
609 TableInfo table5 = schemaObj.GetTable("FIRST");
613 TableInfo table6 = schemaObj.GetTable("FIRST");
618 TableInfo table7 = schemaObj.GetTable("FIRST");
736 EXPECT_FALSE(schema.GetTable("STUDENT").Empty());
737 EXPECT_FALSE(schema.GetTable("StudENT").Empty());
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_single_relational_storage_engine.cpp207 if (DBCommon::CaseInsensitiveCompare(schema.GetTable(tableName).GetTableName(), tableName)) { in CreateDistributedTable()
209 if (schema.GetTable(tableName).GetTableSyncType() != syncType) { in CreateDistributedTable()
253 bool isUpgraded = schema.GetTable(sharedTableName).GetTableName() == sharedTableName; in CreateDistributedSharedTable()
286 table.SetSourceTableReference(schema.GetTable(tableName).GetTableReference()); in CreateDistributedTable()
616 TableInfo sourceTableInfo = schema.GetTable(reference.sourceTableName); in CheckReference()
617 TableInfo targetTableInfo = schema.GetTable(reference.targetTableName); in CheckReference()
701 !DBCommon::CaseInsensitiveCompare(schema.GetTable(tableName).GetTableName(), tableName)) { in CleanTrackerData()
862 TableInfo tableInfo = schema.GetTable(oldTableName); in DoAlterSharedTableName()
946 TableInfo tableInfo = schema.GetTable(tableSchema.sharedTableName); in CheckIfExistUserTable()
1033 TableInfo table = GetSchema().GetTable(tableName); in GenLogInfoForUpgrade()
H A Dsqlite_relational_store.cpp447 TableInfo tableInfo = localSchema.GetTable(tableName); in CreateDistributedTable()
1221 TableInfo tableInfo = localSchema.GetTable(tableName); in CheckObjectValid()
1283 TableInfo tableInfo = localSchema.GetTable(trackerSchema.tableName); in SetTrackerTable()
1507 auto table = schema.GetTable(tableName); in CheckSchemaForUpsertData()
1575 TableInfo tableInfo = localSchema.GetTable(tableSchema.name); in CheckCloudSchema()
H A Dsqlite_single_ver_relational_storage_executor_extend.cpp167 TableInfo localTable = localSchema_.GetTable(tableSchema.name); in GetPrimaryKeyHashValue()
465 std::vector<FieldInfo> fieldInfos = localSchema.GetTable(tableName).GetFieldInfos(); in DoCleanLogAndData()
H A Dsqlite_single_ver_relational_storage_executor.cpp287 TableInfo tableInfo = localSchema_.GetTable(tableName); in CompareSchemaTableColumns()
315 TableInfo tableInfo = schema.GetTable(tableName); in UpgradeDistributedTable()
H A Dsqlite_single_ver_relational_storage_extend_executor.cpp1099 std::vector<FieldInfo> fieldInfos = localSchema.GetTable(tableName).GetFieldInfos(); in DoCleanAssetId()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dschema_negotiate.cpp103 … if (!DBCommon::CaseInsensitiveCompare(remoteSchema.GetTable(it.first).GetTableName(), it.first)) { in MakeOpinionEachTable()
108 …int errCode = it.second.CompareWithTable(remoteSchema.GetTable(it.first), localSchema.GetSchemaVer… in MakeOpinionEachTable()
114 …errCode = remoteSchema.GetTable(it.first).CompareWithTable(it.second, remoteSchema.GetSchemaVersio… in MakeOpinionEachTable()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dschema_mgr.cpp36 TableInfo tableInfo = localSchema.GetTable(tableName); in ChkSchema()
155 TableInfo tableInfo = localSchema.GetTable(tableName); in SetCloudDbSchema()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_relational_get_data_test.cpp504 … ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(g_tableName),
509 … ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(g_tableName),
713 … ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(g_tableName),
799 … ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(g_tableName),
871 … ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(g_tableName),
944 … ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(g_tableName),
1046 ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(tableName),
1062 … ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(g_tableName),
1219 … ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(g_tableName),
1482 ASSERT_EQ(E_OK, SQLiteUtils::CreateSameStuTable(db, store->GetSchemaInfo().GetTable(tableName),
/ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/
H A Dobject_storage_engine.h58 virtual uint32_t GetTable(const std::string &key, std::map<std::string, Value> &result) = 0;
H A Dflat_object_storage_engine.h36 uint32_t GetTable(const std::string &key, std::map<std::string, Value> &result) override;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/relational/
H A Drelational_schema_object.h50 TableInfo GetTable(const std::string& tableName) const;
/ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/
H A Dobject_store_test.cpp942 uint32_t ret = objectStorageEngine->GetTable(sessionId, result);
960 ret = objectStorageEngine->GetTable(sessionId, result);
980 ret = objectStorageEngine->GetTable(sessionId, result);
1005 ret = objectStorageEngine->GetTable(sessionId, result);
1370 uint32_t ret = storageEngine->GetTable(sessionId, tableResult);
1373 ret = storageEngine->GetTable("", tableResult);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/
H A Drelational_sync_data_inserter.cpp59 TableInfo localTable = localSchema.GetTable(query.GetTableName()); in CreateInserter()
H A Drelational_sync_able_storage.cpp423 }, storageEngine_->GetSchema().GetTable(token->GetQuery().GetTableName())); in GetSyncDataForQuerySync()
467 const auto fieldInfos = schema.GetTable(token->GetQuery().GetTableName()).GetFieldInfos(); in GetSyncDataNext()
551 remoteSchema.GetTable(query.GetTableName()).GetFieldInfos(), info); in SaveSyncDataItems()
684 …errCode = handle->CreateDistributedDeviceTable(device, storageEngine_->GetSchema().GetTable(table)… in CreateDistributedDeviceTable()
827 TableInfo table = schema.GetTable(query.GetTableName()); in CheckAndInitQueryCondition()
1811 …TableInfo localTable = GetSchemaInfo().GetTable(tableName); // for upsert, the table must exist in… in UpsertDataInTransaction()
/ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/fuzztest/objectstore_fuzzer/
H A Dobjectstore_fuzzer.cpp324 uint32_t ret = storageEngine->GetTable(skey, tableResult); in GetTableFuzz()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dquery_object.cpp471 const auto &tableInfo = schemaObj.GetTable(tableName_); in SetSchema()
/ohos5.0/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/
H A Dflat_object_storage_engine.cpp153 uint32_t FlatObjectStorageEngine::GetTable(const std::string &key, std::map<std::string, Value> &re… in GetTable() function in OHOS::ObjectStore::FlatObjectStorageEngine
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/
H A Drelational_schema_object.cpp127 TableInfo RelationalSchemaObject::GetTable(const std::string &tableName) const in GetTable() function in DistributedDB::RelationalSchemaObject