Handle missing written_rows in insert

plausible · Feb 3, 2025 · c600a85 · c600a85
1 parent 9f5a7e7
commit c600a85
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}