mirror of
https://github.com/hanzoai/base.git
synced 2026-10-21 03:41:50 +00:00
zeekay
d02a70442d
Drop-in replacement — same API, same package name (dbx). 75 Go files updated. Zero pocketbase references in imports.
33 lines
756 B
Go
33 lines
756 B
Go
//go:build !no_pg_driver
|
|
|
|
package core
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/hanzoai/dbx"
|
|
_ "github.com/jackc/pgx/v5/stdlib" // register "pgx" driver
|
|
)
|
|
|
|
// PostgresDBConnect creates a new PostgreSQL database connection.
|
|
// The dsn should be a PostgreSQL connection string like:
|
|
// "postgres://user:pass@host:5432/dbname?sslmode=disable"
|
|
func PostgresDBConnect(dsn string) (*dbx.DB, error) {
|
|
db, err := dbx.Open("pgx", dsn)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to connect to PostgreSQL: %w", err)
|
|
}
|
|
|
|
// Connection pool settings
|
|
db.DB().SetMaxOpenConns(50)
|
|
db.DB().SetMaxIdleConns(10)
|
|
|
|
// Verify connection
|
|
if err := db.DB().Ping(); err != nil {
|
|
db.Close()
|
|
return nil, fmt.Errorf("failed to ping PostgreSQL: %w", err)
|
|
}
|
|
|
|
return db, nil
|
|
}
|