public class ReactiveSessionImpl extends SessionImpl implements ReactiveSession
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.| Constructor and Description |
|---|
ReactiveSessionImpl(SessionFactoryImpl delegate, SessionCreationOptions options, ReactiveConnection connection) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitclear, contains, detach, disableFetchProfile, disableFilter, enableFetchProfile, enableFilter, getCacheMode, getCurrentLockMode, getEnabledFilter, getEntityName, getHibernateFlushMode, getIdentifier, getPersistenceContext, getReference, isDefaultReadOnly, isDirty, isFetchProfileEnabled, isOpen, isReadOnly, setCacheMode, setDefaultReadOnly, setHibernateFlushMode, setReadOnlygetFactorypublic ReactiveSessionImpl(SessionFactoryImpl delegate,
SessionCreationOptions options,
ReactiveConnection connection)public SessionImplementor getSharedContract()
getSharedContract in interface ReactiveQueryExecutorgetSharedContract in interface ReactiveSessionpublic Dialect getDialect()
getDialect in interface ReactiveQueryExecutorprotected StatefulPersistenceContext createPersistenceContext()
public ReactiveActionQueue getReactiveActionQueue()
getReactiveActionQueue in interface ReactiveSessionpublic Object immediateLoad(String entityName, Serializable id) throws HibernateException
HibernateExceptionpublic CompletionStage<Object> reactiveImmediateLoad(String entityName, Serializable id) throws HibernateException
reactiveImmediateLoad in interface ReactiveSessionHibernateExceptionpublic <T> CompletionStage<T> reactiveFetch(T association, boolean unproxy)
reactiveFetch in interface ReactiveSessionpublic <E,T> CompletionStage<T> reactiveFetch(E entity, <any> field)
reactiveFetch in interface ReactiveSessionpublic <T> ReactiveNativeQueryImpl<T> createReactiveNativeQuery(String sqlString)
createReactiveNativeQuery in interface ReactiveSessionpublic <T> ReactiveNativeQuery<T> createReactiveNativeQuery(String sqlString, String resultSetMapping)
createReactiveNativeQuery in interface ReactiveSessionpublic <T> ResultSetMapping<T> getResultSetMapping(Class<T> resultType, String mappingName)
getResultSetMapping in interface ReactiveQueryExecutorpublic <T> ReactiveQuery<T> createReactiveNativeQuery(String sqlString, Class<T> resultClass)
createReactiveNativeQuery in interface ReactiveSessionpublic <R> ReactiveQueryImpl<R> createReactiveQuery(String queryString)
createReactiveQuery in interface ReactiveSessionpublic <R> ReactiveQuery<R> createReactiveQuery(String queryString, Class<R> resultType)
createReactiveQuery in interface ReactiveSession@Deprecated public void initializeCollection(PersistentCollection collection, boolean writing)
reactiveInitializeCollection(PersistentCollection, boolean) insteadpublic CompletionStage<Void> reactiveInitializeCollection(PersistentCollection collection, boolean writing)
reactiveInitializeCollection in interface ReactiveSessionprotected ReactiveHQLQueryPlan getQueryPlan(String query, boolean shallow) throws HibernateException
HibernateExceptionprotected CompletionStage<Void> reactiveAutoFlushIfRequired(Set<?> querySpaces) throws HibernateException
HibernateExceptionpublic <T> CompletionStage<List<T>> reactiveList(String query, QueryParameters parameters) throws HibernateException
reactiveList in interface ReactiveQueryExecutorHibernateExceptionpublic <T> CompletionStage<List<T>> reactiveList(NativeSQLQuerySpecification spec, QueryParameters parameters)
reactiveList in interface ReactiveQueryExecutorpublic <R> ReactiveQuery<R> createReactiveNamedQuery(String name)
createReactiveNamedQuery in interface ReactiveSessionpublic <R> ReactiveQuery<R> createReactiveNamedQuery(String name, Class<R> resultClass)
createReactiveNamedQuery in interface ReactiveSessionpublic <T> ReactiveQuery<T> createReactiveCriteriaQuery(String jpaqlString, Class<T> resultClass, CriteriaQueryOptions queryOptions)
createReactiveCriteriaQuery in interface ReactiveSessionpublic CompletionStage<Integer> executeReactiveUpdate(String query, QueryParameters parameters)
executeReactiveUpdate in interface ReactiveQueryExecutorpublic CompletionStage<Integer> executeReactiveUpdate(NativeSQLQuerySpecification specification, QueryParameters parameters)
executeReactiveUpdate in interface ReactiveQueryExecutorpublic void addBulkCleanupAction(BulkOperationCleanupAction action)
addBulkCleanupAction in interface ReactiveQueryExecutorpublic CompletionStage<Void> reactivePersist(Object entity)
reactivePersist in interface ReactiveSessionpublic CompletionStage<Void> reactivePersist(Object object, IdentitySet copiedAlready)
reactivePersist in interface ReactiveSessionpublic CompletionStage<Void> reactivePersistOnFlush(Object entity, IdentitySet copiedAlready)
reactivePersistOnFlush in interface ReactiveSessionpublic CompletionStage<Void> reactiveRemove(Object entity)
reactiveRemove in interface ReactiveSessionpublic CompletionStage<Void> reactiveRemove(Object object, boolean isCascadeDeleteEnabled, IdentitySet transientEntities) throws HibernateException
reactiveRemove in interface ReactiveSessionHibernateExceptionpublic <T> CompletionStage<T> reactiveMerge(T object) throws HibernateException
reactiveMerge in interface ReactiveSessionHibernateExceptionpublic CompletionStage<Void> reactiveMerge(Object object, MergeContext copiedAlready) throws HibernateException
reactiveMerge in interface ReactiveSessionHibernateExceptionpublic CompletionStage<Void> reactiveFlush()
reactiveFlush in interface ReactiveSessionpublic CompletionStage<Void> reactiveAutoflush()
reactiveAutoflush in interface ReactiveSessionpublic ExceptionConverter getExceptionConverter()
public CompletionStage<Void> reactiveRefresh(Object entity, LockOptions lockOptions)
reactiveRefresh in interface ReactiveSessionpublic CompletionStage<Void> reactiveRefresh(Object object, IdentitySet refreshedAlready)
reactiveRefresh in interface ReactiveSessionCompletionStage<Void> fireRefresh(RefreshEvent event)
public CompletionStage<Void> reactiveLock(Object object, LockOptions lockOptions)
reactiveLock in interface ReactiveSessionpublic <T> CompletionStage<T> reactiveGet(Class<T> entityClass, Serializable id)
reactiveGet in interface ReactiveSessionpublic <T> CompletionStage<T> reactiveFind(Class<T> entityClass, Object id, LockOptions lockOptions, <any> fetchGraph)
reactiveFind in interface ReactiveSessionpublic <T> CompletionStage<List<T>> reactiveFind(Class<T> entityClass, Object... ids)
reactiveFind in interface ReactiveSessionprotected void delayedAfterCompletion()
public void afterOperation(boolean success)
public void checkTransactionNeededForUpdateOperation(String exceptionMessage)
public <T> T unwrap(Class<T> clazz)
public ReactiveConnection getReactiveConnection()
ReactiveConnectionSupplierReactiveConnection that is associated with the current session.getReactiveConnection in interface ReactiveConnectionSupplierpublic void close()
throws HibernateExceptionclose in interface ReactiveSessionHibernateExceptionpublic <T> <any> createEntityGraph(Class<T> entity, String name)
createEntityGraph in interface ReactiveSessionpublic <T> <any> createEntityGraph(Class<T> entity)
createEntityGraph in interface ReactiveSessionpublic <T> <any> getEntityGraph(Class<T> entity, String name)
getEntityGraph in interface ReactiveSessionpublic Integer getBatchSize()
getBatchSize in interface ReactiveSessionpublic void setBatchSize(Integer batchSize)
setBatchSize in interface ReactiveSessionpublic <T> Class<? extends T> getEntityClass(T entity)
getEntityClass in interface ReactiveSessionpublic Serializable getEntityId(Object entity)
getEntityId in interface ReactiveSession