mirror of
https://github.com/hanzoai/base.git
synced 2026-10-21 03:41:50 +00:00
zeekay
c711ca3d20
SQLDialect interface abstracts SQLite vs PostgreSQL SQL differences: - JSON ops (json_extract vs ->>, json_each vs jsonb_array_elements) - Date formatting (strftime vs to_char) - Schema introspection (PRAGMA vs information_schema) - ID generation (randomblob vs gen_random_bytes) Adds PostgresDBConnect via pgx driver and DataDSN/AuxDSN config fields for connecting Base to Neon serverless PostgreSQL instead of SQLite.
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
|
|
}
|