dbx

Aug 31, 2025

Changes in this version

type Context

+ func NewDatabaseContext(parent context.Context, db Database) Context

+ type DatabaseWithContext interface

Feb 13, 2023

Changes in this version

type DefaultDatabase

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

+ func (d *DefaultDatabase) ExecContext(dbContext context.Context, query string, args ...interface{}) (sql.Result, error)

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

+ func (d *DefaultDatabase) QueryContext(dbContext context.Context, query string, args ...interface{}) (*sql.Rows, error)

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

+ func (d *DefaultDatabase) QueryRowContext(dbContext context.Context, query string, args ...interface{}) *sql.Row

Feb 10, 2023

Changes in this version

+ func TransactionWithResult(ctx context.Context, db Database, op OperationWithResult[T], setters ...Option) (T, error)

type Context

+ func NewContextFrom(ctx context.Context, creator ContextCreator) Context

Feb 10, 2023

Changes in this version

+ func WithContext(ctx context.Context, dbCtx Context) context.Context

type Context

+ func FromContext(ctx context.Context) Context

+ func FromContextOrNew(ctx context.Context, db ContextCreator) Context

+ func NewContext(parent context.Context, exec Executor) Context

type Option

+ func WithNewTransaction() Option

Feb 9, 2023

Changes in this version

+ var ErrInvalidContext = errors.New("invalid context")

type Option

+ func WithNew() Option

Jan 25, 2023

Changes in this version

type Context

+ func FromDB(parent context.Context, db *sql.DB) Context

+ func FromOrNew(ctx context.Context, db Database) Context

+ func FromTx(parent context.Context, tx *sql.Tx) Context

+ type OperationWithResult func(ctx Context) (T, error)

+ type Option func(opts *sql.TxOptions)

+ func WithIsolationLevel(level sql.IsolationLevel) Option

+ func WithReadOnly(readOnly bool) Option

Jan 24, 2023

Changes in this version

+ func Transaction(ctx context.Context, db Database, op Operation[T]) (T, error)

+ func TransactionWith(ctx context.Context, db Database, op Operation[T], opts *sql.TxOptions) (T, error)

Jan 24, 2023

Changes in this version

+ type Beginner interface

+ Begin func() (*sql.Tx, error)

+ BeginTx func(context.Context, *sql.TxOptions) (*sql.Tx, error)

+ type ContextCreator interface

+ Context func(ctx context.Context) Context

+ type ContextReceiver func(ctx Context) error

type DefaultDatabase

+ func (d *DefaultDatabase) Begin() (*sql.Tx, error)

+ func (d *DefaultDatabase) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ type Transactor interface

+ Commit func() error

+ Rollback func() error

Jan 24, 2023

Changes in this version

+ func Is(ctx context.Context) bool

+ func With(ctx context.Context, dbCtx Context) context.Context

+ type Context interface

+ Begin func(operation Operation) error

+ BeginWith func(operation Operation, opts *sql.TxOptions) error

+ Executor func() Executor

+ func As(ctx context.Context) (Context, bool)

+ func From(ctx context.Context) Context

+ func New(parent context.Context, db *sql.DB) Context

+ func WithTx(parent context.Context, tx *sql.Tx) Context

+ type Database interface

+ Context func(ctx context.Context) Context

+ Transaction func(ctx context.Context, receiver Receiver) error

+ TransactionWith func(ctx context.Context, receiver Receiver, opts *sql.TxOptions) error

+ func NewDatabase(db *sql.DB) Database

+ type DefaultContext struct

+ func (c *DefaultContext) Begin(handler Operation) error

+ func (c *DefaultContext) BeginWith(handler Operation, opts *sql.TxOptions) error

+ func (c *DefaultContext) Deadline() (deadline time.Time, ok bool)

+ func (c *DefaultContext) Done() <-chan struct{}

+ func (c *DefaultContext) Err() error

+ func (c *DefaultContext) Executor() Executor

+ func (c *DefaultContext) Value(key interface{}) interface{}

+ type DefaultDatabase struct

+ func (d DefaultDatabase) Context(ctx context.Context) Context

+ func (d DefaultDatabase) Transaction(ctx context.Context, receiver Receiver) error

+ func (d DefaultDatabase) TransactionWith(ctx context.Context, receiver Receiver, opts *sql.TxOptions) error

+ type Executor interface

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

+ ExecContext func(dbContext context.Context, query string, args ...interface{}) (sql.Result, error)

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

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

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

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

+ type Operation func(executor Executor) error

+ type Receiver func(ctx Context) error