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

Update InterpreterInsertQuery.cpp

Browse Source
This commit is contained in:
alexey-milovidov 2018-11-20 21:36:13 +03:00 committed by GitHub
parent 8ff62c9da6
commit 596e136b73
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -156,7 +156,8 @@ BlockIO InterpreterInsertQuery::execute()
String uristr = typeid_cast<const ASTLiteral &>(*query.in_file).value.safeGet<String>();
// create Datastream based on Format:
String format = query.format;
if (format.empty()) format = "Values";
if (format.empty())
format = context.getDefaultFormat();
auto & settings = context.getSettingsRef();
@ -177,20 +178,20 @@ BlockIO InterpreterInsertQuery::execute()
Poco::URI uri(uriPrefix);
String scheme = uri.getScheme();
std::vector<String> fuzzyNameList = parseDescription(fuzzyFileNames, 0, fuzzyFileNames.length(), ',' , 100/* hard coded max files */);
std::vector<String> fuzzyNameList = parseDescription(fuzzyFileNames, 0, fuzzyFileNames.length(), ',', 100/* hard coded max files */);
std::vector<std::vector<String> > fileNames;
for(auto fuzzyName : fuzzyNameList)
for (const auto & fuzzyName : fuzzyNameList)
fileNames.push_back(parseDescription(fuzzyName, 0, fuzzyName.length(), '|', 100));
BlockInputStreams inputs;
for (auto & vecNames : fileNames)
for (const auto & vecNames : fileNames)
{
for (auto & name: vecNames)
for (const auto & name : vecNames)
{
std::unique_ptr<ReadBuffer> read_buf = nullptr;
std::unique_ptr<ReadBuffer> read_buf;
if (scheme.empty() || scheme == "file")
{