|
|
@ -141,7 +141,6 @@ func (s statement) QueryRowsPartialCtx(ctx context.Context, v any, args ...any)
|
|
|
|
func (s statement) queryRows(ctx context.Context, scanFn func(any, rowsScanner) error,
|
|
|
|
func (s statement) queryRows(ctx context.Context, scanFn func(any, rowsScanner) error,
|
|
|
|
v any, args ...any) error {
|
|
|
|
v any, args ...any) error {
|
|
|
|
var scanFailed bool
|
|
|
|
var scanFailed bool
|
|
|
|
|
|
|
|
|
|
|
|
err := s.brk.DoWithAcceptable(func() error {
|
|
|
|
err := s.brk.DoWithAcceptable(func() error {
|
|
|
|
return queryStmt(ctx, s.stmt, func(rows *sql.Rows) error {
|
|
|
|
return queryStmt(ctx, s.stmt, func(rows *sql.Rows) error {
|
|
|
|
err := scanFn(v, rows)
|
|
|
|
err := scanFn(v, rows)
|
|
|
|