diff options
| author | Stefan Majewsky <majewsky@gmx.net> | 2026-09-17 16:08:15 +0200 |
|---|---|---|
| committer | Stefan Majewsky <majewsky@gmx.net> | 2026-09-17 16:08:49 +0200 |
| commit | c148274afefae3c9dce478076422f5e0fad4e902 (patch) | |
| tree | 33da4ef037b7f4d936663eccbdda45baf2c57138 /connector.go | |
| parent | 6f9d4966728f36c1eeceb0527c2e40b304a05d7a (diff) | |
| download | go-gg-pgx-c148274afefae3c9dce478076422f5e0fad4e902.tar.gz | |
bump gg to 0.15.0
Diffstat (limited to 'connector.go')
| -rw-r--r-- | connector.go | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/connector.go b/connector.go index 1914ddb..e24ff61 100644 --- a/connector.go +++ b/connector.go @@ -13,16 +13,24 @@ import ( // SingleConnector returns a [pgruntime.Connector] that spawns individual database connections. func SingleConnector() pgruntime.Connector[*Conn] { - return func(ctx context.Context, dbURL string) (*Conn, error) { - conn, err := pgx.Connect(ctx, dbURL) + return func(ctx context.Context, target pgruntime.ConnectionTarget) (*Conn, error) { + dbURL, err := target.IntoURL() + if err != nil { + return nil, err + } + conn, err := pgx.Connect(ctx, dbURL.String()) return maybe(NewConn, conn), err } } // PoolConnector returns a [pgruntime.Connector] that spawns database connection pools. func PoolConnector() pgruntime.Connector[*Pool] { - return func(ctx context.Context, dbURL string) (*Pool, error) { - pool, err := pgxpool.New(ctx, dbURL) + return func(ctx context.Context, target pgruntime.ConnectionTarget) (*Pool, error) { + dbURL, err := target.IntoURL() + if err != nil { + return nil, err + } + pool, err := pgxpool.New(ctx, dbURL.String()) return maybe(NewPool, pool), err } } |
