anchor.diff:  %% @end
   %%
   query(Connection, SQL) ->
  -  case pgsql:squery(Connection, SQL) of
  -    {ok, _Columns, _Rows} -> ok;
  +  case epgsql:squery(Connection, SQL) of
  +    {ok, _} -> ok;
  +    {ok, _, _} -> ok;
  +    {ok, _, _, _} -> ok;
       {error, Error} -> {error, Error}
     end.
  
positive.code: %% @end
  %%
  close(Conn) ->
    pgsql:close(Conn).
  
  %% @spec connect(DSN) -> Result
  %% @doc Create a new PostgreSQL connection
  
negative.code: %%
  connect(#pgsql_listen_dsn{host=Host, port=Port, user=User,
                            password=Password, dbname=DBName}) ->
     epgsql:connect(Host, User, Password, [{database, DBName},
                                           {port, Port},
                                           {timeout, 2500},
                                           {async, self()}]).
  
  %% @spec listen(Connection, Channel) -> Result
  %% @where
  