poolwrapper

Documentation

Index

• type Pool
  • func NewPool(pool *pgxpool.Pool) *Pool
  • func (p Pool) Begin(ctx context.Context) (pgx.Tx, error)
  • func (p Pool) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error)
  • func (p Pool) Exec(ctx context.Context, sql string, args ...any) (commandTag pgconn.CommandTag, err error)
  • func (p Pool) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
  • func (p Pool) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
  • func (p Pool) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults
  • func (p Pool) TxFunc(ctx context.Context, f func(context.Context, pgx.Tx) error) (err error)

Types

type Pool

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

func NewPool

func NewPool(pool *pgxpool.Pool) *Pool

func (Pool) Begin

func (p Pool) Begin(ctx context.Context) (pgx.Tx, error)

func (Pool) CopyFrom

func (p Pool) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)

func (Pool) Exec

func (p Pool) Exec(ctx context.Context, sql string, args ...any) (commandTag pgconn.CommandTag, err error)

func (Pool) Query

func (p Pool) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

func (Pool) QueryRow

func (p Pool) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row

func (Pool) SendBatch

func (p Pool) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults

func (Pool) TxFunc

func (p Pool) TxFunc(ctx context.Context, f func(context.Context, pgx.Tx) error) (err error)