From 939a727969ba102a928d6396fb04f8ae716ceaa9 Mon Sep 17 00:00:00 2001 From: spiral Date: Sat, 3 Dec 2022 11:58:30 +0000 Subject: [PATCH] fix(stats): use pooled connections to postgres --- services/scheduled_tasks/db.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/services/scheduled_tasks/db.go b/services/scheduled_tasks/db.go index e16076a2..789a2893 100644 --- a/services/scheduled_tasks/db.go +++ b/services/scheduled_tasks/db.go @@ -4,15 +4,15 @@ import ( "context" redis "github.com/go-redis/redis/v8" - pgx "github.com/jackc/pgx/v4" + "github.com/jackc/pgx/v4/pgxpool" ) -var data_db *pgx.Conn -var messages_db *pgx.Conn -var stats_db *pgx.Conn +var data_db *pgxpool.Pool +var messages_db *pgxpool.Pool +var stats_db *pgxpool.Pool var rdb *redis.Client -func run_simple_pg_query(c *pgx.Conn, sql string) { +func run_simple_pg_query(c *pgxpool.Pool, sql string) { _, err := c.Exec(context.Background(), sql) if err != nil { panic(err) @@ -26,8 +26,8 @@ func connect_dbs() { rdb = redis_connect(get_env_var("REDIS_ADDR")) } -func pg_connect(url string) *pgx.Conn { - conn, err := pgx.Connect(context.Background(), url) +func pg_connect(url string) *pgxpool.Pool { + conn, err := pgxpool.Connect(context.Background(), url) if err != nil { panic(err) }