sqltx

README

Golang SQL transaction

Helper for sql transactions

Install

go get -u github.com/andrdru/sqltx

Usage

see examples

// add helper to repo

User interface {
  sqltx.Tx

  TX(action func(txRepo User) error) error
}

// TX simplify DoTransaction call for User interface
func (m *user) TX(action func(txRepo User) error) error {
  return m.DoTransaction(
    func(tx sqltx.QueryExecutor) sqltx.Tx { return NewUser(tx) },
    func(txRepo sqltx.Tx) error { return action(txRepo.(User)) },
  )
}

// call

err = userRepo.TX(func(txRepo repo.User) (err error) {
  err = txRepo.CreateUser(ctx, 1, "Vasya")
  if err != nil {
    return err
  }
  
  return nil
}

if err != nil {
  log.Fatalf("transaction rollback: %s", err)
}

Documentation

Index

• Variables
• type QueryExecutor
• type Tx
  • func NewTx(db QueryExecutor) Tx

Variables

var (
	// ErrDatabaseTypeInvalid throws when QueryExecutor not *sql.DB
	// are you try to run transaction in transaction?
	ErrDatabaseTypeInvalid = errors.New("wrong database struct type")
)

Types

type QueryExecutor

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

QueryExecutor is execution interface of sql.Tx and sql.DB

type Tx

type Tx interface {
	DoTransaction(construct func(tx QueryExecutor) Tx, action func(txRepo Tx) error) (err error)
	DB() (db QueryExecutor)
}

Tx repo tx helper

func NewTx

func NewTx(db QueryExecutor) Tx