public interface ReactiveEntityPersister
EntityPersister
. Supports non-blocking insert/update/delete operations.ReactiveAbstractEntityPersister
Modifier and Type | Method and Description |
---|---|
CompletionStage<?> | deleteReactive(Serializable id, Object version, Object object, SharedSessionContractImplementor session) Delete the given instance without blocking. |
ReactiveUniqueEntityLoader | getAppropriateLoader(LockOptions lockOptions, SharedSessionContractImplementor session) |
CompletionStage<Serializable> | insertReactive(Object[] fields, Object object, SharedSessionContractImplementor session) Insert the given instance state without blocking. |
CompletionStage<?> | insertReactive(Serializable id, Object[] fields, Object object, SharedSessionContractImplementor session) Insert the given instance state without blocking. |
CompletionStage<Void> | lockReactive(Serializable id, Object version, Object object, LockOptions lockOptions, SharedSessionContractImplementor session) Obtain a pessimistic lock without blocking |
CompletionStage<Object> | reactiveGetCurrentVersion(Serializable id, SharedSessionContractImplementor session) |
CompletionStage<Object[]> | reactiveGetDatabaseSnapshot(Serializable id, SharedSessionContractImplementor session) Get the current database state of the object, in a "hydrated" form, without resolving identifiers |
default <E,T> CompletionStage<T> | reactiveInitializeLazyProperty(<any> field, E entity, SharedSessionContractImplementor session) |
CompletionStage<Object> | reactiveLoad(Serializable id, Object optionalObject, LockOptions lockOptions, SharedSessionContractImplementor session) |
CompletionStage<Object> | reactiveLoad(Serializable id, Object optionalObject, LockOptions lockOptions, SharedSessionContractImplementor session, Boolean readOnly) |
CompletionStage<List<Object>> | reactiveMultiLoad(Serializable[] ids, SessionImplementor session, MultiLoadOptions loadOptions) |
CompletionStage<?> | updateReactive(Serializable id, Object[] fields, int[] dirtyFields, boolean hasDirtyCollection, Object[] oldFields, Object oldVersion, Object object, Object rowId, SharedSessionContractImplementor session) Update the given instance state without blocking. |
CompletionStage<?> insertReactive(Serializable id, Object[] fields, Object object, SharedSessionContractImplementor session)
EntityPersister#insert(Serializable, Object[], Object, SharedSessionContractImplementor)
CompletionStage<Serializable> insertReactive(Object[] fields, Object object, SharedSessionContractImplementor session)
EntityPersister#insert(Object[], Object, SharedSessionContractImplementor)
CompletionStage<?> deleteReactive(Serializable id, Object version, Object object, SharedSessionContractImplementor session) throws HibernateException
HibernateException
EntityPersister#delete(Serializable, Object, Object, SharedSessionContractImplementor)
CompletionStage<?> updateReactive(Serializable id, Object[] fields, int[] dirtyFields, boolean hasDirtyCollection, Object[] oldFields, Object oldVersion, Object object, Object rowId, SharedSessionContractImplementor session) throws HibernateException
HibernateException
EntityPersister#update(Serializable, Object[], int[], boolean, Object[], Object, Object, Object, SharedSessionContractImplementor)
CompletionStage<Void> lockReactive(Serializable id, Object version, Object object, LockOptions lockOptions, SharedSessionContractImplementor session) throws HibernateException
HibernateException
CompletionStage<List<Object>> reactiveMultiLoad(Serializable[] ids, SessionImplementor session, MultiLoadOptions loadOptions)
CompletionStage<Object> reactiveLoad(Serializable id, Object optionalObject, LockOptions lockOptions, SharedSessionContractImplementor session)
CompletionStage<Object> reactiveLoad(Serializable id, Object optionalObject, LockOptions lockOptions, SharedSessionContractImplementor session, Boolean readOnly)
ReactiveUniqueEntityLoader getAppropriateLoader(LockOptions lockOptions, SharedSessionContractImplementor session)
CompletionStage<Object> reactiveGetCurrentVersion(Serializable id, SharedSessionContractImplementor session)
CompletionStage<Object[]> reactiveGetDatabaseSnapshot(Serializable id, SharedSessionContractImplementor session)
default <E,T> CompletionStage<T> reactiveInitializeLazyProperty(<any> field, E entity, SharedSessionContractImplementor session)