Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

HHH-16138 Fix update statement join emulation for old DB2 versions

This commit is contained in:
Christian Beikov 2023-12-22 11:54:44 +01:00
parent 836263eb9a
commit 53dbc959e1
3 changed files with 117 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
hibernate-community-dialects/src/main/java/org/hibernate/community/dialect/DB2LegacySqlAstTranslator.java
View File

@ -339,12 +339,27 @@ public class DB2LegacySqlAstTranslator<T extends JdbcOperation> extends Abstract
@Override
protected void visitUpdateStatementOnly(UpdateStatement statement) {
final boolean closeWrapper = renderReturningClause( statement );
super.visitUpdateStatementOnly( statement );
if ( supportsFromClauseInUpdate() || !hasNonTrivialFromClause( statement.getFromClause() ) ) {
super.visitUpdateStatementOnly( statement );
}
else {
if ( closeWrapper ) {
// Merge statements can't be used in the `from final table( ... )` syntax
visitUpdateStatementEmulateTupleSet( statement );
}
else {
visitUpdateStatementEmulateMerge( statement );
}
}
if ( closeWrapper ) {
appendSql( ')' );
}
}
protected boolean supportsFromClauseInUpdate() {
return getDB2Version().isSameOrAfter( 11 );
}
@Override
protected void visitInsertStatementOnly(InsertSelectStatement statement) {
final boolean closeWrapper = renderReturningClause( statement );

17
hibernate-core/src/main/java/org/hibernate/dialect/DB2SqlAstTranslator.java
View File

@ -342,12 +342,27 @@ public class DB2SqlAstTranslator<T extends JdbcOperation> extends AbstractSqlAst
@Override
protected void visitUpdateStatementOnly(UpdateStatement statement) {
final boolean closeWrapper = renderReturningClause( statement );
super.visitUpdateStatementOnly( statement );
if ( supportsFromClauseInUpdate() || !hasNonTrivialFromClause( statement.getFromClause() ) ) {
super.visitUpdateStatementOnly( statement );
}
else {
if ( closeWrapper ) {
// Merge statements can't be used in the `from final table( ... )` syntax
visitUpdateStatementEmulateTupleSet( statement );
}
else {
visitUpdateStatementEmulateMerge( statement );
}
}
if ( closeWrapper ) {
appendSql( ')' );
}
}
protected boolean supportsFromClauseInUpdate() {
return getDB2Version().isSameOrAfter( 11 );
}
@Override
protected void visitInsertStatementOnly(InsertSelectStatement statement) {
final boolean closeWrapper = renderReturningClause( statement );

115
hibernate-core/src/main/java/org/hibernate/sql/ast/spi/AbstractSqlAstTranslator.java
View File

@ -1421,7 +1421,7 @@ public abstract class AbstractSqlAstTranslator<T extends JdbcOperation> implemen
appendSql( " as t" );
clauseStack.pop();
final QueryPartTableReference inlineView = updateSourceAsSubquery( statement );
final QueryPartTableReference inlineView = updateSourceAsSubquery( statement, false );
appendSql( " using " );
clauseStack.push( Clause.FROM );
visitQueryPartTableReference( inlineView );
@ -1456,8 +1456,8 @@ public abstract class AbstractSqlAstTranslator<T extends JdbcOperation> implemen
visitReturningColumns( statement.getReturningColumns() );
}
private QueryPartTableReference updateSourceAsSubquery(UpdateStatement statement) {
final QuerySpec inlineView = new QuerySpec( true );
private QueryPartTableReference updateSourceAsSubquery(UpdateStatement statement, boolean correlated) {
final QuerySpec inlineView = new QuerySpec( !correlated );
final SelectClause selectClause = inlineView.getSelectClause();
final List<Assignment> assignments = statement.getAssignments();
final List<String> columnNames = new ArrayList<>( assignments.size() );
@ -1479,36 +1479,67 @@ public abstract class AbstractSqlAstTranslator<T extends JdbcOperation> implemen
throw new IllegalQueryOperationException( "Unsupported tuple assignment in update query with joins." );
}
}
final String rowIdExpression = dialect.rowId( null );
if ( rowIdExpression == null ) {
final TableGroup dmlTargetTableGroup = statement.getFromClause().getRoots().get( 0 );
assert dmlTargetTableGroup.getPrimaryTableReference() == statement.getTargetTable();
final EntityIdentifierMapping identifierMapping = dmlTargetTableGroup.getModelPart()
.asEntityMappingType()
.getIdentifierMapping();
identifierMapping.forEachSelectable(
0,
(selectionIndex, selectableMapping) -> {
selectClause.addSqlSelection( new SqlSelectionImpl(
new ColumnReference( statement.getTargetTable(), selectableMapping )
) );
columnNames.add( selectableMapping.getSelectionExpression() );
if ( !correlated ) {
final String rowIdExpression = dialect.rowId( null );
if ( rowIdExpression == null ) {
final TableGroup dmlTargetTableGroup = statement.getFromClause().getRoots().get( 0 );
assert dmlTargetTableGroup.getPrimaryTableReference() == statement.getTargetTable();
final EntityIdentifierMapping identifierMapping = dmlTargetTableGroup.getModelPart()
.asEntityMappingType()
.getIdentifierMapping();
identifierMapping.forEachSelectable(
0,
(selectionIndex, selectableMapping) -> {
selectClause.addSqlSelection( new SqlSelectionImpl(
new ColumnReference( statement.getTargetTable(), selectableMapping )
) );
columnNames.add( selectableMapping.getSelectionExpression() );
}
);
}
else {
selectClause.addSqlSelection( new SqlSelectionImpl(
new ColumnReference(
statement.getTargetTable(),
rowIdExpression,
sessionFactory.getTypeConfiguration().getBasicTypeRegistry()
.resolve( Object.class, dialect.rowIdSqlType() )
)
) );
columnNames.add( "c" + columnNames.size() );
}
}
if ( correlated ) {
for ( TableGroup root : statement.getFromClause().getRoots() ) {
if ( statement.getTargetTable() == root.getPrimaryTableReference() ) {
final TableGroup dmlTargetTableGroup = new StandardTableGroup(
true,
new NavigablePath( "dual" ),
null,
null,
new NamedTableReference( getDual(), "d_" ),
null,
sessionFactory
);
inlineView.getFromClause().addRoot( dmlTargetTableGroup );
dmlTargetTableGroup.getTableReferenceJoins().addAll( root.getTableReferenceJoins() );
for ( TableGroupJoin tableGroupJoin : root.getTableGroupJoins() ) {
dmlTargetTableGroup.addTableGroupJoin( tableGroupJoin );
}
);
for ( TableGroupJoin tableGroupJoin : root.getNestedTableGroupJoins() ) {
dmlTargetTableGroup.addNestedTableGroupJoin( tableGroupJoin );
}
}
else {
inlineView.getFromClause().addRoot( root );
}
}
}
else {
selectClause.addSqlSelection( new SqlSelectionImpl(
new ColumnReference(
statement.getTargetTable(),
rowIdExpression,
sessionFactory.getTypeConfiguration().getBasicTypeRegistry()
.resolve( Object.class, dialect.rowIdSqlType() )
)
) );
columnNames.add( "c" + columnNames.size() );
}
for ( TableGroup root : statement.getFromClause().getRoots() ) {
inlineView.getFromClause().addRoot( root );
for ( TableGroup root : statement.getFromClause().getRoots() ) {
inlineView.getFromClause().addRoot( root );
}
}
inlineView.applyPredicate( statement.getRestriction() );
@ -1545,6 +1576,30 @@ public abstract class AbstractSqlAstTranslator<T extends JdbcOperation> implemen
visitReturningColumns( statement.getReturningColumns() );
}
protected void visitUpdateStatementEmulateTupleSet(UpdateStatement statement) {
renderUpdateClause( statement );
appendSql( " set " );
char separator = '(';
try {
clauseStack.push( Clause.SET );
for ( Assignment assignment : statement.getAssignments() ) {
final List<ColumnReference> columnReferences = assignment.getAssignable().getColumnReferences();
for ( ColumnReference columnReference : columnReferences ) {
appendSql( separator );
separator = COMMA_SEPARATOR_CHAR;
columnReference.appendColumnForWrite( this, null );
}
}
appendSql( ")=" );
updateSourceAsSubquery( statement, true ).getStatement().accept( this );
}
finally {
clauseStack.pop();
}
visitWhereClause( determineWhereClauseRestrictionWithJoinEmulation( statement ) );
}
private QueryPartTableReference updateSourceAsInlineView(UpdateStatement statement) {
final QuerySpec inlineView = new QuerySpec( true );
final SelectClause selectClause = inlineView.getSelectClause();