thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-26 09:32:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

do CREATE query async

Browse Source
This commit is contained in:
serxa 2023-09-13 19:34:18 +00:00
parent 93cf15dba2
commit 2920f04fff
1 changed files with 15 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/Interpreters/InterpreterCreateQuery.cpp
View File

@ -15,6 +15,7 @@
#include <Core/Defines.h> #include <Core/Defines.h>
#include <Core/SettingsEnums.h> #include <Core/SettingsEnums.h>
#include <Core/ServerSettings.h>
#include <IO/WriteBufferFromFile.h> #include <IO/WriteBufferFromFile.h>
#include <IO/WriteHelpers.h> #include <IO/WriteHelpers.h>
@ -324,8 +325,20 @@ BlockIO InterpreterCreateQuery::createDatabase(ASTCreateQuery & create)
{ {
/// We use global context here, because storages lifetime is bigger than query context lifetime /// We use global context here, because storages lifetime is bigger than query context lifetime
TablesLoader loader{getContext()->getGlobalContext(), {{database_name, database}}, mode}; TablesLoader loader{getContext()->getGlobalContext(), {{database_name, database}}, mode};
waitLoad(currentPoolOr(AsyncLoaderPoolId::Foreground), loader.loadTablesAsync()); auto load_tasks = loader.loadTablesAsync();
waitLoad(currentPoolOr(AsyncLoaderPoolId::Foreground), loader.startupTablesAsync()); auto startup_tasks = loader.startupTablesAsync();
if (getContext()->getGlobalContext()->getServerSettings().async_load_databases)
{
scheduleLoad(load_tasks);
scheduleLoad(startup_tasks);
}
else
{
/// First prioritize, schedule and wait all the load table tasks
waitLoad(currentPoolOr(AsyncLoaderPoolId::Foreground), load_tasks);
/// Only then prioritize, schedule and wait all the startup tasks
waitLoad(currentPoolOr(AsyncLoaderPoolId::Foreground), startup_tasks);
}
} }
} }
catch (...) catch (...)