Check rows.Err

internal/dbtest/db_test.go

@@ -339,6 +339,7 @@ func testScanSingleRowByRow(t *testing.T, db *bun.DB) {
 
 		nums = append(nums, num)
 	}
+	require.NoError(t, rows.Err())
 
 	require.Equal(t, []int{3, 2, 1}, nums)
 }

model_map_slice.go

@@ -56,6 +56,9 @@ func (m *mapSliceModel) ScanRows(ctx context.Context, rows *sql.Rows) (int, erro
 		slice = append(slice, m.m)
 		n++
 	}
+	if err := rows.Err(); err != nil {
+		return 0, err
+	}
 
 	*m.slicePtr = slice
 	return n, nil

model_slice.go

@@ -62,6 +62,9 @@ func (m *sliceModel) ScanRows(ctx context.Context, rows *sql.Rows) (int, error)
 		}
 		n++
 	}
+	if err := rows.Err(); err != nil {
+		return 0, err
+	}
 
 	return n, nil
 }

model_table_has_many.go

@@ -72,6 +72,9 @@ func (m *hasManyModel) ScanRows(ctx context.Context, rows *sql.Rows) (int, error
 
 		n++
 	}
+	if err := rows.Err(); err != nil {
+		return 0, err
+	}
 
 	return n, nil
 }

model_table_m2m.go

@@ -72,6 +72,9 @@ func (m *m2mModel) ScanRows(ctx context.Context, rows *sql.Rows) (int, error) {
 
 		n++
 	}
+	if err := rows.Err(); err != nil {
+		return 0, err
+	}
 
 	return n, nil
 }

model_table_slice.go

@@ -89,6 +89,9 @@ func (m *sliceTableModel) ScanRows(ctx context.Context, rows *sql.Rows) (int, er
 
 		n++
 	}
+	if err := rows.Err(); err != nil {
+		return 0, err
+	}
 
 	return n, nil
 }