dbtxn

package

v0.9.13 Latest Latest Go to latest Published: Feb 14, 2021 License: MIT Imports: 6 Imported by: 0

Details

View Source

const ContextKey key = iota

ContextKey to get transaction

This section is empty.

func Error(ctx context.Context) error

Error of transaction

type CommitFn func() error

CommitFn is commit function to close the transaction

type Context struct {
	TxMap map[*sql.DB]Tx
	Err   error
}

Context of transaction

func Begin(parent *context.Context) *Context

Begin transaction

func Find(ctx context.Context) *Context

Find transaction context

func NewContext() *Context

NewContext return new instance of Context

func (c *Context) Begin(ctx context.Context, db *sql.DB) (sq.BaseRunner, error)

Begin transaction

func (c *Context) Commit() error

Commit if no error

func (c *Context) SetError(err error) bool

SetError to set error to txn context

type Tx interface {
	sq.BaseRunner
	Rollback() error
	Commit() error
}

Tx is interface for *db.Tx

type UseHandler struct {
	*Context
	sq.BaseRunner
}

UseHandler responsible to handle transaction

func Use(ctx context.Context, db *sql.DB) (*UseHandler, error)

Use transaction if possible