gopkg/pgx
2
0
Fork 0
Code Activity

Fix pgxpool BatchResults for QueryFunc

Browse Source
This commit is contained in:
Jack Christensen
2021-09-11 11:05:44 -05:00
parent 38cd1b40aa
commit 435605a59c
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pgxpool/batch_results.go
+8
View File
@@ -17,6 +17,10 @@ func (br errBatchResults) Query() (pgx.Rows, error) {
return errRows{err: br.err}, br.err return errRows{err: br.err}, br.err
} }
func (br errBatchResults) QueryFunc(scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error) {
return nil, br.err
}
func (br errBatchResults) QueryRow() pgx.Row { func (br errBatchResults) QueryRow() pgx.Row {
return errRow{err: br.err} return errRow{err: br.err}
} }
@@ -38,6 +42,10 @@ func (br *poolBatchResults) Query() (pgx.Rows, error) {
return br.br.Query() return br.br.Query()
} }
func (br *poolBatchResults) QueryFunc(scans []interface{}, f func(pgx.QueryFuncRow) error) (pgconn.CommandTag, error) {
return br.br.QueryFunc(scans, f)
}
func (br *poolBatchResults) QueryRow() pgx.Row { func (br *poolBatchResults) QueryRow() pgx.Row {
return br.br.QueryRow() return br.br.QueryRow()
} }