@@ -18,6 +18,7 @@ import (
1818 "google.golang.org/grpc"
1919 "google.golang.org/grpc/credentials/insecure"
2020 "google.golang.org/grpc/keepalive"
21+ "github.com/jackc/pgx/v5/pgxpool"
2122
2223 "github.com/PythonHacker24/linux-acl-management-backend/api/routes"
2324 "github.com/PythonHacker24/linux-acl-management-backend/config"
@@ -29,7 +30,6 @@ import (
2930 "github.com/PythonHacker24/linux-acl-management-backend/internal/session"
3031 "github.com/PythonHacker24/linux-acl-management-backend/internal/transprocessor"
3132 "github.com/PythonHacker24/linux-acl-management-backend/internal/utils"
32- "github.com/jackc/pgx/v5"
3333)
3434
3535func main () {
@@ -183,13 +183,13 @@ func run(ctx context.Context) error {
183183 config .BackendConfig .Database .ArchivalPQ .SSLMode ,
184184 )
185185
186- connPQ , err := pgx . Connect (context .Background (), pqDB )
186+ poolPQ , err := pgxpool . New (context .Background (), pqDB )
187187 if err != nil {
188- fmt .Fprintf (os .Stderr , "Unable to connect to database : %v\n " , err )
188+ fmt .Fprintf (os .Stderr , "Unable to create connection pool : %v\n " , err )
189189 os .Exit (1 )
190190 }
191191
192- archivalPQ := postgresql .New (connPQ )
192+ archivalPQ := postgresql .New (poolPQ )
193193
194194 /* create a session manager */
195195 sessionManager := session .NewManager (logRedisClient , archivalPQ , errChLog )
@@ -321,7 +321,7 @@ func run(ctx context.Context) error {
321321 }
322322
323323 /* close archival database connection */
324- connPQ .Close (context . Background () )
324+ poolPQ .Close ()
325325
326326 zap .L ().Info ("All background processes closed gracefully" )
327327
0 commit comments