HHH-10264 - hibernate.cache.auto_evict_collection_cache problems;

HHH-9140 - Error in CollectionCacheInvalidator when hibernate.cache.auto_evict_collection_cache is enabled

(cherry picked from commit 1d5b077)

Author: sebersole

hibernate-core/src/main/java/org/hibernate/cache/internal/CollectionCacheInvalidator.java

@@ -45,8 +45,11 @@
 public class CollectionCacheInvalidator
 		implements Integrator, PostInsertEventListener, PostDeleteEventListener, PostUpdateEventListener {
 	private static final Logger LOG = Logger.getLogger( CollectionCacheInvalidator.class.getName() );
-	public static final String PROPAGATE_EXCEPTION = "hibernate.test.auto_evict_collection_cache.propagate_exception";
-	private boolean propagateException;
+
+	/**
+	 * Exposed for use in testing
+	 */
+	public static boolean PROPAGATE_EXCEPTION = false;
 
 	@Override
 	public void integrate(Metadata metadata, SessionFactoryImplementor sessionFactory,
@@ -87,8 +90,6 @@ private void integrate(SessionFactoryServiceRegistry serviceRegistry, SessionFac
 			// Nothing to do, if caching is disabled
 			return;
 		}
-		propagateException = Boolean.parseBoolean(
-				sessionFactory.getProperties().getProperty( PROPAGATE_EXCEPTION ) );
 		EventListenerRegistry eventListenerRegistry = serviceRegistry.getService( EventListenerRegistry.class );
 		eventListenerRegistry.appendListeners( EventType.POST_INSERT, this );
 		eventListenerRegistry.appendListeners( EventType.POST_DELETE, this );
@@ -149,7 +150,7 @@ public void doAfterTransactionCompletion(boolean success, SessionImplementor ses
 			}
 		}
 		catch ( Exception e ) {
-			if ( propagateException ) {
+			if ( PROPAGATE_EXCEPTION ) {
 				throw new IllegalStateException( e );
 			}
 			// don't let decaching influence other logic

hibernate-core/src/test/java/org/hibernate/test/cache/CollectionCacheEvictionTest.java

@@ -17,6 +17,8 @@
 
 import org.hibernate.testing.TestForIssue;
 import org.hibernate.testing.junit4.BaseCoreFunctionalTestCase;
+import org.junit.After;
+import org.junit.Before;
 import org.junit.Test;
 
 import static org.junit.Assert.assertEquals;
@@ -34,14 +36,23 @@ protected Class<?>[] getAnnotatedClasses() {
 		return new Class[] { User.class, Company.class };
 	}
 
+	@Before
+	public void before() {
+		CollectionCacheInvalidator.PROPAGATE_EXCEPTION = true;
+	}
+
+	@After
+	public void after() {
+		CollectionCacheInvalidator.PROPAGATE_EXCEPTION = false;
+	}
+
 	@Override
 	protected void configure(Configuration cfg) {
 		super.configure( cfg );
 		cfg.setProperty( Environment.AUTO_EVICT_COLLECTION_CACHE, "true" );
 		cfg.setProperty( Environment.USE_SECOND_LEVEL_CACHE, "true" );
 		cfg.setProperty( Environment.USE_QUERY_CACHE, "true" );
 		cfg.setProperty( Environment.CACHE_PROVIDER_CONFIG, "true" );
-		cfg.setProperty( CollectionCacheInvalidator.PROPAGATE_EXCEPTION, "true" );
 	}
 
 	@Override

hibernate-core/src/test/java/org/hibernate/test/cache/CollectionCacheEvictionWithoutMappedByTest.java

@@ -24,6 +24,8 @@
 import org.hibernate.cfg.Environment;
 
 import org.hibernate.testing.junit4.BaseCoreFunctionalTestCase;
+import org.junit.After;
+import org.junit.Before;
 import org.junit.Test;
 
 import static org.junit.Assert.assertEquals;
@@ -38,13 +40,22 @@ protected Class<?>[] getAnnotatedClasses() {
 		return new Class[] {Person.class, People.class};
 	}
 
+	@Before
+	public void before() {
+		CollectionCacheInvalidator.PROPAGATE_EXCEPTION = true;
+	}
+
+	@After
+	public void after() {
+		CollectionCacheInvalidator.PROPAGATE_EXCEPTION = false;
+	}
+
 	@Override
 	protected void configure(Configuration cfg) {
 		cfg.setProperty( Environment.AUTO_EVICT_COLLECTION_CACHE, "true" );
 		cfg.setProperty( Environment.USE_SECOND_LEVEL_CACHE, "true" );
 		cfg.setProperty( Environment.USE_QUERY_CACHE, "true" );
 		cfg.setProperty( Environment.CACHE_PROVIDER_CONFIG, "true" );
-		cfg.setProperty( CollectionCacheInvalidator.PROPAGATE_EXCEPTION, "true" );
 	}
 
 	private People createPeople() {