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

Class TableBasedUpdateHandler

java.lang.Object

org.hibernate.query.sqm.mutation.internal.AbstractMutationHandler

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

All Implemented Interfaces:

Handler, UpdateHandler, MultiTableHandler

public class TableBasedUpdateHandler
extends AbstractMutationHandler
implements UpdateHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	TableBasedUpdateHandler.TableUpdater

Constructor Summary

Constructors

Constructor	Description
TableBasedUpdateHandler(SqmUpdateStatement<?> sqmUpdate, DomainParameterXref domainParameterXref, TemporaryTable idTable, TemporaryTableStrategy temporaryTableStrategy, boolean forceDropAfterUse, Function<SharedSessionContractImplementor,String> sessionUidAccess, DomainQueryExecutionContext context, MutableObject<JdbcParameterBindings> firstJdbcParameterBindingsConsumer)

Method Summary

Modifier and Type	Method	Description
protected Expression	asExpression(SelectClause selectClause)
protected void	collectTableReference(TableReferenceJoin tableReferenceJoin, BiConsumer<String,TableReference> consumer)
protected void	collectTableReference(TableReference tableReference, BiConsumer<String,TableReference> consumer)
protected QuerySpec	createExistsSubQuerySpec(String targetTableExpression, Supplier<Consumer<SelectableConsumer>> tableKeyColumnVisitationSupplier, QuerySpec idTableSubQuery, SessionFactoryImplementor sessionFactory)
JdbcParameterBindings	createJdbcParameterBindings(DomainQueryExecutionContext context)	Create the JdbcParameterBindings for this multi-table handler based on the execution context.
boolean	dependsOnParameterBindings()	Signals that the SQL depends on the parameter bindings e.g.
int	execute(JdbcParameterBindings jdbcParameterBindings, DomainQueryExecutionContext context)	Execute the multi-table update or delete indicated by the SQM AST passed in when this Handler was created.
protected AfterUseAction	getAfterUseAction()
protected TemporaryTable	getIdTable()
protected CacheableSqmInterpretation<InsertSelectStatement,JdbcOperationQueryMutation>	getMatchingIdsIntoIdTableInsert()
protected Function<SharedSessionContractImplementor,String>	getSessionUidAccess()
protected @Nullable JdbcParameter	getSessionUidParameter()
protected List<TableBasedUpdateHandler.TableUpdater>	getTableUpdaters()
protected TemporaryTableStrategy	getTemporaryTableStrategy()
boolean	isCompatibleWith(JdbcParameterBindings jdbcParameterBindings, QueryOptions queryOptions)
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 org.hibernate.query.sqm.mutation.internal.AbstractMutationHandler

getEntityDescriptor, getSessionFactory, getSqmStatement

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hibernate.query.sqm.mutation.internal.Handler

execute

Constructor Details

TableBasedUpdateHandler

public TableBasedUpdateHandler(SqmUpdateStatement<?> sqmUpdate,
 DomainParameterXref domainParameterXref,
 TemporaryTable idTable,
 TemporaryTableStrategy temporaryTableStrategy,
 boolean forceDropAfterUse,
 Function<SharedSessionContractImplementor,String> sessionUidAccess,
 DomainQueryExecutionContext context,
 MutableObject<JdbcParameterBindings> firstJdbcParameterBindingsConsumer)

Method Details

createJdbcParameterBindings

public JdbcParameterBindings createJdbcParameterBindings(DomainQueryExecutionContext context)

Description copied from interface: MultiTableHandler

Create the JdbcParameterBindings for this multi-table handler based on the execution context.

Specified by:

createJdbcParameterBindings in interface MultiTableHandler

Parameters:

context - Contextual information needed for execution

Returns:

The built parameter bindings

dependsOnParameterBindings

public boolean dependsOnParameterBindings()

Description copied from interface: MultiTableHandler

Signals that the SQL depends on the parameter bindings e.g. due to the need for inlining of parameter values or multiValued parameters.

Specified by:

dependsOnParameterBindings in interface Handler

Specified by:

dependsOnParameterBindings in interface MultiTableHandler

isCompatibleWith

public boolean isCompatibleWith(JdbcParameterBindings jdbcParameterBindings,
 QueryOptions queryOptions)

Specified by:

isCompatibleWith in interface Handler

Specified by:

isCompatibleWith in interface MultiTableHandler

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,
 SessionFactoryImplementor sessionFactory)

makeInsertSourceSelectQuerySpec

protected static QuerySpec makeInsertSourceSelectQuerySpec(QuerySpec idTableSubQuery)

resolveMutatingTableKeyExpression

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

asExpression

protected Expression asExpression(SelectClause selectClause)

collectTableReference

protected void collectTableReference(TableReference tableReference,
 BiConsumer<String,TableReference> consumer)

collectTableReference

protected void collectTableReference(TableReferenceJoin tableReferenceJoin,
 BiConsumer<String,TableReference> consumer)

execute

public int execute(JdbcParameterBindings jdbcParameterBindings,
 DomainQueryExecutionContext context)

Description copied from interface: MultiTableHandler

Execute the multi-table update or delete indicated by the SQM AST passed in when this Handler was created.

Specified by:

execute in interface MultiTableHandler

Parameters:

jdbcParameterBindings - The parameter bindings for JDBC parameters

context - Contextual information needed for execution

Returns:

The "number of rows affected" count

getTableUpdaters

protected List<TableBasedUpdateHandler.TableUpdater> getTableUpdaters()

getAfterUseAction

protected AfterUseAction getAfterUseAction()

getIdTable

protected TemporaryTable getIdTable()

getTemporaryTableStrategy

protected TemporaryTableStrategy getTemporaryTableStrategy()

getMatchingIdsIntoIdTableInsert

protected CacheableSqmInterpretation<InsertSelectStatement,JdbcOperationQueryMutation> getMatchingIdsIntoIdTableInsert()

getSessionUidAccess

protected Function<SharedSessionContractImplementor,String> getSessionUidAccess()

getSessionUidParameter

protected @Nullable JdbcParameter getSessionUidParameter()