thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-22 07:31:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Allow to insert from any format

Browse Source
This commit is contained in:
alesapin 2019-02-07 16:58:36 +03:00
parent 48bd750856
commit b0a77ff3f7
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbms/src/Interpreters/InterpreterInsertQuery.cpp
View File

@ -146,7 +146,11 @@ BlockIO InterpreterInsertQuery::execute()
else if (query.data)
{
auto data_in = std::make_unique<ReadBufferFromMemory>(query.data, query.end - query.data);
res.in = context.getInputFormat("Values", *data_in, table->getSampleBlock(), context.getSettingsRef().max_insert_block_size);
std::string format = "Values";
if (!query.format.empty())
format = query.format;
res.in = context.getInputFormat(format, *data_in, table->getSampleBlock(), context.getSettingsRef().max_insert_block_size);
res.in = std::make_shared<OwningBlockInputStream<ReadBufferFromMemory>>(res.in, std::move(data_in));
res.in = std::make_shared<NullAndDoCopyBlockInputStream>(res.in, res.out);