Skip to content

Commit c22a8f3

Browse files
SanneDavideD
authored andcommitted
ReactiveMutationExecutorPostInsert needs to implement ReactiveMutationExecutor
1 parent 2710143 commit c22a8f3

File tree

1 file changed

+14
-2
lines changed

1 file changed

+14
-2
lines changed

hibernate-reactive-core/src/main/java/org/hibernate/reactive/engine/jdbc/mutation/internal/ReactiveMutationExecutorPostInsert.java

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,16 +5,28 @@
55
*/
66
package org.hibernate.reactive.engine.jdbc.mutation.internal;
77

8-
import org.hibernate.engine.jdbc.mutation.MutationExecutor;
8+
import org.hibernate.engine.jdbc.mutation.OperationResultChecker;
9+
import org.hibernate.engine.jdbc.mutation.TableInclusionChecker;
910
import org.hibernate.engine.jdbc.mutation.internal.MutationExecutorPostInsert;
1011
import org.hibernate.engine.spi.SharedSessionContractImplementor;
12+
import org.hibernate.reactive.engine.jdbc.env.internal.ReactiveMutationExecutor;
1113
import org.hibernate.sql.model.MutationOperationGroup;
14+
import org.hibernate.sql.model.ValuesAnalysis;
1215

13-
public class ReactiveMutationExecutorPostInsert extends MutationExecutorPostInsert implements MutationExecutor {
16+
public class ReactiveMutationExecutorPostInsert extends MutationExecutorPostInsert implements ReactiveMutationExecutor {
1417

1518
public ReactiveMutationExecutorPostInsert(
1619
MutationOperationGroup mutationOperationGroup,
1720
SharedSessionContractImplementor session) {
1821
super( mutationOperationGroup, session );
1922
}
23+
24+
public Object execute(
25+
Object modelReference,
26+
ValuesAnalysis valuesAnalysis,
27+
TableInclusionChecker inclusionChecker,
28+
OperationResultChecker resultChecker,
29+
SharedSessionContractImplementor session) {
30+
throw LOG.nonReactiveMethodCall( "executeReactive" );
31+
}
2032
}

0 commit comments

Comments
 (0)