Skip to content

Commit 33e82d5

Browse files
committed
Respect the DecodeOpts inside a transaction
1 parent 309df00 commit 33e82d5

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

src/pog_ffi.erl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,8 @@ start(Config) ->
8585
query(Pool, Sql, Arguments, Timeout) ->
8686
Res = case Pool of
8787
{single_connection, Conn} ->
88-
pgo_handler:extended_query(Conn, Sql, Arguments, #{});
88+
DecodeOpts = element(11, Conn),
89+
pgo_handler:extended_query(Conn, Sql, Arguments, DecodeOpts, #{});
8990
{pool, Name} ->
9091
Options = #{
9192
pool => Name,
@@ -102,7 +103,8 @@ query(Pool, Sql, Arguments, Timeout) ->
102103
end.
103104

104105
query_extended(Conn, Sql) ->
105-
case pgo_handler:extended_query(Conn, Sql, [], #{queue_time => undefined}) of
106+
DecodeOpts = element(11, Conn),
107+
case pgo_handler:extended_query(Conn, Sql, [], DecodeOpts, #{queue_time => undefined}) of
106108
#{rows := Rows, num_rows := NumRows} ->
107109
{ok, {NumRows, Rows}};
108110

0 commit comments

Comments
 (0)