fix

Author: DavideD

hibernate-reactive-core/src/main/java/org/hibernate/reactive/query/sql/internal/ReactiveNativeQueryImpl.java

@@ -142,19 +142,14 @@ private ReactiveSelectQueryPlan<R> reactiveSelectPlan() {
 	private ReactiveNonSelectQueryPlan reactiveNonSelectPlan() {
 		final QueryInterpretationCache.Key cacheKey = generateNonSelectInterpretationsKey();
 		if ( cacheKey != null ) {
-			NonSelectQueryPlan queryPlan = getSession().getFactory().getQueryEngine()
-					.getInterpretationCache().getNonSelectQueryPlan( cacheKey );
+			NonSelectQueryPlan queryPlan = getSession().getFactory().getQueryEngine().getInterpretationCache().getNonSelectQueryPlan( cacheKey );
 			if ( queryPlan != null ) {
 				return (ReactiveNonSelectQueryPlan) queryPlan;
 			}
 		}
 
-		final String sqlString = expandParameterLists();
-		ReactiveNonSelectQueryPlan queryPlan = new ReactiveNativeNonSelectQueryPlan(
-				sqlString,
-				getQuerySpaces(),
-				getParameterOccurrences()
-		);
+		final String sqlString = expandParameterLists( 1 );
+		ReactiveNonSelectQueryPlan queryPlan = new ReactiveNativeNonSelectQueryPlan( sqlString, getQuerySpaces(), getParameterOccurrences() );
 		if ( cacheKey != null ) {
 			getSession().getFactory().getQueryEngine().getInterpretationCache()
 					.cacheNonSelectQueryPlan( cacheKey, queryPlan );

hibernate-reactive-core/src/main/java/org/hibernate/reactive/sql/results/ReactiveResultSetMapping.java

@@ -27,7 +27,7 @@
 import org.hibernate.sql.results.jdbc.spi.JdbcValuesMetadata;
 
 /**
- * @see org.hibernate.query.results.ResultSetMappingImpl
+ * @see org.hibernate.query.results.internal.ResultSetMappingImpl
  */
 public class ReactiveResultSetMapping implements ResultSetMapping, ReactiveValuesMappingProducer {
 
@@ -62,6 +62,11 @@ public CompletionStage<JdbcValuesMapping> reactiveResolve(
 				.thenApply( columnCount -> delegate.resolve( jdbcResultsMetadata, loadQueryInfluencers, sessionFactory ) );
 	}
 
+	@Override
+	public ResultSetMapping cacheKeyInstance() {
+		return new ReactiveResultSetMapping( delegate.cacheKeyInstance() );
+	}
+
 	@Override
 	public String getMappingIdentifier() {
 		return delegate.getMappingIdentifier();