diff --git a/hibernate-core/src/main/java/org/hibernate/engine/jdbc/internal/JdbcCoordinatorImpl.java b/hibernate-core/src/main/java/org/hibernate/engine/jdbc/internal/JdbcCoordinatorImpl.java index 3388f7c3ae..9a4ba49a3b 100644 --- a/hibernate-core/src/main/java/org/hibernate/engine/jdbc/internal/JdbcCoordinatorImpl.java +++ b/hibernate-core/src/main/java/org/hibernate/engine/jdbc/internal/JdbcCoordinatorImpl.java @@ -67,13 +67,9 @@ public class JdbcCoordinatorImpl implements JdbcCoordinator { private transient long transactionTimeOutInstant = -1; - private final HashMap> xref = new HashMap<>(); - private final Set unassociatedResultSets = new HashSet<>(); - private Statement lastQuery; private final boolean isUserSuppliedConnection; - /** * If true, manually (and temporarily) circumvent aggressive release processing. */ @@ -174,7 +170,6 @@ public class JdbcCoordinatorImpl implements JdbcCoordinator { LOG.closingUnreleasedBatch(); currentBatch.release(); } - cleanup(); } finally { connection = logicalConnection.close(); @@ -366,23 +361,6 @@ public class JdbcCoordinatorImpl implements JdbcCoordinator { releasesEnabled = false; } - private void cleanup() { - for ( Map.Entry> entry : xref.entrySet() ) { - closeAll( entry.getValue() ); - close( entry.getKey() ); - } - xref.clear(); - - closeAll( unassociatedResultSets ); - } - - protected void closeAll(Set resultSets) { - for ( ResultSet resultSet : resultSets ) { - close( resultSet ); - } - resultSets.clear(); - } - @SuppressWarnings({ "unchecked" }) protected void close(Statement statement) { LOG.tracev( "Closing prepared statement [{0}]", statement );