summaryrefslogtreecommitdiff
path: root/connector.go
diff options
context:
space:
mode:
authorStefan Majewsky <majewsky@gmx.net>2026-09-17 16:08:15 +0200
committerStefan Majewsky <majewsky@gmx.net>2026-09-17 16:08:49 +0200
commitc148274afefae3c9dce478076422f5e0fad4e902 (patch)
tree33da4ef037b7f4d936663eccbdda45baf2c57138 /connector.go
parent6f9d4966728f36c1eeceb0527c2e40b304a05d7a (diff)
downloadgo-gg-pgx-c148274afefae3c9dce478076422f5e0fad4e902.tar.gz
bump gg to 0.15.0
Diffstat (limited to 'connector.go')
-rw-r--r--connector.go16
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
}
}