txn_pgx

Documentation

Index

• func PgxExecute[D txn.Doer[PgxOptions, PgxBeginner]](ctx context.Context, db PgxBeginner, do D, ...) (D, error)
• type PgxBeginner
• type PgxDoer
• type PgxDoerBase
  • func (do *PgxDoerBase[_]) IsReadOnly() bool
  • func (do *PgxDoerBase[_]) SetReadOnly(title string)
  • func (do *PgxDoerBase[_]) SetReadWrite(title string)
  • func (do *PgxDoerBase[S]) SetStmt(s S)
  • func (do *PgxDoerBase[S]) Stmt() S
• type PgxOptions
• type PgxTxn
  • func PgxBeginTxn(ctx context.Context, db PgxBeginner, opt PgxOptions) (*PgxTxn, error)
  • func (w *PgxTxn) Commit(ctx context.Context) error
  • func (w *PgxTxn) IsNil() bool
  • func (w *PgxTxn) Rollback(ctx context.Context) error

Functions

func PgxExecute

func PgxExecute[D txn.Doer[PgxOptions, PgxBeginner]](
	ctx context.Context, db PgxBeginner, do D, fn txn.DoFunc[PgxOptions, PgxBeginner, D]) (D, error)

Types

type PgxBeginner

type PgxBeginner = *pgxpool.Pool

type PgxDoer

type PgxDoer[Stmt any] interface {
	txn.Doer[PgxOptions, PgxBeginner]
	Stmt() Stmt
	SetStmt(Stmt)
}

type PgxDoerBase

type PgxDoerBase[Stmt any] struct {
	txn.DoerBase[PgxOptions, PgxBeginner]
	// contains filtered or unexported fields
}

func (*PgxDoerBase[_]) IsReadOnly

func (do *PgxDoerBase[_]) IsReadOnly() bool

func (*PgxDoerBase[_]) SetReadOnly

func (do *PgxDoerBase[_]) SetReadOnly(title string)

func (*PgxDoerBase[_]) SetReadWrite

func (do *PgxDoerBase[_]) SetReadWrite(title string)

func (*PgxDoerBase[S]) SetStmt

func (do *PgxDoerBase[S]) SetStmt(s S)

func (*PgxDoerBase[S]) Stmt

func (do *PgxDoerBase[S]) Stmt() S

type PgxOptions

type PgxOptions = *pgx.TxOptions

type PgxTxn

type PgxTxn struct {
	Raw pgx.Tx
}

func PgxBeginTxn

func PgxBeginTxn(ctx context.Context, db PgxBeginner, opt PgxOptions) (*PgxTxn, error)

func (*PgxTxn) Commit

func (w *PgxTxn) Commit(ctx context.Context) error

func (*PgxTxn) IsNil

func (w *PgxTxn) IsNil() bool

func (*PgxTxn) Rollback

func (w *PgxTxn) Rollback(ctx context.Context) error