[#1379] add reactiveForceFlush() ReactiveSession method

Signed-off-by: blafond <blafond@redhat.com>

Author: blafond

hibernate-reactive-core/src/main/java/org/hibernate/reactive/session/ReactiveSession.java

@@ -13,6 +13,7 @@
 import org.hibernate.LockOptions;
 import org.hibernate.UnknownProfileException;
 import org.hibernate.collection.spi.PersistentCollection;
+import org.hibernate.engine.spi.EntityEntry;
 import org.hibernate.engine.spi.PersistenceContext;
 import org.hibernate.engine.spi.SessionImplementor;
 import org.hibernate.event.internal.MergeContext;
@@ -68,6 +69,8 @@ public interface ReactiveSession extends ReactiveQueryExecutor {
 
 	CompletionStage<Void> reactiveAutoflush();
 
+	CompletionStage<Void> reactiveForceFlush(EntityEntry entry);
+
 	CompletionStage<Void> reactiveRefresh(Object entity, LockOptions lockMode);
 
 	CompletionStage<Void> reactiveRefresh(Object child, IdentitySet refreshedAlready);

hibernate-reactive-core/src/main/java/org/hibernate/reactive/session/impl/ReactiveSessionImpl.java

@@ -898,6 +898,26 @@ public CompletionStage<Void> reactiveAutoflush() {
 		return getHibernateFlushMode().lessThan( FlushMode.COMMIT ) ? voidFuture() : doFlush();
 	}
 
+	@Override
+	public CompletionStage<Void> reactiveForceFlush(EntityEntry entry) {
+		if ( log.isDebugEnabled() ) {
+			log.debugf(
+					"Flushing to force deletion of re-saved object: %s",
+					MessageHelper.infoString( entry.getPersister(), entry.getId(), getFactory() )
+			);
+		}
+
+		if ( getPersistenceContextInternal().getCascadeLevel() > 0 ) {
+			return CompletionStages.failedFuture( new ObjectDeletedException(
+					"deleted object would be re-saved by cascade (remove deleted object from associations)",
+					entry.getId(),
+					entry.getPersister().getEntityName()
+			) );
+		}
+		checkOpenOrWaitingForAutoClose();
+		return doFlush();
+	}
+
 	private CompletionStage<Void> doFlush() {
 		checkTransactionNeededForUpdateOperation( "no transaction is in progress" );
 		pulseTransactionCoordinator();