Package org.hibernate.reactive.session.impl

Class ReactiveSessionImpl

java.lang.Object

org.hibernate.internal.AbstractSharedSessionContract

org.hibernate.internal.SessionImpl

org.hibernate.reactive.session.impl.ReactiveSessionImpl

All Implemented Interfaces:

jakarta.persistence.EntityManager, Serializable, AutoCloseable, org.hibernate.engine.jdbc.LobCreationContext, org.hibernate.engine.spi.SessionImplementor, org.hibernate.engine.spi.SharedSessionContractImplementor, org.hibernate.event.spi.EventSource, org.hibernate.loader.internal.LoadAccessContext, org.hibernate.query.QueryProducer, org.hibernate.query.spi.QueryProducerImplementor, ReactiveSharedSessionContractImplementor, ReactiveConnectionSupplier, ReactiveQueryProducer, ReactiveSession, org.hibernate.resource.jdbc.spi.JdbcSessionOwner, org.hibernate.resource.transaction.spi.TransactionCoordinatorBuilder.Options, org.hibernate.Session, org.hibernate.SharedSessionContract, org.hibernate.type.descriptor.java.JavaType.CoercionContext, org.hibernate.type.descriptor.WrapperOptions

public class ReactiveSessionImpl
extends org.hibernate.internal.SessionImpl
implements ReactiveSession, org.hibernate.event.spi.EventSource

An ReactiveSession implemented by extension of the SessionImpl 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.AbstractSharedSessionContract

closed, waitingForAutoClose

Constructor Summary

Constructors

Constructor	Description
ReactiveSessionImpl(org.hibernate.internal.SessionFactoryImpl delegate, org.hibernate.internal.SessionCreationOptions options, ReactiveConnection connection)

Method Summary

Modifier and Type	Method	Description
void	afterOperation(boolean success)
void	checkOpen()
void	checkTransactionNeededForUpdateOperation(String exceptionMessage)
void	clear()
void	close()
<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)
protected org.hibernate.engine.spi.PersistenceContext	createPersistenceContext()
protected <T> ReactiveQueryImplementor<T>	createReactiveCriteriaQuery(org.hibernate.query.sqm.tree.SqmStatement<T> criteria, Class<T> resultType)
<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 name)
<R> ReactiveQueryImplementor<R>	createReactiveNamedQuery(String name, Class<R> resultType)
<T> ReactiveNativeQueryImplementor<T>	createReactiveNativeQuery(String sqlString)
<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)
<T> ReactiveNativeQuery<T>	createReactiveNativeQuery(String sqlString, Class<T> resultClass)
<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)
protected <T> ReactiveNativeQueryImpl<T>	createReactiveNativeQueryImplementor(Class<T> resultType, org.hibernate.query.sql.spi.NamedNativeQueryMemento<?> memento)
<R> ReactiveQuery<R>	createReactiveQuery(jakarta.persistence.criteria.CriteriaQuery<R> criteriaQuery)
<R> ReactiveQuery<R>	createReactiveQuery(jakarta.persistence.TypedQueryReference<R> typedQueryReference)
<R> ReactiveQuery<R>	createReactiveQuery(String queryString)
<R> ReactiveQuery<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)
protected <T> ReactiveSqmQueryImpl<T>	createReactiveSqmQueryImplementor(Class<T> resultType, org.hibernate.query.sqm.spi.NamedSqmQueryMemento<?> memento)
void	delayedAfterCompletion()
Integer	getBatchSize()
org.hibernate.dialect.Dialect	getDialect()
<T> Class<T>	getEntityClass(T entity)
<T> org.hibernate.graph.spi.RootGraphImplementor<T>	getEntityGraph(Class<T> entity, String name)
Object	getEntityId(Object entity)
org.hibernate.engine.spi.ExceptionConverter	getExceptionConverter()
ReactiveActionQueue	getReactiveActionQueue()
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.SessionImplementor	getSharedContract()
Object	immediateLoad(String entityName, Object id)
void	initializeCollection(org.hibernate.collection.spi.PersistentCollection<?> collection, boolean writing)	Deprecated. use reactiveInitializeCollection(PersistentCollection, boolean) instead
Object	load(org.hibernate.event.spi.LoadEventListener.LoadType loadType, Object id, String entityName, org.hibernate.LockOptions lockOptions, Boolean readOnly)
void	prepareForQueryExecution(boolean requiresTxn)
CompletionStage<Void>	reactiveAutoflush()
CompletionStage<Boolean>	reactiveAutoFlushIfRequired(Set<String> querySpaces)
CompletionStage<Void>	reactiveClose()
<E, T> CompletionStage<T>	reactiveFetch(E entity, jakarta.persistence.metamodel.Attribute<E,T> field)
<T> CompletionStage<T>	reactiveFetch(T association, boolean unproxy)
<T> CompletionStage<List<T>>	reactiveFind(Class<T> entityClass, Object... ids)
<T> CompletionStage<T>	reactiveFind(Class<T> entityClass, Object id, org.hibernate.LockMode lockMode, jakarta.persistence.EntityGraph<T> fetchGraph)
<T> CompletionStage<T>	reactiveFind(Class<T> entityClass, Object id, org.hibernate.LockOptions lockOptions, jakarta.persistence.EntityGraph<T> fetchGraph)
<T> CompletionStage<T>	reactiveFind(Class<T> entityClass, Map<String,Object> ids)
CompletionStage<Void>	reactiveFlush()
CompletionStage<Void>	reactiveForceFlush(org.hibernate.engine.spi.EntityEntry entry)
<T> CompletionStage<T>	reactiveGet(Class<T> entityClass, Object id)
CompletionStage<Object>	reactiveImmediateLoad(String entityName, Object id)	Load the data for the object with the specified id into a newly created object.
CompletionStage<Void>	reactiveInitializeCollection(org.hibernate.collection.spi.PersistentCollection<?> collection, boolean writing)
CompletionStage<Object>	reactiveInternalLoad(String entityName, Object id, boolean eager, boolean nullable)
CompletionStage<Object>	reactiveLoad(org.hibernate.event.spi.LoadEventListener.LoadType loadType, Object id, String entityName, org.hibernate.LockOptions lockOptions, Boolean readOnly)
CompletionStage<Void>	reactiveLock(Object entity, org.hibernate.LockMode lockMode)
CompletionStage<Void>	reactiveLock(Object object, org.hibernate.LockOptions lockOptions)
CompletionStage<Void>	reactiveLock(String entityName, Object object, org.hibernate.LockOptions lockOptions)
CompletionStage<Void>	reactiveMerge(Object object, org.hibernate.event.spi.MergeContext copiedAlready)
<T> CompletionStage<T>	reactiveMerge(T object)
CompletionStage<Void>	reactivePersist(Object entity)
CompletionStage<Void>	reactivePersist(Object object, org.hibernate.event.spi.PersistContext copiedAlready)
CompletionStage<Void>	reactivePersist(String entityName, Object entity)
CompletionStage<Void>	reactivePersistOnFlush(Object entity, org.hibernate.event.spi.PersistContext copiedAlready)
CompletionStage<Void>	reactiveRefresh(Object object, org.hibernate.event.spi.RefreshContext refreshedAlready)
CompletionStage<Void>	reactiveRefresh(Object entity, org.hibernate.LockMode lockMode)
CompletionStage<Void>	reactiveRefresh(Object entity, org.hibernate.LockOptions lockOptions)
CompletionStage<Void>	reactiveRemove(Object entity)
CompletionStage<Void>	reactiveRemove(String entityName, Object child, boolean isCascadeDeleteEnabled, org.hibernate.event.spi.DeleteContext transientEntities)
CompletionStage<Void>	reactiveRemoveOrphanBeforeUpdates(String entityName, Object child)
void	removeOrphanBeforeUpdates(String entityName, Object child)
void	setBatchSize(Integer batchSize)
<T> T	unwrap(Class<T> clazz)

Methods inherited from class org.hibernate.internal.SessionImpl

addEventListeners, addSharedSessionTransactionObserver, afterScrollOperation, afterTransactionBegin, afterTransactionCompletion, applyLockOptionsHint, applyQuerySettingsAndHints, applyQuerySettingsAndHints, asEventSource, autoFlushIfRequired, autoFlushIfRequired, autoPreFlush, beforeTransactionCompletion, bestGuessEntityName, bestGuessEntityName, byId, byId, byMultipleIds, byMultipleIds, byMultipleNaturalId, byMultipleNaturalId, byNaturalId, byNaturalId, bySimpleNaturalId, bySimpleNaturalId, cancelQuery, checkNoUnresolvedActionsAfterOperation, checkNoUnresolvedActionsBeforeOperation, checkOpenOrWaitingForAutoClose, checkSessionFactoryOpen, checkTransactionNeededForLock, cleanupOnClose, closeWithoutOpenChecks, contains, contains, createActionQueue, createNamedStoredProcedureQuery, createQuery, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureQuery, createStoredProcedureQuery, createStoredProcedureQuery, delete, detach, determineAppropriateLocalCacheMode, disableFetchProfile, enableFetchProfile, evict, find, find, find, find, find, find, find, find, findMultiple, findMultiple, flush, flushBeforeTransactionCompletion, forceFlush, forceFlush, get, get, get, get, get, get, getActionQueue, getCacheRetrieveMode, getCacheStoreMode, getContextEntityIdentifier, getCurrentLockMode, getDelegate, getEntityManagerFactory, getEntityName, getEntityPersister, getEntityUsingInterceptor, getFetchBatchSize, getFlushMode, getHibernateFlushMode, getIdentifier, getLoadQueryInfluencers, getLobHelper, getLockMode, getManagedEntities, getManagedEntities, getManagedEntities, getManagedEntities, getMetamodel, getPersistenceContext, getPersistenceContextInternal, getProperties, getReadOnlyFromLoadQueryInfluencers, getReference, getReference, getReference, getSession, getStatistics, guessEntityName, instantiate, instantiate, internalLoad, internalLoadType, isAutoCloseSessionEnabled, isDefaultReadOnly, isDirty, isEventSource, isFetchProfileEnabled, isIdentifierRollbackEnabled, isOpen, isReadOnly, isSubselectFetchingEnabled, load, loadFromSecondLevelCache, lock, lock, lock, lock, lock, lock, lock, logIgnoringEntityNotFound, makeLoadEvent, makeLoadEvent, makePostLoadEvent, merge, merge, merge, merge, persist, persist, persist, persistOnFlush, pulseTransactionCoordinator, readOnlyHint, refresh, refresh, refresh, refresh, refresh, refresh, refresh, registerProcess, releaseLoadEvent, releasePostLoadEvent, remove, removeSharedSessionTransactionObserver, replicate, replicate, sessionWithOptions, setCacheRetrieveMode, setCacheStoreMode, setDefaultReadOnly, setFetchBatchSize, setFlushMode, setHibernateFlushMode, setProperty, setReadOnly, setSubselectFetchingEnabled, shouldAutoClose, shouldCloseJdbcCoordinatorOnClose, startTransactionBoundary, toString

Methods inherited from class org.hibernate.internal.AbstractSharedSessionContract

accessTransaction, afterObtainConnection, beforeReleaseConnection, beginTransaction, buildNamedQuery, checkMutationQuery, checkOpen, checkResultType, checkSelectionQuery, checkTransactionSynchStatus, createCriteriaQuery, createEntityGraph, createEntityGraph, createMutationQuery, createMutationQuery, createMutationQuery, createMutationQuery, createNamedMutationQuery, createNamedQuery, createNamedQuery, createNamedSelectionQuery, createNamedSelectionQuery, createNativeMutationQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQueryImplementor, createNativeQueryImplementor, createNativeQueryImplementor, createQuery, createQuery, createQuery, createQuery, createQuery, createQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery, createSqmQueryImplementor, createSqmQueryImplementor, createSqmQueryImplementor, disableFilter, doReturningWork, doWork, enableFilter, execute, generateEntityKey, getCacheMode, getCacheTransactionSynchronization, getConfiguredJdbcBatchSize, getCriteriaBuilder, getCurrentTransaction, getEnabledFilter, getEntityGraph, getEntityGraphs, getEntityNameResolver, getEventListenerManager, getEventMonitor, 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, isOpenOrWaitingForAutoClose, isTransactionInProgress, joinTransaction, markForRollbackOnly, prepareForAutoClose, requireCollectionPersister, requireEntityPersister, requireEntityPersister, setCacheMode, setClosed, setCriteriaCopyTreeEnabled, setCriteriaPlanCacheEnabled, setJdbcBatchSize, setNativeJdbcParametersIgnored, setUpMultitenancy, shouldAutoJoinTransaction, useStreamForLobBinding

Methods inherited from class java.lang.Object

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

Methods inherited from interface jakarta.persistence.EntityManager

contains, createNamedStoredProcedureQuery, createNativeQuery, createNativeQuery, createNativeQuery, createStoredProcedureQuery, createStoredProcedureQuery, createStoredProcedureQuery, find, find, find, find, find, getCriteriaBuilder, getDelegate, getEntityManagerFactory, getLockMode, getMetamodel, getProperties, getTransaction, isJoinedToTransaction, isOpen, joinTransaction, lock, lock, lock, refresh, refresh, refresh, refresh

Methods inherited from interface org.hibernate.event.spi.EventSource

delete, forceFlush, forceFlush, getActionQueue, instantiate, merge, persist, persistOnFlush, refresh

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

afterObtainConnection, afterTransactionBegin, afterTransactionCompletion, beforeReleaseConnection, beforeTransactionCompletion, flushBeforeTransactionCompletion, getEventManager, getEventMonitor, getJdbcBatchSize, getJdbcConnectionAccess, getJdbcSessionContext, getSqlExceptionHelper, getTransactionCoordinator, startTransactionBoundary

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

execute, fromContext

Methods inherited from interface org.hibernate.query.QueryProducer

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

Methods inherited from interface org.hibernate.query.spi.QueryProducerImplementor

createMutationQuery, createMutationQuery, createMutationQuery, createNamedMutationQuery, createNamedQuery, createNamedQuery, createNativeMutationQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createQuery, createQuery, createQuery, createQuery, createQuery, createQuery, getCacheMode, getNamedNativeQuery, getNamedNativeQuery, getNamedQuery

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

createEntityGraph, getFactory

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

contains, detach, disableFetchProfile, disableFilter, enableFetchProfile, enableFilter, getCacheMode, getCurrentLockMode, getEnabledFilter, getEntityName, getFetchBatchSize, getHibernateFlushMode, getIdentifier, getReference, isDefaultReadOnly, isDirty, isFetchProfileEnabled, isOpen, isReadOnly, isSubselectFetchingEnabled, reactiveFind, setCacheMode, setDefaultReadOnly, setFetchBatchSize, setHibernateFlushMode, setReadOnly, setSubselectFetchingEnabled

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

getPersistenceContext

Methods inherited from interface org.hibernate.Session

addEventListeners, byId, byId, byMultipleIds, byMultipleIds, byMultipleNaturalId, byMultipleNaturalId, byNaturalId, byNaturalId, bySimpleNaturalId, bySimpleNaturalId, cancelQuery, contains, createEntityGraph, createEntityGraph, createNamedQuery, createNamedQuery, createQuery, createQuery, createQuery, createQuery, createQuery, createQuery, detach, disableFetchProfile, enableFetchProfile, evict, find, find, find, findMultiple, findMultiple, flush, get, get, get, get, get, get, getCacheMode, getCacheRetrieveMode, getCacheStoreMode, getCurrentLockMode, getEntityGraph, getEntityGraphs, getEntityName, getFetchBatchSize, getFlushMode, getHibernateFlushMode, getIdentifier, getLobHelper, getManagedEntities, getManagedEntities, getManagedEntities, getManagedEntities, getReference, getReference, getReference, getStatistics, isDefaultReadOnly, isDirty, isFetchProfileEnabled, isReadOnly, isSubselectFetchingEnabled, load, lock, lock, lock, merge, merge, merge, persist, persist, refresh, refresh, remove, replicate, replicate, sessionWithOptions, setCacheMode, setCacheRetrieveMode, setCacheStoreMode, setDefaultReadOnly, setFetchBatchSize, setFlushMode, setHibernateFlushMode, setProperty, setReadOnly, setSubselectFetchingEnabled

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

callWithConnection, createQuery, getSession, getSessionFactory, runWithConnection

Methods inherited from interface org.hibernate.SharedSessionContract

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

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

accessTransaction, afterScrollOperation, asEventSource, asSessionImplementor, asStatelessSession, autoFlushIfRequired, autoFlushIfRequired, autoPreFlush, bestGuessEntityName, bestGuessEntityName, checkOpen, createEntityGraph, createEntityGraph, flush, generateEntityKey, getCacheTransactionSynchronization, getConfiguredJdbcBatchSize, getContextEntityIdentifier, getEntityGraph, getEntityPersister, getEntityUsingInterceptor, getEventListenerManager, getFactory, getHibernateFlushMode, getInterceptor, getJdbcCoordinator, getJdbcServices, getLoadQueryInfluencers, getNativeJdbcParametersIgnored, getPersistenceContext, getPersistenceContextInternal, getSessionAssociationMarkers, getSessionFactory, getSessionIdentifier, getSessionToken, getTypeConfiguration, guessEntityName, instantiate, internalLoad, isClosed, isCriteriaCopyTreeEnabled, isCriteriaPlanCacheEnabled, isDefaultReadOnly, isEventSource, isIdentifierRollbackEnabled, isOpenOrWaitingForAutoClose, isSessionImplementor, isStatelessSession, isTransactionInProgress, loadFromSecondLevelCache, lock, markForRollbackOnly, registerProcess, setCriteriaCopyTreeEnabled, setCriteriaPlanCacheEnabled, setNativeJdbcParametersIgnored

Methods inherited from interface org.hibernate.resource.transaction.spi.TransactionCoordinatorBuilder.Options

shouldAutoJoinTransaction

Methods inherited from interface org.hibernate.type.descriptor.WrapperOptions

getJdbcTimeZone, getJsonFormatMapper, getLobCreator, getPreferredSqlTypeCodeForBoolean, getXmlFormatMapper, useStreamForLobBinding

Constructor Details

ReactiveSessionImpl

public ReactiveSessionImpl(org.hibernate.internal.SessionFactoryImpl delegate,
 org.hibernate.internal.SessionCreationOptions options,
 ReactiveConnection connection)

Method Details

getSharedContract

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

Specified by:

getSharedContract in interface ReactiveQueryProducer

Specified by:

getSharedContract in interface ReactiveSession

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

createPersistenceContext

protected org.hibernate.engine.spi.PersistenceContext createPersistenceContext()

Overrides:

createPersistenceContext in class org.hibernate.internal.SessionImpl

getReactiveActionQueue

public ReactiveActionQueue getReactiveActionQueue()

Specified by:

getReactiveActionQueue in interface ReactiveSession

immediateLoad

public Object immediateLoad(String entityName,
 Object id)
                     throws org.hibernate.HibernateException

Specified by:

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

Overrides:

immediateLoad in class org.hibernate.internal.SessionImpl

Throws:

org.hibernate.HibernateException

reactiveImmediateLoad

public CompletionStage<Object> reactiveImmediateLoad(String entityName,
 Object id)
                                              throws org.hibernate.HibernateException

Load the data for the object with the specified id into a newly created object. This is only called when lazily initializing a proxy. Do NOT return a proxy.

Specified by:

reactiveImmediateLoad in interface ReactiveSharedSessionContractImplementor

Throws:

org.hibernate.HibernateException

reactiveInternalLoad

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

Specified by:

reactiveInternalLoad in interface ReactiveQueryProducer

load

public Object load(org.hibernate.event.spi.LoadEventListener.LoadType loadType,
 Object id,
 String entityName,
 org.hibernate.LockOptions lockOptions,
 Boolean readOnly)

Specified by:

load in interface org.hibernate.loader.internal.LoadAccessContext

Overrides:

load in class org.hibernate.internal.SessionImpl

reactiveLoad

public CompletionStage<Object> reactiveLoad(org.hibernate.event.spi.LoadEventListener.LoadType loadType,
 Object id,
 String entityName,
 org.hibernate.LockOptions lockOptions,
 Boolean readOnly)

Specified by:

reactiveLoad in interface ReactiveSession

See Also:

• SessionImpl.load(LoadEventListener.LoadType, Object, String, LockOptions, Boolean)

reactiveFetch

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

Specified by:

reactiveFetch in interface ReactiveQueryProducer

reactiveFetch

public <E,
T> CompletionStage<T> reactiveFetch(E entity,
 jakarta.persistence.metamodel.Attribute<E,T> field)

Specified by:

reactiveFetch in interface ReactiveSession

createReactiveQuery

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

Specified by:

createReactiveQuery in interface ReactiveQueryProducer

createReactiveCriteriaQuery

protected <T> ReactiveQueryImplementor<T> createReactiveCriteriaQuery(org.hibernate.query.sqm.tree.SqmStatement<T> criteria,
 Class<T> resultType)

createReactiveQuery

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

Specified by:

createReactiveQuery in interface ReactiveQueryProducer

createReactiveQuery

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

Specified by:

createReactiveQuery in interface ReactiveQueryProducer

createReactiveQuery

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

Specified by:

createReactiveQuery in interface ReactiveQueryProducer

createReactiveNativeQuery

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

Specified by:

createReactiveNativeQuery 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

createReactiveNativeQuery

public <T> ReactiveNativeQuery<T> createReactiveNativeQuery(String sqlString,
 Class<T> 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

createReactiveNamedQuery

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

Specified by:

createReactiveNamedQuery in interface ReactiveQueryProducer

createReactiveNamedQuery

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

Specified by:

createReactiveNamedQuery in interface ReactiveQueryProducer

createReactiveNativeQueryImplementor

protected <T> ReactiveNativeQueryImpl<T> createReactiveNativeQueryImplementor(Class<T> resultType,
 org.hibernate.query.sql.spi.NamedNativeQueryMemento<?> memento)

createReactiveSqmQueryImplementor

protected <T> ReactiveSqmQueryImpl<T> createReactiveSqmQueryImplementor(Class<T> resultType,
 org.hibernate.query.sqm.spi.NamedSqmQueryMemento<?> memento)

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

createNamedReactiveMutationQuery

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

Specified by:

createNamedReactiveMutationQuery in interface ReactiveQueryProducer

createNamedReactiveSelectionQuery

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

Specified by:

createNamedReactiveSelectionQuery 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

initializeCollection

@Deprecated
public void initializeCollection(org.hibernate.collection.spi.PersistentCollection<?> collection,
 boolean writing)

Deprecated.

use reactiveInitializeCollection(PersistentCollection, boolean) instead

Specified by:

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

Overrides:

initializeCollection in class org.hibernate.internal.SessionImpl

reactiveInitializeCollection

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

Specified by:

reactiveInitializeCollection in interface ReactiveSharedSessionContractImplementor

reactivePersist

public CompletionStage<Void> reactivePersist(Object entity)

Specified by:

reactivePersist in interface ReactiveSession

reactivePersist

public CompletionStage<Void> reactivePersist(String entityName,
 Object entity)

Specified by:

reactivePersist in interface ReactiveSession

reactivePersist

public CompletionStage<Void> reactivePersist(Object object,
 org.hibernate.event.spi.PersistContext copiedAlready)

Specified by:

reactivePersist in interface ReactiveSession

reactivePersistOnFlush

public CompletionStage<Void> reactivePersistOnFlush(Object entity,
 org.hibernate.event.spi.PersistContext copiedAlready)

Specified by:

reactivePersistOnFlush in interface ReactiveSession

reactiveRemove

public CompletionStage<Void> reactiveRemove(Object entity)

Specified by:

reactiveRemove in interface ReactiveSession

reactiveRemove

public CompletionStage<Void> reactiveRemove(String entityName,
 Object child,
 boolean isCascadeDeleteEnabled,
 org.hibernate.event.spi.DeleteContext transientEntities)

Specified by:

reactiveRemove in interface ReactiveSession

reactiveMerge

public <T> CompletionStage<T> reactiveMerge(T object)
                                     throws org.hibernate.HibernateException

Specified by:

reactiveMerge in interface ReactiveSession

Throws:

org.hibernate.HibernateException

reactiveMerge

public CompletionStage<Void> reactiveMerge(Object object,
 org.hibernate.event.spi.MergeContext copiedAlready)
                                    throws org.hibernate.HibernateException

Specified by:

reactiveMerge in interface ReactiveSession

Throws:

org.hibernate.HibernateException

reactiveFlush

public CompletionStage<Void> reactiveFlush()

Specified by:

reactiveFlush in interface ReactiveSession

reactiveAutoflush

public CompletionStage<Void> reactiveAutoflush()

Specified by:

reactiveAutoflush in interface ReactiveSession

reactiveAutoFlushIfRequired

public CompletionStage<Boolean> reactiveAutoFlushIfRequired(Set<String> querySpaces)

Specified by:

reactiveAutoFlushIfRequired in interface ReactiveSharedSessionContractImplementor

reactiveForceFlush

public CompletionStage<Void> reactiveForceFlush(org.hibernate.engine.spi.EntityEntry entry)

Specified by:

reactiveForceFlush in interface ReactiveSession

getExceptionConverter

public org.hibernate.engine.spi.ExceptionConverter getExceptionConverter()

Specified by:

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

Overrides:

getExceptionConverter in class org.hibernate.internal.AbstractSharedSessionContract

reactiveRefresh

public CompletionStage<Void> reactiveRefresh(Object entity,
 org.hibernate.LockOptions lockOptions)

Specified by:

reactiveRefresh in interface ReactiveSession

reactiveRefresh

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

Specified by:

reactiveRefresh in interface ReactiveSession

reactiveRefresh

public CompletionStage<Void> reactiveRefresh(Object object,
 org.hibernate.event.spi.RefreshContext refreshedAlready)

Specified by:

reactiveRefresh in interface ReactiveSession

reactiveLock

public CompletionStage<Void> reactiveLock(Object object,
 org.hibernate.LockOptions lockOptions)

Specified by:

reactiveLock in interface ReactiveSession

reactiveLock

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

Specified by:

reactiveLock in interface ReactiveSession

reactiveLock

public CompletionStage<Void> reactiveLock(String entityName,
 Object object,
 org.hibernate.LockOptions lockOptions)

Specified by:

reactiveLock in interface ReactiveSession

reactiveGet

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

Specified by:

reactiveGet in interface ReactiveSession

reactiveFind

public <T> CompletionStage<T> reactiveFind(Class<T> entityClass,
 Object id,
 org.hibernate.LockOptions lockOptions,
 jakarta.persistence.EntityGraph<T> fetchGraph)

Specified by:

reactiveFind in interface ReactiveSession

reactiveFind

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

Specified by:

reactiveFind in interface ReactiveSession

reactiveFind

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

Specified by:

reactiveFind in interface ReactiveSession

reactiveFind

public <T> CompletionStage<T> reactiveFind(Class<T> entityClass,
 Map<String,Object> ids)

Specified by:

reactiveFind in interface ReactiveSession

delayedAfterCompletion

public void delayedAfterCompletion()

Specified by:

delayedAfterCompletion in interface org.hibernate.loader.internal.LoadAccessContext

Overrides:

delayedAfterCompletion in class org.hibernate.internal.SessionImpl

afterOperation

public void afterOperation(boolean success)

Specified by:

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

Overrides:

afterOperation in class org.hibernate.internal.SessionImpl

checkTransactionNeededForUpdateOperation

public void checkTransactionNeededForUpdateOperation(String exceptionMessage)

Specified by:

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

Overrides:

checkTransactionNeededForUpdateOperation in class org.hibernate.internal.AbstractSharedSessionContract

unwrap

public <T> T unwrap(Class<T> clazz)

Specified by:

unwrap in interface jakarta.persistence.EntityManager

Specified by:

unwrap in interface org.hibernate.Session

Specified by:

unwrap in interface org.hibernate.SharedSessionContract

Overrides:

unwrap in class org.hibernate.internal.SessionImpl

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

close

public void close()
           throws org.hibernate.HibernateException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface jakarta.persistence.EntityManager

Specified by:

close in interface org.hibernate.SharedSessionContract

Overrides:

close in class org.hibernate.internal.SessionImpl

Throws:

org.hibernate.HibernateException

reactiveClose

public CompletionStage<Void> reactiveClose()

Specified by:

reactiveClose in interface ReactiveSession

getBatchSize

public Integer getBatchSize()

Specified by:

getBatchSize in interface ReactiveSession

setBatchSize

public void setBatchSize(Integer batchSize)

Specified by:

setBatchSize in interface ReactiveSession

getEntityClass

public <T> Class<T> getEntityClass(T entity)

Specified by:

getEntityClass in interface ReactiveSession

getEntityId

public Object getEntityId(Object entity)

Specified by:

getEntityId in interface ReactiveSession

checkOpen

public void checkOpen()

Specified by:

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

removeOrphanBeforeUpdates

public void removeOrphanBeforeUpdates(String entityName,
 Object child)

Specified by:

removeOrphanBeforeUpdates in interface org.hibernate.event.spi.EventSource

Overrides:

removeOrphanBeforeUpdates in class org.hibernate.internal.SessionImpl

reactiveRemoveOrphanBeforeUpdates

public CompletionStage<Void> reactiveRemoveOrphanBeforeUpdates(String entityName,
 Object child)

Specified by:

reactiveRemoveOrphanBeforeUpdates in interface ReactiveSession

clear

public void clear()

Specified by:

clear in interface jakarta.persistence.EntityManager

Specified by:

clear in interface ReactiveSession

Specified by:

clear in interface org.hibernate.Session

Overrides:

clear in class org.hibernate.internal.SessionImpl

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