Upgraded to pgx

This commit is contained in:
Magnus Åhall 2025-09-23 21:47:39 +02:00
parent 825cf0fc9a
commit ad601219ec
3 changed files with 66 additions and 49 deletions

View file

@ -1,8 +1,11 @@
package dbschema
import (
// External
"github.com/jackc/pgx/v5/pgxpool"
// Standard
"database/sql"
"context"
"fmt"
)
@ -13,10 +16,10 @@ func newDatabase(host string, port int, dbName, user, pass string) (dbase Databa
dbase.Username = user
dbase.Password = pass
dbase.db, err = sql.Open("postgres", dbase.sqlConnString())
dbase.db, err = pgxpool.New(context.Background(), dbase.sqlConnString())
return
}// }}}
func databaseFromInstance(db *sql.DB) (dbase Database, err error) {
func databaseFromInstance(db *pgxpool.Pool) (dbase Database, err error) {
dbase.db = db
return
}