Skip to content

Commit 87d0e96

Browse files
SanneDavideD
authored andcommitted
Better efficiency for cloning of ReactiveUpdateCoordinatorStandard
1 parent 25f3003 commit 87d0e96

File tree

2 files changed

+18
-9
lines changed

2 files changed

+18
-9
lines changed

hibernate-reactive-core/src/main/java/org/hibernate/reactive/persister/entity/impl/ReactiveUpdateCoordinatorStandardScopeFactory.java

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -12,22 +12,24 @@
1212
import org.hibernate.reactive.persister.entity.mutation.ReactiveUpdateCoordinator;
1313
import org.hibernate.reactive.persister.entity.mutation.ReactiveUpdateCoordinatorStandard;
1414

15-
public class ReactiveUpdateCoordinatorStandardScopeFactory extends UpdateCoordinatorStandard implements ReactiveUpdateCoordinator {
16-
17-
private final AbstractEntityPersister entityPersister;
18-
private final SessionFactoryImplementor factory;
15+
final class ReactiveUpdateCoordinatorStandardScopeFactory extends UpdateCoordinatorStandard implements ReactiveUpdateCoordinator {
1916

2017
public ReactiveUpdateCoordinatorStandardScopeFactory(
2118
AbstractEntityPersister entityPersister,
2219
SessionFactoryImplementor factory) {
2320
super( entityPersister, factory );
24-
this.entityPersister = entityPersister;
25-
this.factory = factory;
2621
}
2722

2823
@Override
2924
public ReactiveScopedUpdateCoordinator makeScopedCoordinator() {
30-
return new ReactiveUpdateCoordinatorStandard( entityPersister, factory );
25+
return new ReactiveUpdateCoordinatorStandard(
26+
entityPersister(),
27+
factory(),
28+
this.getStaticUpdateGroup(),
29+
this.getBatchKey(),
30+
this.getVersionUpdateGroup(),
31+
this.getVersionUpdateBatchkey()
32+
);
3133
}
3234

3335
}

hibernate-reactive-core/src/main/java/org/hibernate/reactive/persister/entity/mutation/ReactiveUpdateCoordinatorStandard.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@
1010

1111
import java.util.concurrent.atomic.AtomicInteger;
1212

13+
import org.hibernate.engine.jdbc.batch.spi.BatchKey;
1314
import org.hibernate.engine.jdbc.mutation.ParameterUsage;
1415
import org.hibernate.engine.jdbc.mutation.spi.MutationExecutorService;
1516
import org.hibernate.engine.spi.EntityEntry;
@@ -42,8 +43,14 @@ public class ReactiveUpdateCoordinatorStandard extends UpdateCoordinatorStandard
4243

4344
private CompletableFuture<Void> updateResultStage;
4445

45-
public ReactiveUpdateCoordinatorStandard(AbstractEntityPersister entityPersister, SessionFactoryImplementor factory) {
46-
super( entityPersister, factory );
46+
public ReactiveUpdateCoordinatorStandard(
47+
AbstractEntityPersister entityPersister,
48+
SessionFactoryImplementor factory,
49+
MutationOperationGroup staticUpdateGroup,
50+
BatchKey batchKey,
51+
MutationOperationGroup versionUpdateGroup,
52+
BatchKey versionUpdateBatchkey) {
53+
super( entityPersister, factory, staticUpdateGroup, batchKey, versionUpdateGroup, versionUpdateBatchkey );
4754
}
4855

4956
// Utility method to use method reference

0 commit comments

Comments
 (0)