[#2220] Fix errors with ORM 7.0.0.CR1

Plus, update expected Oracle default database mapping in tests:

* `Double` and `double` java types changes from `FLOAT` to `BINARY_DOUBLE`
* `Float` and `float` java types changes from `FLOAT` to `BINARY_FLOAT`

Changes to ReactiveAbstractSelectionQuery

Author: DavideD

hibernate-reactive-core/src/main/java/org/hibernate/reactive/generator/values/internal/ReactiveGeneratedValuesHelper.java

@@ -5,13 +5,6 @@
  */
 package org.hibernate.reactive.generator.values.internal;
 
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.concurrent.CompletionStage;
-
 import org.hibernate.HibernateException;
 import org.hibernate.Internal;
 import org.hibernate.dialect.Dialect;
@@ -48,8 +41,15 @@
 import org.hibernate.sql.results.jdbc.spi.JdbcValuesSourceProcessingOptions;
 import org.hibernate.type.descriptor.WrapperOptions;
 
-import static org.hibernate.generator.internal.NaturalIdHelper.getNaturalIdPropertyNames;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.CompletionStage;
+
 import static org.hibernate.generator.values.internal.GeneratedValuesHelper.noCustomSql;
+import static org.hibernate.internal.NaturalIdHelper.getNaturalIdPropertyNames;
 import static org.hibernate.reactive.sql.results.spi.ReactiveListResultsConsumer.UniqueSemantic.NONE;
 
 /**

hibernate-reactive-core/src/main/java/org/hibernate/reactive/loader/ast/internal/ReactiveSingleIdEntityLoaderStandardImpl.java

@@ -55,8 +55,7 @@ public CompletionStage<T> load(
 			SharedSessionContractImplementor session) {
 		final ReactiveSingleIdLoadPlan<T> loadPlan = (ReactiveSingleIdLoadPlan<T>) resolveLoadPlan(
 				lockOptions,
-				session.getLoadQueryInfluencers(),
-				session.getFactory()
+				session.getLoadQueryInfluencers()
 		);
 		return loadPlan.load( key, readOnly, true, session );
 	}
@@ -68,7 +67,7 @@ public CompletionStage<T> load(
 			LockOptions lockOptions,
 			Boolean readOnly,
 			SharedSessionContractImplementor session) {
-		final ReactiveSingleIdLoadPlan<T> loadPlan = (ReactiveSingleIdLoadPlan<T>) resolveLoadPlan( lockOptions, session.getLoadQueryInfluencers(), session.getFactory() );
+		final ReactiveSingleIdLoadPlan<T> loadPlan = (ReactiveSingleIdLoadPlan<T>) resolveLoadPlan( lockOptions, session.getLoadQueryInfluencers() );
 		return loadPlan.load( key, entityInstance, readOnly, false, session );
 	}
 

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

@@ -5,6 +5,7 @@
  */
 package org.hibernate.reactive.query.internal;
 
+import jakarta.persistence.TypedQuery;
 import java.util.Map;
 import java.util.function.Consumer;
 
@@ -48,6 +49,11 @@ public void registerNamedQuery(String name, Query query) {
 		delegate.registerNamedQuery( name, query );
 	}
 
+	@Override
+	public <R> TypedQueryReference<R> registerNamedQuery(String name, TypedQuery<R> query) {
+		return delegate.registerNamedQuery( name, query );
+	}
+
 	@Override
 	public void visitSqmQueryMementos(Consumer<NamedSqmQueryMemento<?>> action) {
 		delegate.visitSqmQueryMementos( action );

hibernate-reactive-core/src/main/java/org/hibernate/reactive/query/spi/ReactiveAbstractSelectionQuery.java

@@ -30,7 +30,7 @@
 import org.hibernate.query.spi.QueryOptions;
 import org.hibernate.query.sqm.internal.DomainParameterXref;
 import org.hibernate.query.sqm.internal.SqmInterpretationsKey;
-import org.hibernate.query.sqm.internal.SqmInterpretationsKey.InterpretationsKeySource;
+import org.hibernate.query.sqm.spi.InterpretationsKeySource;
 import org.hibernate.query.sqm.tree.SqmStatement;
 import org.hibernate.query.sqm.tree.select.SqmSelectStatement;
 import org.hibernate.reactive.engine.impl.ReactiveCallbackImpl;

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

@@ -1250,10 +1250,6 @@ private <T> ReactiveEntityPersister entityPersister(Class<T> entityClass) {
 		return (ReactiveEntityPersister) getFactory().getMappingMetamodel().getEntityDescriptor( entityClass );
 	}
 
-	private EntityPersister requireEntityPersister(Class<?> entityClass) {
-		return getFactory().getMappingMetamodel().getEntityDescriptor( entityClass );
-	}
-
 	private CompletionStage<Void> fireReactiveLoad(LoadEvent event, LoadEventListener.LoadType loadType) {
 		checkOpenOrWaitingForAutoClose();
 
@@ -1283,10 +1279,6 @@ public void checkTransactionNeededForUpdateOperation(String exceptionMessage) {
 		//no-op because we don't support transactions
 	}
 
-	private Boolean getReadOnlyFromLoadQueryInfluencers() {
-		return getLoadQueryInfluencers().getReadOnly();
-	}
-
 	private class ReactiveIdentifierLoadAccessImpl<T> {
 
 		private final EntityPersister entityPersister;

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

@@ -5,11 +5,6 @@
  */
 package org.hibernate.reactive.session.impl;
 
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.CompletionStage;
-import java.util.function.Supplier;
-
 import org.hibernate.HibernateException;
 import org.hibernate.LockMode;
 import org.hibernate.LockOptions;
@@ -28,10 +23,6 @@
 import org.hibernate.engine.spi.PersistentAttributeInterceptable;
 import org.hibernate.engine.spi.PersistentAttributeInterceptor;
 import org.hibernate.engine.spi.SharedSessionContractImplementor;
-import org.hibernate.event.spi.PostInsertEvent;
-import org.hibernate.event.spi.PostInsertEventListener;
-import org.hibernate.event.spi.PreInsertEvent;
-import org.hibernate.event.spi.PreInsertEventListener;
 import org.hibernate.generator.BeforeExecutionGenerator;
 import org.hibernate.generator.Generator;
 import org.hibernate.graph.GraphSemantic;
@@ -89,6 +80,10 @@
 import jakarta.persistence.criteria.CriteriaDelete;
 import jakarta.persistence.criteria.CriteriaQuery;
 import jakarta.persistence.criteria.CriteriaUpdate;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionStage;
+import java.util.function.Supplier;
 
 import static java.lang.Boolean.TRUE;
 import static java.lang.invoke.MethodHandles.lookup;
@@ -340,29 +335,6 @@ private CompletionStage<Void> reactiveInsert(Object entity, ReactiveEntityPersis
 		}
 	}
 
-	private boolean firePreInsert(Object entity, Object id, Object[] state, EntityPersister persister) {
-		if ( getFactory().getEventListenerGroups().eventListenerGroup_PRE_INSERT.isEmpty() ) {
-			return false;
-		}
-		else {
-			boolean veto = false;
-			final PreInsertEvent event = new PreInsertEvent( entity, id, state, persister, null );
-			for ( PreInsertEventListener listener : getFactory().getEventListenerGroups().eventListenerGroup_PRE_INSERT.listeners() ) {
-				veto |= listener.onPreInsert( event );
-			}
-			return veto;
-		}
-	}
-
-	private void firePostInsert(Object entity, Object id, Object[] state, EntityPersister persister) {
-		if ( !getFactory().getEventListenerGroups().eventListenerGroup_POST_INSERT.isEmpty() ) {
-			final PostInsertEvent event = new PostInsertEvent( entity, id, state, persister, null );
-			for ( PostInsertEventListener listener : getFactory().getEventListenerGroups().eventListenerGroup_POST_INSERT.listeners() ) {
-				listener.onPostInsert( event );
-			}
-		}
-	}
-
 	private CompletionStage<?> generateId(EntityPersister persister, Object entity, Generator generator) {
 		if ( generator.generatesOnInsert() ) {
             if ( generator instanceof ReactiveIdentifierGenerator<?> reactiveGenerator ) {

hibernate-reactive-core/src/main/java/org/hibernate/reactive/sql/exec/internal/StandardReactiveSelectExecutor.java

@@ -412,14 +412,17 @@ public CompletionStage<ReactiveValuesResultSet> resolveJdbcValuesSource(
         }
 	}
 
+	/**
+	 * Copied from Hibernate ORM
+	 */
 	private static CacheMode resolveCacheMode(ExecutionContext executionContext) {
 		final QueryOptions queryOptions = executionContext.getQueryOptions();
 		final SharedSessionContract session = executionContext.getSession();
-        return coalesceSuppliedValues(
-                () -> queryOptions == null ? null : queryOptions.getCacheMode(),
-                session::getCacheMode,
-                () -> CacheMode.NORMAL
-        );
+		return coalesceSuppliedValues(
+				() -> queryOptions == null ? null : queryOptions.getCacheMode(),
+				session::getCacheMode,
+				() -> CacheMode.NORMAL
+		);
 	}
 
 	/**

hibernate-reactive-core/src/main/java/org/hibernate/reactive/type/descriptor/jdbc/ReactiveJsonArrayJdbcType.java

@@ -5,12 +5,6 @@
  */
 package org.hibernate.reactive.type.descriptor.jdbc;
 
-import java.sql.CallableStatement;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.sql.SQLException;
-
-import org.hibernate.dialect.JsonHelper;
 import org.hibernate.metamodel.mapping.EmbeddableMappingType;
 import org.hibernate.type.SqlTypes;
 import org.hibernate.type.descriptor.ValueBinder;
@@ -23,9 +17,14 @@
 import org.hibernate.type.descriptor.jdbc.BasicExtractor;
 import org.hibernate.type.descriptor.jdbc.JdbcLiteralFormatter;
 import org.hibernate.type.descriptor.jdbc.JdbcType;
+import org.hibernate.type.descriptor.jdbc.JsonHelper;
 import org.hibernate.type.descriptor.jdbc.JsonJdbcType;
 
 import io.vertx.core.json.JsonArray;
+import java.sql.CallableStatement;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
 
 /**
  * @see org.hibernate.type.descriptor.jdbc.JsonArrayJdbcType

hibernate-reactive-core/src/main/java/org/hibernate/reactive/type/descriptor/jdbc/ReactiveOracleArrayJdbcType.java

@@ -13,7 +13,8 @@
 
 import org.hibernate.HibernateException;
 import org.hibernate.dialect.Dialect;
-import org.hibernate.dialect.OracleArrayJdbcType;
+
+import org.hibernate.dialect.type.OracleArrayJdbcType;
 import org.hibernate.reactive.adaptor.impl.ArrayAdaptor;
 import org.hibernate.type.BasicType;
 import org.hibernate.type.descriptor.ValueBinder;
@@ -30,7 +31,7 @@
 import static java.sql.Types.ARRAY;
 
 /**
- * @see org.hibernate.dialect.OracleArrayJdbcType
+ * @see org.hibernate.dialect.type.OracleArrayJdbcType
  */
 public class ReactiveOracleArrayJdbcType extends OracleArrayJdbcType {
 

hibernate-reactive-core/src/main/java/org/hibernate/reactive/type/descriptor/jdbc/ReactiveXmlArrayJdbcType.java

@@ -5,19 +5,19 @@
  */
 package org.hibernate.reactive.type.descriptor.jdbc;
 
-import java.sql.CallableStatement;
-import java.sql.PreparedStatement;
-import java.sql.SQLException;
-import java.sql.SQLXML;
-
-import org.hibernate.dialect.XmlHelper;
 import org.hibernate.reactive.logging.impl.Log;
 import org.hibernate.type.descriptor.ValueBinder;
 import org.hibernate.type.descriptor.WrapperOptions;
 import org.hibernate.type.descriptor.java.JavaType;
 import org.hibernate.type.descriptor.jdbc.BasicBinder;
 import org.hibernate.type.descriptor.jdbc.JdbcType;
 import org.hibernate.type.descriptor.jdbc.XmlArrayJdbcType;
+import org.hibernate.type.descriptor.jdbc.XmlHelper;
+
+import java.sql.CallableStatement;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.sql.SQLXML;
 
 import static java.lang.invoke.MethodHandles.lookup;
 import static org.hibernate.reactive.logging.impl.LoggerFactory.make;