blob: 179a87ac3c0a2e514ffcc3abe0f618532d84951d [file] [log] [blame]
// Package pool contains an interface for pgxpool.Pool.
package pool
import (
"context"
"github.com/jackc/pgconn"
"github.com/jackc/pgx/v4"
"github.com/jackc/pgx/v4/pgxpool"
)
// Pool is an interface for *pgxpool.Pool.
type Pool interface {
Close()
Acquire(ctx context.Context) (*pgxpool.Conn, error)
AcquireFunc(ctx context.Context, f func(*pgxpool.Conn) error) error
AcquireAllIdle(ctx context.Context) []*pgxpool.Conn
Config() *pgxpool.Config
Exec(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)
Query(ctx context.Context, sql string, args ...interface{}) (pgx.Rows, error)
QueryRow(ctx context.Context, sql string, args ...interface{}) pgx.Row
QueryFunc(ctx context.Context, sql string, args []interface{}, scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error)
SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults
Begin(ctx context.Context) (pgx.Tx, error)
BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
BeginFunc(ctx context.Context, f func(pgx.Tx) error) error
BeginTxFunc(ctx context.Context, txOptions pgx.TxOptions, f func(pgx.Tx) error) error
CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
Ping(ctx context.Context) error
}
// Confirm pgxpool.Pool implements Pool.
var _ Pool = (*pgxpool.Pool)(nil)