Fix compilation error

DavideD · DavideD · commit e6f30c6f8c5f · 2024-06-06T14:23:00.000+02:00
diff --git a/hibernate-reactive-core/src/main/java/org/hibernate/reactive/provider/ReactivePersistenceProvider.java b/hibernate-reactive-core/src/main/java/org/hibernate/reactive/provider/ReactivePersistenceProvider.java
@@ -22,6 +22,7 @@
 import org.hibernate.reactive.provider.impl.ReactiveProviderChecker;
 
 import jakarta.persistence.EntityManagerFactory;
+import jakarta.persistence.PersistenceConfiguration;
 import jakarta.persistence.spi.LoadState;
 import jakarta.persistence.spi.PersistenceProvider;
 import jakarta.persistence.spi.PersistenceUnitInfo;
@@ -38,6 +39,12 @@ public class ReactivePersistenceProvider implements PersistenceProvider {
 
 	private final PersistenceUtilHelper.MetadataCache cache = new PersistenceUtilHelper.MetadataCache();
 
+	@Override
+	public EntityManagerFactory createEntityManagerFactory(PersistenceConfiguration persistenceConfiguration) {
+		// Same as ORM
+		throw log.notYetImplemented();
+	}
+
 	/**
 	 * {@inheritDoc}
 	 * <p/>
diff --git a/hibernate-reactive-core/src/main/java/org/hibernate/reactive/session/impl/ReactiveSessionImpl.java b/hibernate-reactive-core/src/main/java/org/hibernate/reactive/session/impl/ReactiveSessionImpl.java
@@ -337,7 +337,7 @@ public <R> ReactiveQuery<R> createReactiveQuery(CriteriaQuery<R> criteriaQuery)
 				}
 			}
 
-			return createCriteriaQuery( selectStatement, criteriaQuery.getResultType() );
+			return createReactiveCriteriaQuery( selectStatement, criteriaQuery.getResultType() );
 		}
 		catch (RuntimeException e) {
 			if ( getSessionFactory().getJpaMetamodel().getJpaCompliance().isJpaTransactionComplianceEnabled() ) {
@@ -347,7 +347,7 @@ public <R> ReactiveQuery<R> createReactiveQuery(CriteriaQuery<R> criteriaQuery)
 		}
 	}
 
-	private <T> ReactiveQueryImplementor<T> createCriteriaQuery(SqmStatement<T> criteria, Class<T> resultType) {
+	protected <T> ReactiveQueryImplementor<T> createReactiveCriteriaQuery(SqmStatement<T> criteria, Class<T> resultType) {
 		final ReactiveQuerySqmImpl<T> query = new ReactiveQuerySqmImpl<>( criteria, resultType, this );
 		applyQuerySettingsAndHints( query );
 		return query;
@@ -522,7 +522,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(String hqlString
 	public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaUpdate<R> updateQuery) {
 		checkOpen();
 		try {
-			return createCriteriaQuery( (SqmUpdateStatement<R>) updateQuery, null );
+			return createReactiveCriteriaQuery( (SqmUpdateStatement<R>) updateQuery, null );
 		}
 		catch ( RuntimeException e ) {
 			throw getExceptionConverter().convert( e );
@@ -533,7 +533,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaUpdate<R
 	public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaDelete<R> deleteQuery) {
 		checkOpen();
 		try {
-			return createCriteriaQuery( (SqmDeleteStatement<R>) deleteQuery, null );
+			return createReactiveCriteriaQuery( (SqmDeleteStatement<R>) deleteQuery, null );
 		}
 		catch ( RuntimeException e ) {
 			throw getExceptionConverter().convert( e );
@@ -544,7 +544,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaDelete<R
 	public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(JpaCriteriaInsertSelect<R> insertSelect) {
 		checkOpen();
 		try {
-			return createCriteriaQuery( (SqmInsertSelectStatement<R>) insertSelect, null );
+			return createReactiveCriteriaQuery( (SqmInsertSelectStatement<R>) insertSelect, null );
 		}
 		catch ( RuntimeException e ) {
 			throw getExceptionConverter().convert( e );
diff --git a/hibernate-reactive-core/src/main/java/org/hibernate/reactive/session/impl/ReactiveStatelessSessionImpl.java b/hibernate-reactive-core/src/main/java/org/hibernate/reactive/session/impl/ReactiveStatelessSessionImpl.java
@@ -720,7 +720,7 @@ public <R> ReactiveQuery<R> createReactiveQuery(CriteriaQuery<R> criteriaQuery)
 				}
 			}
 
-			return createCriteriaQuery( selectStatement, criteriaQuery.getResultType() );
+			return createReactiveCriteriaQuery( selectStatement, criteriaQuery.getResultType() );
 		}
 		catch (RuntimeException e) {
 			if ( getSessionFactory().getJpaMetamodel().getJpaCompliance().isJpaTransactionComplianceEnabled() ) {
@@ -730,7 +730,7 @@ public <R> ReactiveQuery<R> createReactiveQuery(CriteriaQuery<R> criteriaQuery)
 		}
 	}
 
-	private <T> ReactiveQuery<T> createCriteriaQuery(SqmStatement<T> criteria, Class<T> resultType) {
+	private <T> ReactiveQuery<T> createReactiveCriteriaQuery(SqmStatement<T> criteria, Class<T> resultType) {
 		final ReactiveQuerySqmImpl<T> query = new ReactiveQuerySqmImpl<>( criteria, resultType, this );
 		applyQuerySettingsAndHints( query );
 		return query;
@@ -908,7 +908,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(String hqlString
 	public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaUpdate<R> updateQuery) {
 		checkOpen();
 		try {
-			return createCriteriaQuery( (SqmUpdateStatement<R>) updateQuery, null );
+			return createReactiveCriteriaQuery( (SqmUpdateStatement<R>) updateQuery, null );
 		}
 		catch ( RuntimeException e ) {
 			throw getExceptionConverter().convert( e );
@@ -919,7 +919,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaUpdate<R
 	public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaDelete<R> deleteQuery) {
 		checkOpen();
 		try {
-			return createCriteriaQuery( (SqmDeleteStatement<R>) deleteQuery, null );
+			return createReactiveCriteriaQuery( (SqmDeleteStatement<R>) deleteQuery, null );
 		}
 		catch ( RuntimeException e ) {
 			throw getExceptionConverter().convert( e );
@@ -930,7 +930,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaDelete<R
 	public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(JpaCriteriaInsertSelect<R> insertSelect) {
 		checkOpen();
 		try {
-			return createCriteriaQuery( (SqmInsertSelectStatement<R>) insertSelect, null );
+			return createReactiveCriteriaQuery( (SqmInsertSelectStatement<R>) insertSelect, null );
 		}
 		catch ( RuntimeException e ) {
 			throw getExceptionConverter().convert( e );

Original file line number	Diff line number	Diff line change
`@@ -337,7 +337,7 @@ public <R> ReactiveQuery<R> createReactiveQuery(CriteriaQuery<R> criteriaQuery)`
`337`	`337`	`}`
`338`	`338`	`}`
`339`	`339`
`340`		`- return createCriteriaQuery( selectStatement, criteriaQuery.getResultType() );`
	`340`	`+ return createReactiveCriteriaQuery( selectStatement, criteriaQuery.getResultType() );`
`341`	`341`	`}`
`342`	`342`	`catch (RuntimeException e) {`
`343`	`343`	`if ( getSessionFactory().getJpaMetamodel().getJpaCompliance().isJpaTransactionComplianceEnabled() ) {`
`@@ -347,7 +347,7 @@ public <R> ReactiveQuery<R> createReactiveQuery(CriteriaQuery<R> criteriaQuery)`
`347`	`347`	`}`
`348`	`348`	`}`
`349`	`349`
`350`		`- private <T> ReactiveQueryImplementor<T> createCriteriaQuery(SqmStatement<T> criteria, Class<T> resultType) {`
	`350`	`+ protected <T> ReactiveQueryImplementor<T> createReactiveCriteriaQuery(SqmStatement<T> criteria, Class<T> resultType) {`
`351`	`351`	`final ReactiveQuerySqmImpl<T> query = new ReactiveQuerySqmImpl<>( criteria, resultType, this );`
`352`	`352`	`applyQuerySettingsAndHints( query );`
`353`	`353`	`return query;`
`@@ -522,7 +522,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(String hqlString`
`522`	`522`	`public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaUpdate<R> updateQuery) {`
`523`	`523`	`checkOpen();`
`524`	`524`	`try {`
`525`		`- return createCriteriaQuery( (SqmUpdateStatement<R>) updateQuery, null );`
	`525`	`+ return createReactiveCriteriaQuery( (SqmUpdateStatement<R>) updateQuery, null );`
`526`	`526`	`}`
`527`	`527`	`catch ( RuntimeException e ) {`
`528`	`528`	`throw getExceptionConverter().convert( e );`
`@@ -533,7 +533,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaUpdate<R`
`533`	`533`	`public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaDelete<R> deleteQuery) {`
`534`	`534`	`checkOpen();`
`535`	`535`	`try {`
`536`		`- return createCriteriaQuery( (SqmDeleteStatement<R>) deleteQuery, null );`
	`536`	`+ return createReactiveCriteriaQuery( (SqmDeleteStatement<R>) deleteQuery, null );`
`537`	`537`	`}`
`538`	`538`	`catch ( RuntimeException e ) {`
`539`	`539`	`throw getExceptionConverter().convert( e );`
`@@ -544,7 +544,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaDelete<R`
`544`	`544`	`public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(JpaCriteriaInsertSelect<R> insertSelect) {`
`545`	`545`	`checkOpen();`
`546`	`546`	`try {`
`547`		`- return createCriteriaQuery( (SqmInsertSelectStatement<R>) insertSelect, null );`
	`547`	`+ return createReactiveCriteriaQuery( (SqmInsertSelectStatement<R>) insertSelect, null );`
`548`	`548`	`}`
`549`	`549`	`catch ( RuntimeException e ) {`
`550`	`550`	`throw getExceptionConverter().convert( e );`
Original file line number	Diff line number	Diff line change
`@@ -720,7 +720,7 @@ public <R> ReactiveQuery<R> createReactiveQuery(CriteriaQuery<R> criteriaQuery)`
`720`	`720`	`}`
`721`	`721`	`}`
`722`	`722`
`723`		`- return createCriteriaQuery( selectStatement, criteriaQuery.getResultType() );`
	`723`	`+ return createReactiveCriteriaQuery( selectStatement, criteriaQuery.getResultType() );`
`724`	`724`	`}`
`725`	`725`	`catch (RuntimeException e) {`
`726`	`726`	`if ( getSessionFactory().getJpaMetamodel().getJpaCompliance().isJpaTransactionComplianceEnabled() ) {`
`@@ -730,7 +730,7 @@ public <R> ReactiveQuery<R> createReactiveQuery(CriteriaQuery<R> criteriaQuery)`
`730`	`730`	`}`
`731`	`731`	`}`
`732`	`732`
`733`		`- private <T> ReactiveQuery<T> createCriteriaQuery(SqmStatement<T> criteria, Class<T> resultType) {`
	`733`	`+ private <T> ReactiveQuery<T> createReactiveCriteriaQuery(SqmStatement<T> criteria, Class<T> resultType) {`
`734`	`734`	`final ReactiveQuerySqmImpl<T> query = new ReactiveQuerySqmImpl<>( criteria, resultType, this );`
`735`	`735`	`applyQuerySettingsAndHints( query );`
`736`	`736`	`return query;`
`@@ -908,7 +908,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(String hqlString`
`908`	`908`	`public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaUpdate<R> updateQuery) {`
`909`	`909`	`checkOpen();`
`910`	`910`	`try {`
`911`		`- return createCriteriaQuery( (SqmUpdateStatement<R>) updateQuery, null );`
	`911`	`+ return createReactiveCriteriaQuery( (SqmUpdateStatement<R>) updateQuery, null );`
`912`	`912`	`}`
`913`	`913`	`catch ( RuntimeException e ) {`
`914`	`914`	`throw getExceptionConverter().convert( e );`
`@@ -919,7 +919,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaUpdate<R`
`919`	`919`	`public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaDelete<R> deleteQuery) {`
`920`	`920`	`checkOpen();`
`921`	`921`	`try {`
`922`		`- return createCriteriaQuery( (SqmDeleteStatement<R>) deleteQuery, null );`
	`922`	`+ return createReactiveCriteriaQuery( (SqmDeleteStatement<R>) deleteQuery, null );`
`923`	`923`	`}`
`924`	`924`	`catch ( RuntimeException e ) {`
`925`	`925`	`throw getExceptionConverter().convert( e );`
`@@ -930,7 +930,7 @@ public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(CriteriaDelete<R`
`930`	`930`	`public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(JpaCriteriaInsertSelect<R> insertSelect) {`
`931`	`931`	`checkOpen();`
`932`	`932`	`try {`
`933`		`- return createCriteriaQuery( (SqmInsertSelectStatement<R>) insertSelect, null );`
	`933`	`+ return createReactiveCriteriaQuery( (SqmInsertSelectStatement<R>) insertSelect, null );`
`934`	`934`	`}`
`935`	`935`	`catch ( RuntimeException e ) {`
`936`	`936`	`throw getExceptionConverter().convert( e );`