@@ -10,7 +10,6 @@ import (
1010 "github.com/pkg/errors"
1111 "github.com/uptrace/bun"
1212 "github.com/uptrace/bun/dialect/pgdialect"
13- "github.com/uptrace/bun/driver/pgdriver"
1413)
1514
1615// Bun -
@@ -35,16 +34,26 @@ func (db *Bun) Connect(ctx context.Context, cfg config.Database) error {
3534 return errors .Wrap (ErrUnsupportedDatabaseType , cfg .Kind )
3635 }
3736 if cfg .Path != "" {
38- db .sqldb = sql .OpenDB (pgdriver .NewConnector (pgdriver .WithDSN (cfg .Path )))
37+ conn , err := sql .Open ("postgres" , cfg .Path )
38+ if err != nil {
39+ return err
40+ }
41+ db .sqldb = conn
3942 db .conn = bun .NewDB (db .sqldb , pgdialect .New ())
4043 } else {
41- db .sqldb = sql .OpenDB (pgdriver .NewConnector (
42- pgdriver .WithAddr (fmt .Sprintf ("%s:%d" , cfg .Host , cfg .Port )),
43- pgdriver .WithDatabase (cfg .Database ),
44- pgdriver .WithPassword (cfg .Password ),
45- pgdriver .WithUser (cfg .User ),
46- pgdriver .WithInsecure (true ),
47- ))
44+ connStr := fmt .Sprintf (
45+ "postgres://%s:%s@%s:%d/%s?sslmode=disable" ,
46+ cfg .User ,
47+ cfg .Password ,
48+ cfg .Host ,
49+ cfg .Port ,
50+ cfg .Database ,
51+ )
52+ conn , err := sql .Open ("postgres" , connStr )
53+ if err != nil {
54+ return err
55+ }
56+ db .sqldb = conn
4857 db .conn = bun .NewDB (db .sqldb , pgdialect .New ())
4958 }
5059 maxOpenConns := 4 * runtime .GOMAXPROCS (0 )
0 commit comments