From 900e1c1ed346440d1989ac80b42a2798ece5f1e5 Mon Sep 17 00:00:00 2001
From: Zach Daniel <zach@zachdaniel.dev>
Date: Sun, 5 Apr 2026 18:13:39 -0400
Subject: [PATCH] accept counter option in to_sql/4 and pass it to
 prepare_query/4

---
 lib/ecto/adapters/sql.ex | 18 ++++++++++++------
 1 file changed, 12 insertions(+), 6 deletions(-)

diff --git a/lib/ecto/adapters/sql.ex b/lib/ecto/adapters/sql.ex
index f7a557c6..88d3d913 100644
--- a/lib/ecto/adapters/sql.ex
+++ b/lib/ecto/adapters/sql.ex
@@ -492,10 +492,16 @@ defmodule Ecto.Adapters.SQL do
   """
 
   @doc @to_sql_doc
-  @spec to_sql(:all | :update_all | :delete_all, Ecto.Repo.t(), Ecto.Queryable.t()) ::
+  @spec to_sql(:all | :update_all | :delete_all, Ecto.Repo.t(), Ecto.Queryable.t(), Keyword.t()) ::
           {String.t(), query_params}
-  def to_sql(kind, repo, queryable) do
-    case Ecto.Adapter.Queryable.prepare_query(kind, repo, queryable) do
+  def to_sql(kind, repo, queryable, opts \\ []) do
+    prepare_opts =
+      case Keyword.fetch(opts, :counter) do
+        {:ok, counter} -> [counter: counter]
+        :error -> []
+      end
+
+    case Ecto.Adapter.Queryable.prepare_query(kind, repo, queryable, prepare_opts) do
       {{:cached, _update, _reset, {_id, cached}}, params} ->
         {String.Chars.to_string(cached), params}
 
@@ -825,10 +831,10 @@ defmodule Ecto.Adapters.SQL do
       end
 
       @doc unquote(to_sql_doc)
-      @spec to_sql(:all | :update_all | :delete_all, Ecto.Queryable.t()) ::
+      @spec to_sql(:all | :update_all | :delete_all, Ecto.Queryable.t(), Keyword.t()) ::
               {String.t(), Ecto.Adapters.SQL.query_params()}
-      def to_sql(operation, queryable) do
-        Ecto.Adapters.SQL.to_sql(operation, get_dynamic_repo(), queryable)
+      def to_sql(operation, queryable, opts \\ []) do
+        Ecto.Adapters.SQL.to_sql(operation, get_dynamic_repo(), queryable, opts)
       end
 
       @doc unquote(explain_doc)