@@ -44,7 +44,6 @@ public class DeleteOrUpsertOperation implements SelfExecutingUpdateOperation {
44
44
45
45
private final OptionalTableUpdate optionalTableUpdate ;
46
46
47
-
48
47
public DeleteOrUpsertOperation (
49
48
EntityMutationTarget mutationTarget ,
50
49
EntityTableMapping tableMapping ,
@@ -56,6 +55,16 @@ public DeleteOrUpsertOperation(
56
55
this .optionalTableUpdate = optionalTableUpdate ;
57
56
}
58
57
58
+ /*
59
+ * Used by Hibernate Reactive
60
+ */
61
+ protected DeleteOrUpsertOperation (DeleteOrUpsertOperation original ) {
62
+ this .mutationTarget = original .mutationTarget ;
63
+ this .tableMapping = original .tableMapping ;
64
+ this .upsertOperation = original .upsertOperation ;
65
+ this .optionalTableUpdate = original .optionalTableUpdate ;
66
+ }
67
+
59
68
@ Override
60
69
public MutationType getMutationType () {
61
70
return MutationType .UPDATE ;
@@ -197,4 +206,18 @@ private void performUpsert(JdbcValueBindings jdbcValueBindings, SharedSessionCon
197
206
198
207
MODEL_MUTATION_LOGGER .tracef ( "`%s` rows upserted into `%s`" , rowCount , tableMapping .getTableName () );
199
208
}
209
+
210
+ /*
211
+ * Used by Hibernate Reactive
212
+ */
213
+ public UpsertOperation getUpsertOperation () {
214
+ return upsertOperation ;
215
+ }
216
+
217
+ /*
218
+ * Used by Hibernate Reactive
219
+ */
220
+ public OptionalTableUpdate getOptionalTableUpdate () {
221
+ return optionalTableUpdate ;
222
+ }
200
223
}
0 commit comments