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

dbms: Server: add optimization in InterpreterSelectQuery initialization. [#METR-14099]

Browse Source
This commit is contained in:
Alexey Arno 2014-12-24 17:05:55 +03:00
parent b0256d0990
commit 008668b3da
1 changed files with 17 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
dbms/src/Interpreters/InterpreterSelectQuery.cpp
View File

@ -35,15 +35,24 @@ namespace DB
void InterpreterSelectQuery::init(BlockInputStreamPtr input, const Names & required_column_names, const NamesAndTypesList & table_column_names)
{
/// В случае цепочки UNION ALL функуция rewriteExpressionList() может выкинуть исключение,
/// если не вызвали до этого функцию renameColumns(). Поэтому сначала выполняется инициализация.
/// После вызова rewriteExpressionList(), имеется устаревшая информация для выполнения запроса.
/// Тогда необходимо сделать повторную инициализацию.
basic_init(true, input, table_column_names);
if (!required_column_names.empty())
if (isFirstSelectInsideUnionAll())
{
rewriteExpressionList(required_column_names);
basic_init(false, input, table_column_names);
/// В случае цепочки UNION ALL функуция rewriteExpressionList() может выкинуть исключение,
/// если не вызвали до этого функцию renameColumns(). Поэтому сначала выполняется инициализация.
basic_init(true, input, table_column_names);
if (!required_column_names.empty() && (context.getColumns().size() != required_column_names.size()))
{
rewriteExpressionList(required_column_names);
/// После вызова rewriteExpressionList(), имеется устаревшая информация для выполнения запроса.
/// Тогда необходимо сделать повторную инициализацию.
basic_init(false, nullptr, table_column_names);
}
}
else
{
if (!required_column_names.empty())
rewriteExpressionList(required_column_names);
basic_init(true, input, table_column_names);
}
}