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

HHH-18854 Allow HR to change DeleteOrUpsertOperation

This commit is contained in:
Davide D'Alto 2024-11-20 14:03:26 +01:00
parent 25790c26df
commit 5b3e06e534
No known key found for this signature in database
GPG Key ID: 163581B9C6E9FC17
1 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
hibernate-core/src/main/java/org/hibernate/sql/model/jdbc/DeleteOrUpsertOperation.java
View File

@ -44,7 +44,6 @@ public class DeleteOrUpsertOperation implements SelfExecutingUpdateOperation {
private final OptionalTableUpdate optionalTableUpdate; private final OptionalTableUpdate optionalTableUpdate;
public DeleteOrUpsertOperation( public DeleteOrUpsertOperation(
EntityMutationTarget mutationTarget, EntityMutationTarget mutationTarget,
EntityTableMapping tableMapping, EntityTableMapping tableMapping,
@ -56,6 +55,16 @@ public class DeleteOrUpsertOperation implements SelfExecutingUpdateOperation {
this.optionalTableUpdate = optionalTableUpdate; this.optionalTableUpdate = optionalTableUpdate;
} }
/*
* Used by Hibernate Reactive
*/
protected DeleteOrUpsertOperation(DeleteOrUpsertOperation original) {
this.mutationTarget = original.mutationTarget;
this.tableMapping = original.tableMapping;
this.upsertOperation = original.upsertOperation;
this.optionalTableUpdate = original.optionalTableUpdate;
}
@Override @Override
public MutationType getMutationType() { public MutationType getMutationType() {
return MutationType.UPDATE; return MutationType.UPDATE;
@ -197,4 +206,18 @@ public class DeleteOrUpsertOperation implements SelfExecutingUpdateOperation {
MODEL_MUTATION_LOGGER.tracef( "`%s` rows upserted into `%s`", rowCount, tableMapping.getTableName() ); MODEL_MUTATION_LOGGER.tracef( "`%s` rows upserted into `%s`", rowCount, tableMapping.getTableName() );
} }
/*
* Used by Hibernate Reactive
*/
public UpsertOperation getUpsertOperation() {
return upsertOperation;
}
/*
* Used by Hibernate Reactive
*/
public OptionalTableUpdate getOptionalTableUpdate() {
return optionalTableUpdate;
}
} }