Function NewFromURL

server-source-code/internal/database/db.go:61–93

NewFromURL creates a pgx pool and sqlc Queries from a raw database URL. Used for per-host pools; no retry logic. Caller must ensure the database is reachable. maxConns and minConns override pool size (0 uses defaults: 5 max, 1 min).

(ctx context.Context, databaseURL string, maxConns, minConns int, cfg *config.Config)

// Used for per-host pools; no retry logic. Caller must ensure the database is reachable.
// maxConns and minConns override pool size (0 uses defaults: 5 max, 1 min).
func NewFromURL(ctx context.Context, databaseURL string, maxConns, minConns int, cfg *config.Config) (*DB, error) {
	if databaseURL == "" {
		return nil, fmt.Errorf("database URL is required")
	}
	poolCfg, err := pgxpool.ParseConfig(databaseURL)
	if err != nil {
		return nil, fmt.Errorf("parse pool config: %w", err)
	}
	if maxConns <= 0 {
		maxConns = 5
	}
	if minConns < 0 {
		minConns = 1
	}
	poolCfg.MaxConns = safeconv.ClampToInt32(maxConns)
	poolCfg.MinConns = safeconv.ClampToInt32(minConns)
	poolCfg.ConnConfig.ConnectTimeout = time.Duration(cfg.DBConnectTimeout) * time.Second
	poolCfg.HealthCheckPeriod = 30 * time.Second
	setUTCTimeZone(poolCfg)
	pool, err := pgxpool.NewWithConfig(ctx, poolCfg)
	if err != nil {
		return nil, fmt.Errorf("create pgx pool: %w", err)
	}
	if err := pool.Ping(ctx); err != nil {
		pool.Close()
		return nil, fmt.Errorf("ping host database: %w", err)
	}
	return &DB{
		pool:    pool,
		Queries: db.New(pool),
		cfg:     cfg,
	}, nil
}

// waitForDB retries connection until DB is available.
func (d *DB) waitForDB(ctx context.Context) error {