Package org.hibernate.reactive.persister.entity.mutation

Class ReactiveUpdateCoordinatorStandard

java.lang.Object

org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

org.hibernate.persister.entity.mutation.UpdateCoordinatorStandard

org.hibernate.reactive.persister.entity.mutation.ReactiveUpdateCoordinatorStandard

All Implemented Interfaces:

UpdateCoordinator, ReactiveScopedUpdateCoordinator

public class ReactiveUpdateCoordinatorStandard
extends UpdateCoordinatorStandard
implements ReactiveScopedUpdateCoordinator

Reactive version of UpdateCoordinatorStandard, but it cannot be share between multiple update operations.

Nested Class Summary

Nested classes/interfaces inherited from class org.hibernate.persister.entity.mutation.UpdateCoordinatorStandard

UpdateCoordinatorStandard.DirtinessChecker, UpdateCoordinatorStandard.InclusionChecker, UpdateCoordinatorStandard.UpdateValuesAnalysisImpl

Field Summary

Fields inherited from class org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

dialect, entityPersister, factory, mutationExecutorService

Constructor Summary

Constructors

Constructor	Description
ReactiveUpdateCoordinatorStandard(AbstractEntityPersister entityPersister, SessionFactoryImplementor factory, MutationOperationGroup staticUpdateGroup, BatchKey batchKey, MutationOperationGroup versionUpdateGroup, BatchKey versionUpdateBatchkey)

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	coordinateReactiveUpdate(Object entity, Object id, Object rowId, Object[] values, Object oldVersion, Object[] incomingOldValues, int[] incomingDirtyAttributeIndexes, boolean hasDirtyCollection, SharedSessionContractImplementor session)
protected void	doDynamicUpdate(Object entity, Object id, Object rowId, Object[] values, Object[] oldValues, UpdateCoordinatorStandard.InclusionChecker dirtinessChecker, UpdateCoordinatorStandard.UpdateValuesAnalysisImpl valuesAnalysis, SharedSessionContractImplementor session)
protected void	doStaticUpdate(Object entity, Object id, Object rowId, Object[] values, Object[] oldValues, UpdateCoordinatorStandard.UpdateValuesAnalysisImpl valuesAnalysis, SharedSessionContractImplementor session)
protected void	doVersionUpdate(Object entity, Object id, Object version, Object oldVersion, SharedSessionContractImplementor session)

Methods inherited from class org.hibernate.persister.entity.mutation.UpdateCoordinatorStandard

coordinateUpdate, decomposeForUpdate, dirtyAttributeIndexes, doVersionUpdate, forceVersionIncrement, forceVersionIncrement, generateDynamicUpdateGroup, getBatchKey, getPropertiesToUpdate, getPropertyUpdateability, getStaticUpdateGroup, getVersionUpdateBatchkey, getVersionUpdateGroup, handlePotentialImplicitForcedVersionIncrement, isModifiableEntity, performUpdate, resolveUpdateVersionBatchKeyAccess, toString

Methods inherited from class org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

bindPartitionColumnValueBindings, createOperationGroup, dialect, entityPersister, factory, resolveBatchKeyAccess

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReactiveUpdateCoordinatorStandard

public ReactiveUpdateCoordinatorStandard(AbstractEntityPersister entityPersister,
                                         SessionFactoryImplementor factory,
                                         MutationOperationGroup staticUpdateGroup,
                                         BatchKey batchKey,
                                         MutationOperationGroup versionUpdateGroup,
                                         BatchKey versionUpdateBatchkey)

Method Detail

coordinateReactiveUpdate

public CompletionStage<Void> coordinateReactiveUpdate(Object entity,
                                                      Object id,
                                                      Object rowId,
                                                      Object[] values,
                                                      Object oldVersion,
                                                      Object[] incomingOldValues,
                                                      int[] incomingDirtyAttributeIndexes,
                                                      boolean hasDirtyCollection,
                                                      SharedSessionContractImplementor session)

Specified by:

coordinateReactiveUpdate in interface ReactiveScopedUpdateCoordinator

doVersionUpdate

protected void doVersionUpdate(Object entity,
                               Object id,
                               Object version,
                               Object oldVersion,
                               SharedSessionContractImplementor session)

Overrides:

doVersionUpdate in class UpdateCoordinatorStandard

doDynamicUpdate

protected void doDynamicUpdate(Object entity,
                               Object id,
                               Object rowId,
                               Object[] values,
                               Object[] oldValues,
                               UpdateCoordinatorStandard.InclusionChecker dirtinessChecker,
                               UpdateCoordinatorStandard.UpdateValuesAnalysisImpl valuesAnalysis,
                               SharedSessionContractImplementor session)

Overrides:

doDynamicUpdate in class UpdateCoordinatorStandard

doStaticUpdate

protected void doStaticUpdate(Object entity,
                              Object id,
                              Object rowId,
                              Object[] values,
                              Object[] oldValues,
                              UpdateCoordinatorStandard.UpdateValuesAnalysisImpl valuesAnalysis,
                              SharedSessionContractImplementor session)

Overrides:

doStaticUpdate in class UpdateCoordinatorStandard