diff --git a/sq/scanner.go b/sq/scanner.go index b34fb3f..00833a6 100644 --- a/sq/scanner.go +++ b/sq/scanner.go @@ -73,6 +73,10 @@ func ScanSingle[TData any](rows *sqlx.Rows, mode StructScanMode, sec StructScanS } } + if err := rows.Err(); err != nil { + return *new(TData), err + } + return data, nil } else { @@ -130,5 +134,8 @@ func ScanAll[TData any](rows *sqlx.Rows, mode StructScanMode, sec StructScanSafe return nil, err } } + if err := rows.Err(); err != nil { + return nil, err + } return res, nil }