public class ReactiveSingleTableEntityPersister extends SingleTableEntityPersister implements ReactiveAbstractEntityPersister
ReactiveEntityPersister
backed by SingleTableEntityPersister
and ReactiveAbstractEntityPersister
.ReactiveAbstractEntityPersister.DeleteExpectation, ReactiveAbstractEntityPersister.InsertExpectation, ReactiveAbstractEntityPersister.UpdateExpectation
log
Constructor and Description |
---|
ReactiveSingleTableEntityPersister(PersistentClass persistentClass, EntityDataAccess cacheAccessStrategy, NaturalIdDataAccess naturalIdRegionAccessStrategy, PersisterCreationContext creationContext) |
Modifier and Type | Method and Description |
---|---|
boolean | check(int rows, Serializable id, int tableNumber, Expectation expectation, PreparedStatement statement, String sql) |
protected UniqueEntityLoader | createEntityLoader(LockMode lockMode, LoadQueryInfluencers loadQueryInfluencers) |
protected UniqueEntityLoader | createEntityLoader(LockOptions lockOptions, LoadQueryInfluencers loadQueryInfluencers) |
protected void | createLoaders() |
void | delete(Serializable id, Object version, int j, Object object, String sql, SharedSessionContractImplementor session, Object[] loadedState) |
void | delete(Serializable id, Object version, Object object, SharedSessionContractImplementor session) |
ReactiveUniqueEntityLoader | getAppropriateLoader(LockOptions lockOptions, SharedSessionContractImplementor session) |
String[][] | getLazyPropertyColumnAliases() |
String[] | getUpdateStrings(boolean byRowId, boolean hasUninitializedLazyProperties) |
boolean | hasProxy() |
CompletionStage<?> | initializeLazyPropertiesFromDatastore(String fieldName, Object entity, SharedSessionContractImplementor session, Serializable id, EntityEntry entry) |
boolean | initializeLazyProperty(String fieldName, Object entity, SharedSessionContractImplementor session, EntityEntry entry, int lazyIndex, Object selectedValue) |
Serializable | insert(Object[] fields, boolean[] notNull, String sql, Object object, SharedSessionContractImplementor session) |
Serializable | insert(Object[] fields, Object object, SharedSessionContractImplementor session) |
void | insert(Serializable id, Object[] fields, boolean[] notNull, int j, String sql, Object object, SharedSessionContractImplementor session) |
void | insert(Serializable id, Object[] fields, Object object, SharedSessionContractImplementor session) |
List | multiLoad(Serializable[] ids, SharedSessionContractImplementor session, MultiLoadOptions loadOptions) |
void | preInsertInMemoryValueGeneration(Object[] fields, Object object, SharedSessionContractImplementor session) |
void | update(Serializable id, Object[] fields, int[] dirtyFields, boolean hasDirtyCollection, Object[] oldFields, Object oldVersion, Object object, Object rowId, SharedSessionContractImplementor session) |
boolean | update(Serializable id, Object[] fields, Object[] oldFields, Object rowId, boolean[] includeProperty, int j, Object oldVersion, Object object, String sql, SharedSessionContractImplementor session) |
void | updateOrInsert(Serializable id, Object[] fields, Object[] oldFields, Object rowId, boolean[] includeProperty, int j, Object oldVersion, Object object, String sql, SharedSessionContractImplementor session) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
delegate, deleteReactive, deleteReactive, generateSelectLockString, generateSQLDeleteStrings, generateUpdateLockString, getReactiveConnection, getSQLLazySelectString, getVersionType, hasUnenhancedProxy, initializeLazyProperty, initLazyProperty, insertReactive, insertReactive, insertReactive, insertReactive, isAllOrDirtyOptimisticLocking, isBatchable, lockReactive, nextVersionForLock, processSnapshot, reactiveGetCurrentVersion, reactiveGetDatabaseSnapshot, reactiveInitializeLazyPropertiesFromDatastore, reactiveInitializeLazyProperty, reactiveLoad, reactiveLoad, reactiveMultiLoad, updateOrInsertReactive, updateReactive, updateReactive
public ReactiveSingleTableEntityPersister(PersistentClass persistentClass, EntityDataAccess cacheAccessStrategy, NaturalIdDataAccess naturalIdRegionAccessStrategy, PersisterCreationContext creationContext) throws HibernateException
HibernateException
public boolean hasProxy()
protected void createLoaders()
protected UniqueEntityLoader createEntityLoader(LockMode lockMode, LoadQueryInfluencers loadQueryInfluencers) throws MappingException
MappingException
protected UniqueEntityLoader createEntityLoader(LockOptions lockOptions, LoadQueryInfluencers loadQueryInfluencers) throws MappingException
MappingException
public Serializable insert(Object[] fields, boolean[] notNull, String sql, Object object, SharedSessionContractImplementor session) throws HibernateException
HibernateException
public void insert(Serializable id, Object[] fields, boolean[] notNull, int j, String sql, Object object, SharedSessionContractImplementor session) throws HibernateException
HibernateException
public Serializable insert(Object[] fields, Object object, SharedSessionContractImplementor session) throws HibernateException
HibernateException
public void insert(Serializable id, Object[] fields, Object object, SharedSessionContractImplementor session)
public void delete(Serializable id, Object version, int j, Object object, String sql, SharedSessionContractImplementor session, Object[] loadedState) throws HibernateException
HibernateException
public void delete(Serializable id, Object version, Object object, SharedSessionContractImplementor session) throws HibernateException
HibernateException
public void updateOrInsert(Serializable id, Object[] fields, Object[] oldFields, Object rowId, boolean[] includeProperty, int j, Object oldVersion, Object object, String sql, SharedSessionContractImplementor session) throws HibernateException
HibernateException
public boolean update(Serializable id, Object[] fields, Object[] oldFields, Object rowId, boolean[] includeProperty, int j, Object oldVersion, Object object, String sql, SharedSessionContractImplementor session) throws HibernateException
HibernateException
public void update(Serializable id, Object[] fields, int[] dirtyFields, boolean hasDirtyCollection, Object[] oldFields, Object oldVersion, Object object, Object rowId, SharedSessionContractImplementor session) throws HibernateException
HibernateException
public List multiLoad(Serializable[] ids, SharedSessionContractImplementor session, MultiLoadOptions loadOptions)
public ReactiveUniqueEntityLoader getAppropriateLoader(LockOptions lockOptions, SharedSessionContractImplementor session)
getAppropriateLoader
in interface ReactiveEntityPersister
public void preInsertInMemoryValueGeneration(Object[] fields, Object object, SharedSessionContractImplementor session)
preInsertInMemoryValueGeneration
in interface ReactiveAbstractEntityPersister
public String[] getUpdateStrings(boolean byRowId, boolean hasUninitializedLazyProperties)
getUpdateStrings
in interface ReactiveAbstractEntityPersister
public boolean check(int rows, Serializable id, int tableNumber, Expectation expectation, PreparedStatement statement, String sql) throws HibernateException
check
in interface ReactiveAbstractEntityPersister
HibernateException
public boolean initializeLazyProperty(String fieldName, Object entity, SharedSessionContractImplementor session, EntityEntry entry, int lazyIndex, Object selectedValue)
initializeLazyProperty
in interface ReactiveAbstractEntityPersister
public CompletionStage<?> initializeLazyPropertiesFromDatastore(String fieldName, Object entity, SharedSessionContractImplementor session, Serializable id, EntityEntry entry)
public String[][] getLazyPropertyColumnAliases()
getLazyPropertyColumnAliases
in interface ReactiveAbstractEntityPersister