Skip to content

Commit 8f830a5

Browse files
Completed the PostgreSQL main intergation with initialization
1 parent 11fa192 commit 8f830a5

File tree

1 file changed

+12
-3
lines changed

1 file changed

+12
-3
lines changed

cmd/laclm/main.go

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -133,10 +133,19 @@ func run(ctx context.Context) error {
133133
zap.L().Fatal("Failed to connect to Redis", zap.Error(err))
134134
}
135135

136-
connPQ, err := pgx.Connect(context.Background(), os.Getenv("DATABASE_URL"))
136+
pqDB := fmt.Sprintf("postgres://%s:%s@%s:%d/%s?sslmode=%s",
137+
config.BackendConfig.Database.ArchivalPQ.User,
138+
config.BackendConfig.Database.ArchivalPQ.Password,
139+
config.BackendConfig.Database.ArchivalPQ.Host,
140+
config.BackendConfig.Database.ArchivalPQ.Port,
141+
config.BackendConfig.Database.ArchivalPQ.DBName,
142+
config.BackendConfig.Database.ArchivalPQ.SSLMode,
143+
)
144+
145+
connPQ, err := pgx.Connect(context.Background(), pqDB)
137146
if err != nil {
138-
fmt.Fprintf(os.Stderr, "Unable to connect to database: %v\n", err)
139-
os.Exit(1)
147+
fmt.Fprintf(os.Stderr, "Unable to connect to database: %v\n", err)
148+
os.Exit(1)
140149
}
141150

142151
archivalPQ := postgresql.New(connPQ)

0 commit comments

Comments
 (0)