From fae36e98b4c3d72941e3f209a87047332ff51ba1 Mon Sep 17 00:00:00 2001 From: Sam Brannen Date: Mon, 21 Mar 2022 16:21:08 +0100 Subject: [PATCH] Remove obsolete code in R2dbcTransactionManager See gh-28059 Closes gh-28202 --- .../connection/R2dbcTransactionManager.java | 17 ----------------- 1 file changed, 17 deletions(-) diff --git a/spring-r2dbc/src/main/java/org/springframework/r2dbc/connection/R2dbcTransactionManager.java b/spring-r2dbc/src/main/java/org/springframework/r2dbc/connection/R2dbcTransactionManager.java index 9d5ff8e3cf..c17449c355 100644 --- a/spring-r2dbc/src/main/java/org/springframework/r2dbc/connection/R2dbcTransactionManager.java +++ b/spring-r2dbc/src/main/java/org/springframework/r2dbc/connection/R2dbcTransactionManager.java @@ -360,11 +360,6 @@ public class R2dbcTransactionManager extends AbstractReactiveTransactionManager afterCleanup = afterCleanup.then(Mono.from(con.setAutoCommit(true))); } - if (txObject.getPreviousIsolationLevel() != null) { - afterCleanup = afterCleanup - .then(Mono.from(con.setTransactionIsolationLevel(txObject.getPreviousIsolationLevel()))); - } - return afterCleanup.then(Mono.defer(() -> { try { if (txObject.isNewConnectionHolder()) { @@ -519,9 +514,6 @@ public class R2dbcTransactionManager extends AbstractReactiveTransactionManager @Nullable private ConnectionHolder connectionHolder; - @Nullable - private IsolationLevel previousIsolationLevel; - private boolean newConnectionHolder; private boolean mustRestoreAutoCommit; @@ -552,15 +544,6 @@ public class R2dbcTransactionManager extends AbstractReactiveTransactionManager return (this.connectionHolder != null); } - public void setPreviousIsolationLevel(@Nullable IsolationLevel previousIsolationLevel) { - this.previousIsolationLevel = previousIsolationLevel; - } - - @Nullable - public IsolationLevel getPreviousIsolationLevel() { - return this.previousIsolationLevel; - } - public void setMustRestoreAutoCommit(boolean mustRestoreAutoCommit) { this.mustRestoreAutoCommit = mustRestoreAutoCommit; }