Skip to content

Commit 80b119b

Browse files
committed
Clean up potential code problems
From github-code-scanning
1 parent 827b65a commit 80b119b

File tree

3 files changed

+13
-7
lines changed

3 files changed

+13
-7
lines changed

hibernate-reactive-core/src/main/java/org/hibernate/reactive/event/impl/DefaultReactiveDeleteEventListener.java

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,6 @@
2727
import org.hibernate.event.spi.DeleteEvent;
2828
import org.hibernate.event.spi.DeleteEventListener;
2929
import org.hibernate.event.spi.EventSource;
30-
import org.hibernate.internal.util.collections.IdentitySet;
3130
import org.hibernate.jpa.event.spi.CallbackRegistry;
3231
import org.hibernate.jpa.event.spi.CallbackRegistryConsumer;
3332
import org.hibernate.persister.entity.EntityPersister;
@@ -75,17 +74,17 @@ public void wasJpaBootstrap(boolean wasJpaBootstrap) {
7574
@Deprecated
7675
@Override
7776
public void onDelete(DeleteEvent event) {
78-
throw new UnsupportedOperationException("Use the reactive version instead: reactiveOnDelete(DeleteEvent)");
77+
throw LOG.nonReactiveMethodCall( "reactiveOnDelete" );
7978
}
8079

8180
/**
8281
* @deprecated only the reactive version is supported
83-
* @see #reactiveOnDelete(DeleteEvent, IdentitySet)
82+
* @see #reactiveOnDelete(DeleteEvent, DeleteContext)
8483
*/
8584
@Deprecated
8685
@Override
8786
public void onDelete(DeleteEvent event, DeleteContext transientEntities) throws HibernateException {
88-
throw new UnsupportedOperationException("Use the reactive version instead: reactiveOnDelete(DeleteEvent, DeleteContext)");
87+
throw LOG.nonReactiveMethodCall( "reactiveOnDelete" );
8988
}
9089

9190
/**
@@ -94,6 +93,7 @@ public void onDelete(DeleteEvent event, DeleteContext transientEntities) throws
9493
* @param event The delete event to be handled.
9594
*
9695
*/
96+
@Override
9797
public CompletionStage<Void> reactiveOnDelete(DeleteEvent event) throws HibernateException {
9898
return reactiveOnDelete( event, DeleteContext.create() );
9999
}
@@ -105,6 +105,7 @@ public CompletionStage<Void> reactiveOnDelete(DeleteEvent event) throws Hibernat
105105
* @param transientEntities The cache of entities already deleted
106106
*
107107
*/
108+
@Override
108109
public CompletionStage<Void> reactiveOnDelete(DeleteEvent event, DeleteContext transientEntities) throws HibernateException {
109110
EventSource source = event.getSession();
110111
if ( event.getObject() instanceof CompletionStage ) {

hibernate-reactive-core/src/main/java/org/hibernate/reactive/id/impl/EmulatedSequenceReactiveIdentifierGenerator.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,27 +70,33 @@ protected int determineIncrement(Properties params) {
7070
return getInt( SequenceStyleGenerator.INCREMENT_PARAM, params, SequenceStyleGenerator.DEFAULT_INCREMENT_SIZE );
7171
}
7272

73+
@Override
7374
protected Object[] updateParameters(long currentValue, long updatedValue) {
7475
return new Object[] { updatedValue, currentValue };
7576
}
7677

78+
@Override
7779
protected Object[] insertParameters(long insertedValue) {
7880
return new Object[] { insertedValue };
7981
}
8082

83+
@Override
8184
protected Object[] selectParameters() {
8285
return new Object[] {};
8386
}
8487

88+
@Override
8589
protected String buildSelectQuery() {
8690
return "select tbl." + valueColumnName + " from " + renderedTableName + " tbl";
8791
}
8892

93+
@Override
8994
protected String buildUpdateQuery() {
9095
return "update " + renderedTableName + " set " + valueColumnName + "=?"
9196
+ " where " + valueColumnName + "=?";
9297
}
9398

99+
@Override
94100
protected String buildInsertQuery() {
95101
return "insert into " + renderedTableName + " (" + valueColumnName + ") "
96102
+ " values (?)";

hibernate-reactive-core/src/main/java/org/hibernate/reactive/loader/ast/internal/ReactiveSingleIdEntityLoaderStandardImpl.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@ public class ReactiveSingleIdEntityLoaderStandardImpl<T> extends SingleIdEntityL
3838

3939
private AtomicInteger nonReusablePlansGenerated = new AtomicInteger();
4040

41+
@Override
4142
public AtomicInteger getNonReusablePlansGenerated() {
4243
return nonReusablePlansGenerated;
4344
}
@@ -46,15 +47,12 @@ public AtomicInteger getNonReusablePlansGenerated() {
4647

4748
private final EntityMappingType entityDescriptor;
4849

49-
protected final SessionFactoryImplementor sessionFactory;
50-
5150
public ReactiveSingleIdEntityLoaderStandardImpl(
5251
EntityMappingType entityDescriptor,
5352
SessionFactoryImplementor sessionFactory) {
5453
super( entityDescriptor, sessionFactory );
5554
// todo (6.0) : consider creating a base AST and "cloning" it
5655
this.entityDescriptor = entityDescriptor;
57-
this.sessionFactory = sessionFactory;
5856
}
5957

6058
@Override
@@ -127,6 +125,7 @@ public CompletionStage<T> load(
127125
}
128126

129127
@Internal
128+
@Override
130129
public ReactiveSingleIdLoadPlan<T> resolveLoadPlan(
131130
LockOptions lockOptions,
132131
LoadQueryInfluencers loadQueryInfluencers,

0 commit comments

Comments
 (0)