refactor: extract connection to database logic to db module

This commit is contained in:
2026-03-30 11:44:27 -05:00
parent e6373267b1
commit 5e23e20e5a
2 changed files with 38 additions and 19 deletions

View File

@@ -7,31 +7,22 @@ import (
"os"
"git.ksdemosapps.com/kylesoda/pgx-learning/internal/config"
"git.ksdemosapps.com/kylesoda/pgx-learning/internal/db"
"git.ksdemosapps.com/kylesoda/pgx-learning/internal/db/postgres"
"git.ksdemosapps.com/kylesoda/pgx-learning/internal/models"
"git.ksdemosapps.com/kylesoda/pgx-learning/internal/repository"
"github.com/jackc/pgx/v5/pgxpool"
"github.com/urfave/cli/v2"
)
var pool *pgxpool.Pool
var ctx = context.Background()
func init() {
var err error
pool, err = pgxpool.New(ctx, config.Db.Url)
if err != nil {
log.Fatal("Unable to connect to database:", err)
}
if err := pool.Ping(ctx); err != nil {
log.Fatal("Unable to ping database:", err)
}
// fmt.Println("Connected to PostgreSQL database!")
}
func main() {
ctx := context.Background()
pool, err := db.Connect(ctx, config.Db.Url)
if err != nil {
log.Fatal(err)
}
defer db.Close(pool)
taskRespository := postgres.NewTaskRepository(pool)
app := &cli.App{
@@ -175,7 +166,7 @@ func main() {
},
}
err := app.Run(os.Args)
err = app.Run(os.Args)
if err != nil {
log.Fatal(err)
}