|
7 | 7 |
|
8 | 8 | import java.util.concurrent.CompletionStage;
|
9 | 9 |
|
10 |
| -import org.hibernate.FlushMode; |
11 | 10 | import org.hibernate.LockOptions;
|
12 | 11 | import org.hibernate.engine.spi.SharedSessionContractImplementor;
|
13 | 12 | import org.hibernate.internal.util.collections.ArrayHelper;
|
14 | 13 | import org.hibernate.metamodel.mapping.EntityMappingType;
|
| 14 | +import org.hibernate.query.Query; |
| 15 | +import org.hibernate.query.QueryFlushMode; |
15 | 16 | import org.hibernate.query.named.NamedQueryMemento;
|
16 |
| -import org.hibernate.query.spi.QueryImplementor; |
17 | 17 | import org.hibernate.reactive.loader.ast.spi.ReactiveSingleIdEntityLoader;
|
18 | 18 | import org.hibernate.reactive.query.ReactiveSelectionQuery;
|
19 | 19 |
|
@@ -45,14 +45,11 @@ public EntityMappingType getLoadable() {
|
45 | 45 | @Override
|
46 | 46 | public CompletionStage<T> load(Object pkValue, LockOptions lockOptions, Boolean readOnly, SharedSessionContractImplementor session) {
|
47 | 47 | // noinspection unchecked
|
48 |
| - final QueryImplementor<T> query = namedQueryMemento |
49 |
| - .toQuery( session, entityDescriptor.getMappedJavaType().getJavaTypeClass() ); |
50 |
| - |
| 48 | + final Query<T> query = namedQueryMemento.toQuery( session, entityDescriptor.getMappedJavaType().getJavaTypeClass() ); |
51 | 49 | //noinspection unchecked
|
52 | 50 | query.setParameter( (Parameter<Object>) query.getParameters().iterator().next(), pkValue );
|
53 |
| - query.setHibernateFlushMode( FlushMode.MANUAL ); |
54 |
| - |
55 |
| - return ( (ReactiveSelectionQuery) query ).reactiveUnique(); |
| 51 | + query.setQueryFlushMode( QueryFlushMode.NO_FLUSH ); |
| 52 | + return ( (ReactiveSelectionQuery<T>) query ).reactiveUnique(); |
56 | 53 | }
|
57 | 54 |
|
58 | 55 | @Override
|
|
0 commit comments