sqltx

Documentation

Index

• func NewDB(db *sql.DB) tx.DB
• type DB
  • func (p *DB) Begin(_ context.Context) (tx.Transaction, error)
• type Tx
  • func From(ctx context.Context) (*Tx, bool)
  • func (p *Tx) Commit(_ context.Context) error
  • func (p *Tx) Rollback(_ context.Context) error

Functions

func NewDB

func NewDB(db *sql.DB) tx.DB

NewDB instantiates new tx.DB *sql.DB wrapper

Types

type DB

type DB struct {
	*sql.DB
}

DB implements tx.DB

func (*DB) Begin

func (p *DB) Begin(_ context.Context) (tx.Transaction, error)

Begin begins sql transaction

type Tx

type Tx struct {
	*sql.Tx
}

Tx wraps *sql.TX in order top implement tx.Transaction

func From

func From(ctx context.Context) (*Tx, bool)

From returns underlying *sql.Tx (wrapped in *Tx)

func (*Tx) Commit

func (p *Tx) Commit(_ context.Context) error

Commit commits the transaction

func (*Tx) Rollback

func (p *Tx) Rollback(_ context.Context) error

Rollback rolls back the transaction