/
db.go
32 lines (26 loc) · 666 Bytes
/
db.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
package main
import (
"context"
"fmt"
"log"
"os"
"github.com/exaring/otelpgx"
"github.com/jackc/pgx/v5/pgxpool"
)
var conn *pgxpool.Pool
func connectDB() {
var err error
connConfig, err := pgxpool.ParseConfig(os.Getenv("DATABASE_URL"))
if err != nil {
log.Fatalf("Unable to parse DATABASE_URL: %v", err)
}
connConfig.ConnConfig.Tracer = otelpgx.NewTracer()
fmt.Println("connConfig.ConnConfig.Tracer: ", connConfig.ConnConfig.Tracer)
conn, err = pgxpool.NewWithConfig(context.Background(), connConfig)
if err != nil {
log.Fatalf("connect to database: %v", err)
}
if err != nil {
log.Fatalf("Unable to connect to database: %v\n", err)
}
}