dbi

Documentation

Index

• func Get(ctx context.Context, db DBI, val any, query string, vals ...any) error
• func ReadOnly[T any](ctx context.Context, db *sql.DB, fn func(DBI) (T, error)) (T, error)
• func ReadWrite[T any](ctx context.Context, db *sql.DB, fn func(DBI) (T, error)) (T, error)
• func TranslateNotFound(from, to error) error
• func WithTx[T any](ctx context.Context, db *sql.DB, opts *sql.TxOptions, ...) (T, error)
• type DBI
• type Factory
• type TxDal
  • func (t *TxDal) Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
  • func (t *TxDal) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)
  • func (t *TxDal) QueryRow(ctx context.Context, query string, args ...any) *sql.Row

Functions

func Get

func Get(ctx context.Context, db DBI, val any, query string, vals ...any) error

func ReadOnly

func ReadOnly[T any](ctx context.Context, db *sql.DB, fn func(DBI) (T, error)) (T, error)

ReadOnly executes fn within a read-only transaction. The transaction is committed if fn returns nil, otherwise rolled back.

func ReadWrite

func ReadWrite[T any](ctx context.Context, db *sql.DB, fn func(DBI) (T, error)) (T, error)

ReadWrite executes fn within a read-write transaction. The transaction is committed if fn returns nil, otherwise rolled back.

func TranslateNotFound

func TranslateNotFound(from, to error) error

func WithTx

func WithTx[T any](ctx context.Context, db *sql.DB, opts *sql.TxOptions, fn func(*TxDal) (T, error)) (T, error)

Types

type DBI

type DBI interface {
	Query(context.Context, string, ...any) (*sql.Rows, error)
	QueryRow(context.Context, string, ...any) *sql.Row
	Exec(context.Context, string, ...any) (sql.Result, error)
}

type Factory

type Factory[T any] func(DBI) T

type TxDal

type TxDal struct {
	Tx *sql.Tx
}

func (*TxDal) Exec

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

func (*TxDal) Query

func (t *TxDal) Query(ctx context.Context, query string, args ...any) (*sql.Rows, error)

func (*TxDal) QueryRow

func (t *TxDal) QueryRow(ctx context.Context, query string, args ...any) *sql.Row