/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
H A D | distributeddb_cloud_reference_sync_test.cpp | 58 DataBaseSchema GetSchema(const std::vector<std::string> &tableNames); 165 DataBaseSchema DistributedDBCloudReferenceSyncTest::GetSchema(const std::vector<std::string> &tableNames) in GetSchema() argument 168 for (const auto &table : tableNames) { in GetSchema() 437 std::vector<std::string> tableNames = { parentTableName_, childTableName_ }; in HWTEST_F() local 438 Query query = Query::Select().FromTable(tableNames); in HWTEST_F() 463 std::vector<std::string> tableNames = { sharedParentTableName_, sharedChildTableName_ }; in HWTEST_F() local 464 Query query = Query::Select().FromTable(tableNames); in HWTEST_F() 489 std::vector<std::string> tableNames = { childTableName_, parentTableName_ }; in HWTEST_F() local 490 Query query = Query::Select().FromTable(tableNames); in HWTEST_F() 493 tableNames in HWTEST_F() 520 std::vector<std::string> tableNames = { sharedParentTableName_, sharedChildTableName_ }; HWTEST_F() local 567 std::vector<std::string> tableNames = { sharedParentTableName_, sharedChildTableName_ }; HWTEST_F() local 608 std::vector<std::string> tableNames = { sharedParentTableName_, sharedChildTableName_ }; HWTEST_F() local 637 std::vector<std::string> tableNames = { sharedParentTableName_, sharedChildTableName_ }; HWTEST_F() local 676 std::vector<std::string> tableNames = { parentTableName_, childTableName_ }; HWTEST_F() local 749 std::vector<std::string> tableNames = { "table_a", "table_b", "table_d" }; HWTEST_F() local 805 std::vector<std::string> tableNames = { "table_a", "table_e" }; HWTEST_F() local 880 std::vector<std::string> tableNames = { "table_a", "table_b", "table_c" }; HWTEST_F() local 936 std::vector<std::string> tableNames = { "table_b", "table_d", "table_e" }; HWTEST_F() local 988 std::vector<std::string> tableNames = { "table_e" }; HWTEST_F() local 1014 std::vector<std::string> tableNames = { "table_a" }; HWTEST_F() local [all...] |
H A D | distributeddb_cloud_task_merge_test.cpp | 219 void DistributedDBCloudTaskMergeTest::CheckCloudTableCount(const std::vector<std::string> &tableNames, in CheckCloudTableCount() argument 222 for (const auto &tableName : tableNames) { in CheckCloudTableCount()
|
H A D | distributeddb_cloud_check_sync_test.cpp | 835 std::vector<std::string> tableNames = {tableName_, tableWithoutPrimaryName_}; in HWTEST_F() local 836 Query normalQuery = Query::Select().FromTable({tableNames}); in HWTEST_F() 937 std::vector<std::string> tableNames = {tableName_}; in HWTEST_F() local 938 Query normalQuery = Query::Select().FromTable({tableNames}); in HWTEST_F()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
H A D | schema_meta.cpp | 40 std::vector<std::string> tableNames; in GetTableNames() local 41 tableNames.reserve(tables.size()); in GetTableNames() 43 tableNames.push_back(table.name); in GetTableNames() 45 tableNames.push_back(table.sharedTableName); in GetTableNames() 48 return tableNames; in GetTableNames()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
H A D | param_check_utils.cpp | 271 std::set<std::string> tableNames; in CheckSharedTableName() local 283 tableNames.find(tableSchema.sharedTableName) != tableNames.end() || in CheckSharedTableName() 284 tableNames.find(tableSchema.name) != tableNames.end()) { in CheckSharedTableName() 291 tableNames.insert(tableSchema.name); in CheckSharedTableName()
|
H A D | query.cpp | 34 Query &Query::FromTable(const std::vector<std::string> &tableNames) in FromTable() argument 36 queryExpression_.SetTables(tableNames); in FromTable()
|
H A D | query_expression.cpp | 364 void QueryExpression::SetTables(const std::vector<std::string> &tableNames) in SetTables() argument 369 for (const auto &table: tableNames) { in SetTables()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/ |
H A D | data_share_profile_config.cpp | 59 SetValue(node[GET_NAME(tableNames)], tableNames); in Marshal() 66 GetValue(node, GET_NAME(tableNames), tableNames); in Unmarshal()
|
H A D | data_share_profile_config.h | 41 std::vector<std::string> tableNames; member
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
H A D | sqlite_single_relational_storage_engine.h | 61 std::pair<std::vector<std::string>, int> CalTableRef(const std::vector<std::string> &tableNames, 87 int CleanTrackerDeviceTable(const std::vector<std::string> &tableNames, RelationalSchemaObject &trackerSchemaObj,
|
H A D | sqlite_single_relational_storage_engine.cpp | 957 const std::vector<std::string> &tableNames, const std::map<std::string, std::string> &sharedTableOriginNames) in CalTableRef() 959 std::pair<std::vector<std::string>, int> res = { tableNames, E_OK }; in CalTableRef() 972 for (size_t i = 0; i < tableNames.size(); ++i) { in CalTableRef() 973 for (size_t j = i + 1; j < tableNames.size(); ++j) { in CalTableRef() 977 if (reachableWithShared[tableNames[i]][tableNames[j]]) { in CalTableRef() 985 auto actualTable = DBCommon::GenerateNodesByNodeWeight(tableNames, reachableWithShared, tableWeight); in CalTableRef() 990 int SQLiteSingleRelationalStorageEngine::CleanTrackerDeviceTable(const std::vector<std::string> &tableNames, in CleanTrackerDeviceTable() argument 994 int errCode = handle->CheckAndCleanDistributedTable(tableNames, missingTrackerTables); in CleanTrackerDeviceTable() 956 CalTableRef( const std::vector<std::string> &tableNames, const std::map<std::string, std::string> &sharedTableOriginNames) CalTableRef() argument
|
H A D | sqlite_relational_store.cpp | 925 std::vector<std::string> tableNames; in GetAllDistributedTableName() local 930 tableNames.push_back(table.second.GetTableName()); in GetAllDistributedTableName() 932 return tableNames; in GetAllDistributedTableName() 1003 std::set<std::string> tableNames; in PrepareSharedTable() local 1007 tableNames.insert(table.name); in PrepareSharedTable() 1027 if (tableNames.find(oldOriginTableName) == tableNames.end()) { in PrepareSharedTable() 1156 const auto tableNames = syncObject.GetRelationTableNames(); in CheckQueryValid() local 1157 for (const auto &tableName : tableNames) { in CheckQueryValid() 1207 int SQLiteRelationalStore::CheckTableName(const std::vector<std::string> &tableNames) in CheckTableName() argument [all...] |
H A D | sqlite_relational_store.h | 153 int CheckTableName(const std::vector<std::string> &tableNames);
|
H A D | sqlite_single_ver_relational_storage_executor.h | 95 int CheckAndCleanDistributedTable(const std::vector<std::string> &tableNames, 160 int DeleteTable(const std::vector<std::string> &tableNames); 162 int AlterTableName(const std::map<std::string, std::string> &tableNames);
|
H A D | sqlite_single_ver_relational_storage_executor.cpp | 1337 int SQLiteSingleVerRelationalStorageExecutor::CheckAndCleanDistributedTable(const std::vector<std::string> &tableNames, in CheckAndCleanDistributedTable() argument 1340 if (tableNames.empty()) { in CheckAndCleanDistributedTable() 1351 for (const auto &tableName : tableNames) { in CheckAndCleanDistributedTable() 1461 int SQLiteSingleVerRelationalStorageExecutor::GetMaxTimestamp(const std::vector<std::string> &tableNames, in GetMaxTimestamp() argument 1465 for (const auto &tableName : tableNames) { in GetMaxTimestamp()
|
H A D | sqlite_single_ver_relational_storage_extend_executor.cpp | 648 int SQLiteSingleVerRelationalStorageExecutor::DeleteTable(const std::vector<std::string> &tableNames) in DeleteTable() argument 650 for (const auto &tableName : tableNames) { in DeleteTable() 695 int SQLiteSingleVerRelationalStorageExecutor::AlterTableName(const std::map<std::string, std::string> &tableNames) in AlterTableName() argument 697 for (const auto &tableName : tableNames) { in AlterTableName()
|
/foundation/distributeddatamgr/relational_store/interfaces/ndk/src/ |
H A D | relational_store.cpp | 663 std::vector<std::string> tableNames; in OH_Rdb_SetDistributedTables() local 664 tableNames.reserve(count); in OH_Rdb_SetDistributedTables() 669 tableNames.emplace_back(tables[i]); in OH_Rdb_SetDistributedTables() 672 tableNames, DistributedTableType::DISTRIBUTED_CLOUD, { cfg.isAutoSync })); in OH_Rdb_SetDistributedTables() 878 std::vector<std::string> tableNames; in OH_Rdb_CloudSync() local 883 tableNames.emplace_back(tables[i]); in OH_Rdb_CloudSync() 901 return ConvertorErrorCode::NativeToNdk(rdbStore->GetStore()->Sync(syncOption, tableNames, progressCallback)); in OH_Rdb_CloudSync()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
H A D | cloud_db_sync_utils_test.h | 70 static void callSync(const std::vector<std::string> &tableNames, SyncMode mode, DBStatus dbStatus,
|
H A D | cloud_db_sync_utils_test.cpp | 247 void CloudDBSyncUtilsTest::callSync(const std::vector<std::string> &tableNames, SyncMode mode, DBStatus dbStatus, in callSync() argument 251 Query query = Query::Select().FromTable(tableNames); in callSync()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
H A D | distributeddb_interfaces_query_test.cpp | 279 const std::vector<std::string> tableNames = {tableName1, tableName2}; in HWTEST_F() local 280 expression1.SetTables(tableNames); in HWTEST_F()
|
H A D | distributeddb_cloud_interfaces_relational_remove_device_data_test.cpp | 312 void CheckCloudTotalCount(const std::vector<std::string> &tableNames, std::vector<int64_t> expectCounts) in CheckCloudTotalCount() argument 315 for (size_t i = 0; i < tableNames.size(); ++i) { in CheckCloudTotalCount() 319 g_virtualCloudDb->Query(tableNames[i], extend, data); in CheckCloudTotalCount() 515 void CopySharedDataFromOriginalTable(sqlite3 *&db, const std::vector<std::string> &tableNames) in CopySharedDataFromOriginalTable() argument 517 for (const auto &tableName: tableNames) { in CopySharedDataFromOriginalTable()
|
H A D | distributeddb_cloud_interfaces_relational_ext_test.cpp | 202 void PrepareData(const std::vector<std::string> &tableNames, bool primaryKeyIsRowId, in PrepareData() argument 213 for (const auto &tableName : tableNames) { in PrepareData() 236 for (const auto &tableName : tableNames) { in PrepareData()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/include/ |
H A D | query.h | 36 DB_API Query &FromTable(const std::vector<std::string> &tableNames);
|
H A D | query_expression.h | 152 void SetTables(const std::vector<std::string> &tableNames);
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
H A D | relational_schema_object.cpp | 120 std::vector<std::string> tableNames; 122 tableNames.emplace_back(it.first); 124 return tableNames;
|