Package org.hibernate.query.sqm.mutation.internal.temptable

Class UpdateExecutionDelegate

java.lang.Object

org.hibernate.query.sqm.mutation.internal.temptable.UpdateExecutionDelegate

All Implemented Interfaces:

TableBasedUpdateHandler.ExecutionDelegate

public class UpdateExecutionDelegate
extends Object
implements TableBasedUpdateHandler.ExecutionDelegate

Constructor Summary

Constructors

Constructor

Description

UpdateExecutionDelegate(MultiTableSqmMutationConverter sqmConverter, TemporaryTable idTable, AfterUseAction afterUseAction, Function<SharedSessionContractImplementor,String> sessionUidAccess, DomainParameterXref domainParameterXref, TableGroup updatingTableGroup, Map<String,TableReference> tableReferenceByAlias, List<Assignment> assignments, Predicate suppliedPredicate, Map<SqmParameter<?>,List<List<JdbcParameter>>> parameterResolutions, Map<SqmParameter<?>,MappingModelExpressible<?>> paramTypeResolutions, DomainQueryExecutionContext executionContext)

Method Summary

Modifier and Type	Method	Description
protected Expression	asExpression(SelectClause selectClause)
protected QuerySpec	createExistsSubQuerySpec(String targetTableExpression, Supplier<Consumer<SelectableConsumer>> tableKeyColumnVisitationSupplier, QuerySpec idTableSubQuery)
int	execute(ExecutionContext executionContext)
protected AfterUseAction	getAfterUseAction()
protected Map<TableReference,List<Assignment>>	getAssignmentsByTable()
protected EntityMappingType	getEntityDescriptor()
protected TemporaryTable	getIdTable()	For Hibernate Reactive
protected JdbcParameterBindings	getJdbcParameterBindings()
protected SessionFactoryImplementor	getSessionFactory()
protected Function<SharedSessionContractImplementor,String>	getSessionUidAccess()
protected MultiTableSqmMutationConverter	getSqmConverter()
protected Predicate	getSuppliedPredicate()
protected TableGroup	getUpdatingTableGroup()
protected boolean	isTableOptional(String tableExpression)
protected static QuerySpec	makeInsertSourceSelectQuerySpec(QuerySpec idTableSubQuery)
protected Expression	resolveMutatingTableKeyExpression(String tableExpression, Supplier<Consumer<SelectableConsumer>> tableKeyColumnVisitationSupplier)
protected TableReference	resolveTableReference(ColumnReference columnReference, Map<String,TableReference> tableReferenceByAlias)
protected NamedTableReference	resolveUnionTableReference(TableReference tableReference, String tableExpression)

Methods inherited from class java.lang.Object

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

Constructor Detail

UpdateExecutionDelegate

public UpdateExecutionDelegate(MultiTableSqmMutationConverter sqmConverter,
                               TemporaryTable idTable,
                               AfterUseAction afterUseAction,
                               Function<SharedSessionContractImplementor,String> sessionUidAccess,
                               DomainParameterXref domainParameterXref,
                               TableGroup updatingTableGroup,
                               Map<String,TableReference> tableReferenceByAlias,
                               List<Assignment> assignments,
                               Predicate suppliedPredicate,
                               Map<SqmParameter<?>,List<List<JdbcParameter>>> parameterResolutions,
                               Map<SqmParameter<?>,MappingModelExpressible<?>> paramTypeResolutions,
                               DomainQueryExecutionContext executionContext)

Method Detail

execute

public int execute(ExecutionContext executionContext)

Specified by:

execute in interface TableBasedUpdateHandler.ExecutionDelegate

resolveTableReference

protected TableReference resolveTableReference(ColumnReference columnReference,
                                               Map<String,TableReference> tableReferenceByAlias)

resolveUnionTableReference

protected NamedTableReference resolveUnionTableReference(TableReference tableReference,
                                                         String tableExpression)

isTableOptional

protected boolean isTableOptional(String tableExpression)

createExistsSubQuerySpec

protected QuerySpec createExistsSubQuerySpec(String targetTableExpression,
                                             Supplier<Consumer<SelectableConsumer>> tableKeyColumnVisitationSupplier,
                                             QuerySpec idTableSubQuery)

makeInsertSourceSelectQuerySpec

protected static QuerySpec makeInsertSourceSelectQuerySpec(QuerySpec idTableSubQuery)

resolveMutatingTableKeyExpression

protected Expression resolveMutatingTableKeyExpression(String tableExpression,
                                                       Supplier<Consumer<SelectableConsumer>> tableKeyColumnVisitationSupplier)

asExpression

protected Expression asExpression(SelectClause selectClause)

getIdTable

protected TemporaryTable getIdTable()

For Hibernate Reactive

getSuppliedPredicate

protected Predicate getSuppliedPredicate()

getSqmConverter

protected MultiTableSqmMutationConverter getSqmConverter()

getSessionUidAccess

protected Function<SharedSessionContractImplementor,String> getSessionUidAccess()

getJdbcParameterBindings

protected JdbcParameterBindings getJdbcParameterBindings()

getEntityDescriptor

protected EntityMappingType getEntityDescriptor()

getAfterUseAction

protected AfterUseAction getAfterUseAction()

getUpdatingTableGroup

protected TableGroup getUpdatingTableGroup()

getAssignmentsByTable

protected Map<TableReference,List<Assignment>> getAssignmentsByTable()

getSessionFactory

protected SessionFactoryImplementor getSessionFactory()