Fix

Author: DavideD

hibernate-reactive-core/src/main/java/org/hibernate/reactive/query/sqm/mutation/internal/temptable/ReactiveSoftDeleteExecutionDelegate.java

@@ -1,3 +1,8 @@
+/* Hibernate, Relational Persistence for Idiomatic Java
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * Copyright: Red Hat Inc. and Hibernate Authors
+ */
 package org.hibernate.reactive.query.sqm.mutation.internal.temptable;
 
 import java.util.ArrayList;

hibernate-reactive-core/src/main/java/org/hibernate/reactive/query/sqm/mutation/internal/temptable/ReactiveTableBasedDeleteHandler.java

@@ -56,17 +56,26 @@ public ReactiveTableBasedDeleteHandler(
 	@Override
 	public CompletionStage<Integer> reactiveExecute(DomainQueryExecutionContext executionContext) {
 		if ( LOG.isTraceEnabled() ) {
-			LOG.tracef(
-					"Starting multi-table delete execution - %s",
-					getSqmDeleteOrUpdateStatement().getRoot().getModel().getName()
-			);
+			LOG.tracef( "Starting multi-table delete execution - %s", getSqmDeleteOrUpdateStatement().getRoot().getModel().getName() );
 		}
 		return resolveDelegate( executionContext ).reactiveExecute( executionContext );
 	}
 
 	protected ReactiveExecutionDelegate resolveDelegate(DomainQueryExecutionContext executionContext) {
 		if ( getEntityDescriptor().getSoftDeleteMapping() != null ) {
-			// TODO : implement a reactive version of SoftDeleteExecutionDelegate
+			return new ReactiveSoftDeleteExecutionDelegate(
+					getEntityDescriptor(),
+					getIdTable(),
+					getTemporaryTableStrategy(),
+					isForceDropAfterUse(),
+					getSqmDeleteOrUpdateStatement(),
+					getDomainParameterXref(),
+					executionContext.getQueryOptions(),
+					executionContext.getSession().getLoadQueryInfluencers(),
+					executionContext.getQueryParameterBindings(),
+					getSessionUidAccess(),
+					getSessionFactory()
+			);
 		}
 		return new ReactiveRestrictedDeleteExecutionDelegate(
 				getEntityDescriptor(),
@@ -75,10 +84,10 @@ protected ReactiveExecutionDelegate resolveDelegate(DomainQueryExecutionContext
 				isForceDropAfterUse(),
 				getSqmDeleteOrUpdateStatement(),
 				getDomainParameterXref(),
-				getSessionUidAccess(),
 				executionContext.getQueryOptions(),
 				executionContext.getSession().getLoadQueryInfluencers(),
 				executionContext.getQueryParameterBindings(),
+				getSessionUidAccess(),
 				getSessionFactory()
 		);
 	}