anchor.diff:      end.
   
   create_table(Conn, TableName, TableDefinition) when is_atom(TableName) ->
  -    Res = pgsql:squery(Conn, ["CREATE TABLE ", atom_to_list(TableName), " ( ", tabledefinition_to_sql(TableDefinition), " )"]),
  +    Res = epgsql:squery(Conn, ["CREATE TABLE ", atom_to_list(TableName), " ( ", tabledefinition_to_sql(TableDefinition), " )"]),
       case Res of
           {ok, [], []} ->
               ok;
  
positive.code:     end.
  
  migration_done(Conn, Tag, up) ->
      Res = pgsql:equery(Conn, "INSERT INTO schema_migrations (version, migrated_at) values ($1, current_timestamp)",
                         [atom_to_list(Tag)]),
      case Res of
          {ok, _ResultRows} ->
  
negative.code:             {error, Reason}
      end;
  migration_done(Conn, Tag, down) ->
      Res = epgsql:equery(Conn, "DELETE FROM schema_migrations WHERE version = $1", [atom_to_list(Tag)]),
      case Res of
          {ok, _Result} ->
              ok;
  