transaction

Documentation

Index

• func TestMultipleQueriesWithTx(t *testing.T)
• func TestMultipleQueriesWithWrapTx(t *testing.T)
• type Builder
  • func NewBuilder(pool *pgxpool.Pool) Builder
  • func (t Builder) Build(ctx context.Context) (tx pgx.Tx, err error)
• type Executor
  • func NewTransactionExecutor(tx pgx.Tx, queryRunner *query.Executor) *Executor
  • func (executor *Executor) Commit(ctx context.Context) error
  • func (executor *Executor) Rollback(ctx context.Context) error
• type Strategy
  • func NewStrategy(tx pgx.Tx) *Strategy
  • func (strategy *Strategy) Handle(ctx context.Context, handler func(ctx context.Context, tx *Executor) error) (err error)

Functions

func TestMultipleQueriesWithTx

func TestMultipleQueriesWithTx(t *testing.T)

func TestMultipleQueriesWithWrapTx

func TestMultipleQueriesWithWrapTx(t *testing.T)

Types

type Builder

type Builder struct {
	// contains filtered or unexported fields
}

func NewBuilder

func NewBuilder(pool *pgxpool.Pool) Builder

func (Builder) Build

func (t Builder) Build(ctx context.Context) (tx pgx.Tx, err error)

type Executor

type Executor struct {
	*query.Executor
	// contains filtered or unexported fields
}

func NewTransactionExecutor

func NewTransactionExecutor(tx pgx.Tx, queryRunner *query.Executor) *Executor

func (*Executor) Commit

func (executor *Executor) Commit(ctx context.Context) error

func (*Executor) Rollback

func (executor *Executor) Rollback(ctx context.Context) error

type Strategy

type Strategy struct {
	// contains filtered or unexported fields
}

func NewStrategy

func NewStrategy(tx pgx.Tx) *Strategy

func (*Strategy) Handle

func (strategy *Strategy) Handle(
	ctx context.Context,
	handler func(ctx context.Context, tx *Executor) error,
) (err error)