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

Apply suggestion

Browse Source
This commit is contained in:
avogar 2023-09-18 18:41:04 +00:00
parent 5bd2e9f610
commit f974970c3c
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/Processors/Formats/Impl/JSONRowInputFormat.cpp
View File

@ -40,16 +40,27 @@ void JSONRowInputFormat::readPrefix()
JSONUtils::skipArrayStart(*peekable_buf); JSONUtils::skipArrayStart(*peekable_buf);
data_in_square_brackets = true; data_in_square_brackets = true;
} }
catch (...) catch (const ParsingException &)
{
parse_as_json_each_row = true;
}
catch (const Exception & e)
{
if (e.code() != ErrorCodes::INCORRECT_DATA)
throw;
parse_as_json_each_row = true;
}
if (parse_as_json_each_row)
{ {
peekable_buf->rollbackToCheckpoint(); peekable_buf->rollbackToCheckpoint();
JSONEachRowRowInputFormat::readPrefix(); JSONEachRowRowInputFormat::readPrefix();
parse_as_json_each_row = true;
return;
} }
else if (validate_types_from_metadata)
if (validate_types_from_metadata) {
JSONUtils::validateMetadataByHeader(names_and_types_from_metadata, getPort().getHeader()); JSONUtils::validateMetadataByHeader(names_and_types_from_metadata, getPort().getHeader());
}
} }
void JSONRowInputFormat::readSuffix() void JSONRowInputFormat::readSuffix()