This is an automated email from the ASF dual-hosted git repository. asf-gitbox-commits pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/cayenne.git
commit ac01c70b88f8eca347f527803baed2f8d8f4f14b Author: Andrus Adamchik <[email protected]> AuthorDate: Fri Jul 3 18:07:55 2026 -0400 CAY-2912 Compact SQL logger cleanup --- .../src/main/java/org/apache/cayenne/access/LoggingObserver.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/cayenne/src/main/java/org/apache/cayenne/access/LoggingObserver.java b/cayenne/src/main/java/org/apache/cayenne/access/LoggingObserver.java index efc26acca..2168ecce1 100644 --- a/cayenne/src/main/java/org/apache/cayenne/access/LoggingObserver.java +++ b/cayenne/src/main/java/org/apache/cayenne/access/LoggingObserver.java @@ -56,7 +56,9 @@ class LoggingObserver implements OperationObserver { this.logger = logger; } - private void flushPending() { + // a batch reports its counts across several next*Count callbacks; the accumulated total can only be logged as a + // single "updated:N" line once the batch is done, i.e. at the next statement or on success. + private void flushPendingBatchUpdate() { if (!headerEmitted && batchHasUpdate && current != null) { logger.logUpdate(current, batchUpdateSum, generatedKeys != null ? generatedKeys : List.of()); headerEmitted = true; @@ -95,13 +97,13 @@ class LoggingObserver implements OperationObserver { @Override public void onSuccess() { - flushPending(); + flushPendingBatchUpdate(); current = null; } @Override public void nextStatement(Query query, TranslatedStatement statement) { - flushPending(); + flushPendingBatchUpdate(); this.current = statement; this.headerEmitted = false; this.batchHasUpdate = false;
