anchor.diff:                   execute ->
                        reply(State, Result);
                    C when C == squery; C == equery ->
  -                     State#state{columns = [],
  -                                 rows = [],
  -                                 results = [Result | State#state.results]}
  +                     add_result(State, Result)
                end,
       {noreply, State2};
   
  
positive.code:                 rows = [],
                  results = []}.
  
  notify_async(#state{async = Pid}, Msg) ->
      case is_pid(Pid) of
          true  -> Pid ! {pgsql, self(), Msg};
  
negative.code: on_message(Error = {error, _}, State) ->
      State2 = case command_tag(State) of
                   C when C == squery; C == equery ->
                       add_result(State, Error);
                   _ ->
                       sync_required(reply(State, Error))
               end,
  