You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by lu...@apache.org on 2022/07/13 10:14:08 UTC
[shardingsphere] branch master updated: Remove reset operations which has already considered in Hikari (#19094)
This is an automated email from the ASF dual-hosted git repository.
lujingshang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new e48bea0c88c Remove reset operations which has already considered in Hikari (#19094)
e48bea0c88c is described below
commit e48bea0c88c7fad0a9f7df34198752040c4c5467
Author: 吴伟杰 <wu...@apache.org>
AuthorDate: Wed Jul 13 18:14:00 2022 +0800
Remove reset operations which has already considered in Hikari (#19094)
---
.../jdbc/connection/JDBCBackendConnection.java | 13 -------------
1 file changed, 13 deletions(-)
diff --git a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/JDBCBackendConnection.java b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/JDBCBackendConnection.java
index aacc8a989be..c2583d6e7ad 100644
--- a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/JDBCBackendConnection.java
+++ b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/communication/jdbc/connection/JDBCBackendConnection.java
@@ -257,7 +257,6 @@ public final class JDBCBackendConnection implements BackendConnection<Void>, Exe
if (forceRollback && connectionSession.getTransactionStatus().isInTransaction()) {
each.rollback();
}
- resetConnection(each);
each.close();
} catch (final SQLException ex) {
result.add(ex);
@@ -271,18 +270,6 @@ public final class JDBCBackendConnection implements BackendConnection<Void>, Exe
return result;
}
- private void resetConnection(final Connection connection) throws SQLException {
- if (null == connection) {
- return;
- }
- if (connectionSession.isReadOnly()) {
- connection.setReadOnly(false);
- }
- if (null != connectionSession.getDefaultIsolationLevel()) {
- connection.setTransactionIsolation(TransactionUtil.getTransactionIsolationLevel(connectionSession.getIsolationLevel()));
- }
- }
-
/**
* Close federation executor.
*