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

check only selected columns against destination table

Browse Source
This commit is contained in:
Yakov Olkhovskiy 2022-04-12 09:29:32 -04:00
parent dc314d53b3
commit 25101de7e2
1 changed files with 15 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/Interpreters/InterpreterCreateQuery.cpp
View File

@ -1074,28 +1074,25 @@ BlockIO InterpreterCreateQuery::createTable(ASTCreateQuery & create)
/// Check type compatible for materialized dest table and select columns
if (create.select && create.is_materialized_view && create.to_table_id)
{
StoragePtr to_table = DatabaseCatalog::instance().getTable({create.to_table_id.database_name,
create.to_table_id.table_name,
create.to_table_id.uuid},
getContext());
const auto & to_output_columns = to_table->getInMemoryMetadataPtr()->getSampleBlock();
ColumnsWithTypeAndName view_output_columns;
for (const auto & [name, type] : properties.columns.getAllPhysical())
view_output_columns.emplace_back(type, name);
Block input_columns = InterpreterSelectWithUnionQuery(
Block input_block = InterpreterSelectWithUnionQuery(
create.select->clone(), getContext(), SelectQueryOptions().analyze()).getSampleBlock();
ActionsDAG::makeConvertingActions(
input_columns.getColumnsWithTypeAndName(),
view_output_columns,
ActionsDAG::MatchColumnsMode::Name);
StoragePtr to_table = DatabaseCatalog::instance().getTable(
{create.to_table_id.database_name, create.to_table_id.table_name, create.to_table_id.uuid},
getContext()
);
Block to_columns = to_table->getInMemoryMetadataPtr()->getSampleBlock();
ColumnsWithTypeAndName output_columns;
for (const auto & column : input_block)
output_columns.push_back(to_columns.findByName(column.name)->cloneEmpty());
ActionsDAG::makeConvertingActions(
view_output_columns,
to_output_columns.getColumnsWithTypeAndName(),
ActionsDAG::MatchColumnsMode::Name);
input_block.getColumnsWithTypeAndName(),
output_columns,
ActionsDAG::MatchColumnsMode::Name
);
}
DatabasePtr database;