From ac6473e0392a320cc171228cab79deb34a8479f1 Mon Sep 17 00:00:00 2001 From: Rob Bygrave Date: Tue, 10 Oct 2023 00:59:06 +1300 Subject: [PATCH] Change SQL log to include executeBatch() via BatchedPstmt --- .../java/io/ebeaninternal/server/persist/BatchedPstmt.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/ebean-core/src/main/java/io/ebeaninternal/server/persist/BatchedPstmt.java b/ebean-core/src/main/java/io/ebeaninternal/server/persist/BatchedPstmt.java index ddd1747a1..e39f79629 100644 --- a/ebean-core/src/main/java/io/ebeaninternal/server/persist/BatchedPstmt.java +++ b/ebean-core/src/main/java/io/ebeaninternal/server/persist/BatchedPstmt.java @@ -84,6 +84,9 @@ public final class BatchedPstmt implements SpiProfileTransactionEvent { */ private void flushStatementBatch() throws SQLException { final int[] rows = pstmt.executeBatch(); + if (transaction.isLogSql()) { + transaction.logSql(" -- executeBatch() size:{0} sql:{1}", rows.length, sql); + } if (rows.length != list.size()) { throw new IllegalStateException("Invalid state on executeBatch, rows:" + rows.length + " != " + list.size()); } @@ -153,6 +156,9 @@ public final class BatchedPstmt implements SpiProfileTransactionEvent { private void executeAndCheckRowCounts() throws SQLException { try { results = pstmt.executeBatch(); + if (transaction.isLogSql()) { + transaction.logSql(" -- executeBatch() size:{0} sql:{1}", results.length, sql); + } if (results.length != list.size()) { throw new SQLException("Invalid state on executeBatch, rows:" + results.length + " != " + list.size()); }