Skip to content

Commit e8ad992

Browse files
committed
No retries on handle_declare, as it requires a transaction
1 parent ce227e0 commit e8ad992

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

lib/db_connection.ex

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -312,14 +312,13 @@ defmodule DBConnection do
312312
Declare a cursor using a query prepared by `c:handle_prepare/3`. Return
313313
`{:ok, query, cursor, state}` to return altered query `query` and cursor
314314
`cursor` for a stream and continue, `{:error, exception, state}` to return an
315-
error and continue or `{:disconnect | :disconnect_and_retry, exception, state}`
316-
to error and disconnect (and optionally retry).
315+
error and continue or `{:disconnect, exception, state}` to error and disconnect.
317316
318317
This callback is called in the client process.
319318
"""
320319
@callback handle_declare(query, params, opts :: Keyword.t(), state :: any) ::
321320
{:ok, query, cursor, new_state :: any}
322-
| {:error | :disconnect | :disconnect_and_retry, Exception.t(), new_state :: any}
321+
| {:error | :disconnect, Exception.t(), new_state :: any}
323322

324323
@doc """
325324
Fetch the next result from a cursor declared by `c:handle_declare/4`. Return
@@ -1933,7 +1932,7 @@ defmodule DBConnection do
19331932
bad_return!(other, conn, meter)
19341933

19351934
other ->
1936-
retry_or_handle_common_result(other, conn, meter)
1935+
handle_common_result(other, conn, meter)
19371936
end
19381937
end
19391938

0 commit comments

Comments
 (0)