Fix

Author: Gazizonoki

ydb/public/lib/ydb_cli/common/csv_parser.cpp

@@ -14,7 +14,7 @@ class TCsvParseException : public TMisuseException {
         if (ColumnName.has_value()) {
             *this << "Csv parsing error on line " << Line << " in column \"" << ColumnName << "\": ";
         } else {
-            *this << "Csv parsing error on line " << Line << "\": ";
+            *this << "Csv parsing error on line " << Line << ": ";
         }
     }
 
@@ -323,11 +323,19 @@ TValue TCsvParser::FieldToValue(TTypeParser& parser, TStringBuf token) const {
     return converter.Convert(token);
 }
 
+TStringBuf TCsvParser::Consume(NCsvFormat::CsvSplitter& splitter) const {
+    try {
+        return splitter.Consume();
+    } catch (std::exception& e) {
+        throw TCsvParseException() << e.what();
+    }
+}
+
 void TCsvParser::GetParams(TString&& data, TParamsBuilder& builder) const {
     NCsvFormat::CsvSplitter splitter(data, Delimeter);
     auto headerIt = Header.begin();
     do {
-        TStringBuf token = splitter.Consume();
+        TStringBuf token = Consume(splitter);
         if (headerIt == Header.end()) {
             throw TCsvParseException() << "Header contains less fields than data. Header: \"" << HeaderRow << "\", data: \"" << data << "\"";
         }
@@ -362,7 +370,7 @@ void TCsvParser::GetValue(TString&& data, TValueBuilder& builder, const TType& t
     auto headerIt = Header.cbegin();
     std::map<TString, TStringBuf> fields;
     do {
-        TStringBuf token = splitter.Consume();
+        TStringBuf token = Consume(splitter);;
         if (headerIt == Header.cend()) {
             throw TCsvParseException() << "Header contains less fields than data. Header: \"" << HeaderRow << "\", data: \"" << data << "\"";
         }

ydb/public/lib/ydb_cli/common/csv_parser.h

@@ -27,6 +27,7 @@ class TCsvParser {
     void GetParams(TString&& data, TParamsBuilder& builder) const;
     void GetValue(TString&& data, TValueBuilder& builder, const TType& type) const;
     TType GetColumnsType() const;
+    TStringBuf Consume(NCsvFormat::CsvSplitter& splitter) const;
 
 private:
     TValue FieldToValue(TTypeParser& parser, TStringBuf token) const;