Package org.hibernate.reactive.session.impl

Class ReactiveStatelessSessionImpl

java.lang.Object

org.hibernate.internal.AbstractSharedSessionContract

org.hibernate.internal.StatelessSessionImpl

org.hibernate.reactive.session.impl.ReactiveStatelessSessionImpl

All Implemented Interfaces:

Serializable, AutoCloseable, org.hibernate.engine.jdbc.LobCreationContext, org.hibernate.engine.spi.SharedSessionContractImplementor, org.hibernate.query.QueryProducer, org.hibernate.query.spi.QueryProducerImplementor, ReactiveSharedSessionContractImplementor, ReactiveConnectionSupplier, ReactiveQueryProducer, ReactiveStatelessSession, org.hibernate.resource.jdbc.spi.JdbcSessionOwner, org.hibernate.resource.transaction.spi.TransactionCoordinatorBuilder.Options, org.hibernate.SharedSessionContract, org.hibernate.StatelessSession, org.hibernate.type.descriptor.java.JavaType.CoercionContext, org.hibernate.type.descriptor.WrapperOptions

public class ReactiveStatelessSessionImpl
extends org.hibernate.internal.StatelessSessionImpl
implements ReactiveStatelessSession

An ReactiveStatelessSession implemented by extension of the StatelessSessionImpl in Hibernate core. Extension was preferred to delegation because there are places where Hibernate core compares the identity of session instances.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.hibernate.engine.jdbc.LobCreationContext

org.hibernate.engine.jdbc.LobCreationContext.Callback<T extends Object>

Field Summary

Fields inherited from class org.hibernate.internal.StatelessSessionImpl

MULTI_ID_LOAD_OPTIONS

Fields inherited from class org.hibernate.internal.AbstractSharedSessionContract

closed, waitingForAutoClose

Constructor Summary

Constructors

Constructor	Description
ReactiveStatelessSessionImpl(org.hibernate.internal.SessionFactoryImpl factory, org.hibernate.internal.SessionCreationOptions options, ReactiveConnection connection)

Method Summary

Modifier and Type	Method	Description
void	checkOpen()
void	checkTransactionNeededForUpdateOperation(String exceptionMessage)
void	close()
void	close(CompletableFuture<Void> closing)
<T> org.hibernate.graph.spi.RootGraphImplementor<T>	createEntityGraph(Class<T> entity)
<T> org.hibernate.graph.spi.RootGraphImplementor<T>	createEntityGraph(Class<T> entity, String name)
<R> ReactiveMutationQuery<R>	createNamedReactiveMutationQuery(String queryName)
<R> ReactiveSelectionQuery<R>	createNamedReactiveSelectionQuery(String queryName)
<R> ReactiveSelectionQuery<R>	createNamedReactiveSelectionQuery(String queryName, Class<R> expectedResultType)
<R> ReactiveMutationQuery<R>	createNativeReactiveMutationQuery(String sqlString)
<R> ReactiveMutationQuery<R>	createReactiveMutationQuery(jakarta.persistence.criteria.CriteriaDelete<R> deleteQuery)
<R> ReactiveMutationQuery<R>	createReactiveMutationQuery(jakarta.persistence.criteria.CriteriaUpdate<R> updateQuery)
<R> ReactiveMutationQuery<R>	createReactiveMutationQuery(String hqlString)
<R> ReactiveMutationQuery<R>	createReactiveMutationQuery(org.hibernate.query.criteria.JpaCriteriaInsert<R> insert)
<R> ReactiveQueryImplementor<R>	createReactiveNamedQuery(String queryName)
<R> ReactiveQueryImplementor<R>	createReactiveNamedQuery(String queryName, Class<R> resultType)
<R> ReactiveNativeQueryImplementor<R>	createReactiveNativeQuery(String sqlString)
<R> ReactiveNativeQuery<R>	createReactiveNativeQuery(String sqlString, Class<R> resultClass)
<R> ReactiveNativeQuery<R>	createReactiveNativeQuery(String sqlString, Class<R> resultClass, String tableAlias)	Deprecated, for removal: This API element is subject to removal in a future version.
<R> ReactiveNativeQuery<R>	createReactiveNativeQuery(String queryString, Class<R> resultType, AffectedEntities affectedEntities)
<R> ReactiveNativeQuery<R>	createReactiveNativeQuery(String sqlString, String resultSetMappingName)	Deprecated, for removal: This API element is subject to removal in a future version.
<R> ReactiveNativeQuery<R>	createReactiveNativeQuery(String sqlString, String resultSetMappingName, Class<R> resultClass)	Deprecated, for removal: This API element is subject to removal in a future version.
<R> ReactiveNativeQuery<R>	createReactiveNativeQuery(String queryString, AffectedEntities affectedEntities)
<R> ReactiveNativeQueryImpl<R>	createReactiveNativeQuery(String queryString, ResultSetMapping<R> resultSetMapping)
<R> ReactiveNativeQuery<R>	createReactiveNativeQuery(String queryString, ResultSetMapping<R> resultSetMapping, AffectedEntities affectedEntities)
<R> ReactiveQuery<R>	createReactiveQuery(jakarta.persistence.criteria.CriteriaQuery<R> criteriaQuery)
<R> ReactiveQuery<R>	createReactiveQuery(jakarta.persistence.TypedQueryReference<R> typedQueryReference)
<R> ReactiveSqmQueryImplementor<R>	createReactiveQuery(String queryString)
<R> ReactiveSqmQueryImplementor<R>	createReactiveQuery(String queryString, Class<R> expectedResultType)
<R> ReactiveSelectionQuery<R>	createReactiveSelectionQuery(jakarta.persistence.criteria.CriteriaQuery<R> criteria)
<R> ReactiveSelectionQuery<R>	createReactiveSelectionQuery(String hqlString, Class<R> resultType)
org.hibernate.dialect.Dialect	getDialect()
<T> org.hibernate.graph.spi.RootGraphImplementor<T>	getEntityGraph(Class<T> entity, String name)
ReactiveEntityPersister	getEntityPersister(String entityName, Object object)
org.hibernate.engine.spi.LoadQueryInfluencers	getLoadQueryInfluencers()
org.hibernate.engine.spi.PersistenceContext	getPersistenceContext()
org.hibernate.engine.spi.PersistenceContext	getPersistenceContextInternal()
ReactiveConnection	getReactiveConnection()	Obtain the ReactiveConnection that is associated with the current session.
<T> ResultSetMapping<T>	getResultSetMapping(Class<T> resultType, String mappingName)
org.hibernate.engine.spi.SharedSessionContractImplementor	getSharedContract()
protected Object	internalLoadGet(String entityName, Object id, org.hibernate.engine.spi.PersistenceContext persistenceContext)
void	prepareForQueryExecution(boolean requiresTxn)
CompletionStage<Void>	reactiveDelete(Object entity)
CompletionStage<Void>	reactiveDeleteAll(int batchSize, Object... entities)
CompletionStage<Void>	reactiveDeleteAll(Object... entities)
<T> CompletionStage<T>	reactiveFetch(T association, boolean unproxy)
<T> CompletionStage<T>	reactiveGet(Class<T> entityClass, Object id)
<T> CompletionStage<List<T>>	reactiveGet(Class<T> entityClass, Object... ids)
<T> CompletionStage<T>	reactiveGet(Class<T> entityClass, Object id, org.hibernate.LockMode lockMode, jakarta.persistence.EntityGraph<T> fetchGraph)
<T> CompletionStage<T>	reactiveGet(String entityName, Object id)
<T> CompletionStage<T>	reactiveGet(String entityName, Object id, org.hibernate.LockMode lockMode, jakarta.persistence.EntityGraph<T> fetchGraph)
CompletionStage<Object>	reactiveImmediateLoad(String entityName, Object id)
CompletionStage<Void>	reactiveInitializeCollection(org.hibernate.collection.spi.PersistentCollection<?> collection, boolean writing)
CompletionStage<Void>	reactiveInsert(Object entity)
CompletionStage<Void>	reactiveInsertAll(int batchSize, Object... entities)
CompletionStage<Void>	reactiveInsertAll(Object... entities)
CompletionStage<Object>	reactiveInternalLoad(String entityName, Object id, boolean eager, boolean nullable)
CompletionStage<Void>	reactiveRefresh(Object entity)
CompletionStage<Void>	reactiveRefresh(Object entity, org.hibernate.LockMode lockMode)
CompletionStage<Void>	reactiveRefreshAll(int batchSize, Object... entities)
CompletionStage<Void>	reactiveRefreshAll(Object... entities)
CompletionStage<Void>	reactiveUpdate(Object entity)
CompletionStage<Void>	reactiveUpdateAll(int batchSize, Object... entities)
CompletionStage<Void>	reactiveUpdateAll(Object... entities)
CompletionStage<Void>	reactiveUpsert(Object entity)
CompletionStage<Void>	reactiveUpsertAll(int batchSize, Object... entities)

Methods inherited from class org.hibernate.internal.StatelessSessionImpl

afterOperation, afterScrollOperation, afterTransactionBegin, afterTransactionCompletion, autoFlushIfRequired, autoPreFlush, beforeTransactionCompletion, bestGuessEntityName, delete, delete, deleteMultiple, fetch, firePostDelete, firePostInsert, firePostRecreate, firePostRemove, firePostUpdate, firePostUpdate, firePostUpsert, firePreDelete, firePreInsert, firePreRecreate, firePreRemove, firePreUpdate, firePreUpdate, firePreUpsert, flush, flushBeforeTransactionCompletion, forEachOwnedCollection, get, get, get, get, get, get, get, get, getContextEntityIdentifier, getEntityUsingInterceptor, getHibernateFlushMode, getIdentifier, getMultiple, getMultiple, getMultiple, getMultiple, guessEntityName, idToUpsert, immediateLoad, initializeCollection, insert, insert, insertMultiple, instantiate, instantiate, instantiateEmpty, internalLoad, isAutoCloseSessionEnabled, isDefaultReadOnly, isIdentifierRollbackEnabled, isTransactionInProgress, loadFromSecondLevelCache, lock, lockCacheItem, lockCacheItem, refresh, refresh, refresh, refresh, registerProcess, removeCacheItem, removeCacheItem, shouldAutoClose, shouldAutoJoinTransaction, unwrap, update, update, updateMultiple, upsert, upsert, upsertMultiple, versionToUpsert, wrap

Methods inherited from class org.hibernate.internal.AbstractSharedSessionContract

accessTransaction, addSharedSessionTransactionObserver, afterObtainConnection, applyQuerySettingsAndHints, applyQuerySettingsAndHints, beforeReleaseConnection, beginTransaction, buildNamedQuery, checkMutationQuery, checkOpen, checkResultType, checkSelectionQuery, checkTransactionSynchStatus, cleanupOnClose, createCriteriaQuery, createEntityGraph, createMutationQuery, createMutationQuery, createMutationQuery, createMutationQuery, createNamedMutationQuery, createNamedQuery, createNamedQuery, createNamedSelectionQuery, createNamedSelectionQuery, createNamedStoredProcedureQuery, createNativeMutationQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQueryImplementor, createNativeQueryImplementor, createNativeQueryImplementor, createQuery, createQuery, createQuery, createQuery, createQuery, createQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery, createSqmQueryImplementor, createSqmQueryImplementor, createSqmQueryImplementor, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureQuery, createStoredProcedureQuery, createStoredProcedureQuery, delayedAfterCompletion, disableFilter, doReturningWork, doWork, enableFilter, execute, generateEntityKey, getCacheMode, getCacheTransactionSynchronization, getConfiguredJdbcBatchSize, getCriteriaBuilder, getCurrentTransaction, getEnabledFilter, getEntityGraph, getEntityGraphs, getEntityNameResolver, getEventListenerManager, getEventMonitor, getExceptionConverter, getFactory, getInterceptor, getJdbcBatchSize, getJdbcConnectionAccess, getJdbcCoordinator, getJdbcServices, getJdbcSessionContext, getJdbcTimeZone, getJsonFormatMapper, getLobCreator, getNamedNativeQuery, getNamedNativeQuery, getNamedProcedureCall, getNamedQuery, getNativeJdbcParametersIgnored, getPreferredSqlTypeCodeForBoolean, getResultSetMappingMemento, getSessionAssociationMarkers, getSessionFactory, getSessionIdentifier, getSessionToken, getTenantIdentifier, getTenantIdentifierValue, getTransaction, getTransactionCoordinator, getTypeConfiguration, getXmlFormatMapper, interpretHql, isClosed, isConnected, isCriteriaCopyTreeEnabled, isCriteriaPlanCacheEnabled, isJoinedToTransaction, isOpen, isOpenOrWaitingForAutoClose, joinTransaction, markForRollbackOnly, prepareForAutoClose, pulseTransactionCoordinator, removeSharedSessionTransactionObserver, requireCollectionPersister, requireEntityPersister, requireEntityPersister, setCacheMode, setClosed, setCriteriaCopyTreeEnabled, setCriteriaPlanCacheEnabled, setJdbcBatchSize, setNativeJdbcParametersIgnored, setUpMultitenancy, shouldCloseJdbcCoordinatorOnClose, startTransactionBoundary, useStreamForLobBinding

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.hibernate.resource.jdbc.spi.JdbcSessionOwner

getEventManager, getSqlExceptionHelper

Methods inherited from interface org.hibernate.engine.jdbc.LobCreationContext

fromContext

Methods inherited from interface org.hibernate.query.QueryProducer

createMutationQuery, createNamedSelectionQuery, createNamedSelectionQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery

Methods inherited from interface org.hibernate.reactive.session.ReactiveQueryProducer

getFactory

Methods inherited from interface org.hibernate.reactive.engine.spi.ReactiveSharedSessionContractImplementor

reactiveAutoFlushIfRequired

Methods inherited from interface org.hibernate.reactive.session.ReactiveStatelessSession

getIdentifier, isOpen

Methods inherited from interface org.hibernate.SharedSessionContract

beginTransaction, createNamedStoredProcedureQuery, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureQuery, createStoredProcedureQuery, createStoredProcedureQuery, disableFilter, doReturningWork, doWork, enableFilter, fromTransaction, getCacheMode, getCriteriaBuilder, getEnabledFilter, getEntityGraphs, getJdbcBatchSize, getNamedProcedureCall, getTenantIdentifier, getTenantIdentifierValue, getTransaction, inTransaction, isConnected, isJoinedToTransaction, isOpen, joinTransaction, setCacheMode, setJdbcBatchSize

Methods inherited from interface org.hibernate.engine.spi.SharedSessionContractImplementor

asEventSource, asSessionImplementor, asStatelessSession, autoFlushIfRequired, bestGuessEntityName, getSession, isEventSource, isSessionImplementor, isStatelessSession

Constructor Details

ReactiveStatelessSessionImpl

public ReactiveStatelessSessionImpl(org.hibernate.internal.SessionFactoryImpl factory,
 org.hibernate.internal.SessionCreationOptions options,
 ReactiveConnection connection)

Method Details

getPersistenceContext

public org.hibernate.engine.spi.PersistenceContext getPersistenceContext()

Specified by:

getPersistenceContext in interface ReactiveSharedSessionContractImplementor

Specified by:

getPersistenceContext in interface org.hibernate.engine.spi.SharedSessionContractImplementor

Overrides:

getPersistenceContext in class org.hibernate.internal.StatelessSessionImpl

checkOpen

public void checkOpen()

Specified by:

checkOpen in interface org.hibernate.engine.spi.SharedSessionContractImplementor

getDialect

public org.hibernate.dialect.Dialect getDialect()

Specified by:

getDialect in interface ReactiveQueryProducer

Specified by:

getDialect in interface org.hibernate.engine.spi.SharedSessionContractImplementor

Specified by:

getDialect in interface org.hibernate.type.descriptor.WrapperOptions

Overrides:

getDialect in class org.hibernate.internal.AbstractSharedSessionContract

getSharedContract

public org.hibernate.engine.spi.SharedSessionContractImplementor getSharedContract()

Specified by:

getSharedContract in interface ReactiveQueryProducer

getPersistenceContextInternal

public org.hibernate.engine.spi.PersistenceContext getPersistenceContextInternal()

Specified by:

getPersistenceContextInternal in interface org.hibernate.engine.spi.SharedSessionContractImplementor

Overrides:

getPersistenceContextInternal in class org.hibernate.internal.StatelessSessionImpl

getReactiveConnection

public ReactiveConnection getReactiveConnection()

Description copied from interface: ReactiveConnectionSupplier

Obtain the ReactiveConnection that is associated with the current session.

Specified by:

getReactiveConnection in interface ReactiveConnectionSupplier

checkTransactionNeededForUpdateOperation

public void checkTransactionNeededForUpdateOperation(String exceptionMessage)

Specified by:

checkTransactionNeededForUpdateOperation in interface org.hibernate.engine.spi.SharedSessionContractImplementor

Overrides:

checkTransactionNeededForUpdateOperation in class org.hibernate.internal.AbstractSharedSessionContract

reactiveGet

public <T> CompletionStage<T> reactiveGet(Class<T> entityClass,
 Object id)

Specified by:

reactiveGet in interface ReactiveStatelessSession

reactiveGet

public <T> CompletionStage<List<T>> reactiveGet(Class<T> entityClass,
 Object... ids)

Specified by:

reactiveGet in interface ReactiveStatelessSession

reactiveGet

public <T> CompletionStage<T> reactiveGet(String entityName,
 Object id)

Specified by:

reactiveGet in interface ReactiveStatelessSession

reactiveGet

public <T> CompletionStage<T> reactiveGet(Class<T> entityClass,
 Object id,
 org.hibernate.LockMode lockMode,
 jakarta.persistence.EntityGraph<T> fetchGraph)

Specified by:

reactiveGet in interface ReactiveStatelessSession

getLoadQueryInfluencers

public org.hibernate.engine.spi.LoadQueryInfluencers getLoadQueryInfluencers()

Specified by:

getLoadQueryInfluencers in interface org.hibernate.engine.spi.SharedSessionContractImplementor

Overrides:

getLoadQueryInfluencers in class org.hibernate.internal.StatelessSessionImpl

reactiveGet

public <T> CompletionStage<T> reactiveGet(String entityName,
 Object id,
 org.hibernate.LockMode lockMode,
 jakarta.persistence.EntityGraph<T> fetchGraph)

Specified by:

reactiveGet in interface ReactiveStatelessSession

getEntityPersister

public ReactiveEntityPersister getEntityPersister(String entityName,
 Object object)
                                           throws org.hibernate.HibernateException

Specified by:

getEntityPersister in interface org.hibernate.engine.spi.SharedSessionContractImplementor

Overrides:

getEntityPersister in class org.hibernate.internal.StatelessSessionImpl

Throws:

org.hibernate.HibernateException

reactiveInsert

public CompletionStage<Void> reactiveInsert(Object entity)

Specified by:

reactiveInsert in interface ReactiveStatelessSession

reactiveDelete

public CompletionStage<Void> reactiveDelete(Object entity)

Specified by:

reactiveDelete in interface ReactiveStatelessSession

reactiveUpdate

public CompletionStage<Void> reactiveUpdate(Object entity)

Specified by:

reactiveUpdate in interface ReactiveStatelessSession

reactiveRefresh

public CompletionStage<Void> reactiveRefresh(Object entity)

Specified by:

reactiveRefresh in interface ReactiveStatelessSession

reactiveRefresh

public CompletionStage<Void> reactiveRefresh(Object entity,
 org.hibernate.LockMode lockMode)

Specified by:

reactiveRefresh in interface ReactiveStatelessSession

reactiveUpsert

public CompletionStage<Void> reactiveUpsert(Object entity)

Specified by:

reactiveUpsert in interface ReactiveStatelessSession

See Also:

• StatelessSessionImpl.upsert(Object)

reactiveUpsertAll

public CompletionStage<Void> reactiveUpsertAll(int batchSize,
 Object... entities)

Specified by:

reactiveUpsertAll in interface ReactiveStatelessSession

reactiveInsertAll

public CompletionStage<Void> reactiveInsertAll(Object... entities)

Specified by:

reactiveInsertAll in interface ReactiveStatelessSession

reactiveInsertAll

public CompletionStage<Void> reactiveInsertAll(int batchSize,
 Object... entities)

Specified by:

reactiveInsertAll in interface ReactiveStatelessSession

reactiveUpdateAll

public CompletionStage<Void> reactiveUpdateAll(Object... entities)

Specified by:

reactiveUpdateAll in interface ReactiveStatelessSession

reactiveUpdateAll

public CompletionStage<Void> reactiveUpdateAll(int batchSize,
 Object... entities)

Specified by:

reactiveUpdateAll in interface ReactiveStatelessSession

reactiveDeleteAll

public CompletionStage<Void> reactiveDeleteAll(Object... entities)

Specified by:

reactiveDeleteAll in interface ReactiveStatelessSession

reactiveDeleteAll

public CompletionStage<Void> reactiveDeleteAll(int batchSize,
 Object... entities)

Specified by:

reactiveDeleteAll in interface ReactiveStatelessSession

reactiveRefreshAll

public CompletionStage<Void> reactiveRefreshAll(Object... entities)

Specified by:

reactiveRefreshAll in interface ReactiveStatelessSession

reactiveRefreshAll

public CompletionStage<Void> reactiveRefreshAll(int batchSize,
 Object... entities)

Specified by:

reactiveRefreshAll in interface ReactiveStatelessSession

reactiveInternalLoad

public CompletionStage<Object> reactiveInternalLoad(String entityName,
 Object id,
 boolean eager,
 boolean nullable)

Specified by:

reactiveInternalLoad in interface ReactiveQueryProducer

reactiveImmediateLoad

public CompletionStage<Object> reactiveImmediateLoad(String entityName,
 Object id)

Specified by:

reactiveImmediateLoad in interface ReactiveSharedSessionContractImplementor

internalLoadGet

protected Object internalLoadGet(String entityName,
 Object id,
 org.hibernate.engine.spi.PersistenceContext persistenceContext)

Overrides:

internalLoadGet in class org.hibernate.internal.StatelessSessionImpl

reactiveInitializeCollection

public CompletionStage<Void> reactiveInitializeCollection(org.hibernate.collection.spi.PersistentCollection<?> collection,
 boolean writing)

Specified by:

reactiveInitializeCollection in interface ReactiveSharedSessionContractImplementor

reactiveFetch

public <T> CompletionStage<T> reactiveFetch(T association,
 boolean unproxy)

Specified by:

reactiveFetch in interface ReactiveQueryProducer

createEntityGraph

public <T>
org.hibernate.graph.spi.RootGraphImplementor<T> createEntityGraph(Class<T> entity)

Specified by:

createEntityGraph in interface ReactiveQueryProducer

Specified by:

createEntityGraph in interface org.hibernate.SharedSessionContract

Specified by:

createEntityGraph in interface org.hibernate.engine.spi.SharedSessionContractImplementor

Overrides:

createEntityGraph in class org.hibernate.internal.AbstractSharedSessionContract

createEntityGraph

public <T>
org.hibernate.graph.spi.RootGraphImplementor<T> createEntityGraph(Class<T> entity,
 String name)

Specified by:

createEntityGraph in interface ReactiveQueryProducer

Specified by:

createEntityGraph in interface org.hibernate.SharedSessionContract

Overrides:

createEntityGraph in class org.hibernate.internal.AbstractSharedSessionContract

getEntityGraph

public <T>
org.hibernate.graph.spi.RootGraphImplementor<T> getEntityGraph(Class<T> entity,
 String name)

Specified by:

getEntityGraph in interface ReactiveQueryProducer

createReactiveQuery

public <R> ReactiveQuery<R> createReactiveQuery(jakarta.persistence.TypedQueryReference<R> typedQueryReference)

Specified by:

createReactiveQuery in interface ReactiveQueryProducer

createReactiveQuery

public <R> ReactiveSqmQueryImplementor<R> createReactiveQuery(String queryString)

Specified by:

createReactiveQuery in interface ReactiveQueryProducer

createReactiveQuery

public <R> ReactiveQuery<R> createReactiveQuery(jakarta.persistence.criteria.CriteriaQuery<R> criteriaQuery)

Specified by:

createReactiveQuery in interface ReactiveQueryProducer

prepareForQueryExecution

public void prepareForQueryExecution(boolean requiresTxn)

Specified by:

prepareForQueryExecution in interface org.hibernate.engine.spi.SharedSessionContractImplementor

Overrides:

prepareForQueryExecution in class org.hibernate.internal.AbstractSharedSessionContract

createReactiveQuery

public <R> ReactiveSqmQueryImplementor<R> createReactiveQuery(String queryString,
 Class<R> expectedResultType)

Specified by:

createReactiveQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

public <R> ReactiveNativeQueryImplementor<R> createReactiveNativeQuery(String sqlString)

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

public <R> ReactiveNativeQuery<R> createReactiveNativeQuery(String sqlString,
 Class<R> resultClass)

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

@Deprecated(forRemoval=true)
public <R> ReactiveNativeQuery<R> createReactiveNativeQuery(String sqlString,
 Class<R> resultClass,
 String tableAlias)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

@Deprecated(forRemoval=true)
public <R> ReactiveNativeQuery<R> createReactiveNativeQuery(String sqlString,
 String resultSetMappingName)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

@Deprecated(forRemoval=true)
public <R> ReactiveNativeQuery<R> createReactiveNativeQuery(String sqlString,
 String resultSetMappingName,
 Class<R> resultClass)

Deprecated, for removal: This API element is subject to removal in a future version.

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

createReactiveSelectionQuery

public <R> ReactiveSelectionQuery<R> createReactiveSelectionQuery(String hqlString,
 Class<R> resultType)

Specified by:

createReactiveSelectionQuery in interface ReactiveQueryProducer

createReactiveSelectionQuery

public <R> ReactiveSelectionQuery<R> createReactiveSelectionQuery(jakarta.persistence.criteria.CriteriaQuery<R> criteria)

Specified by:

createReactiveSelectionQuery in interface ReactiveQueryProducer

createReactiveMutationQuery

public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(String hqlString)

Specified by:

createReactiveMutationQuery in interface ReactiveQueryProducer

createReactiveMutationQuery

public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(jakarta.persistence.criteria.CriteriaUpdate<R> updateQuery)

Specified by:

createReactiveMutationQuery in interface ReactiveQueryProducer

createReactiveMutationQuery

public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(jakarta.persistence.criteria.CriteriaDelete<R> deleteQuery)

Specified by:

createReactiveMutationQuery in interface ReactiveQueryProducer

createReactiveMutationQuery

public <R> ReactiveMutationQuery<R> createReactiveMutationQuery(org.hibernate.query.criteria.JpaCriteriaInsert<R> insert)

Specified by:

createReactiveMutationQuery in interface ReactiveQueryProducer

createNamedReactiveSelectionQuery

public <R> ReactiveSelectionQuery<R> createNamedReactiveSelectionQuery(String queryName)

Specified by:

createNamedReactiveSelectionQuery in interface ReactiveQueryProducer

createNamedReactiveMutationQuery

public <R> ReactiveMutationQuery<R> createNamedReactiveMutationQuery(String queryName)

Specified by:

createNamedReactiveMutationQuery in interface ReactiveQueryProducer

createReactiveNamedQuery

public <R> ReactiveQueryImplementor<R> createReactiveNamedQuery(String queryName)

Specified by:

createReactiveNamedQuery in interface ReactiveQueryProducer

createReactiveNamedQuery

public <R> ReactiveQueryImplementor<R> createReactiveNamedQuery(String queryName,
 Class<R> resultType)

Specified by:

createReactiveNamedQuery in interface ReactiveQueryProducer

createNamedReactiveSelectionQuery

public <R> ReactiveSelectionQuery<R> createNamedReactiveSelectionQuery(String queryName,
 Class<R> expectedResultType)

Specified by:

createNamedReactiveSelectionQuery in interface ReactiveQueryProducer

createNativeReactiveMutationQuery

public <R> ReactiveMutationQuery<R> createNativeReactiveMutationQuery(String sqlString)

Specified by:

createNativeReactiveMutationQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

public <R> ReactiveNativeQuery<R> createReactiveNativeQuery(String queryString,
 AffectedEntities affectedEntities)

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

public <R> ReactiveNativeQuery<R> createReactiveNativeQuery(String queryString,
 Class<R> resultType,
 AffectedEntities affectedEntities)

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

public <R> ReactiveNativeQueryImpl<R> createReactiveNativeQuery(String queryString,
 ResultSetMapping<R> resultSetMapping)

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

public <R> ReactiveNativeQuery<R> createReactiveNativeQuery(String queryString,
 ResultSetMapping<R> resultSetMapping,
 AffectedEntities affectedEntities)

Specified by:

createReactiveNativeQuery in interface ReactiveQueryProducer

getResultSetMapping

public <T> ResultSetMapping<T> getResultSetMapping(Class<T> resultType,
 String mappingName)

Specified by:

getResultSetMapping in interface ReactiveQueryProducer

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.hibernate.SharedSessionContract

Specified by:

close in interface org.hibernate.StatelessSession

Overrides:

close in class org.hibernate.internal.AbstractSharedSessionContract

close

public void close(CompletableFuture<Void> closing)

Specified by:

close in interface ReactiveStatelessSession