Package org.hibernate.persister.entity.mutation

Class AbstractMutationCoordinator

java.lang.Object

org.hibernate.persister.entity.mutation.AbstractMutationCoordinator

Direct Known Subclasses:

AbstractDeleteCoordinator, InsertCoordinatorStandard, UpdateCoordinatorStandard

@Internal
public abstract class AbstractMutationCoordinator
extends Object

Base support for coordinating mutations against an entity

Implementation Note:

Split simply to help minimize the size of AbstractEntityPersister

Field Summary

Fields

Modifier and Type	Field	Description
protected final Dialect	dialect
protected final EntityPersister	entityPersister
protected final SessionFactoryImplementor	factory
protected final MutationExecutorService	mutationExecutorService

Constructor Summary

Constructors

Constructor	Description
AbstractMutationCoordinator(EntityPersister entityPersister, SessionFactoryImplementor factory)

Method Summary

Modifier and Type	Method	Description
protected static void	applyKeyRestriction(Object rowId, EntityPersister entityPersister, RestrictedTableMutationBuilder<?,?> tableMutationBuilder, EntityTableMapping tableMapping)
protected void	bindPartitionColumnValueBindings(Object[] loadedState, SharedSessionContractImplementor session, JdbcValueBindings jdbcValueBindings)
protected void	breakDownKeyJdbcValues(Object id, Object rowId, SharedSessionContractImplementor session, JdbcValueBindings jdbcValueBindings, EntityTableMapping tableMapping)
protected MutationOperation	createOperation(ValuesAnalysis valuesAnalysis, TableMutation<?> singleTableMutation)
protected MutationOperationGroup	createOperationGroup(ValuesAnalysis valuesAnalysis, MutationGroup mutationGroup)
protected Dialect	dialect()
protected EntityPersister	entityPersister()
protected SessionFactoryImplementor	factory()
protected abstract BatchKey	getBatchKey()
protected void	handleValueGeneration(AttributeMapping attributeMapping, MutationGroupBuilder mutationGroupBuilder, OnExecutionGenerator generator)
protected static boolean	needsRowId(EntityPersister entityPersister, EntityTableMapping tableMapping)
protected BatchKeyAccess	resolveBatchKeyAccess(boolean dynamicUpdate, SharedSessionContractImplementor session)

Methods inherited from class java.lang.Object

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

Field Details

entityPersister

protected final EntityPersister entityPersister

factory

protected final SessionFactoryImplementor factory

mutationExecutorService

protected final MutationExecutorService mutationExecutorService

dialect

protected final Dialect dialect

Constructor Details

AbstractMutationCoordinator

public AbstractMutationCoordinator(EntityPersister entityPersister,
 SessionFactoryImplementor factory)

Method Details

entityPersister

protected EntityPersister entityPersister()

factory

protected SessionFactoryImplementor factory()

dialect

protected Dialect dialect()

resolveBatchKeyAccess

protected BatchKeyAccess resolveBatchKeyAccess(boolean dynamicUpdate,
 SharedSessionContractImplementor session)

getBatchKey

protected abstract BatchKey getBatchKey()

createOperationGroup

protected MutationOperationGroup createOperationGroup(ValuesAnalysis valuesAnalysis,
 MutationGroup mutationGroup)

createOperation

protected MutationOperation createOperation(ValuesAnalysis valuesAnalysis,
 TableMutation<?> singleTableMutation)

handleValueGeneration

protected void handleValueGeneration(AttributeMapping attributeMapping,
 MutationGroupBuilder mutationGroupBuilder,
 OnExecutionGenerator generator)

bindPartitionColumnValueBindings

protected void bindPartitionColumnValueBindings(Object[] loadedState,
 SharedSessionContractImplementor session,
 JdbcValueBindings jdbcValueBindings)

needsRowId

protected static boolean needsRowId(EntityPersister entityPersister,
 EntityTableMapping tableMapping)

applyKeyRestriction

protected static void applyKeyRestriction(Object rowId,
 EntityPersister entityPersister,
 RestrictedTableMutationBuilder<?,?> tableMutationBuilder,
 EntityTableMapping tableMapping)

breakDownKeyJdbcValues

protected void breakDownKeyJdbcValues(Object id,
 Object rowId,
 SharedSessionContractImplementor session,
 JdbcValueBindings jdbcValueBindings,
 EntityTableMapping tableMapping)