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 String	CTE_TABLE_IDENTIFIER
static String	DML_RESULT_TABLE_NAME_PREFIX
static 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, Map<SqmParameter<?>,List<List<JdbcParameter>>> parameterResolutions, SessionFactoryImplementor factory)
protected Expression	createCountStar(SessionFactoryImplementor factory, MultiTableSqmMutationConverter sqmConverter)
static CteTable	createCteTable(CteTable sqmCteTable, List<CteColumn> sqmCteColumns, SessionFactoryImplementor factory)
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()
SessionFactoryImplementor	getSessionFactory()
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 Detail

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 Detail

CteInsertHandler

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

Method Detail

createCteTable

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

getSqmStatement

public SqmInsertStatement<?> getSqmStatement()

getEntityDescriptor

public EntityMappingType getEntityDescriptor()

getCteTable

public CteTable getCteTable()

getSessionFactory

public SessionFactoryImplementor getSessionFactory()

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,
                            Map<SqmParameter<?>,List<List<JdbcParameter>>> parameterResolutions,
                            SessionFactoryImplementor factory)

resolveUnionTableReference

protected NamedTableReference resolveUnionTableReference(TableReference tableReference,
                                                         String tableExpression)

getCteTableName

protected String getCteTableName(String tableExpression)

getCteTableName

protected String getCteTableName(String tableExpression,
                                 String subPrefix)