From 198c05e9831cebee40be643207d6aa223bff3e0e Mon Sep 17 00:00:00 2001 From: Lukas Eder Date: Wed, 3 May 2023 17:41:12 +0200 Subject: [PATCH] [jOOQ/jOOQ#14840] Apply Settings.batchSize also to BatchMultiple --- jOOQ/src/main/java/org/jooq/impl/BatchMultiple.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/jOOQ/src/main/java/org/jooq/impl/BatchMultiple.java b/jOOQ/src/main/java/org/jooq/impl/BatchMultiple.java index e7aa72fa9e..2ff8d4b4d2 100644 --- a/jOOQ/src/main/java/org/jooq/impl/BatchMultiple.java +++ b/jOOQ/src/main/java/org/jooq/impl/BatchMultiple.java @@ -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) {