|
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