github/jooq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[jOOQ/jOOQ#14840] Apply Settings.batchSize also to BatchMultiple

Browse Source
This commit is contained in:
Lukas Eder 2023-05-03 17:41:12 +02:00
parent 5d84509b47
commit 198c05e983
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
jOOQ/src/main/java/org/jooq/impl/BatchMultiple.java
View File

@ -38,6 +38,8 @@
package org.jooq.impl;
import java.sql.SQLException;
import java.util.Arrays;
import java.util.stream.IntStream;
import java.util.stream.Stream;
import org.jooq.Configuration;
@ -85,7 +87,12 @@ final class BatchMultiple extends AbstractBatch {
@Override
public final int[] execute() {
return execute(Tools.configuration(configuration), queries);
return
Tools.chunks(Arrays.asList(queries), SettingsTools.getBatchSize(Tools.settings(configuration)))
.stream()
.map(chunk -> execute(Tools.configuration(configuration), chunk.toArray(Tools.EMPTY_QUERY)))
.flatMapToInt(IntStream::of)
.toArray();
}
static int[] execute(Configuration configuration, Query[] queries) {