Home
last modified time | relevance | path

Searched refs:tableName (Results 1 – 25 of 218) sorted by relevance

123456789

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/
Dcloud_meta_data.cpp28 Key CloudMetaData::GetPrefixTableName(const TableName &tableName) in GetPrefixTableName() argument
30 TableName newName = CloudDbConstant::CLOUD_META_TABLE_PREFIX + tableName; in GetPrefixTableName()
35 int CloudMetaData::GetLocalWaterMark(const TableName &tableName, Timestamp &localMark) in GetLocalWaterMark() argument
38 if (cloudMetaVals_.count(tableName) == 0) { in GetLocalWaterMark()
39 int ret = ReadMarkFromMeta(tableName); in GetLocalWaterMark()
44 localMark = cloudMetaVals_[tableName].localMark; in GetLocalWaterMark()
48 int CloudMetaData::GetCloudWaterMark(const TableName &tableName, std::string &cloudMark) in GetCloudWaterMark() argument
51 if (cloudMetaVals_.count(tableName) == 0) { in GetCloudWaterMark()
52 int ret = ReadMarkFromMeta(tableName); in GetCloudWaterMark()
57 cloudMark = cloudMetaVals_[tableName].cloudMark; in GetCloudWaterMark()
[all …]
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_tool/src/command/
Dlist_command_v10.cpp30 static int32_t ListAsset(const ExecEnv &env, const std::string &tableName, const std::string &uri) in ListAsset() argument
32 if (tableName.empty()) { in ListAsset()
36 printf("Table Name: %s\n", tableName.c_str()); in ListAsset()
38 auto res = UserFileClientEx::Query(tableName, uri, resultSet); in ListAsset()
43 printf("%s query issue failed. tableName:%s, uri:%s\n", STR_FAIL.c_str(), tableName.c_str(), in ListAsset()
62 static int32_t ListAssets(const ExecEnv &env, const std::string &tableName) in ListAssets() argument
64 if (tableName.empty()) { in ListAssets()
68 printf("Table Name: %s\n", tableName.c_str()); in ListAssets()
70 auto res = UserFileClientEx::Query(tableName, "", resultSet); in ListAssets()
75 printf("%s query issue failed. tableName:%s\n", STR_FAIL.c_str(), tableName.c_str()); in ListAssets()
[all …]
Drecv_command_v10.cpp84 static int32_t RecvAsset(const ExecEnv &env, const std::string &tableName, const std::string &uri) in RecvAsset() argument
86 if (tableName.empty()) { in RecvAsset()
90 printf("Table Name: %s\n", tableName.c_str()); in RecvAsset()
92 auto res = UserFileClientEx::Query(tableName, uri, resultSet); in RecvAsset()
96 …printf("%s query issue. tableName:%s, uri:%s\n", STR_FAIL.c_str(), tableName.c_str(), uri.c_str()); in RecvAsset()
115 static int32_t RecvAssets(const ExecEnv &env, const std::string &tableName) in RecvAssets() argument
117 if (tableName.empty()) { in RecvAssets()
121 printf("Table Name: %s\n", tableName.c_str()); in RecvAssets()
123 auto res = UserFileClientEx::Query(tableName, "", resultSet); in RecvAssets()
127 printf("%s query issue. tableName:%s\n", STR_FAIL.c_str(), tableName.c_str()); in RecvAssets()
[all …]
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
Drdb_predicates.cpp25 RdbPredicates::RdbPredicates(const std::string &tableName) : AbsRdbPredicates(tableName) in RdbPredicates() argument
41 RdbPredicates *RdbPredicates::CrossJoin(const std::string &tableName) in CrossJoin() argument
43 return Join(JoinType::CROSS, tableName); in CrossJoin()
49 RdbPredicates *RdbPredicates::InnerJoin(const std::string &tableName) in InnerJoin() argument
51 return Join(JoinType::INNER, tableName); in InnerJoin()
57 RdbPredicates *RdbPredicates::LeftOuterJoin(const std::string &tableName) in LeftOuterJoin() argument
59 return Join(JoinType::LEFT, tableName); in LeftOuterJoin()
64 RdbPredicates *RdbPredicates::Join(int join, const std::string &tableName) in Join() argument
66 if (tableName.empty()) { in Join()
72 joinTableNames.push_back(tableName); in Join()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/cloud/
Dcloud_meta_data.h35 int GetLocalWaterMark(const TableName &tableName, Timestamp &localMark);
36 int GetCloudWaterMark(const TableName &tableName, std::string &cloudMark);
38 int SetLocalWaterMark(const TableName &tableName, Timestamp localMark);
39 int SetCloudWaterMark(const TableName &tableName, std::string &cloudMark);
41 int CleanWaterMark(const TableName &tableName);
49 int ReadMarkFromMeta(const TableName &tableName);
50 int WriteMarkToMeta(const TableName &tableName, Timestamp localmark, std::string &cloudMark);
53 Key GetPrefixTableName(const TableName &tableName);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
Dstorage_proxy.h40 int GetLocalWaterMark(const std::string &tableName, Timestamp &localMark);
42 int PutLocalWaterMark(const std::string &tableName, Timestamp &localMark);
44 int GetCloudWaterMark(const std::string &tableName, std::string &cloudMark);
46 int SetCloudWaterMark(const std::string &tableName, std::string &cloudMark);
54 …int GetUploadCount(const std::string &tableName, const Timestamp &timestamp, const bool isCloudFor…
59 int GetCloudData(const std::string &tableName, const Timestamp &timeRange,
64 int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket,
67 int PutCloudSyncData(const std::string &tableName, DownloadData &downloadData);
72 int CheckSchema(const TableName &tableName) const;
76 …int GetPrimaryColNamesWithAssetsFields(const TableName &tableName, std::vector<std::string> &colNa…
[all …]
Dicloud_sync_storage_interface.h53 virtual int ChkSchema(const TableName &tableName) = 0;
59 virtual int GetCloudTableSchema(const TableName &tableName, TableSchema &tableSchema) = 0;
67 …virtual int GetUploadCount(const std::string &tableName, const Timestamp &timestamp, const bool is…
79 virtual int GetInfoByPrimaryKeyOrGid(const std::string &tableName, const VBucket &vBucket,
82 virtual int PutCloudSyncData(const std::string &tableName, DownloadData &downloadData) = 0;
90 …virtual int FillCloudAssetForDownload(const std::string &tableName, VBucket &asset, bool isDownloa…
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
Drelational_virtual_device.cpp27 int RelationalVirtualDevice::PutData(const std::string &tableName, const std::vector<VirtualRowData… in PutData() argument
29 …rn static_cast<VirtualRelationalVerSyncDBInterface *>(storage_)->PutLocalData(dataList, tableName); in PutData()
32 int RelationalVirtualDevice::GetAllSyncData(const std::string &tableName, std::vector<VirtualRowDat… in GetAllSyncData() argument
34 …return static_cast<VirtualRelationalVerSyncDBInterface *>(storage_)->GetAllSyncData(tableName, dat… in GetAllSyncData()
37 int RelationalVirtualDevice::GetSyncData(const std::string &tableName, in GetSyncData() argument
40 …ast<VirtualRelationalVerSyncDBInterface *>(storage_)->GetVirtualSyncData(tableName, hashKey, data); in GetSyncData()
53 void RelationalVirtualDevice::EraseSyncData(const std::string &tableName) in EraseSyncData() argument
55 static_cast<VirtualRelationalVerSyncDBInterface *>(storage_)->EraseSyncData(tableName); in EraseSyncData()
Drelational_virtual_device.h31 int PutData(const std::string &tableName, const std::vector<VirtualRowData> &dataList);
32 int GetAllSyncData(const std::string &tableName, std::vector<VirtualRowData> &data);
33 int GetSyncData(const std::string &tableName, const std::string &hashKey, VirtualRowData &data);
37 void EraseSyncData(const std::string &tableName);
40 void PutDeviceData(const std::string &tableName, const std::vector<T> &data) in PutDeviceData() argument
46 this->PutData(tableName, dataList); in PutDeviceData()
/foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_tool/src/
Duserfile_client_ex.cpp48 static bool CheckTableName(const std::string &tableName) in CheckTableName() argument
54 if (tableName.empty()) { in CheckTableName()
57 if (VALID_TABLENAME_WHITELIST.find(tableName) == VALID_TABLENAME_WHITELIST.end()) { in CheckTableName()
63 static std::string GetOperation(const std::string &tableName) in GetOperation() argument
70 auto item = TYPE_OPERATION_MAP.find(tableName); in GetOperation()
74 MEDIA_ERR_LOG("get operation failed. tableName:%{public}s", tableName.c_str()); in GetOperation()
90 static inline std::string GetInsertUri(const std::string &tableName) in GetInsertUri() argument
93 std::string operation = GetOperation(tableName); in GetInsertUri()
95 MEDIA_ERR_LOG("get insert uri failed. tableName:%{public}s", tableName.c_str()); in GetInsertUri()
105 static inline std::string GetQueryUri(const std::string &tableName) in GetQueryUri() argument
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
Dprocess_notifier.cpp32 void ProcessNotifier::Init(const std::vector<std::string> &tableName, in Init() argument
38 for (const auto &table: tableName) { in Init()
49 if (process.tableName.empty()) { in UpdateProcess()
53 syncProcess_.tableProcess[process.tableName].process = process.tableStatus; in UpdateProcess()
56 …syncProcess_.tableProcess[process.tableName].downLoadInfo.batchIndex = process.downLoadInfo.batchI… in UpdateProcess()
57 … syncProcess_.tableProcess[process.tableName].downLoadInfo.total = process.downLoadInfo.total; in UpdateProcess()
58 …syncProcess_.tableProcess[process.tableName].downLoadInfo.failCount = process.downLoadInfo.failCou… in UpdateProcess()
59 …syncProcess_.tableProcess[process.tableName].downLoadInfo.successCount = process.downLoadInfo.succ… in UpdateProcess()
63 …syncProcess_.tableProcess[process.tableName].upLoadInfo.batchIndex = process.upLoadInfo.batchIndex; in UpdateProcess()
64 syncProcess_.tableProcess[process.tableName].upLoadInfo.total = process.upLoadInfo.total; in UpdateProcess()
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
Dvirtual_cloud_db.cpp32 DBStatus VirtualCloudDb::BatchInsert(const std::string &tableName, std::vector<VBucket> &&record, in BatchInsert() argument
58 cloudData_[tableName].push_back(cloudData); in BatchInsert()
64 DBStatus VirtualCloudDb::BatchInsertWithGid(const std::string &tableName, std::vector<VBucket> &&re… in BatchInsertWithGid() argument
88 cloudData_[tableName].push_back(cloudData); in BatchInsertWithGid()
95 DBStatus VirtualCloudDb::BatchUpdate(const std::string &tableName, std::vector<VBucket> &&record, in BatchUpdate() argument
104 return InnerUpdate(tableName, std::move(record), extend, false); in BatchUpdate()
107 DBStatus VirtualCloudDb::BatchDelete(const std::string &tableName, std::vector<VBucket> &extend) in BatchDelete() argument
119 return InnerUpdate(tableName, std::move(record), extend, true); in BatchDelete()
176 DBStatus VirtualCloudDb::DeleteByGid(const std::string &tableName, VBucket &extend) in DeleteByGid() argument
178 for (auto &tableData : cloudData_[tableName]) { in DeleteByGid()
[all …]
Dvirtual_cloud_db.h27 DBStatus BatchInsert(const std::string &tableName, std::vector<VBucket> &&record,
30 DBStatus BatchInsertWithGid(const std::string &tableName, std::vector<VBucket> &&record,
33 DBStatus BatchUpdate(const std::string &tableName, std::vector<VBucket> &&record,
36 DBStatus BatchDelete(const std::string &tableName, std::vector<VBucket> &extend) override;
38 …DBStatus Query(const std::string &tableName, VBucket &extend, std::vector<VBucket> &data) override;
40 DBStatus DeleteByGid(const std::string &tableName, VBucket &extend);
62 … void SetIncrementData(const std::string &tableName, const VBucket &record, const VBucket &extend);
64 uint32_t GetQueryTimes(const std::string &tableName);
73 DBStatus InnerUpdate(const std::string &tableName, std::vector<VBucket> &&record,
76 DBStatus UpdateCloudData(const std::string &tableName, CloudData &&cloudData);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
Dstorage_proxy.cpp53 int StorageProxy::GetLocalWaterMark(const std::string &tableName, Timestamp &localMark) in GetLocalWaterMark() argument
63 return cloudMetaData_->GetLocalWaterMark(tableName, localMark); in GetLocalWaterMark()
66 int StorageProxy::PutLocalWaterMark(const std::string &tableName, Timestamp &localMark) in PutLocalWaterMark() argument
76 return cloudMetaData_->SetLocalWaterMark(tableName, localMark); in PutLocalWaterMark()
79 int StorageProxy::GetCloudWaterMark(const std::string &tableName, std::string &cloudMark) in GetCloudWaterMark() argument
85 return cloudMetaData_->GetCloudWaterMark(tableName, cloudMark); in GetCloudWaterMark()
88 int StorageProxy::SetCloudWaterMark(const std::string &tableName, std::string &cloudMark) in SetCloudWaterMark() argument
94 return cloudMetaData_->SetCloudWaterMark(tableName, cloudMark); in SetCloudWaterMark()
137 int StorageProxy::GetUploadCount(const std::string &tableName, const Timestamp &localMark, in GetUploadCount() argument
148 return store_->GetUploadCount(tableName, localMark, isCloudForcePush, count); in GetUploadCount()
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
Ddistributeddb_cloud_interfaces_relational_ext_test.cpp107 void PrepareData(const std::string &tableName, bool primaryKeyIsRowId) in PrepareData() argument
118 sql = "create table " + tableName + "(rowid INTEGER primary key, id int, name TEXT);"; in PrepareData()
120 … sql = "create table " + tableName + "(rowid int, id int, name TEXT, PRIMARY KEY(id, name));"; in PrepareData()
134 EXPECT_EQ(delegate->CreateDistributedTable(tableName, DistributedDB::CLOUD_COOPERATION), OK); in PrepareData()
152 const std::string tableName = "sync_data"; variable
153 PrepareData(tableName, false);
161 std::string sql = "insert into " + tableName + " VALUES(2, 1, 'zhangsan');";
168 sql = "select * from " + DBConstant::RELATIONAL_PREFIX + tableName + "_log;";
210 const std::string tableName = "sync_data"; variable
211 PrepareData(tableName, false);
[all …]
/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/mock/include/
Drdb_predicates.h26 explicit RdbPredicates(const std::string &tableName);
30 RdbPredicates *CrossJoin(const std::string &tableName);
31 RdbPredicates *InnerJoin(const std::string &tableName);
32 RdbPredicates *LeftOuterJoin(const std::string &tableName);
39 RdbPredicates *Join(int join, const std::string &tableName);
/foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/
Drdb_predicates.h35 API_EXPORT explicit RdbPredicates(const std::string &tableName);
50 API_EXPORT RdbPredicates *CrossJoin(const std::string &tableName);
55 API_EXPORT RdbPredicates *InnerJoin(const std::string &tableName);
60 API_EXPORT RdbPredicates *LeftOuterJoin(const std::string &tableName);
76 RdbPredicates *Join(int join, const std::string &tableName);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/
Drdb_delegate.cpp68 int64_t RdbDelegate::Insert(const std::string &tableName, const DataShareValuesBucket &valuesBucket) in Insert() argument
76 int ret = store_->Insert(rowId, tableName, bucket); in Insert()
78 ZLOGE("Insert failed %{public}s %{public}d", tableName.c_str(), ret); in Insert()
83 …const std::string &tableName, const DataSharePredicates &predicate, const DataShareValuesBucket &v… in Update() argument
91 RdbPredicates predicates = RdbDataShareAdapter::RdbUtils::ToPredicates(predicate, tableName); in Update()
94 ZLOGE("Update failed %{public}s %{public}d", tableName.c_str(), ret); in Update()
98 int64_t RdbDelegate::Delete(const std::string &tableName, const DataSharePredicates &predicate) in Delete() argument
105 RdbPredicates predicates = RdbDataShareAdapter::RdbUtils::ToPredicates(predicate, tableName); in Delete()
108 ZLOGE("Delete failed %{public}s %{public}d", tableName.c_str(), ret); in Delete()
112 std::shared_ptr<DataShareResultSet> RdbDelegate::Query(const std::string &tableName, in Query() argument
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
Dsqlite_single_ver_relational_storage_executor.h46 …int UpgradeDistributedTable(const std::string &tableName, DistributedTableMode mode, bool &schemaC…
69 int DeleteDistributedDeviceTable(const std::string &device, const std::string &tableName);
71 int DeleteDistributedAllDeviceTableLog(const std::string &tableName);
73 int DeleteDistributedDeviceTableLog(const std::string &device, const std::string &tableName);
75 int DeleteDistributedLogTable(const std::string &tableName);
95 …int GetUploadCount(const std::string &tableName, const Timestamp &timestamp, const bool isCloudFor…
106 …int PutCloudSyncData(const std::string &tableName, const TableSchema &tableSchema, DownloadData &d…
112 int FillCloudAssetForUpload(const std::string &tableName, const CloudSyncBatch &data);
124 …int CleanCloudDataAndLogOnUserTable(const std::string &tableName, const std::string &logTableName);
128 int GetCloudAssets(const std::string &tableName, const std::vector<FieldInfo> &fieldInfos,
[all …]
Dsqlite_single_ver_relational_storage_extend_executor.cpp26 int SQLiteSingleVerRelationalStorageExecutor::GetQueryInfoSql(const std::string &tableName, const V… in GetQueryInfoSql() argument
30 return GetQueryLogSql(tableName, vBucket, pkSet, querySql); in GetQueryInfoSql()
51 …sql += " from '" + DBCommon::GetLogTableName(tableName) + "' AS a LEFT JOIN '" + tableName + "' AS… in GetQueryInfoSql()
61 …LiteSingleVerRelationalStorageExecutor::GetFillDownloadAssetStatement(const std::string &tableName, in GetFillDownloadAssetStatement() argument
64 std::string sql = "UPDATE " + tableName + " SET "; in GetFillDownloadAssetStatement()
70 … sql += "SELECT data_key FROM " + DBCommon::GetLogTableName(tableName) + " where cloud_gid = ?);"; in GetFillDownloadAssetStatement()
134 int SQLiteSingleVerRelationalStorageExecutor::FillCloudAssetForUpload(const std::string &tableName, in FillCloudAssetForUpload() argument
153 errCode = InitFillUploadAssetStatement(tableName, data, i, stmt); in FillCloudAssetForUpload()
179 …QLiteSingleVerRelationalStorageExecutor::InitFillUploadAssetStatement(const std::string &tableName, in InitFillUploadAssetStatement() argument
185 std::string sql = "UPDATE " + tableName + " SET "; in InitFillUploadAssetStatement()
[all …]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
Drdb_cloud.cpp33 const std::string &tableName, std::vector<DBVBucket> &&record, std::vector<DBVBucket> &extend) in BatchInsert() argument
36 auto error = cloudDB_->BatchInsert(tableName, ValueProxy::Convert(std::move(record)), extends); in BatchInsert()
44 const std::string &tableName, std::vector<DBVBucket> &&record, std::vector<DBVBucket> &extend) in BatchUpdate() argument
47 auto error = cloudDB_->BatchUpdate(tableName, ValueProxy::Convert(std::move(record)), extends); in BatchUpdate()
54 DBStatus RdbCloud::BatchDelete(const std::string &tableName, std::vector<DBVBucket> &extend) in BatchDelete() argument
56 auto error = cloudDB_->BatchDelete(tableName, ValueProxy::Convert(std::move(extend))); in BatchDelete()
60 DBStatus RdbCloud::Query(const std::string &tableName, DBVBucket &extend, std::vector<DBVBucket> &d… in Query() argument
62 auto cursor = cloudDB_->Query(tableName, ValueProxy::Convert(std::move(extend))); in Query()
65 Anonymous::Change(tableName).c_str(), extend.size()); in Query()
85 ZLOGD("query end, table:%{public}s", Anonymous::Change(tableName).c_str()); in Query()
/foundation/communication/netmanager_base/services/netstatsmanager/src/
Dnet_stats_data_handler.cpp63 …tsDataHandler::WriteStatsData(const std::vector<NetStatsInfo> &infos, const std::string &tableName) in WriteStatsData() argument
65 NETMGR_LOG_I("WriteStatsData enter tableName:%{public}s", tableName.c_str()); in WriteStatsData()
66 if (infos.empty() || tableName.empty()) { in WriteStatsData()
67 …GR_LOG_E("Param wrong, info: %{public}zu, tableName: %{public}zu", infos.size(), tableName.size()); in WriteStatsData()
71 if (tableName == UID_TABLE) { in WriteStatsData()
76 if (tableName == IFACE_TABLE) { in WriteStatsData()
90 int32_t NetStatsDataHandler::DeleteByDate(const std::string &tableName, uint64_t start, uint64_t en… in DeleteByDate() argument
93 return helper->DeleteData(tableName, start, end); in DeleteByDate()
/foundation/communication/netmanager_base/services/netstatsmanager/include/
Dnet_stats_database_helper.h41 int32_t CreateTable(const std::string &tableName, const std::string &tableInfo);
42 int32_t InsertData(const std::string &tableName, const std::string &paramList,
44 …int32_t SelectData(std::vector<NetStatsInfo> &infos, const std::string &tableName, uint64_t start,…
49 int32_t DeleteData(const std::string &tableName, uint64_t start, uint64_t end);
50 int32_t DeleteData(const std::string &tableName, uint64_t uid);
51 int32_t ClearData(const std::string &tableName);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
Dsqlite_single_relational_storage_engine.cpp153 …SyncTableTypeToMeta(SQLiteSingleVerRelationalStorageExecutor *handle, const std::string &tableName, in SaveSyncTableTypeToMeta() argument
157 DBCommon::StringToVector(SYNC_TABLE_TYPE + tableName, key); in SaveSyncTableTypeToMeta()
168 int SQLiteSingleRelationalStorageEngine::CreateDistributedTable(const std::string &tableName, in CreateDistributedTable() argument
174 if (schema.GetTable(tableName).GetTableName() == tableName) { in CreateDistributedTable()
176 if (schema.GetTable(tableName).GetTableSyncType() != syncType) { in CreateDistributedTable()
181 int errCode = UpgradeDistributedTable(tableName, schemaChanged, syncType); in CreateDistributedTable()
194 return CreateDistributedTable(tableName, isUpgraded, identity, schema, syncType); in CreateDistributedTable()
197 int SQLiteSingleRelationalStorageEngine::CreateDistributedTable(const std::string &tableName, bool … in CreateDistributedTable() argument
217 table.SetTableName(tableName); in CreateDistributedTable()
235 errCode = SaveSyncTableTypeToMeta(handle, tableName, tableSyncType); in CreateDistributedTable()
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/
Dicloud_db.h33 virtual DBStatus BatchInsert(const std::string &tableName, std::vector<VBucket> &&record,
35 virtual DBStatus BatchUpdate(const std::string &tableName, std::vector<VBucket> &&record,
37 virtual DBStatus BatchDelete(const std::string &tableName, std::vector<VBucket> &extend) = 0;
41 …virtual DBStatus Query(const std::string &tableName, VBucket &extend, std::vector<VBucket> &data) …

123456789