|
@@ -32,7 +32,7 @@
|
|
-record(squery,
|
|
-record(squery,
|
|
{query :: iodata(),
|
|
{query :: iodata(),
|
|
columns = [],
|
|
columns = [],
|
|
- decoder}).
|
|
|
|
|
|
+ decoder = undefined :: epgsql_wire:row_decoder() | undefined}).
|
|
|
|
|
|
init(Sql) ->
|
|
init(Sql) ->
|
|
#squery{query = Sql}.
|
|
#squery{query = Sql}.
|
|
@@ -63,7 +63,8 @@ handle_message(?COMMAND_COMPLETE, Bin, Sock, #squery{columns = Cols} = St) ->
|
|
_ ->
|
|
_ ->
|
|
{ok, Cols, Rows}
|
|
{ok, Cols, Rows}
|
|
end,
|
|
end,
|
|
- {add_result, Result, {complete, Complete}, Sock, St#squery{columns = []}};
|
|
|
|
|
|
+ {add_result, Result, {complete, Complete}, Sock, St#squery{columns = [],
|
|
|
|
+ decoder = undefined}};
|
|
handle_message(?EMPTY_QUERY, _, Sock, St) ->
|
|
handle_message(?EMPTY_QUERY, _, Sock, St) ->
|
|
{add_result, {ok, [], []}, {complete, empty}, Sock, St};
|
|
{add_result, {ok, [], []}, {complete, empty}, Sock, St};
|
|
handle_message(?READY_FOR_QUERY, _Status, Sock, _State) ->
|
|
handle_message(?READY_FOR_QUERY, _Status, Sock, _State) ->
|