database

Oct 18, 2026

Changes in this version

+ func ScanTime[D TimeDest](dest D) sql.Scanner

+ type TimeDest interface

Oct 17, 2026

Changes in this version

+ var ErrMixedPlaceholders = errors.New("database: query mixes ? placeholders with $n parameters")

+ var ErrUnterminatedSQL = errors.New("database: query ends inside an unterminated literal, identifier or comment")

+ func RebindChecked(d Dialect, query string) (string, error)

Oct 17, 2026

Changes in this version

+ func Rebind(d Dialect, query string) string

type DB

+ func (db *DB) AddQueryObserver(obs QueryObserver)

Oct 17, 2026

Changes in this version

type Tx

+ func (tx *Tx) AfterCommit(fn func(ctx context.Context))

Oct 16, 2026

Changes in this version

type DB

+ func (db *DB) SetQueryObserver(obs QueryObserver)

type Dialect

+ var MySQL Dialect = mysqlDialect{}

type Driver

+ DSN func(rawURL string) (string, error)

type Option

+ func WithQueryObserver(obs QueryObserver) Option

+ type Query struct

+ Args []any

+ Duration time.Duration

+ Err error

+ SQL string

+ type QueryObserver interface

+ ObserveQuery func(ctx context.Context, q Query)

Oct 16, 2026

Changes in this version

type DB

+ func (db *DB) Encrypter() Encrypter

+ type Encrypter interface

+ Open func(token string, ad []byte) ([]byte, error)

+ Seal func(plaintext, ad []byte) string

type Option

+ func WithEncrypter(e Encrypter) Option

type Tx

+ func (tx *Tx) Encrypter() Encrypter

Oct 16, 2026

Changes in this version

+ func RunInTx(ctx context.Context, ex Executor, fn func(tx *Tx) error) error

+ type Config struct

+ Log *slog.Logger

+ MaxIdle int

+ MaxIdleTime time.Duration

+ MaxLifetime time.Duration

+ MaxOpen int

+ type DB struct

+ func FromSQL(conn *sql.DB, dialect Dialect) *DB

+ func Open(ctx context.Context, rawURL string, opts ...Option) (*DB, error)

+ func (db *DB) Close() error

+ func (db *DB) Dialect() Dialect

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

+ func (db *DB) Ping(ctx context.Context) error

+ func (db *DB) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ func (db *DB) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

+ func (db *DB) SQL() *sql.DB

+ func (db *DB) Tx(ctx context.Context, fn func(tx *Tx) error) (err error)

+ type Dialect interface

+ Name func() string

+ Placeholder func(n int) string

+ Quote func(ident string) string

+ var Postgres Dialect = postgresDialect{}

+ var SQLite Dialect = sqliteDialect{}

+ type Driver struct

+ Dialect Dialect

+ SQLName string

+ Schemes []string

+ type Executor interface

+ Dialect func() Dialect

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ type Manager struct

+ func NewManager(db *DB) *Manager

+ func (m *Manager) Add(name string, db *DB) error

+ func (m *Manager) Close() error

+ func (m *Manager) Conn(name string) *DB

+ func (m *Manager) Default() *DB

+ func (m *Manager) Names() []string

+ func (m *Manager) Ping(ctx context.Context) error

+ type Option func(*openOptions)

+ func WithConfig(c Config) Option

+ func WithDriver(d Driver) Option

+ type Tx struct

+ func (tx *Tx) Dialect() Dialect

+ func (tx *Tx) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)

+ func (tx *Tx) QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ func (tx *Tx) QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row

+ func (tx *Tx) SQL() *sql.Tx