|
@@ -455,7 +455,9 @@ on_message({$D, <<_Count:?int16, Bin/binary>>}, State) ->
|
|
State#state.columns
|
|
State#state.columns
|
|
end,
|
|
end,
|
|
Data = pgsql_wire:decode_data(Columns, Bin),
|
|
Data = pgsql_wire:decode_data(Columns, Bin),
|
|
- {noreply, State#state{rows = [Data | State#state.rows]}};
|
|
|
|
|
|
+ {noreply, State#state{rows = [Data | State#state.rows],
|
|
|
|
+ columns = Columns %TODO workaround for equery,execute
|
|
|
|
+ }};
|
|
|
|
|
|
%% PortalSuspended
|
|
%% PortalSuspended
|
|
on_message({$s, <<>>}, State) ->
|
|
on_message({$s, <<>>}, State) ->
|