Hhh 19593

hibernate-core/src/main/java/org/hibernate/engine/jdbc/internal/JdbcCoordinatorImpl.java

@@ -49,6 +49,7 @@
  */
 public class JdbcCoordinatorImpl implements JdbcCoordinator {
 	private static final CoreMessageLogger LOG = CoreLogging.messageLogger( JdbcCoordinatorImpl.class );
+	private static final boolean TRACE_ENABLED = LOG.isTraceEnabled();
 
 	private transient final LogicalConnectionImplementor logicalConnection;
 	private transient final JdbcSessionOwner owner;
@@ -141,7 +142,7 @@ public void flushEnding() {
 
 	@Override
 	public Connection close() {
-		LOG.tracev( "Closing JDBC container [{0}]", this );
+		if ( TRACE_ENABLED ) LOG.tracev( "Closing JDBC container [{0}]", this );
 		Connection connection;
 		try {
 			if ( currentBatch != null ) {
@@ -264,7 +265,7 @@ public int determineRemainingTransactionTimeOutPeriod() {
 	@Override
 	public void afterStatementExecution() {
 		final ConnectionReleaseMode connectionReleaseMode = connectionReleaseMode();
-		LOG.tracev( "Starting after statement execution processing [{0}]", connectionReleaseMode );
+		if ( TRACE_ENABLED ) LOG.tracev( "Starting after statement execution processing [{0}]", connectionReleaseMode );
 		if ( connectionReleaseMode == AFTER_STATEMENT ) {
 			if ( ! releasesEnabled ) {
 				LOG.debug( "Skipping aggressive release due to manual disabling" );
@@ -320,7 +321,7 @@ public boolean isReadyForSerialization() {
 	@Override
 	@SuppressWarnings("unchecked")
 	public void registerLastQuery(Statement statement) {
-		LOG.tracev( "Registering last query statement [{0}]", statement );
+		if ( TRACE_ENABLED ) LOG.tracev( "Registering last query statement [{0}]", statement );
 		if ( statement instanceof JdbcWrapper ) {
 			final JdbcWrapper<Statement> wrapper = (JdbcWrapper<Statement>) statement;
 			registerLastQuery( wrapper.getWrappedObject() );

hibernate-core/src/main/java/org/hibernate/resource/jdbc/internal/ResourceRegistryStandardImpl.java

@@ -11,9 +11,7 @@
 import java.sql.SQLException;
 import java.sql.Statement;
 import java.util.ArrayList;
-import java.util.HashMap;
 
-import org.hibernate.HibernateException;
 import org.hibernate.JDBCException;
 import org.hibernate.internal.CoreLogging;
 import org.hibernate.internal.CoreMessageLogger;
@@ -40,17 +38,9 @@ public final class ResourceRegistryStandardImpl implements ResourceRegistry {
 	private static final CoreMessageLogger log = CoreLogging.messageLogger( ResourceRegistryStandardImpl.class );
 	private static final boolean IS_TRACE_ENABLED = log.isTraceEnabled();
 
-	// Dummy value to associate with an Object in the backing Map when we use it as a set:
-	private static final Object PRESENT = new Object();
-
-	//Used instead of Collections.EMPTY_SET to avoid polymorphic calls on xref;
-	//Also, uses an HashMap as it were an HashSet, as technically we just need the Set semantics
-	//but in this case the overhead of HashSet is not negligible.
-	private static final HashMap<ResultSet,Object> EMPTY = new HashMap<>( 1, 0.2f );
-
 	private final JdbcEventHandler jdbcEventHandler;
 
-	private final HashMap<Statement, HashMap<ResultSet,Object>> xref = new HashMap<>();
+	private final ResultsetsTrackingContainer xref = new ResultsetsTrackingContainer();
 
 	private ExtendedState ext;
 	private Statement lastQuery;
@@ -65,18 +55,15 @@ public ResourceRegistryStandardImpl(JdbcEventHandler jdbcEventHandler) {
 
 	@Override
 	public boolean hasRegisteredResources() {
-		return hasRegistered( xref )
+		return xref.hasRegisteredResources()
 			|| ext != null && ext.hasRegisteredResources();
 	}
 
 	@Override
 	public void register(Statement statement, boolean cancelable) {
 		if ( IS_TRACE_ENABLED ) log.tracef( "Registering statement [%s]", statement );
 
-		HashMap<ResultSet,Object> previousValue = xref.putIfAbsent( statement, EMPTY );
-		if ( previousValue != null ) {
-			throw new HibernateException( "JDBC Statement already registered" );
-		}
+		xref.registerExpectingNew( statement );
 
 		if ( cancelable ) {
 			lastQuery = statement;
@@ -87,7 +74,7 @@ public void register(Statement statement, boolean cancelable) {
 	public void release(Statement statement) {
 		if ( IS_TRACE_ENABLED ) log.tracev( "Releasing statement [{0}]", statement );
 
-		final HashMap<ResultSet,Object> resultSets = xref.remove( statement );
+		final ResultSetsSet resultSets = xref.remove( statement );
 		if ( resultSets != null ) {
 			closeAll( resultSets );
 		}
@@ -117,12 +104,12 @@ public void release(ResultSet resultSet, Statement statement) {
 			}
 		}
 		if ( statement != null ) {
-			final HashMap<ResultSet,Object> resultSets = xref.get( statement );
+			final ResultSetsSet resultSets = xref.getForResultSetRemoval( statement );
 			if ( resultSets == null ) {
 				log.unregisteredStatement();
 			}
 			else {
-				resultSets.remove( resultSet );
+				resultSets.removeResultSet( resultSet );
 				if ( resultSets.isEmpty() ) {
 					try {
 						if ( statement.isClosed() ) {
@@ -143,15 +130,14 @@ public void release(ResultSet resultSet, Statement statement) {
 		close( resultSet );
 	}
 
-	private static void closeAll(final HashMap<ResultSet,Object> resultSets) {
+	private static void closeAll(final ResultSetsSet resultSets) {
 		if ( resultSets == null ) {
 			return;
 		}
-		resultSets.forEach( (resultSet, o) -> close( resultSet ) );
-		resultSets.clear();
+		resultSets.forEachResultSet( ResourceRegistryStandardImpl::close );
 	}
 
-	private static void releaseXref(final Statement s, final HashMap<ResultSet, Object> r) {
+	private static void releaseXref(final Statement s, final ResultSetsSet r) {
 		closeAll( r );
 		close( s );
 	}
@@ -219,19 +205,7 @@ public void register(ResultSet resultSet, Statement statement) {
 			}
 		}
 		if ( statement != null ) {
-			HashMap<ResultSet,Object> resultSets = xref.get( statement );
-
-			// Keep this at DEBUG level, rather than warn.  Numerous connection pool implementations can return a
-			// proxy/wrapper around the JDBC Statement, causing excessive logging here.  See HHH-8210.
-			if ( resultSets == null ) {
-				log.debug( "ResultSet statement was not registered (on register)" );
-			}
-
-			if ( resultSets == null || resultSets == EMPTY ) {
-				resultSets = new HashMap<>();
-				xref.put( statement, resultSets );
-			}
-			resultSets.put( resultSet, PRESENT );
+			xref.storeAssociatedResultset( statement, resultSet );
 		}
 		else {
 			getExtendedStateForWrite().storeUnassociatedResultset( resultSet );
@@ -328,7 +302,7 @@ public void releaseResources() {
 		}
 	}
 
-	private static boolean hasRegistered(final HashMap resource) {
+	private static boolean hasRegistered(final ResultSetsSet resource) {
 		return resource != null && !resource.isEmpty();
 	}
 
@@ -344,7 +318,7 @@ private static boolean hasRegistered(final ArrayList resource) {
 	 */
 	private static class ExtendedState {
 		//All fields lazily initialized as well:
-		private HashMap<ResultSet,Object> unassociatedResultSets;
+		private ResultSetsSet unassociatedResultSets;
 		private ArrayList<Blob> blobs;
 		private ArrayList<Clob> clobs;
 		private ArrayList<NClob> nclobs;
@@ -357,17 +331,17 @@ public boolean hasRegisteredResources() {
 		}
 
 		public void releaseUnassociatedResult(final ResultSet resultSet) {
-			final Object removed = unassociatedResultSets == null ? null : unassociatedResultSets.remove( resultSet );
+			final Object removed = unassociatedResultSets == null ? null : unassociatedResultSets.removeResultSet( resultSet );
 			if ( removed == null ) {
 				log.unregisteredResultSetWithoutStatement();
 			}
 		}
 
 		public void storeUnassociatedResultset(ResultSet resultSet) {
 			if ( unassociatedResultSets == null ) {
-				this.unassociatedResultSets = new HashMap<>();
+				this.unassociatedResultSets = new ResultSetsSet();
 			}
-			unassociatedResultSets.put( resultSet, PRESENT );
+			unassociatedResultSets.storeResultSet( resultSet );
 		}
 
 		public void registerBlob(final Blob blob) {
@@ -394,6 +368,7 @@ public void registerNClob(final NClob nclob) {
 
 		public void releaseResources() {
 			closeAll( unassociatedResultSets );
+			unassociatedResultSets.clear();
 
 			if ( blobs != null ) {
 				blobs.forEach( blob -> {

hibernate-core/src/main/java/org/hibernate/resource/jdbc/internal/ResultSetsSet.java

@@ -0,0 +1,94 @@
+/*
+ * SPDX-License-Identifier: Apache-2.0
+ * Copyright Red Hat Inc. and Hibernate Authors
+ */
+package org.hibernate.resource.jdbc.internal;
+
+import java.sql.ResultSet;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.function.Consumer;
+
+/**
+ * Similar goal as in {@link ResultsetsTrackingContainer}: make sure to
+ * be very efficient when handling a single {@link ResultSet}
+ * as it's a very common case, and try to avoid needing the hashcodes.
+ * Yet we want to allow scaling to multiple instances as well.
+ */
+final class ResultSetsSet {
+
+	//Implementation notes:
+	// # if first is null, then the Map in field 'more' is guaranteed to be empty
+	// # The 'more' Map is lazily initialized, but when emptied it's not guaranteed to be made null
+
+	private ResultSet first;
+	//This could have been a set, but we intentionally use a Map instead to avoid the wrapping done in
+	//HashSet.
+	private HashMap<ResultSet,ResultSet> more;
+
+	void forEachResultSet(final Consumer<ResultSet> action) {
+		if ( first != null ) {
+			action.accept( first );
+			if ( more != null ) {
+				more.keySet().forEach( action );
+			}
+		}
+	}
+
+	void storeResultSet(final ResultSet resultSet) {
+		if ( first == null ) {
+			//no need for further checks as we guarantee "more" to be empty in this case
+			first = resultSet;
+		}
+		else if ( first == resultSet ) {
+			//no-op for this special case
+		}
+		else {
+			if ( more == null ) {
+				more = new HashMap<>();
+			}
+			more.put( resultSet, resultSet );
+		}
+	}
+
+	boolean isEmpty() {
+		return first == null;
+	}
+
+	ResultSet removeResultSet(final ResultSet resultSet) {
+		if ( first == resultSet ) {
+			ResultSet v = first;
+			first = null;
+			scaleDown();
+			return v;
+		}
+		else if ( more != null ) {
+			return more.remove( resultSet );
+		}
+		else {
+			return null;
+		}
+	}
+
+	//When slot "first" is made available, make sure to move an entry from "more" into that field.
+	//Any entry will do, so we take the first one if there's any.
+	private void scaleDown() {
+		if ( more != null && !more.isEmpty() ) {
+			Iterator<Map.Entry<ResultSet, ResultSet>> iterator = more.entrySet().iterator();
+			Map.Entry<ResultSet, ResultSet> entry = iterator.next();
+			final ResultSet resultSet = entry.getKey();
+			iterator.remove();
+			first = resultSet;
+		}
+	}
+
+	void clear() {
+		first = null;
+		if ( more != null ) {
+			more.clear();
+			this.more = null;
+		}
+	}
+
+}