stub stream support (#36)

plausible · Apr 17, 2023 · 70884e4 · 70884e4
1 parent 73c0fc3
commit 70884e4
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/lib/ecto/adapters/clickhouse/connection.ex b/lib/ecto/adapters/clickhouse/connection.ex
@@ -25,6 +25,7 @@ defmodule Ecto.Adapters.ClickHouse.Connection do
     DBConnection.execute(conn, query, params, opts)
   end
 
+  # TODO what should be done about transactions? probably will need to build custom Repo.stream
   @impl true
   def query(conn, statement, params, opts) do
     Ch.query(conn, statement, params, opts)
@@ -36,8 +37,8 @@ defmodule Ecto.Adapters.ClickHouse.Connection do
   end
 
   @impl true
-  def stream(_conn, _statement, _params, _opts) do
-    raise "ClickHouse does not support cursors"
+  def stream(conn, statement, params, opts) do
+    Ch.stream(conn, statement, params, opts)
   end
 
   @impl true