hongbo-miao/hongbomiao.com

package utils

import (
    "context"
    "github.com/jackc/pgx/v5/pgxpool"
    "github.com/rs/zerolog/log"
    "os"
)

func InitPostgres(
    postgresHost string,
    postgresPort string,
    postgresDB string,
    postgresUser string,
    postgresPassword string) *pgxpool.Pool {
    databaseURL := "postgresql://" + postgresUser + ":" + postgresPassword + "@" + postgresHost + ":" + postgresPort + "/" + postgresDB
    pg, err := pgxpool.New(context.Background(), databaseURL)
    if err != nil {
        log.Error().Err(err).Msg("conn.Close")
        os.Exit(1)
    }
    return pg
}