changed way pgx connects

This commit is contained in:
2021-10-21 19:44:36 +02:00
parent 70b0f66fb1
commit 18282afcf6

View File

@@ -719,15 +719,10 @@ func main() {
if conf.Db.Driver == "pgx" { if conf.Db.Driver == "pgx" {
pdb, err := sql.Open("pgx", conf.Db.ConnectTo) pdb, err := sql.Open("pgx", conf.Db.ConnectTo)
if err != nil { if err != nil {
log.Panicf("Failed to open database %s: %v", conf.Db.ConnectTo, err) log.Fatalf("Failed to open database %s: %v", conf.Db.ConnectTo, err)
} }
defer func(db *sql.Driver) { db.Client = ent.NewClient(ent.Driver(pdb))
_ = db.Close()
}(pdb)
drv := sql.OpenDB("postgres", pdb.DB())
db.Client = ent.NewClient(ent.Driver(drv))
} else { } else {
db.Client, err = ent.Open(conf.Db.Driver, conf.Db.ConnectTo) db.Client, err = ent.Open(conf.Db.Driver, conf.Db.ConnectTo)
if err != nil { if err != nil {