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

Class CteInsertHandler

java.lang.Object

org.hibernate.query.sqm.mutation.internal.cte.CteInsertHandler

All Implemented Interfaces:

Handler, InsertHandler

public class CteInsertHandler
extends Object
implements InsertHandler

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CTE_TABLE_IDENTIFIER
static final String	DML_RESULT_TABLE_NAME_PREFIX
static final String	ROW_NUMBERS_WITH_SEQUENCE_VALUE

Constructor Summary

Constructors

Constructor	Description
CteInsertHandler(CteTable cteTable, SqmInsertStatement<?> sqmStatement, DomainParameterXref domainParameterXref, SessionFactoryImplementor sessionFactory)

Method Summary

Modifier and Type	Method	Description
protected String	addDmlCtes(CteContainer statement, CteStatement queryCte, List<Map.Entry<List<CteColumn>,Assignment>> assignments, boolean assignsId, MultiTableSqmMutationConverter sqmConverter, SessionFactoryImplementor factory)
protected Expression	createCountStar(SessionFactoryImplementor factory, MultiTableSqmMutationConverter sqmConverter)
static CteTable	createCteTable(CteTable sqmCteTable, List<CteColumn> sqmCteColumns)
int	execute(DomainQueryExecutionContext executionContext)	Execute the multi-table update or delete indicated by the SQM AST passed in when this Handler was created.
CteTable	getCteTable()
protected String	getCteTableName(String tableExpression)
protected String	getCteTableName(String tableExpression, String subPrefix)
DomainParameterXref	getDomainParameterXref()
EntityMappingType	getEntityDescriptor()
SqmInsertStatement<?>	getSqmStatement()
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

Field Details

DML_RESULT_TABLE_NAME_PREFIX

public static final String DML_RESULT_TABLE_NAME_PREFIX

See Also:

• Constant Field Values

CTE_TABLE_IDENTIFIER

public static final String CTE_TABLE_IDENTIFIER

See Also:

• Constant Field Values

ROW_NUMBERS_WITH_SEQUENCE_VALUE

public static final String ROW_NUMBERS_WITH_SEQUENCE_VALUE

See Also:

• Constant Field Values

Constructor Details

CteInsertHandler

public CteInsertHandler(CteTable cteTable,
 SqmInsertStatement<?> sqmStatement,
 DomainParameterXref domainParameterXref,
 SessionFactoryImplementor sessionFactory)

Method Details

createCteTable

public static CteTable createCteTable(CteTable sqmCteTable,
 List<CteColumn> sqmCteColumns)

getSqmStatement

public SqmInsertStatement<?> getSqmStatement()

getEntityDescriptor

public EntityMappingType getEntityDescriptor()

getCteTable

public CteTable getCteTable()

getDomainParameterXref

public DomainParameterXref getDomainParameterXref()

execute

public int execute(DomainQueryExecutionContext executionContext)

Description copied from interface: Handler

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

Specified by:

execute in interface Handler

Parameters:

executionContext - Contextual information needed for execution

Returns:

The "number of rows affected" count

createCountStar

protected Expression createCountStar(SessionFactoryImplementor factory,
 MultiTableSqmMutationConverter sqmConverter)

addDmlCtes

protected String addDmlCtes(CteContainer statement,
 CteStatement queryCte,
 List<Map.Entry<List<CteColumn>,Assignment>> assignments,
 boolean assignsId,
 MultiTableSqmMutationConverter sqmConverter,
 SessionFactoryImplementor factory)

resolveUnionTableReference

protected NamedTableReference resolveUnionTableReference(TableReference tableReference,
 String tableExpression)

getCteTableName

protected String getCteTableName(String tableExpression)

getCteTableName

protected String getCteTableName(String tableExpression,
 String subPrefix)