public interface ReactiveSession extends ReactiveQueryExecutor
reactive session
. This is primarily an internal contract between the various subsystems of Hibernate Reactive.
Stage.Session
, Mutiny.Session
addBulkCleanupAction, executeReactiveUpdate, executeReactiveUpdate, getDialect, getFactory, getResultSetMapping, reactiveList, reactiveList
getReactiveConnection
ReactiveActionQueue getReactiveActionQueue()
PersistenceContext getPersistenceContext()
SessionImplementor getSharedContract()
getSharedContract
in interface ReactiveQueryExecutor
<T> CompletionStage<T> reactiveFetch(T association, boolean unproxy)
<E,T> CompletionStage<T> reactiveFetch(E entity, <any> field)
CompletionStage<Void> reactivePersist(Object entity)
CompletionStage<Void> reactivePersist(Object object, IdentitySet copiedAlready)
CompletionStage<Void> reactivePersistOnFlush(Object entity, IdentitySet copiedAlready)
CompletionStage<Void> reactiveRemove(Object entity)
CompletionStage<Void> reactiveRemove(Object entity, boolean isCascadeDeleteEnabled, IdentitySet transientObjects)
<T> CompletionStage<T> reactiveMerge(T object)
CompletionStage<Void> reactiveMerge(Object object, MergeContext copiedAlready)
CompletionStage<Void> reactiveFlush()
CompletionStage<Void> reactiveAutoflush()
CompletionStage<Void> reactiveRefresh(Object entity, LockOptions lockMode)
CompletionStage<?> reactiveRefresh(Object child, IdentitySet refreshedAlready)
CompletionStage<Void> reactiveLock(Object entity, LockOptions lockMode)
<T> ReactiveQuery<T> createReactiveNativeQuery(String sqlString)
<T> ReactiveNativeQuery<T> createReactiveNativeQuery(String sqlString, String resultSetMapping)
<T> ReactiveQuery<T> createReactiveNativeQuery(String sqlString, Class<T> resultType)
<T> ReactiveQuery<T> createReactiveQuery(String queryString)
<T> ReactiveQuery<T> createReactiveQuery(String queryString, Class<T> resultType)
<R> ReactiveQuery<R> createReactiveNamedQuery(String name)
<R> ReactiveQuery<R> createReactiveNamedQuery(String name, Class<R> resultClass)
<R> ReactiveQuery<R> createReactiveQuery(Criteria<R> criteria)
<T> ReactiveQuery<T> createReactiveCriteriaQuery(String jpaqlString, Class<T> resultClass, CriteriaQueryOptions queryOptions)
<T> CompletionStage<T> reactiveGet(Class<T> entityClass, Serializable id)
<T> CompletionStage<T> reactiveFind(Class<T> entityClass, Object primaryKey, LockOptions lockOptions, <any> fetchGraph)
<T> CompletionStage<List<T>> reactiveFind(Class<T> entityClass, Object... primaryKey)
CompletionStage<Object> reactiveImmediateLoad(String entityName, Serializable id)
CompletionStage<Void> reactiveInitializeCollection(PersistentCollection collection, boolean writing)
void setHibernateFlushMode(FlushMode flushMode)
FlushMode getHibernateFlushMode()
void setCacheMode(CacheMode cacheMode)
CacheMode getCacheMode()
Integer getBatchSize()
void setBatchSize(Integer batchSize)
void detach(Object entity)
boolean isDefaultReadOnly()
void setDefaultReadOnly(boolean readOnly)
void setReadOnly(Object entityOrProxy, boolean readOnly)
boolean isReadOnly(Object entityOrProxy)
Serializable getIdentifier(Object entity)
boolean contains(Object entity)
<T> Class<? extends T> getEntityClass(T entity)
Serializable getEntityId(Object entity)
LockMode getCurrentLockMode(Object entity)
Filter enableFilter(String filterName)
void disableFilter(String filterName)
Filter getEnabledFilter(String filterName)
boolean isFetchProfileEnabled(String name) throws UnknownProfileException
UnknownProfileException
void enableFetchProfile(String name) throws UnknownProfileException
UnknownProfileException
void disableFetchProfile(String name) throws UnknownProfileException
UnknownProfileException
<T> <any> createEntityGraph(Class<T> entity)
void clear()
boolean isDirty()
boolean isOpen()
void close()