public class ReactiveStatelessSessionImpl extends StatelessSessionImpl implements ReactiveStatelessSession
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.| Constructor and Description |
|---|
ReactiveStatelessSessionImpl(SessionFactoryImpl factory, SessionCreationOptions options, ReactiveConnection proxyConnection) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitisOpengetFactorypublic ReactiveStatelessSessionImpl(SessionFactoryImpl factory,
SessionCreationOptions options,
ReactiveConnection proxyConnection)public PersistenceContext getPersistenceContext()
public Dialect getDialect()
getDialect in interface ReactiveQueryExecutorpublic SharedSessionContractImplementor getSharedContract()
getSharedContract in interface ReactiveQueryExecutorpublic PersistenceContext getPersistenceContextInternal()
public ReactiveConnection getReactiveConnection()
ReactiveConnectionSupplierReactiveConnection that is associated with the current session.getReactiveConnection in interface ReactiveConnectionSupplierpublic void checkTransactionNeededForUpdateOperation(String exceptionMessage)
public <T> CompletionStage<T> reactiveGet(Class<T> entityClass, Object id)
reactiveGet in interface ReactiveStatelessSessionpublic <T> CompletionStage<T> reactiveGet(Class<T> entityClass, Object id, LockMode lockMode)
reactiveGet in interface ReactiveStatelessSessionpublic ReactiveEntityPersister getEntityPersister(String entityName, Object object) throws HibernateException
HibernateExceptionpublic CompletionStage<Void> reactiveInsert(Object entity)
reactiveInsert in interface ReactiveStatelessSessionpublic CompletionStage<Void> reactiveDelete(Object entity)
reactiveDelete in interface ReactiveStatelessSessionpublic CompletionStage<Void> reactiveUpdate(Object entity)
reactiveUpdate in interface ReactiveStatelessSessionpublic CompletionStage<Void> reactiveRefresh(Object entity)
reactiveRefresh in interface ReactiveStatelessSessionpublic CompletionStage<Void> reactiveRefresh(Object entity, LockMode lockMode)
reactiveRefresh in interface ReactiveStatelessSessionpublic <R> ReactiveQueryImpl<R> createReactiveQuery(String queryString)
createReactiveQuery in interface ReactiveStatelessSessionpublic <R> ReactiveQuery<R> createReactiveQuery(String queryString, Class<R> resultType)
createReactiveQuery in interface ReactiveStatelessSessionpublic <T> ReactiveNativeQuery<T> createReactiveNativeQuery(String sqlString)
createReactiveNativeQuery in interface ReactiveStatelessSessionpublic <T> ReactiveNativeQuery<T> createReactiveNativeQuery(String sqlString, Class<T> resultClass)
createReactiveNativeQuery in interface ReactiveStatelessSessionpublic <T> ReactiveNativeQuery<T> createReactiveNativeQuery(String sqlString, String resultSetMapping)
createReactiveNativeQuery in interface ReactiveStatelessSessionpublic <T> CompletionStage<List<T>> reactiveList(String query, QueryParameters parameters)
reactiveList in interface ReactiveQueryExecutorpublic <T> CompletionStage<List<T>> reactiveList(NativeSQLQuerySpecification spec, QueryParameters parameters)
reactiveList in interface ReactiveQueryExecutorprotected ReactiveHQLQueryPlan getQueryPlan(String query, boolean shallow) throws HibernateException
HibernateExceptionpublic 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 List<?> listCustomQuery(CustomQuery customQuery, QueryParameters queryParameters)
public <T> ResultSetMapping<T> getResultSetMapping(Class<T> resultType, String mappingName)
getResultSetMapping in interface ReactiveQueryExecutorpublic void close()
close in interface ReactiveStatelessSession