From 435605a59c4958194d3e0260e4c571db58df19ea Mon Sep 17 00:00:00 2001 From: Jack Christensen Date: Sat, 11 Sep 2021 11:05:44 -0500 Subject: [PATCH] Fix pgxpool BatchResults for QueryFunc --- pgxpool/batch_results.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/pgxpool/batch_results.go b/pgxpool/batch_results.go index ec393a8c..c625a474 100644 --- a/pgxpool/batch_results.go +++ b/pgxpool/batch_results.go @@ -17,6 +17,10 @@ func (br errBatchResults) Query() (pgx.Rows, error) { 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 { return errRow{err: br.err} } @@ -38,6 +42,10 @@ func (br *poolBatchResults) Query() (pgx.Rows, error) { 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 { return br.br.QueryRow() }