|
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