Home
last modified time | relevance | path

Searched refs:tables (Results 1 - 25 of 104) sorted by relevance

12345

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_set_cloud_schema_test.cpp398 dataBaseSchema.tables.push_back(tableSchema); in InitCloudEnv()
438 dataBaseSchema.tables.push_back(tableSchema); in HWTEST_F()
439 dataBaseSchema.tables.push_back(tableSchema); in HWTEST_F()
446 dataBaseSchema.tables.clear(); in HWTEST_F()
452 dataBaseSchema.tables.push_back(tableSchema); in HWTEST_F()
458 dataBaseSchema.tables.push_back(tableSchema); in HWTEST_F()
465 dataBaseSchema.tables.clear(); in HWTEST_F()
471 dataBaseSchema.tables.push_back(tableSchema); in HWTEST_F()
477 dataBaseSchema.tables.push_back(tableSchema); in HWTEST_F()
500 dataBaseSchema.tables in HWTEST_F()
1638 const std::vector<std::string> tables = { g_tableName2, g_sharedTableName1 }; HWTEST_F() local
1758 const std::vector<std::string> tables = { g_tableName2, g_sharedTableName1 }; HWTEST_F() local
1856 const std::vector<std::string> tables = { g_tableName2, g_sharedTableName1 }; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/service_impl/
H A Dtypes.rs121 pub(crate) tables: HashMap<String, Table>,
126 let mut tables = HashMap::new(); in from() variables
127 for t in &value.tables.0 { in from()
128 tables.insert(t.table_name.clone(), Table::from(t)); in from()
133 tables, in from()
141 let mut tables = vec![]; in try_from() variables
142 for table in value.tables.values() { in try_from()
143 tables.push(table.try_into()?); in try_from()
149 tables: ipc_conn::SchemaOrderTables(tables), in try_from()
175 pub fn tables(&self) -> &HashMap<String, Table> { tables() functions
[all...]
H A Dcloud_db.rs119 match self.database.tables.get(table) { in batch_delete()
168 match self.database.tables.get(table) { in batch_query()
245 match self.database.tables.get(table) { in upload()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dschema_meta.cpp41 tableNames.reserve(tables.size()); in GetTableNames()
42 for (auto &table : tables) { in GetTableNames()
55 SetValue(node[GET_NAME(tables)], tables); in Marshal()
63 GetValue(node, GET_NAME(tables), tables); in Unmarshal()
/foundation/distributeddatamgr/relational_store/test/native/rdb/fuzztest/rdbimpl_fuzzer/
H A Drdbimpl_fuzzer.cpp31 std::vector<std::string> tables; in RdbStoreImplFuzz() local
32 tables.push_back(rawString); in RdbStoreImplFuzz()
33 rdbStoreImpl.SetDistributedTables(tables, size & 0x1, { size & 0x1 }); in RdbStoreImplFuzz()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_syncer_progress_manager_test.cpp70 std::vector<std::string> tables = {"TestTableA", "TestTableB" }; in HWTEST_F() local
90 int errCode = cloudSyncer.Sync(devices, SYNC_MODE_CLOUD_FORCE_PUSH, tables, [&res]( in HWTEST_F()
101 errCode = cloudSyncer2.Sync(devices, SYNC_MODE_CLOUD_FORCE_PULL, tables, [&res]( in HWTEST_F()
131 std::vector<std::string> tables = {"TestTableA", "TestTableB" }; in HWTEST_F() local
147 int errCode = cloudSyncer3.Sync(devices, SYNC_MODE_CLOUD_MERGE, tables, [&res]( in HWTEST_F()
158 errCode = cloudSyncer4.Sync(devices, SYNC_MODE_PULL_ONLY, tables, [&res]( in HWTEST_F()
188 std::vector<std::string> tables = {"TestTableA", "TestTableB" }; in HWTEST_F() local
206 int errCode = cloudSyncer5.Sync(devices, SYNC_MODE_CLOUD_MERGE, tables, [&res]( in HWTEST_F()
213 EXPECT_EQ(cloudSyncer5.Sync(devices, SYNC_MODE_CLOUD_MERGE, tables, nullptr, 5000), -E_INVALID_ARGS); // 5000 ms in HWTEST_F()
236 std::vector<std::string> tables in HWTEST_F() local
279 std::vector<std::string> tables = {"TestTableA", "TestTableB" }; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
H A Dschema_mgr.cpp155 for (TableSchema &table : cloudSchema.tables) { in SetCloudDbSchema()
176 LOGD("Local schema does not contain following %" PRIu32 " tables: %s", missingTables, msg.c_str()); in SetCloudDbSchema()
185 for (const auto &tableSchema : cloudSchema.tables) { in SetCloudDbSchema()
196 cloudSharedSchema.tables.push_back(sharedTableSchema); in SetCloudDbSchema()
198 for (const auto &sharedTableSchema : cloudSharedSchema.tables) { in SetCloudDbSchema()
199 cloudSchema.tables.push_back(sharedTableSchema); in SetCloudDbSchema()
214 for (const TableSchema &tableSchema : cloudSchema_->tables) { in GetCloudTableSchema()
231 for (const auto &tableSchema : (*cloudSchema_).tables) { in IsSharedTable()
248 for (const auto &item : cloudSchema_->tables) { in GetSharedTableOriginNames()
/foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/
H A Drdb_distributed_test.cpp168 * @tc.desc: test RdbStore set distributed tables
212 std::vector<std::string> tables; in HWTEST_F() local
216 errCode = rdbStore->SetDistributedTables(tables, 1, distributedConfig); in HWTEST_F()
220 tables.push_back("employee"); in HWTEST_F()
221 errCode = rdbStore->SetDistributedTables(tables, 1, distributedConfig); in HWTEST_F()
232 errCode = store->SetDistributedTables(tables, 1, distributedConfig); in HWTEST_F()
248 std::vector<std::string> tables; in HWTEST_F() local
254 errCode = rdbStore->Sync(option, tables, OHOS::DistributedRdb::AsyncDetail()); in HWTEST_F()
269 errCode = store->Sync(option, tables, nullptr); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/
H A Dauto_cache.cpp326 std::vector<std::string> tables; in OnChange() local
328 tables.emplace_back(table); in OnChange()
330 PostDataChange(meta_, tables); in OnChange()
349 std::vector<std::string> tables; in OnChange() local
351 tables.emplace_back(table); in OnChange()
353 PostDataChange(meta_, tables); in OnChange()
370 void AutoCache::Delegate::PostDataChange(const StoreMetaData &meta, const std::vector<std::string> &tables) in PostDataChange() argument
377 info.tables = tables; in PostDataChange()
/foundation/distributeddatamgr/relational_store/test/native/rdb/distributedtest/rdb_store_impl_test/
H A Ddistributed_test_agent.cpp119 std::vector<std::string> tables = { "test" }; in OnProcessMsg() local
120 store_->SetDistributedTables(tables); in OnProcessMsg()
124 AbsRdbPredicates predicate(tables[0]); in OnProcessMsg()
H A Ddistributed_test.cpp166 std::vector<std::string> tables = { "test" }; in HWTEST_F() local
169 std::string test = store_->ObtainDistributedTableName(deviceInfos_[0].networkId, tables[0], errCode); in HWTEST_F()
170 AbsRdbPredicates predicate(tables[0]); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_general_store.cpp72 schema.tables.resize(database.tables.size()); in GetDBSchema()
73 for (size_t i = 0; i < database.tables.size(); i++) { in GetDBSchema()
74 const Table &table = database.tables[i]; in GetDBSchema()
75 DBTable &dbTable = schema.tables[i]; in GetDBSchema()
561 auto tables = rdbQuery->GetTables(); in PreSharing() local
563 if (statement.empty() || tables.empty()) { in PreSharing()
564 ZLOGE("statement size:%{public}zu, tables size:%{public}zu", statement.size(), tables.size()); in PreSharing()
567 std::string sql = BuildSql(*tables in PreSharing()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_store.cpp78 auto it = std::find_if(schema_[user_].tables.begin(), schema_[user_].tables.end(), [&](const auto &table) { in GetCloudTableSchema()
81 if (it != schema_[user_].tables.end()) { in GetCloudTableSchema()
493 std::vector<TableSchema> tables = it->second.tables; in CheckSchema() local
494 if (tables.size() != 1) { in CheckSchema()
495 LOGE("[SqliteCloudKvStore] invalid tables num: %zu", tables.size()); in CheckSchema()
498 TableSchema actualTable = tables[0]; in CheckSchema()
586 if (cloudSchema->tables in GetCompensatedSyncQuery()
[all...]
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_tool/src/command/
H A Dlist_command_v10.cpp98 auto tables = UserFileClientEx::GetSupportTables(); in Start() local
99 for (auto tableName : tables) { in Start()
H A Drecv_command_v10.cpp145 auto tables = UserFileClientEx::GetSupportTables(); in Start() local
146 for (auto tableName : tables) { in Start()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.h55 Tables tables; member
61 const Tables &tables = {}, int32_t triggerMode = 0);
63 SyncInfo(int32_t user, const std::string &bundleName, const MutliStoreTables &tables);
73 std::shared_ptr<GenQuery> GenerateQuery(const std::string &store, const Tables &tables);
H A Dsync_manager.cpp48 int32_t user, const std::string &bundleName, const Store &store, const Tables &tables, int32_t triggerMode) in SyncInfo()
52 tables_[store] = tables; in SyncInfo()
66 SyncManager::SyncInfo::SyncInfo(int32_t user, const std::string &bundleName, const MutliStoreTables &tables) in SyncInfo() argument
67 : user_(user), bundleName_(bundleName), tables_(tables) in SyncInfo()
69 tables_ = tables; in SyncInfo()
77 tables_[param.store] = param.tables; in SyncInfo()
124 std::shared_ptr<GenQuery> SyncManager::SyncInfo::GenerateQuery(const std::string &store, const Tables &tables) in GenerateQuery() argument
131 explicit SyncQuery(const std::vector<std::string> &tables) : tables_(tables) {} in GenerateQuery() argument
147 return std::make_shared<SyncQuery>(it == tables_.end() || it->second.empty() ? tables in GenerateQuery()
47 SyncInfo( int32_t user, const std::string &bundleName, const Store &store, const Tables &tables, int32_t triggerMode) SyncInfo() argument
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/cj/include/
H A Drelational_store_impl_rdbstore.h109 int32_t SetDistributedTables(char** tables, int64_t tablesSize);
110 int32_t SetDistributedTables(char** tables, int64_t tablesSize, int32_t type);
111 int32_t SetDistributedTables(char** tables, int64_t tablesSize, int32_t type,
150 int32_t CloudSync(int32_t mode, CArrStr tables, int64_t callbackId);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/changeevent/
H A Dremote_change_event.h37 std::vector<std::string> tables; member
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/extension/
H A Dcloud_server_impl.cpp190 OhCloudExtHashMap *tables = nullptr; in GetDatabases() local
191 OhCloudExtDatabaseGetTable(pDb.get(), &tables); in GetDatabases()
192 if (tables == nullptr) { in GetDatabases()
195 auto pTables = std::shared_ptr<OhCloudExtHashMap>(tables, [](auto *tables) { in GetDatabases()
196 OhCloudExtHashMapFree(tables); in GetDatabases()
203 void CloudServerImpl::GetTables(std::shared_ptr<OhCloudExtHashMap> tables, DBMeta &dbMeta) in GetTables() argument
207 auto status = OhCloudExtHashMapIterGetKeyValuePair(tables.get(), &keys, &values); in GetTables()
240 dbMeta.tables.emplace_back(std::move(dbTable)); in GetTables()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp193 schema.tables.push_back(tableSchema); in GetSchema()
288 ASSERT_GT(dbSchema.tables.size(), 0u); in CheckAssetsCount()
289 ASSERT_EQ(RelationalTestUtils::SelectData(db_, dbSchema.tables[0], allData), E_OK); in CheckAssetsCount()
334 ASSERT_GT(dbSchema.tables.size(), 0u); in CheckAssetData()
335 ASSERT_EQ(RelationalTestUtils::SelectData(db_, dbSchema.tables[0], allData), E_OK); in CheckAssetData()
841 ASSERT_GT(dbSchema.tables.size(), 0u); in HWTEST_F()
842 ASSERT_EQ(RelationalTestUtils::SelectData(db_, dbSchema.tables[0], allData), E_OK); in HWTEST_F()
866 ASSERT_GT(dbSchema.tables.size(), 0u); in HWTEST_F()
867 auto assets = RelationalTestUtils::GetAllAssets(db_, dbSchema.tables[0], virtualTranslator_); in HWTEST_F()
965 dataBaseSchema.tables in HWTEST_F()
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/cj/src/
H A Drelational_store_ffi.cpp422 int32_t FfiOHOSRelationalStoreSetDistributedTables(int64_t id, char** tables, int64_t tablesSize) in FfiOHOSRelationalStoreSetDistributedTables() argument
428 return nativeRdbStore->SetDistributedTables(tables, tablesSize); in FfiOHOSRelationalStoreSetDistributedTables()
431 int32_t FfiOHOSRelationalStoreSetDistributedTablesType(int64_t id, char** tables, int64_t tablesSize, int32_t type) in FfiOHOSRelationalStoreSetDistributedTablesType() argument
437 return nativeRdbStore->SetDistributedTables(tables, tablesSize, type); in FfiOHOSRelationalStoreSetDistributedTablesType()
440 int32_t FfiOHOSRelationalStoreSetDistributedTablesConfig(int64_t id, char** tables, int64_t tablesSize, in FfiOHOSRelationalStoreSetDistributedTablesConfig() argument
448 return nativeRdbStore->SetDistributedTables(tables, tablesSize, type, config); in FfiOHOSRelationalStoreSetDistributedTablesConfig()
967 int32_t FfiOHOSRelationalStoreCloudSync(int64_t id, int32_t mode, CArrStr tables, int64_t callbackId) in FfiOHOSRelationalStoreCloudSync() argument
973 return nativeRdbStore->CloudSync(mode, tables, callbackId); in FfiOHOSRelationalStoreCloudSync()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dcloud_extra_data.h39 std::vector<std::string> tables; member in OHOS::DistributedData::final
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store.cpp485 TableInfoMap tables = localSchema.GetTables(); in CleanCloudData() local
487 for (const auto &tableInfo : tables) { in CleanCloudData()
572 TableInfoMap tables = sqliteStorageEngine_->GetSchema().GetTables(); // TableInfoMap in RemoveDeviceData() local
573 auto iter = tables.find(tableName); in RemoveDeviceData()
574 if (tables.empty() || (!tableName.empty() && iter == tables.end())) { in RemoveDeviceData()
579 if (iter != tables.end() && iter->second.GetTableSyncType() == CLOUD_COOPERATION) { in RemoveDeviceData()
879 TableInfoMap tables = sqliteStorageEngine_->GetSchema().GetTables(); // TableInfoMap in RemoveDeviceDataInner() local
882 tables.clear(); in RemoveDeviceDataInner()
885 for (const auto &it : tables) { in RemoveDeviceDataInner()
924 TableInfoMap tables = sqliteStorageEngine_->GetSchema().GetTables(); // TableInfoMap GetAllDistributedTableName() local
[all...]
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dtrans_db.cpp253 int TransDB::Sync(const SyncOption &option, const std::vector<std::string> &tables, const AsyncDetail &async) in Sync() argument
255 if (option.mode != TIME_FIRST || tables.empty()) { in Sync()
258 return RdbStore::Sync(option, tables, async); in Sync()

Completed in 20 milliseconds

12345