| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| H A D | rdb_query.cpp | 30 return tables_; in GetTables()
53 ZLOGD("table size:%{public}zu, device size:%{public}zu, op size:%{public}zu", predicates.tables_.size(), in MakeQuery()
55 query_ = predicates.tables_.size() == 1 ? DistributedDB::Query::Select(*predicates.tables_.begin()) in MakeQuery()
57 if (predicates.tables_.size() > 1) { in MakeQuery()
58 query_.FromTable(predicates.tables_); in MakeQuery()
60 if (!predicates.tables_.empty()) { in MakeQuery()
61 predicates_ = std::make_shared<Predicates>(*predicates.tables_.begin()); in MakeQuery()
69 tables_ = predicates.tables_; in MakeQuery()
[all...] |
| H A D | rdb_service_stub.cpp | 138 Anonymous::Change(param.storeName_).c_str(), predicates.tables_.size()); in OnRemoteDoSync()
159 predicates.tables_.empty() ? "null" : predicates.tables_.begin()->c_str()); in OnRemoteDoAsync()
|
| H A D | rdb_query.h | 111 std::vector<std::string> tables_; member in OHOS::DistributedRdb::RdbQuery
|
| H A D | rdb_service_impl.cpp | 519 if (!memo.tables_.empty()) {
540 if (!predicates.tables_.empty()) {
699 if (predicates.tables_.empty()) {
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | rdb_query_test.cpp | 63 EXPECT_EQ(predicates.tables_.size(), 0);
in HWTEST_F()
64 EXPECT_TRUE(predicates.tables_.empty());
in HWTEST_F()
83 predicates.tables_.push_back("table1");
in HWTEST_F()
84 predicates.tables_.push_back("table2");
in HWTEST_F()
91 EXPECT_EQ(predicates.tables_.size(), 2);
in HWTEST_F()
92 EXPECT_TRUE(!predicates.tables_.empty());
in HWTEST_F()
111 predicates.tables_.push_back("table1");
in HWTEST_F()
112 predicates.tables_.push_back("table2");
in HWTEST_F()
149 predicates.tables_.push_back("table1");
in HWTEST_F()
150 predicates.tables_ in HWTEST_F()
[all...] |
| H A D | cloud_data_test.cpp | 673 predicates.tables_.push_back(TEST_CLOUD_BUNDLE); in HWTEST_F()
1511 info.tables_.insert_or_assign(TEST_CLOUD_STORE, value); in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/ |
| H A D | general_watcher_mock.cpp | 25 return tables_;
in GetTables()
|
| H A D | general_watcher_mock.h | 26 std::vector<std::string> tables_;
member in OHOS::DistributedData::MockQuery
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 52 tables_[store] = tables; in SyncInfo()
61 tables_[store] = {}; in SyncInfo()
67 : user_(user), bundleName_(bundleName), tables_(tables) in SyncInfo()
69 tables_ = tables; in SyncInfo()
77 tables_[param.store] = param.tables; in SyncInfo()
131 explicit SyncQuery(const std::vector<std::string> &tables) : tables_(tables) {} in GenerateQuery()
140 return tables_; in GenerateQuery()
144 std::vector<std::string> tables_; in GenerateQuery() member in OHOS::CloudData::final
146 auto it = tables_.find(store); in GenerateQuery()
147 return std::make_shared<SyncQuery>(it == tables_ in GenerateQuery()
[all...] |
| H A D | sync_manager.h | 85 std::map<std::string, std::vector<std::string>> tables_; member in OHOS::CloudData::SyncManager::final
|
| H A D | cloud_service_impl.cpp | 1151 if (predicates.tables_.empty()) { in AllocResourceAndShare()
1152 ZLOGE("invalid args, tables size:%{public}zu, storeId:%{public}s", predicates.tables_.size(), in AllocResourceAndShare()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | relational_schema_object.cpp | 84 for (auto it = tables_.begin(); it != tables_.end(); it++) { in GenerateSchemaString()
85 if (it != tables_.begin()) { in GenerateSchemaString()
97 tables_[table.GetTableName()] = table;
109 tables_.erase(tableName);
115 return tables_;
121 for (const auto &it : tables_) {
129 auto it = tables_.find(tableName);
130 if (it != tables_.end()) {
673 tables_[resultTabl
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | query_expression.cpp | 33 if (!tables_.empty()) { in AssemblyQueryInfo()
361 return tables_; in GetTables()
375 tables_ = syncTable; in SetTables()
395 } else if (!tables_.empty()) { in From()
424 if (!tables_.empty()) { in SetNotSupportIfFromTables()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_task_merge_test.cpp | 116 std::vector<std::string> tables_ = { tableNameA_, tableNameB_, tableNameC_, tableNameD_ }; member in __anon8254::DistributedDBCloudTaskMergeTest
144 for (const auto &table : tables_) { in SetUp()
185 for (const auto &table : tables_) { in GetSchema()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | query_object.h | 88 std::vector<std::string> tables_; member in DistributedDB::QueryObject
|
| H A D | query_sync_object.cpp | 398 return tables_; in GetRelationTableNames()
|
| H A D | query_object.cpp | 87 tables_ = queryExpressions.GetTables(); in QueryObject()
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_types_util.cpp | 60 return ITypesUtil::Marshal(data, input.tables_, input.devices_, input.operations_); in Marshalling()
65 return ITypesUtil::Unmarshal(data, output.tables_, output.devices_, output.operations_); in Unmarshalling()
|
| H A D | abs_rdb_predicates.cpp | 34 predicates_.tables_.push_back(tableName_);
in AbsRdbPredicates()
45 predicates_.tables_ = std::move(tables);
in AbsRdbPredicates()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/relational/ |
| H A D | relational_schema_object.h | 117 TableInfoMap tables_; member in DistributedDB::RelationalSchemaObject
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/include/ |
| H A D | query_expression.h | 178 std::vector<std::string> tables_; member in DistributedDB::final
|
| /foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/ |
| H A D | rdb_types.h | 208 std::vector<std::string> tables_; member
|
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_predicates_test.cpp | 1786 EXPECT_EQ(*(distributedRdbPredicates.tables_.begin()), "AllDataType");
in HWTEST_F()
|