#1072

Author: babyfish-ct

project/gradle.properties

@@ -1,2 +1,2 @@
 group=org.babyfish.jimmer
-version=0.9.90
+version=0.9.91

project/jimmer-sql-kotlin/src/main/kotlin/org/babyfish/jimmer/sql/kt/ast/query/KTypedRootQuery.kt

@@ -27,7 +27,7 @@ interface KTypedRootQuery<R> : KExecutable<List<R>> {
 
     fun forEach(
         con: Connection? = null,
-        batchSize: Int = 0,
+        batchSize: Int = -1,
         block: (R) -> Unit
     )
 }

project/jimmer-sql/src/main/java/org/babyfish/jimmer/sql/runtime/Selectors.java

@@ -85,6 +85,7 @@ public static <R> void forEach(
                     return Internal.usingSqlDraftContext((draftContext) -> {
                         Reader.Context ctx = new Reader.Context(draftContext, sqlClient);
                         List<R> results = new ArrayList<>();
+                        stmt.setFetchSize(batchSize);
                         try (ResultSet resultSet = stmt.executeQuery()) {
                             while (resultSet.next()) {
                                 results.add((R) reader.read(resultSet, ctx));