thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-17 13:13:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

ISSUES-16835 try fix test

Browse Source
This commit is contained in:
zhang2014 2020-11-25 23:52:30 +08:00
parent 6701dfe369
commit 9e5253c9fa
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/Formats/MySQLBlockInputStream.cpp
View File

@ -146,7 +146,8 @@ Block MySQLBlockInputStream::readImpl()
}
else
{
Names missing_names = description.sample_block.getNames();
const auto & sample_names = description.sample_block.getNames();
std::unordered_set<std::string> missing_names(sample_names.begin(), sample_names.end());
for (const auto idx : ext::range(0, row.size()))
{
@ -155,19 +156,23 @@ Block MySQLBlockInputStream::readImpl()
{
const auto & position = description.sample_block.getPositionByName(field_name);
position_mapping[position] = idx;
missing_names.erase(missing_names.begin() + position);
missing_names.erase(field_name);
}
}
if (!missing_names.empty())
{
WriteBufferFromOwnString exception_message;
writeText(missing_names, exception_message);
for (auto iter = missing_names.begin(); iter != missing_names.end(); ++iter)
{
if (iter != missing_names.begin())
exception_message << ", ";
exception_message << *iter;
}
throw Exception("mysqlxx::UseQueryResult must be contain the" + exception_message.str() + " columns.",
ErrorCodes::NUMBER_OF_COLUMNS_DOESNT_MATCH);
}
}
}