|
5 | 5 | */
|
6 | 6 | package org.hibernate.reactive.session.impl;
|
7 | 7 |
|
8 |
| -import java.util.List; |
9 |
| -import java.util.concurrent.CompletableFuture; |
10 |
| -import java.util.concurrent.CompletionStage; |
11 |
| -import java.util.function.Supplier; |
12 |
| - |
13 | 8 | import org.hibernate.HibernateException;
|
14 | 9 | import org.hibernate.LockMode;
|
15 | 10 | import org.hibernate.LockOptions;
|
|
28 | 23 | import org.hibernate.engine.spi.PersistentAttributeInterceptable;
|
29 | 24 | import org.hibernate.engine.spi.PersistentAttributeInterceptor;
|
30 | 25 | import org.hibernate.engine.spi.SharedSessionContractImplementor;
|
31 |
| -import org.hibernate.event.spi.PostInsertEvent; |
32 |
| -import org.hibernate.event.spi.PostInsertEventListener; |
33 |
| -import org.hibernate.event.spi.PreInsertEvent; |
34 |
| -import org.hibernate.event.spi.PreInsertEventListener; |
35 | 26 | import org.hibernate.generator.BeforeExecutionGenerator;
|
36 | 27 | import org.hibernate.generator.Generator;
|
37 | 28 | import org.hibernate.graph.GraphSemantic;
|
|
89 | 80 | import jakarta.persistence.criteria.CriteriaDelete;
|
90 | 81 | import jakarta.persistence.criteria.CriteriaQuery;
|
91 | 82 | import jakarta.persistence.criteria.CriteriaUpdate;
|
| 83 | +import java.util.List; |
| 84 | +import java.util.concurrent.CompletableFuture; |
| 85 | +import java.util.concurrent.CompletionStage; |
| 86 | +import java.util.function.Supplier; |
92 | 87 |
|
93 | 88 | import static java.lang.Boolean.TRUE;
|
94 | 89 | import static java.lang.invoke.MethodHandles.lookup;
|
@@ -340,29 +335,6 @@ private CompletionStage<Void> reactiveInsert(Object entity, ReactiveEntityPersis
|
340 | 335 | }
|
341 | 336 | }
|
342 | 337 |
|
343 |
| - private boolean firePreInsert(Object entity, Object id, Object[] state, EntityPersister persister) { |
344 |
| - if ( getFactory().getEventListenerGroups().eventListenerGroup_PRE_INSERT.isEmpty() ) { |
345 |
| - return false; |
346 |
| - } |
347 |
| - else { |
348 |
| - boolean veto = false; |
349 |
| - final PreInsertEvent event = new PreInsertEvent( entity, id, state, persister, null ); |
350 |
| - for ( PreInsertEventListener listener : getFactory().getEventListenerGroups().eventListenerGroup_PRE_INSERT.listeners() ) { |
351 |
| - veto |= listener.onPreInsert( event ); |
352 |
| - } |
353 |
| - return veto; |
354 |
| - } |
355 |
| - } |
356 |
| - |
357 |
| - private void firePostInsert(Object entity, Object id, Object[] state, EntityPersister persister) { |
358 |
| - if ( !getFactory().getEventListenerGroups().eventListenerGroup_POST_INSERT.isEmpty() ) { |
359 |
| - final PostInsertEvent event = new PostInsertEvent( entity, id, state, persister, null ); |
360 |
| - for ( PostInsertEventListener listener : getFactory().getEventListenerGroups().eventListenerGroup_POST_INSERT.listeners() ) { |
361 |
| - listener.onPostInsert( event ); |
362 |
| - } |
363 |
| - } |
364 |
| - } |
365 |
| - |
366 | 338 | private CompletionStage<?> generateId(EntityPersister persister, Object entity, Generator generator) {
|
367 | 339 | if ( generator.generatesOnInsert() ) {
|
368 | 340 | if ( generator instanceof ReactiveIdentifierGenerator<?> reactiveGenerator ) {
|
|
0 commit comments