This commit is contained in:
Alexey Milovidov 2013-06-25 12:19:10 +00:00
parent 356f394db0
commit a5fc5c235e

View File

@ -175,7 +175,19 @@ protected:
column.name = *it;
column.type = storage.getDataTypeByName(*it);
column.column = column.type->createColumn();
try
{
readData(*it, *column.type, *column.column, max_rows_to_read);
}
catch (const Exception & e)
{
/// Более хорошая диагностика.
if (e.code() == ErrorCodes::CHECKSUM_DOESNT_MATCH || e.code() == ErrorCodes::TOO_LARGE_SIZE_COMPRESSED)
throw Exception(e.message() + " (while reading column " + *it + " from part " + path + ")", e.code());
else
throw;
}
if (column.column->size())
res.insert(column);