executor

Documentation

Index

• func Exec(ctx context.Context, execer Execer, builder Builder) error
• func Get[T any](ctx context.Context, querier Querier, builder Builder) (T, error)
• func Select[T any](ctx context.Context, querier Querier, builder Builder) ([]T, error)
• type Builder
• type Execer
• type Executor
  • func New(ctx context.Context, dsn string) (*Executor, error)
  • func (e *Executor) BeginTx(ctx context.Context) (context.Context, error)
  • func (e *Executor) BeginTxWithOptions(ctx context.Context, options pgx.TxOptions) (context.Context, error)
  • func (e *Executor) CommitTx(ctx context.Context) error
  • func (e *Executor) Execer(ctx context.Context) Execer
  • func (e *Executor) Querier(ctx context.Context) Querier
  • func (e *Executor) RollbackTx(ctx context.Context)
• type Querier
• type TxStack

Functions

func Exec

func Exec(ctx context.Context, execer Execer, builder Builder) error

func Get

func Get[T any](ctx context.Context, querier Querier, builder Builder) (T, error)

func Select

func Select[T any](ctx context.Context, querier Querier, builder Builder) ([]T, error)

Types

type Builder

type Builder interface {
	ToSql() (query string, args []any, err error)
}

type Execer

type Execer interface {
	Exec(ctx context.Context, query string, args ...any) (pgconn.CommandTag, error)
}

type Executor

type Executor struct {
	*pgxpool.Pool
	pgx.Tx
}

func New

func New(ctx context.Context, dsn string) (*Executor, error)

func (*Executor) BeginTx

func (e *Executor) BeginTx(ctx context.Context) (context.Context, error)

func (*Executor) BeginTxWithOptions

func (e *Executor) BeginTxWithOptions(ctx context.Context, options pgx.TxOptions) (context.Context, error)

func (*Executor) CommitTx

func (e *Executor) CommitTx(ctx context.Context) error

func (*Executor) Execer

func (e *Executor) Execer(ctx context.Context) Execer

func (*Executor) Querier

func (e *Executor) Querier(ctx context.Context) Querier

func (*Executor) RollbackTx

func (e *Executor) RollbackTx(ctx context.Context)

type Querier

type Querier interface {
	Query(ctx context.Context, query string, args ...any) (pgx.Rows, error)
}

type TxStack

type TxStack interface {
	Push(tx pgx.Tx)
	Pop() pgx.Tx
	Peek() pgx.Tx
}