Merge pull request #236 from hkrutzer/fix_missing_written_rows

Handle missing written_rows in insert
plausible · Feb 3, 2025 · 220b2a2 · 220b2a2
2 parents 1789543 + c600a85
commit 220b2a2
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/lib/ch/query.ex b/lib/ch/query.ex
@@ -158,8 +158,11 @@ defimpl DBConnection.Query, for: Ch.Query do
 
     num_rows =
       if summary = get_header(headers, "x-clickhouse-summary") do
-        %{"written_rows" => written_rows} = Jason.decode!(summary)
-        String.to_integer(written_rows)
+        summary = Jason.decode!(summary)
+
+        if written_rows = Map.get(summary, "written_rows") do
+          String.to_integer(written_rows)
+        end
       end
 
     %Result{num_rows: num_rows, rows: nil, command: :insert, headers: headers}