|
28 | 28 | import org.hibernate.sql.model.ast.builder.MutationGroupBuilder; |
29 | 29 | import org.hibernate.sql.model.ast.builder.RestrictedTableMutationBuilder; |
30 | 30 | import org.hibernate.sql.model.internal.MutationOperationGroupFactory; |
| 31 | +import org.hibernate.sql.model.internal.OptionalTableUpdate; |
| 32 | +import org.hibernate.sql.model.jdbc.OptionalTableUpdateOperation; |
31 | 33 |
|
32 | 34 | /** |
33 | 35 | * Base support for coordinating mutations against an entity |
@@ -82,8 +84,7 @@ protected MutationOperationGroup createOperationGroup(ValuesAnalysis valuesAnaly |
82 | 84 | case 0: |
83 | 85 | return MutationOperationGroupFactory.noOperations( mutationGroup ); |
84 | 86 | case 1: { |
85 | | - final MutationOperation operation = mutationGroup.getSingleTableMutation() |
86 | | - .createMutationOperation( valuesAnalysis, factory() ); |
| 87 | + final MutationOperation operation = createOperation( valuesAnalysis, mutationGroup.getSingleTableMutation() ); |
87 | 88 | return operation == null |
88 | 89 | ? MutationOperationGroupFactory.noOperations( mutationGroup ) |
89 | 90 | : MutationOperationGroupFactory.singleOperation( mutationGroup, operation ); |
@@ -116,6 +117,13 @@ protected MutationOperationGroup createOperationGroup(ValuesAnalysis valuesAnaly |
116 | 117 | } |
117 | 118 | } |
118 | 119 |
|
| 120 | + /* |
| 121 | + * Used by Hibernate Reactive |
| 122 | + */ |
| 123 | + protected MutationOperation createOperation(ValuesAnalysis valuesAnalysis, TableMutation<?> singleTableMutation) { |
| 124 | + return singleTableMutation.createMutationOperation( valuesAnalysis, factory() ); |
| 125 | + } |
| 126 | + |
119 | 127 | protected void handleValueGeneration( |
120 | 128 | AttributeMapping attributeMapping, |
121 | 129 | MutationGroupBuilder mutationGroupBuilder, |
|
0 commit comments