Skip to content

milvus
milvus

BaiXuePrincess / milvus
与 Fork 源项目一致

Fork自 milvus / milvus

通知 7
Star 4
Fork 0
milvus
milvus

体验新版 GitCode，发现更多精彩内容 >>

提交 817e8f25 编写于 作者: Z zhiru
浏览文件
操作

update 


Former-commit-id: 82c11af9305e823256197114c2ddd4c0a2f2e833
上级 f6cccd3c
隐藏空白更改
内联 并排
Showing with 32 addition and 109 deletion
cpp/src/db/MySQLMetaImpl.cpp
浏览文件 @ 817e8f25
...@@ -193,9 +193,7 @@ namespace meta { ...@@ -193,9 +193,7 @@ namespace meta {
"engine_type INT DEFAULT 1 NOT NULL, " << "engine_type INT DEFAULT 1 NOT NULL, " <<
"store_raw_data BOOL DEFAULT false NOT NULL);"; "store_raw_data BOOL DEFAULT false NOT NULL);";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::Initialize: " << InitializeQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::Initialize: " << InitializeQuery.str();
}
if (!InitializeQuery.exec()) { if (!InitializeQuery.exec()) {
return Status::DBTransactionError("Initialization Error", InitializeQuery.error()); return Status::DBTransactionError("Initialization Error", InitializeQuery.error());
...@@ -212,9 +210,7 @@ namespace meta { ...@@ -212,9 +210,7 @@ namespace meta {
"created_on BIGINT NOT NULL, " << "created_on BIGINT NOT NULL, " <<
"date INT DEFAULT -1 NOT NULL);"; "date INT DEFAULT -1 NOT NULL);";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::Initialize: " << InitializeQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::Initialize: " << InitializeQuery.str();
}
if (!InitializeQuery.exec()) { if (!InitializeQuery.exec()) {
return Status::DBTransactionError("Initialization Error", InitializeQuery.error()); return Status::DBTransactionError("Initialization Error", InitializeQuery.error());
...@@ -305,9 +301,7 @@ namespace meta { ...@@ -305,9 +301,7 @@ namespace meta {
"WHERE table_id = " << quote << table_id << " AND " << "WHERE table_id = " << quote << table_id << " AND " <<
"date in (" << dateListStr << ");"; "date in (" << dateListStr << ");";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::DropPartitionsByDates: " << dropPartitionsByDatesQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::DropPartitionsByDates: " << dropPartitionsByDatesQuery.str();
}
if (!dropPartitionsByDatesQuery.exec()) { if (!dropPartitionsByDatesQuery.exec()) {
ENGINE_LOG_ERROR << "QUERY ERROR WHEN DROPPING PARTITIONS BY DATES"; ENGINE_LOG_ERROR << "QUERY ERROR WHEN DROPPING PARTITIONS BY DATES";
...@@ -352,9 +346,7 @@ namespace meta { ...@@ -352,9 +346,7 @@ namespace meta {
"WHERE table_id = " << quote << table_schema.table_id_ << ";"; "WHERE table_id = " << quote << table_schema.table_id_ << ";";
// ENGINE_LOG_DEBUG << "Create Table : " << createTableQuery.str(); // ENGINE_LOG_DEBUG << "Create Table : " << createTableQuery.str();
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CreateTable: " << createTableQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CreateTable: " << createTableQuery.str();
}
StoreQueryResult res = createTableQuery.store(); StoreQueryResult res = createTableQuery.store();
assert(res && res.num_rows() <= 1); assert(res && res.num_rows() <= 1);
...@@ -390,9 +382,7 @@ namespace meta { ...@@ -390,9 +382,7 @@ namespace meta {
created_on << ", " << files_cnt << ", " << engine_type << ", " << store_raw_data << ");"; created_on << ", " << files_cnt << ", " << engine_type << ", " << store_raw_data << ");";
// ENGINE_LOG_DEBUG << "Create Table : " << createTableQuery.str(); // ENGINE_LOG_DEBUG << "Create Table : " << createTableQuery.str();
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CreateTable: " << createTableQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CreateTable: " << createTableQuery.str();
}
if (SimpleResult res = createTableQuery.execute()) { if (SimpleResult res = createTableQuery.execute()) {
table_schema.id_ = res.insert_id(); //Might need to use SELECT LAST_INSERT_ID()? table_schema.id_ = res.insert_id(); //Might need to use SELECT LAST_INSERT_ID()?
...@@ -457,9 +447,7 @@ namespace meta { ...@@ -457,9 +447,7 @@ namespace meta {
"SET state = " << std::to_string(TableSchema::TO_DELETE) << " " << "SET state = " << std::to_string(TableSchema::TO_DELETE) << " " <<
"WHERE table_id = " << quote << table_id << ";"; "WHERE table_id = " << quote << table_id << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::DeleteTable: " << deleteTableQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::DeleteTable: " << deleteTableQuery.str();
}
if (!deleteTableQuery.exec()) { if (!deleteTableQuery.exec()) {
ENGINE_LOG_ERROR << "QUERY ERROR WHEN DELETING TABLE"; ENGINE_LOG_ERROR << "QUERY ERROR WHEN DELETING TABLE";
...@@ -506,9 +494,7 @@ namespace meta { ...@@ -506,9 +494,7 @@ namespace meta {
"WHERE table_id = " << quote << table_id << " AND " << "WHERE table_id = " << quote << table_id << " AND " <<
"file_type <> " << std::to_string(TableFileSchema::TO_DELETE) << ";"; "file_type <> " << std::to_string(TableFileSchema::TO_DELETE) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::DeleteTableFiles: " << deleteTableFilesQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::DeleteTableFiles: " << deleteTableFilesQuery.str();
}
if (!deleteTableFilesQuery.exec()) { if (!deleteTableFilesQuery.exec()) {
ENGINE_LOG_ERROR << "QUERY ERROR WHEN DELETING TABLE FILES"; ENGINE_LOG_ERROR << "QUERY ERROR WHEN DELETING TABLE FILES";
...@@ -551,9 +537,7 @@ namespace meta { ...@@ -551,9 +537,7 @@ namespace meta {
"WHERE table_id = " << quote << table_schema.table_id_ << " " << "WHERE table_id = " << quote << table_schema.table_id_ << " " <<
"AND state <> " << std::to_string(TableSchema::TO_DELETE) << ";"; "AND state <> " << std::to_string(TableSchema::TO_DELETE) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::DescribeTable: " << describeTableQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::DescribeTable: " << describeTableQuery.str();
}
res = describeTableQuery.store(); res = describeTableQuery.store();
} //Scoped Connection } //Scoped Connection
...@@ -618,9 +602,7 @@ namespace meta { ...@@ -618,9 +602,7 @@ namespace meta {
"AND state <> " << std::to_string(TableSchema::TO_DELETE) << ") " << "AND state <> " << std::to_string(TableSchema::TO_DELETE) << ") " <<
"AS " << quote << "check" << ";"; "AS " << quote << "check" << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::HasTable: " << hasTableQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::HasTable: " << hasTableQuery.str();
}
res = hasTableQuery.store(); res = hasTableQuery.store();
} //Scoped Connection } //Scoped Connection
...@@ -664,9 +646,7 @@ namespace meta { ...@@ -664,9 +646,7 @@ namespace meta {
"FROM Tables " << "FROM Tables " <<
"WHERE state <> " << std::to_string(TableSchema::TO_DELETE) << ";"; "WHERE state <> " << std::to_string(TableSchema::TO_DELETE) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::AllTables: " << allTablesQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::AllTables: " << allTablesQuery.str();
}
res = allTablesQuery.store(); res = allTablesQuery.store();
} //Scoped Connection } //Scoped Connection
...@@ -755,9 +735,7 @@ namespace meta { ...@@ -755,9 +735,7 @@ namespace meta {
quote << file_id << ", " << file_type << ", " << size << ", " << quote << file_id << ", " << file_type << ", " << size << ", " <<
updated_time << ", " << created_on << ", " << date << ");"; updated_time << ", " << created_on << ", " << date << ");";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CreateTableFile: " << createTableFileQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CreateTableFile: " << createTableFileQuery.str();
}
if (SimpleResult res = createTableFileQuery.execute()) { if (SimpleResult res = createTableFileQuery.execute()) {
file_schema.id_ = res.insert_id(); //Might need to use SELECT LAST_INSERT_ID()? file_schema.id_ = res.insert_id(); //Might need to use SELECT LAST_INSERT_ID()?
...@@ -821,9 +799,7 @@ namespace meta { ...@@ -821,9 +799,7 @@ namespace meta {
"FROM TableFiles " << "FROM TableFiles " <<
"WHERE file_type = " << std::to_string(TableFileSchema::TO_INDEX) << ";"; "WHERE file_type = " << std::to_string(TableFileSchema::TO_INDEX) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::FilesToIndex: " << filesToIndexQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::FilesToIndex: " << filesToIndexQuery.str();
}
res = filesToIndexQuery.store(); res = filesToIndexQuery.store();
} //Scoped Connection } //Scoped Connection
...@@ -911,9 +887,7 @@ namespace meta { ...@@ -911,9 +887,7 @@ namespace meta {
"file_type = " << std::to_string(TableFileSchema::TO_INDEX) << " OR " << "file_type = " << std::to_string(TableFileSchema::TO_INDEX) << " OR " <<
"file_type = " << std::to_string(TableFileSchema::INDEX) << ");"; "file_type = " << std::to_string(TableFileSchema::INDEX) << ");";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::FilesToSearch: " << filesToSearchQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::FilesToSearch: " << filesToSearchQuery.str();
}
res = filesToSearchQuery.store(); res = filesToSearchQuery.store();
...@@ -936,9 +910,7 @@ namespace meta { ...@@ -936,9 +910,7 @@ namespace meta {
"file_type = " << std::to_string(TableFileSchema::TO_INDEX) << " OR " << "file_type = " << std::to_string(TableFileSchema::TO_INDEX) << " OR " <<
"file_type = " << std::to_string(TableFileSchema::INDEX) << ");"; "file_type = " << std::to_string(TableFileSchema::INDEX) << ");";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::FilesToSearch: " << filesToSearchQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::FilesToSearch: " << filesToSearchQuery.str();
}
res = filesToSearchQuery.store(); res = filesToSearchQuery.store();
...@@ -1023,9 +995,7 @@ namespace meta { ...@@ -1023,9 +995,7 @@ namespace meta {
"file_type = " << std::to_string(TableFileSchema::RAW) << " " << "file_type = " << std::to_string(TableFileSchema::RAW) << " " <<
"ORDER BY size DESC" << ";"; "ORDER BY size DESC" << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::FilesToMerge: " << filesToMergeQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::FilesToMerge: " << filesToMergeQuery.str();
}
res = filesToMergeQuery.store(); res = filesToMergeQuery.store();
} //Scoped Connection } //Scoped Connection
...@@ -1116,9 +1086,7 @@ namespace meta { ...@@ -1116,9 +1086,7 @@ namespace meta {
"WHERE table_id = " << quote << table_id << " AND " << "WHERE table_id = " << quote << table_id << " AND " <<
"(" << idStr << ");"; "(" << idStr << ");";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::GetTableFiles: " << getTableFileQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::GetTableFiles: " << getTableFileQuery.str();
}
res = getTableFileQuery.store(); res = getTableFileQuery.store();
} //Scoped Connection } //Scoped Connection
...@@ -1200,9 +1168,7 @@ namespace meta { ...@@ -1200,9 +1168,7 @@ namespace meta {
"WHERE created_on < " << std::to_string(now - usecs) << " AND " << "WHERE created_on < " << std::to_string(now - usecs) << " AND " <<
"file_type <> " << std::to_string(TableFileSchema::TO_DELETE) << ";"; "file_type <> " << std::to_string(TableFileSchema::TO_DELETE) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::Archive: " << archiveQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::Archive: " << archiveQuery.str();
}
if (!archiveQuery.exec()) { if (!archiveQuery.exec()) {
return Status::DBTransactionError("QUERY ERROR DURING ARCHIVE", archiveQuery.error()); return Status::DBTransactionError("QUERY ERROR DURING ARCHIVE", archiveQuery.error());
...@@ -1251,9 +1217,7 @@ namespace meta { ...@@ -1251,9 +1217,7 @@ namespace meta {
"FROM TableFiles " << "FROM TableFiles " <<
"WHERE file_type <> " << std::to_string(TableFileSchema::TO_DELETE) << ";"; "WHERE file_type <> " << std::to_string(TableFileSchema::TO_DELETE) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::Size: " << getSizeQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::Size: " << getSizeQuery.str();
}
res = getSizeQuery.store(); res = getSizeQuery.store();
} //Scoped Connection } //Scoped Connection
...@@ -1315,9 +1279,7 @@ namespace meta { ...@@ -1315,9 +1279,7 @@ namespace meta {
"ORDER BY id ASC " << "ORDER BY id ASC " <<
"LIMIT 10;"; "LIMIT 10;";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::DiscardFiles: " << discardFilesQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::DiscardFiles: " << discardFilesQuery.str();
}
// std::cout << discardFilesQuery.str() << std::endl; // std::cout << discardFilesQuery.str() << std::endl;
StoreQueryResult res = discardFilesQuery.store(); StoreQueryResult res = discardFilesQuery.store();
...@@ -1349,9 +1311,7 @@ namespace meta { ...@@ -1349,9 +1311,7 @@ namespace meta {
"updated_time = " << std::to_string(utils::GetMicroSecTimeStamp()) << " " << "updated_time = " << std::to_string(utils::GetMicroSecTimeStamp()) << " " <<
"WHERE " << idsToDiscardStr << ";"; "WHERE " << idsToDiscardStr << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::DiscardFiles: " << discardFilesQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::DiscardFiles: " << discardFilesQuery.str();
}
status = discardFilesQuery.exec(); status = discardFilesQuery.exec();
if (!status) { if (!status) {
...@@ -1397,9 +1357,7 @@ namespace meta { ...@@ -1397,9 +1357,7 @@ namespace meta {
updateTableFileQuery << "SELECT state FROM Tables " << updateTableFileQuery << "SELECT state FROM Tables " <<
"WHERE table_id = " << quote << file_schema.table_id_ << ";"; "WHERE table_id = " << quote << file_schema.table_id_ << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::UpdateTableFile: " << updateTableFileQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::UpdateTableFile: " << updateTableFileQuery.str();
}
StoreQueryResult res = updateTableFileQuery.store(); StoreQueryResult res = updateTableFileQuery.store();
...@@ -1434,9 +1392,7 @@ namespace meta { ...@@ -1434,9 +1392,7 @@ namespace meta {
"date = " << date << " " << "date = " << date << " " <<
"WHERE id = " << id << ";"; "WHERE id = " << id << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::UpdateTableFile: " << updateTableFileQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::UpdateTableFile: " << updateTableFileQuery.str();
}
// std::cout << updateTableFileQuery.str() << std::endl; // std::cout << updateTableFileQuery.str() << std::endl;
...@@ -1491,9 +1447,7 @@ namespace meta { ...@@ -1491,9 +1447,7 @@ namespace meta {
"AND state <> " << std::to_string(TableSchema::TO_DELETE) << ") " << "AND state <> " << std::to_string(TableSchema::TO_DELETE) << ") " <<
"AS " << quote << "check" << ";"; "AS " << quote << "check" << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::UpdateTableFiles: " << updateTableFilesQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::UpdateTableFiles: " << updateTableFilesQuery.str();
}
StoreQueryResult res = updateTableFilesQuery.store(); StoreQueryResult res = updateTableFilesQuery.store();
...@@ -1530,9 +1484,7 @@ namespace meta { ...@@ -1530,9 +1484,7 @@ namespace meta {
"date = " << date << " " << "date = " << date << " " <<
"WHERE id = " << id << ";"; "WHERE id = " << id << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::UpdateTableFiles: " << updateTableFilesQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::UpdateTableFiles: " << updateTableFilesQuery.str();
}
if (!updateTableFilesQuery.exec()) { if (!updateTableFilesQuery.exec()) {
ENGINE_LOG_ERROR << "QUERY ERROR WHEN UPDATING TABLE FILES"; ENGINE_LOG_ERROR << "QUERY ERROR WHEN UPDATING TABLE FILES";
...@@ -1582,9 +1534,7 @@ namespace meta { ...@@ -1582,9 +1534,7 @@ namespace meta {
"WHERE file_type = " << std::to_string(TableFileSchema::TO_DELETE) << " AND " << "WHERE file_type = " << std::to_string(TableFileSchema::TO_DELETE) << " AND " <<
"updated_time < " << std::to_string(now - seconds * US_PS) << ";"; "updated_time < " << std::to_string(now - seconds * US_PS) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << cleanUpFilesWithTTLQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << cleanUpFilesWithTTLQuery.str();
}
StoreQueryResult res = cleanUpFilesWithTTLQuery.store(); StoreQueryResult res = cleanUpFilesWithTTLQuery.store();
...@@ -1628,9 +1578,7 @@ namespace meta { ...@@ -1628,9 +1578,7 @@ namespace meta {
cleanUpFilesWithTTLQuery << "DELETE FROM TableFiles WHERE " << cleanUpFilesWithTTLQuery << "DELETE FROM TableFiles WHERE " <<
idsToDeleteStr << ";"; idsToDeleteStr << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << cleanUpFilesWithTTLQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << cleanUpFilesWithTTLQuery.str();
}
if (!cleanUpFilesWithTTLQuery.exec()) { if (!cleanUpFilesWithTTLQuery.exec()) {
ENGINE_LOG_ERROR << "QUERY ERROR WHEN CLEANING UP FILES WITH TTL"; ENGINE_LOG_ERROR << "QUERY ERROR WHEN CLEANING UP FILES WITH TTL";
...@@ -1669,9 +1617,7 @@ namespace meta { ...@@ -1669,9 +1617,7 @@ namespace meta {
"FROM Tables " << "FROM Tables " <<
"WHERE state = " << std::to_string(TableSchema::TO_DELETE) << ";"; "WHERE state = " << std::to_string(TableSchema::TO_DELETE) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << cleanUpFilesWithTTLQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << cleanUpFilesWithTTLQuery.str();
}
StoreQueryResult res = cleanUpFilesWithTTLQuery.store(); StoreQueryResult res = cleanUpFilesWithTTLQuery.store();
assert(res); assert(res);
...@@ -1697,9 +1643,7 @@ namespace meta { ...@@ -1697,9 +1643,7 @@ namespace meta {
cleanUpFilesWithTTLQuery << "DELETE FROM Tables WHERE " << cleanUpFilesWithTTLQuery << "DELETE FROM Tables WHERE " <<
idsToDeleteStr << ";"; idsToDeleteStr << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << cleanUpFilesWithTTLQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUpFilesWithTTL: " << cleanUpFilesWithTTLQuery.str();
}
if (!cleanUpFilesWithTTLQuery.exec()) { if (!cleanUpFilesWithTTLQuery.exec()) {
ENGINE_LOG_ERROR << "QUERY ERROR WHEN CLEANING UP FILES WITH TTL"; ENGINE_LOG_ERROR << "QUERY ERROR WHEN CLEANING UP FILES WITH TTL";
...@@ -1739,9 +1683,7 @@ namespace meta { ...@@ -1739,9 +1683,7 @@ namespace meta {
"WHERE table_schema = " << quote << mysql_connection_pool_->getDB() << quote << " " << "WHERE table_schema = " << quote << mysql_connection_pool_->getDB() << quote << " " <<
"AND table_name = " << quote << "TableFiles" << quote << ";"; "AND table_name = " << quote << "TableFiles" << quote << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUp: " << cleanUpQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUp: " << cleanUpQuery.str();
}
StoreQueryResult res = cleanUpQuery.store(); StoreQueryResult res = cleanUpQuery.store();
assert(res); assert(res);
...@@ -1749,9 +1691,7 @@ namespace meta { ...@@ -1749,9 +1691,7 @@ namespace meta {
ENGINE_LOG_DEBUG << "Remove table file type as NEW"; ENGINE_LOG_DEBUG << "Remove table file type as NEW";
cleanUpQuery << "DELETE FROM TableFiles WHERE file_type = " << std::to_string(TableFileSchema::NEW) << ";"; cleanUpQuery << "DELETE FROM TableFiles WHERE file_type = " << std::to_string(TableFileSchema::NEW) << ";";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUp: " << cleanUpQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::CleanUp: " << cleanUpQuery.str();
}
if (!cleanUpQuery.exec()) { if (!cleanUpQuery.exec()) {
ENGINE_LOG_ERROR << "QUERY ERROR WHEN CLEANING UP FILES"; ENGINE_LOG_ERROR << "QUERY ERROR WHEN CLEANING UP FILES";
...@@ -1804,9 +1744,7 @@ namespace meta { ...@@ -1804,9 +1744,7 @@ namespace meta {
"file_type = " << std::to_string(TableFileSchema::TO_INDEX) << " OR " << "file_type = " << std::to_string(TableFileSchema::TO_INDEX) << " OR " <<
"file_type = " << std::to_string(TableFileSchema::INDEX) << ");"; "file_type = " << std::to_string(TableFileSchema::INDEX) << ");";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::Count: " << countQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::Count: " << countQuery.str();
}
res = countQuery.store(); res = countQuery.store();
} //Scoped Connection } //Scoped Connection
...@@ -1851,9 +1789,7 @@ namespace meta { ...@@ -1851,9 +1789,7 @@ namespace meta {
Query dropTableQuery = connectionPtr->query(); Query dropTableQuery = connectionPtr->query();
dropTableQuery << "DROP TABLE IF EXISTS Tables, TableFiles;"; dropTableQuery << "DROP TABLE IF EXISTS Tables, TableFiles;";
if (options_.sql_echo) { ENGINE_LOG_DEBUG << "MySQLMetaImpl::DropAll: " << dropTableQuery.str();
ENGINE_LOG_DEBUG << "MySQLMetaImpl::DropAll: " << dropTableQuery.str();
}
if (dropTableQuery.exec()) { if (dropTableQuery.exec()) {
return Status::OK(); return Status::OK();
......
cpp/src/db/Options.h
浏览文件 @ 817e8f25
...@@ -45,7 +45,6 @@ struct DBMetaOptions { ...@@ -45,7 +45,6 @@ struct DBMetaOptions {
std::string path; std::string path;
std::string backend_uri; std::string backend_uri;
ArchiveConf archive_conf = ArchiveConf("delete"); ArchiveConf archive_conf = ArchiveConf("delete");
bool sql_echo = false;
}; // DBMetaOptions }; // DBMetaOptions
struct Options { struct Options {
......
cpp/src/server/DBWrapper.cpp
浏览文件 @ 817e8f25
...@@ -23,17 +23,6 @@ DBWrapper::DBWrapper() { ...@@ -23,17 +23,6 @@ DBWrapper::DBWrapper() {
if(index_size > 0) {//ensure larger than zero, unit is MB if(index_size > 0) {//ensure larger than zero, unit is MB
opt.index_trigger_size = (size_t)index_size * engine::ONE_MB; opt.index_trigger_size = (size_t)index_size * engine::ONE_MB;
} }
std::string sql_echo = config.GetValue(CONFIG_DB_SQL_ECHO, "off");
if (sql_echo == "on") {
opt.meta.sql_echo = true;
}
else if (sql_echo == "off") {
opt.meta.sql_echo = false;
}
else {
std::cout << "ERROR: sql_echo specified in db_config is not one of ['on', 'off']" << std::endl;
kill(0, SIGUSR1);
}
ConfigNode& serverConfig = ServerConfig::GetInstance().GetConfig(CONFIG_SERVER); ConfigNode& serverConfig = ServerConfig::GetInstance().GetConfig(CONFIG_SERVER);
std::string mode = serverConfig.GetValue(CONFIG_CLUSTER_MODE, "single"); std::string mode = serverConfig.GetValue(CONFIG_CLUSTER_MODE, "single");
......
cpp/src/server/ServerConfig.h
浏览文件 @ 817e8f25
...@@ -27,7 +27,6 @@ static const std::string CONFIG_DB_PATH = "db_path"; ...@@ -27,7 +27,6 @@ static const std::string CONFIG_DB_PATH = "db_path";
static const std::string CONFIG_DB_INDEX_TRIGGER_SIZE = "index_building_threshold"; static const std::string CONFIG_DB_INDEX_TRIGGER_SIZE = "index_building_threshold";
static const std::string CONFIG_DB_ARCHIVE_DISK = "archive_disk_threshold"; static const std::string CONFIG_DB_ARCHIVE_DISK = "archive_disk_threshold";
static const std::string CONFIG_DB_ARCHIVE_DAYS = "archive_days_threshold"; static const std::string CONFIG_DB_ARCHIVE_DAYS = "archive_days_threshold";
static const std::string CONFIG_DB_SQL_ECHO = "sql_echo";
static const std::string CONFIG_LOG = "log_config"; static const std::string CONFIG_LOG = "log_config";
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或