1 package pgxpool
2
3 import (
4 "github.com/jackc/pgconn"
5 "github.com/jackc/pgx/v4"
6 )
7
8 type errBatchResults struct {
9 err error
10 }
11
12 func (br errBatchResults) Exec() (pgconn.CommandTag, error) {
13 return nil, br.err
14 }
15
16 func (br errBatchResults) Query() (pgx.Rows, error) {
17 return errRows{err: br.err}, br.err
18 }
19
20 func (br errBatchResults) QueryFunc(scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error) {
21 return nil, br.err
22 }
23
24 func (br errBatchResults) QueryRow() pgx.Row {
25 return errRow{err: br.err}
26 }
27
28 func (br errBatchResults) Close() error {
29 return br.err
30 }
31
32 type poolBatchResults struct {
33 br pgx.BatchResults
34 c *Conn
35 }
36
37 func (br *poolBatchResults) Exec() (pgconn.CommandTag, error) {
38 return br.br.Exec()
39 }
40
41 func (br *poolBatchResults) Query() (pgx.Rows, error) {
42 return br.br.Query()
43 }
44
45 func (br *poolBatchResults) QueryFunc(scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error) {
46 return br.br.QueryFunc(scans, f)
47 }
48
49 func (br *poolBatchResults) QueryRow() pgx.Row {
50 return br.br.QueryRow()
51 }
52
53 func (br *poolBatchResults) Close() error {
54 err := br.br.Close()
55 if br.c != nil {
56 br.c.Release()
57 br.c = nil
58 }
59 return err
60 }
61
View as plain text