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() }