thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-28 20:50:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

ISSUES-4006 fix test failure

Browse Source
This commit is contained in:
zhang2014 2020-07-14 11:05:17 +08:00
parent f5b66810ce
commit eace0153bd
3 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/Databases/DatabaseFactory.cpp
View File

@ -133,7 +133,8 @@ DatabasePtr DatabaseFactory::getImpl(const ASTCreateQuery & create, const String
, std::move(materialize_mode_settings)); , std::move(materialize_mode_settings));
} }
return std::make_shared<DatabaseConnectionMySQL>(context, database_name, metadata_path, engine_define, mysql_database_name, std::move(mysql_pool)); return std::make_shared<DatabaseConnectionMySQL>(
context, database_name, metadata_path, engine_define, mysql_database_name, std::move(mysql_pool));
} }
catch (...) catch (...)
{ {

1
src/Databases/MySQL/DatabaseConnectionMySQL.cpp
View File

@ -71,6 +71,7 @@ DatabaseConnectionMySQL::DatabaseConnectionMySQL(
, mysql_pool(std::move(pool)) , mysql_pool(std::move(pool))
{ {
empty(); /// test database is works fine. empty(); /// test database is works fine.
thread = ThreadFromGlobalPool{&DatabaseConnectionMySQL::cleanOutdatedTables, this};
} }
bool DatabaseConnectionMySQL::empty() const bool DatabaseConnectionMySQL::empty() const

2
src/Databases/MySQL/DatabaseConnectionMySQL.h
View File

@ -91,7 +91,7 @@ private:
void fetchLatestTablesStructureIntoCache(const std::map<String, UInt64> & tables_modification_time) const; void fetchLatestTablesStructureIntoCache(const std::map<String, UInt64> & tables_modification_time) const;
ThreadFromGlobalPool thread{&DatabaseConnectionMySQL::cleanOutdatedTables, this}; ThreadFromGlobalPool thread;
}; };
} }