fix: Throw an error if CSV is malformed (#49)

Co-authored-by: Romuald Rousseau <[email protected]>
RomualdRousseau · Nov 13, 2024 · c40223d · c40223d
1 parent cf63ee0
commit c40223d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/archery-csv/src/main/java/com/github/romualdrousseau/archery/loader/csv/CsvSheet.java b/archery-csv/src/main/java/com/github/romualdrousseau/archery/loader/csv/CsvSheet.java
@@ -129,8 +129,8 @@ private DataFrame processRows(final BufferedReader reader, final DataFrameWriter
 
     private String[] parseOneRow(final String data, final String separator) {
         final var result = new ArrayList<String>();
-        var acc = "";
         var state = 0;
+        var acc = "";
 
         final char[] tmp = data.toCharArray();
         for (int i = 0; i < tmp.length; i++) {
@@ -173,6 +173,10 @@ private String[] parseOneRow(final String data, final String separator) {
             }
         }
 
+        if (state == 1) {
+            throw new RuntimeException(String.format("Malformed CSV: %s", data));
+        }
+
         if (!acc.trim().equals("")) {
             result.add(acc);
         }