Documentation
¶
Index ¶
- func RegisterTypes(ctx context.Context, conn *pgx.Conn) error
- type DBQuerier
- func (q *DBQuerier) GenSeries(ctx context.Context) ([]*int, error)
- func (q *DBQuerier) GenSeries1(ctx context.Context) (*int, error)
- func (q *DBQuerier) GenSeries1Batch(batch genericBatch)
- func (q *DBQuerier) GenSeries1Scan(results pgx.BatchResults) (*int, error)
- func (q *DBQuerier) GenSeriesArr(ctx context.Context) ([][]int, error)
- func (q *DBQuerier) GenSeriesArr1(ctx context.Context) ([]int, error)
- func (q *DBQuerier) GenSeriesArr1Batch(batch genericBatch)
- func (q *DBQuerier) GenSeriesArr1Scan(results pgx.BatchResults) ([]int, error)
- func (q *DBQuerier) GenSeriesArrBatch(batch genericBatch)
- func (q *DBQuerier) GenSeriesArrScan(results pgx.BatchResults) ([][]int, error)
- func (q *DBQuerier) GenSeriesBatch(batch genericBatch)
- func (q *DBQuerier) GenSeriesScan(results pgx.BatchResults) ([]*int, error)
- func (q *DBQuerier) GenSeriesStr(ctx context.Context) ([]*string, error)
- func (q *DBQuerier) GenSeriesStr1(ctx context.Context) (*string, error)
- func (q *DBQuerier) GenSeriesStr1Batch(batch genericBatch)
- func (q *DBQuerier) GenSeriesStr1Scan(results pgx.BatchResults) (*string, error)
- func (q *DBQuerier) GenSeriesStrBatch(batch genericBatch)
- func (q *DBQuerier) GenSeriesStrScan(results pgx.BatchResults) ([]*string, error)
- type Querier
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTypes ¶ added in v0.0.3
RegisterTypes registers custom Postgres types (composites and enums) with the pgx connection's TypeMap so that they can be scanned and encoded correctly. Call this once per connection after connecting.
For pgxpool.Pool, use config.AfterConnect:
config.AfterConnect = func(ctx context.Context, conn *pgx.Conn) error {
return RegisterTypes(ctx, conn)
}
Types ¶
type DBQuerier ¶
type DBQuerier struct {
// contains filtered or unexported fields
}
func NewQuerier ¶
func NewQuerier(conn genericConn) *DBQuerier
NewQuerier creates a DBQuerier that implements Querier. conn is typically *pgx.Conn, pgx.Tx, or *pgxpool.Pool.
func (*DBQuerier) GenSeries1 ¶
GenSeries1 implements Querier.GenSeries1.
func (*DBQuerier) GenSeries1Batch ¶
func (q *DBQuerier) GenSeries1Batch(batch genericBatch)
GenSeries1Batch implements Querier.GenSeries1Batch.
func (*DBQuerier) GenSeries1Scan ¶
func (q *DBQuerier) GenSeries1Scan(results pgx.BatchResults) (*int, error)
GenSeries1Scan implements Querier.GenSeries1Scan.
func (*DBQuerier) GenSeriesArr ¶
GenSeriesArr implements Querier.GenSeriesArr.
func (*DBQuerier) GenSeriesArr1 ¶
GenSeriesArr1 implements Querier.GenSeriesArr1.
func (*DBQuerier) GenSeriesArr1Batch ¶
func (q *DBQuerier) GenSeriesArr1Batch(batch genericBatch)
GenSeriesArr1Batch implements Querier.GenSeriesArr1Batch.
func (*DBQuerier) GenSeriesArr1Scan ¶
func (q *DBQuerier) GenSeriesArr1Scan(results pgx.BatchResults) ([]int, error)
GenSeriesArr1Scan implements Querier.GenSeriesArr1Scan.
func (*DBQuerier) GenSeriesArrBatch ¶
func (q *DBQuerier) GenSeriesArrBatch(batch genericBatch)
GenSeriesArrBatch implements Querier.GenSeriesArrBatch.
func (*DBQuerier) GenSeriesArrScan ¶
func (q *DBQuerier) GenSeriesArrScan(results pgx.BatchResults) ([][]int, error)
GenSeriesArrScan implements Querier.GenSeriesArrScan.
func (*DBQuerier) GenSeriesBatch ¶
func (q *DBQuerier) GenSeriesBatch(batch genericBatch)
GenSeriesBatch implements Querier.GenSeriesBatch.
func (*DBQuerier) GenSeriesScan ¶
func (q *DBQuerier) GenSeriesScan(results pgx.BatchResults) ([]*int, error)
GenSeriesScan implements Querier.GenSeriesScan.
func (*DBQuerier) GenSeriesStr ¶
GenSeriesStr implements Querier.GenSeriesStr.
func (*DBQuerier) GenSeriesStr1 ¶
GenSeriesStr1 implements Querier.GenSeriesStr1.
func (*DBQuerier) GenSeriesStr1Batch ¶
func (q *DBQuerier) GenSeriesStr1Batch(batch genericBatch)
GenSeriesStr1Batch implements Querier.GenSeriesStr1Batch.
func (*DBQuerier) GenSeriesStr1Scan ¶
func (q *DBQuerier) GenSeriesStr1Scan(results pgx.BatchResults) (*string, error)
GenSeriesStr1Scan implements Querier.GenSeriesStr1Scan.
func (*DBQuerier) GenSeriesStrBatch ¶
func (q *DBQuerier) GenSeriesStrBatch(batch genericBatch)
GenSeriesStrBatch implements Querier.GenSeriesStrBatch.
func (*DBQuerier) GenSeriesStrScan ¶
func (q *DBQuerier) GenSeriesStrScan(results pgx.BatchResults) ([]*string, error)
GenSeriesStrScan implements Querier.GenSeriesStrScan.
type Querier ¶
type Querier interface {
GenSeries1(ctx context.Context) (*int, error)
// GenSeries1Batch enqueues a GenSeries1 query into batch to be executed
// later by the batch.
GenSeries1Batch(batch genericBatch)
// GenSeries1Scan scans the result of an executed GenSeries1Batch query.
GenSeries1Scan(results pgx.BatchResults) (*int, error)
GenSeries(ctx context.Context) ([]*int, error)
// GenSeriesBatch enqueues a GenSeries query into batch to be executed
// later by the batch.
GenSeriesBatch(batch genericBatch)
// GenSeriesScan scans the result of an executed GenSeriesBatch query.
GenSeriesScan(results pgx.BatchResults) ([]*int, error)
GenSeriesArr1(ctx context.Context) ([]int, error)
// GenSeriesArr1Batch enqueues a GenSeriesArr1 query into batch to be executed
// later by the batch.
GenSeriesArr1Batch(batch genericBatch)
// GenSeriesArr1Scan scans the result of an executed GenSeriesArr1Batch query.
GenSeriesArr1Scan(results pgx.BatchResults) ([]int, error)
GenSeriesArr(ctx context.Context) ([][]int, error)
// GenSeriesArrBatch enqueues a GenSeriesArr query into batch to be executed
// later by the batch.
GenSeriesArrBatch(batch genericBatch)
// GenSeriesArrScan scans the result of an executed GenSeriesArrBatch query.
GenSeriesArrScan(results pgx.BatchResults) ([][]int, error)
GenSeriesStr1(ctx context.Context) (*string, error)
// GenSeriesStr1Batch enqueues a GenSeriesStr1 query into batch to be executed
// later by the batch.
GenSeriesStr1Batch(batch genericBatch)
// GenSeriesStr1Scan scans the result of an executed GenSeriesStr1Batch query.
GenSeriesStr1Scan(results pgx.BatchResults) (*string, error)
GenSeriesStr(ctx context.Context) ([]*string, error)
// GenSeriesStrBatch enqueues a GenSeriesStr query into batch to be executed
// later by the batch.
GenSeriesStrBatch(batch genericBatch)
// GenSeriesStrScan scans the result of an executed GenSeriesStrBatch query.
GenSeriesStrScan(results pgx.BatchResults) ([]*string, error)
}
Querier is a typesafe Go interface backed by SQL queries.
Methods ending with Batch enqueue a query to run later in a pgx.Batch. After calling SendBatch on pgx.Conn, pgxpool.Pool, or pgx.Tx, use the Scan methods to parse the results.