| // 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) |