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:

MutationCoordinator, UpdateCoordinator, ReactiveScopedUpdateCoordinator

Direct Known Subclasses:

ReactiveMergeCoordinator

public class ReactiveUpdateCoordinatorStandard
extends UpdateCoordinatorStandard
implements ReactiveScopedUpdateCoordinator

Reactive version of UpdateCoordinatorStandard, but it cannot be shared 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
protected GeneratedValues	doDynamicUpdate(Object entity, Object id, Object rowId, Object[] values, Object[] oldValues, UpdateCoordinatorStandard.InclusionChecker dirtinessChecker, UpdateCoordinatorStandard.UpdateValuesAnalysisImpl valuesAnalysis, SharedSessionContractImplementor session)
protected GeneratedValues	doStaticUpdate(Object entity, Object id, Object rowId, Object[] values, Object[] oldValues, UpdateCoordinatorStandard.UpdateValuesAnalysisImpl valuesAnalysis, SharedSessionContractImplementor session)
protected GeneratedValues	doVersionUpdate(Object entity, Object id, Object version, Object oldVersion, SharedSessionContractImplementor session)
CompletionStage<GeneratedValues>	reactiveUpdate(Object entity, Object id, Object rowId, Object[] values, Object oldVersion, Object[] incomingOldValues, int[] incomingDirtyAttributeIndexes, boolean hasDirtyCollection, SharedSessionContractImplementor session)

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

decomposeForUpdate, dirtyAttributeIndexes, doVersionUpdate, forceVersionIncrement, forceVersionIncrement, generateDynamicUpdateGroup, getBatchKey, getPropertiesToUpdate, getPropertyUpdateability, getStaticMutationOperationGroup, getVersionUpdateBatchkey, getVersionUpdateGroup, handlePotentialImplicitForcedVersionIncrement, isModifiableEntity, newTableUpdateBuilder, performUpdate, resolveUpdateVersionBatchKeyAccess, toString, update

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

applyKeyRestriction, bindPartitionColumnValueBindings, breakDownKeyJdbcValues, createOperationGroup, dialect, entityPersister, factory, handleValueGeneration, needsRowId, 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

reactiveUpdate

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

Specified by:

reactiveUpdate in interface ReactiveScopedUpdateCoordinator

doVersionUpdate

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

Overrides:

doVersionUpdate in class UpdateCoordinatorStandard

doDynamicUpdate

protected GeneratedValues 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 GeneratedValues doStaticUpdate(Object entity,
                                         Object id,
                                         Object rowId,
                                         Object[] values,
                                         Object[] oldValues,
                                         UpdateCoordinatorStandard.UpdateValuesAnalysisImpl valuesAnalysis,
                                         SharedSessionContractImplementor session)

Overrides:

doStaticUpdate in class UpdateCoordinatorStandard