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

Fix test failure by respecting custom insert/delete SQL for secondary tables

This commit is contained in:
Christian Beikov 2023-01-25 09:32:16 +01:00
parent 0bb04b1021
commit a0d162cde8
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
hibernate-core/src/main/java/org/hibernate/sql/model/internal/TableUpsert.java
View File

@ -25,6 +25,7 @@ import org.hibernate.sql.model.ast.ColumnValueParameter;
import org.hibernate.sql.model.ast.MutatingTableReference; import org.hibernate.sql.model.ast.MutatingTableReference;
import org.hibernate.sql.model.ast.RestrictedTableMutation; import org.hibernate.sql.model.ast.RestrictedTableMutation;
import org.hibernate.sql.model.ast.TableUpdate; import org.hibernate.sql.model.ast.TableUpdate;
import org.hibernate.sql.model.jdbc.OptionalTableUpdateOperation;
import static org.hibernate.sql.model.ast.AbstractTableUpdate.collectParameters; import static org.hibernate.sql.model.ast.AbstractTableUpdate.collectParameters;
@ -123,9 +124,13 @@ public class TableUpsert
throw new UnsupportedOperationException(); throw new UnsupportedOperationException();
} }
public MutationOperation createMutationOperation( @Override
ValuesAnalysis valuesAnalysis, public MutationOperation createMutationOperation(ValuesAnalysis valuesAnalysis, SessionFactoryImplementor factory) {
SessionFactoryImplementor factory) { if ( getMutatingTable().getTableMapping().getInsertDetails().getCustomSql() != null
|| getMutatingTable().getTableMapping().getDeleteDetails().getCustomSql() != null ) {
// Fallback to the optional table mutation operation because we have to execute user specified SQL
return new OptionalTableUpdateOperation( getMutationTarget(), this, factory );
}
return factory.getJdbcServices().getDialect().createUpsertOperation( return factory.getJdbcServices().getDialect().createUpsertOperation(
getMutationTarget(), getMutationTarget(),
this, this,