sql

Sep 30, 2025

Changes in this version

type DB

+ func (w *DB) ExecContextRetryable(ctx context.Context, query string, retryParams ratex.RetryParams, args ...any) (gosql.Result, error)

+ func (w *DB) QueryContextRetryable(ctx context.Context, query string, retryParams ratex.RetryParams, args ...any) (*gosql.Rows, error)

+ func (w *DB) QueryRowContextRetryable(ctx context.Context, query string, retryParams ratex.RetryParams, args ...any) *gosql.Row

Nov 3, 2023

Changes in this version

+ var ErrConnDone = sql.ErrConnDone

+ var ErrNoRows = sql.ErrNoRows

+ var ErrTxDone = sql.ErrTxDone

+ func CleanQuery(s string) string

+ func MeasureError(id string, err error) error

+ func MeasureQuery(logger LazyLogger, slowQueryThresholdMs int64, id string, op string, ...) func() int64

+ func MeasureStats(db *sql.DB, id string) error

+ func MonitorSQLDriver(db *sql.DB, id string) context.CancelFunc

+ type DB struct

+ func ObserveDB(innerDB *gosql.DB, logger log.Logger, id string) (*DB, error)

+ func (w *DB) Begin() (*Tx, error)

+ func (w *DB) BeginTx(ctx context.Context, opts *TxOptions) (*Tx, error)

+ func (w *DB) Close() error

+ func (w *DB) Exec(query string, args ...interface{}) (gosql.Result, error)

+ func (w *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (gosql.Result, error)

+ func (w *DB) Prepare(query string) (*Stmt, error)

+ func (w *DB) PrepareContext(ctx context.Context, query string) (*Stmt, error)

+ func (w *DB) Query(query string, args ...interface{}) (*gosql.Rows, error)

+ func (w *DB) QueryContext(ctx context.Context, query string, args ...interface{}) (*gosql.Rows, error)

+ func (w *DB) QueryRow(query string, args ...interface{}) *gosql.Row

+ func (w *DB) QueryRowContext(ctx context.Context, query string, args ...interface{}) *gosql.Row

+ func (w *DB) SetSlowQueryThreshold(d time.Duration)

+ type LazyLogger func() log.Logger

+ type Stmt struct

+ func (s *Stmt) Close() error

+ func (s *Stmt) Exec(args ...any) (gosql.Result, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args ...any) (gosql.Result, error)

+ func (s *Stmt) Query(args ...any) (*gosql.Rows, error)

+ func (s *Stmt) QueryContext(ctx context.Context, args ...any) (*gosql.Rows, error)

+ func (s *Stmt) QueryRow(args ...any) *gosql.Row

+ func (s *Stmt) QueryRowContext(ctx context.Context, args ...any) *gosql.Row

+ type Tx struct

+ func (w *Tx) Commit() error

+ func (w *Tx) Context() context.Context

+ func (w *Tx) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (w *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (w *Tx) PrepareContext(ctx context.Context, query string) (*Stmt, error)

+ func (w *Tx) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (w *Tx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (w *Tx) QueryRow(query string, args ...interface{}) *sql.Row

+ func (w *Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (w *Tx) Rollback() error

+ type TxOptions = gosql.TxOptions