Versions in this module Expand all Collapse all v0 v0.42.5 Jan 27, 2026 v0.42.4 Jan 27, 2026 Changes in this version + type Conn struct + func NewConn(conn *pgx.Conn) Conn + func (c Conn) Begin(ctx context.Context) (Tx, error) + func (c Conn) BeginTx(ctx context.Context, opts pgx.TxOptions) (Tx, error) + func (c Conn) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error) + func (c Conn) QueryContext(ctx context.Context, query string, args ...any) (scan.Rows, error) + type Pool struct + func New(ctx context.Context, dsn string) (Pool, error) + func NewPool(pool *pgxpool.Pool) Pool + func NewWithConfig(ctx context.Context, config *pgxpool.Config) (Pool, error) + func (p *Pool) AcquireFunc(ctx context.Context, f func(PoolConn) error) error + func (p Pool) Acquire(ctx context.Context) (PoolConn, error) + func (p Pool) Begin(ctx context.Context) (Tx, error) + func (p Pool) BeginTx(ctx context.Context, opts pgx.TxOptions) (Tx, error) + func (p Pool) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error) + func (p Pool) QueryContext(ctx context.Context, query string, args ...any) (scan.Rows, error) + type PoolConn struct + func NewPoolConn(conn *pgxpool.Conn) PoolConn + func (c PoolConn) Begin(ctx context.Context) (Tx, error) + func (c PoolConn) BeginTx(ctx context.Context, opts pgx.TxOptions) (Tx, error) + func (c PoolConn) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error) + func (c PoolConn) QueryContext(ctx context.Context, query string, args ...any) (scan.Rows, error) + type Tx struct + func NewTx(tx pgx.Tx, cancel context.CancelFunc) Tx + func (t Tx) Begin(ctx context.Context) (pgx.Tx, error) + func (t Tx) Commit(ctx context.Context) error + func (t Tx) Conn() *pgx.Conn + func (t Tx) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, ...) (int64, error) + func (t Tx) Exec(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error) + func (t Tx) ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error) + func (t Tx) LargeObjects() pgx.LargeObjects + func (t Tx) Prepare(ctx context.Context, name, sql string) (*pgconn.StatementDescription, error) + func (t Tx) Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error) + func (t Tx) QueryContext(ctx context.Context, query string, args ...any) (scan.Rows, error) + func (t Tx) QueryRow(ctx context.Context, sql string, args ...any) pgx.Row + func (t Tx) Rollback(ctx context.Context) error + func (t Tx) SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults