db

package

v0.1.3 Latest Latest Go to latest Published: Dec 27, 2024 License: GPL-3.0 Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrNoConnection = errors.New("database connection not initialized")
	ErrNoRows       = sql.ErrNoRows
)

Common errors

func ChangeConfig(db *DB, c Config)

func QueryRow[T any](ctx context.Context, db *DB, query string, scanner SingleRowScanner[T], args ...any) (T, error)

func QueryRows[T any](ctx context.Context, db *DB, query string, scanner Scanner[T], args ...any) ([]T, error)

type Config struct {
	MaxOpenConns    int
	MaxIdleConns    int
	ConnMaxLifetime time.Duration
	ConnMaxIdleTime time.Duration
}

Config represents database configuration

func DefaultConfig() Config

DefaultConfig provides sensible defaults for database configuration

type DB struct {
	*sql.DB
	// contains filtered or unexported fields
}

DB wraps sql.DB to provide additional functionality

func New(source boiler.IOWithAuth) (*DB, error)

New creates a new database connection

func (db *DB) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)

Exec executes a query that doesn't return rows (INSERT, UPDATE, DELETE)

func (db *DB) Health(ctx context.Context) error

Health performs a health check on the database

func (db *DB) Transaction(ctx context.Context, fn func(*sql.Tx) error) error

type Scanner[T any] func(*sql.Rows) (T, error)

type SingleRowScanner[T any] func(*sql.Row) (T, error)