Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove obsolete code in R2dbcTransactionManager

Browse Source 
See gh-28059
Closes gh-28202
This commit is contained in:
Sam Brannen
2022-03-21 16:21:08 +01:00
parent 3da7a48a17
commit fae36e98b4
1 changed files with 0 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
spring-r2dbc/src/main/java/org/springframework/r2dbc/connection/R2dbcTransactionManager.java
View File

@@ -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;
}