1 package pgxpool
2
3 import (
4 "github.com/jackc/pgx/v5"
5 "github.com/jackc/pgx/v5/pgconn"
6 )
7
8 type errBatchResults struct {
9 err error
10 }
11
12 func (br errBatchResults) Exec() (pgconn.CommandTag, error) {
13 return pgconn.CommandTag{}, 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) QueryRow() pgx.Row {
21 return errRow{err: br.err}
22 }
23
24 func (br errBatchResults) Close() error {
25 return br.err
26 }
27
28 type poolBatchResults struct {
29 br pgx.BatchResults
30 c *Conn
31 }
32
33 func (br *poolBatchResults) Exec() (pgconn.CommandTag, error) {
34 return br.br.Exec()
35 }
36
37 func (br *poolBatchResults) Query() (pgx.Rows, error) {
38 return br.br.Query()
39 }
40
41 func (br *poolBatchResults) QueryRow() pgx.Row {
42 return br.br.QueryRow()
43 }
44
45 func (br *poolBatchResults) Close() error {
46 err := br.br.Close()
47 if br.c != nil {
48 br.c.Release()
49 br.c = nil
50 }
51 return err
52 }
53
View as plain text