db

type DB ¶

type DB struct {
	*sql.DB
}

func Connect(ctx context.Context, driverName, dsn string) (*DB, error)

func Open(driverName, dsn string) (*DB, error)

func (d *DB) Transaction(ctx context.Context, fn func(tx *Tx) error) error

func (d *DB) TransactionOpts(ctx context.Context, opts *TransactionOpts, fn func(tx *Tx) error) error

type Executor ¶

type Executor interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type TransactionOpts ¶ added in v0.1.3

type TransactionOpts struct {
	Isolation sql.IsolationLevel
	ReadOnly  bool
}

TransactionOpts mirrors database/sql TxOptions. A nil *TransactionOpts means the database driver's default isolation level and read-write access.

type Tx ¶

type Tx struct {
	*sql.Tx
}