dbtools

Aug 16, 2020

Changes in this version

+ var ErrEmptyDatabase = errors.New("no database connection is set")

+ type ConfigFunc func(*Transaction)

+ func DelayMethod(m retry.DelayMethod) ConfigFunc

+ func RetryCount(n int) ConfigFunc

+ func RetryDelay(d time.Duration) ConfigFunc

+ type DB interface

+ Begin func() (Tx, error)

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

+ type Pool interface

+ Begin func(ctx context.Context) (pgx.Tx, error)

+ BeginTx func(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)

+ type Transaction struct

+ func NewTransaction(conn interface{}, conf ...ConfigFunc) (*Transaction, error)

+ func (t *Transaction) DB(ctx context.Context, transactions ...func(Tx) error) error

+ func (t *Transaction) PGX(ctx context.Context, transactions ...func(pgx.Tx) error) error

+ type Tx interface

+ Commit func() error

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

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

+ Prepare func(query string) (*sql.Stmt, error)

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

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

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

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

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

+ Rollback func() error

+ Stmt func(stmt *sql.Stmt) *sql.Stmt

+ StmtContext func(ctx context.Context, stmt *sql.Stmt) *sql.Stmt

Jul 17, 2019

Changes in this version

+ func Retry(retries int, delay time.Duration, fn func(int) error) error

+ func RetryTransaction(ctx context.Context, db *sql.DB, retries int, delay time.Duration, ...) error

+ func WithTransaction(db *sql.DB, fn ...func(*sql.Tx) error) error