Skip to content

Commit f7db3f0

Browse files
committed
misc cleanups
Signed-off-by: Gavin King <[email protected]>
1 parent 09fa8ef commit f7db3f0

File tree

4 files changed

+16
-16
lines changed

4 files changed

+16
-16
lines changed

hibernate-core/src/main/java/org/hibernate/engine/internal/StatefulPersistenceContext.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -772,10 +772,9 @@ public void reassociateProxy(Object value, Object id) throws MappingException {
772772
*/
773773
private void reassociateProxy(LazyInitializer li, HibernateProxy proxy) {
774774
if ( li.getSession() != this.getSession() ) {
775-
final EntityPersister persister = session.getFactory()
776-
.getRuntimeMetamodels()
777-
.getMappingMetamodel()
778-
.getEntityDescriptor( li.getEntityName() );
775+
final EntityPersister persister =
776+
session.getFactory().getMappingMetamodel()
777+
.getEntityDescriptor( li.getEntityName() );
779778
final EntityKey key = session.generateEntityKey( li.getInternalIdentifier(), persister );
780779
// any earlier proxy takes precedence
781780
final Map<EntityKey, EntityHolderImpl> entityHolderMap = getOrInitializeEntitiesByKey();

hibernate-core/src/main/java/org/hibernate/event/internal/DefaultMergeEventListener.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@
5757
import static org.hibernate.engine.internal.ManagedTypeHelper.isPersistentAttributeInterceptable;
5858
import static org.hibernate.engine.internal.ManagedTypeHelper.isSelfDirtinessTracker;
5959
import static org.hibernate.event.internal.EntityState.getEntityState;
60+
import static org.hibernate.proxy.HibernateProxy.extractLazyInitializer;
6061

6162
/**
6263
* Defines the default copy event listener used by hibernate for copying entities
@@ -111,7 +112,7 @@ public void onMerge(MergeEvent event, MergeContext copiedAlready) throws Hiberna
111112
// NOTE : `original` is the value being merged
112113
if ( original != null ) {
113114
final EventSource source = event.getSession();
114-
final LazyInitializer lazyInitializer = HibernateProxy.extractLazyInitializer( original );
115+
final LazyInitializer lazyInitializer = extractLazyInitializer( original );
115116
if ( lazyInitializer != null ) {
116117
if ( lazyInitializer.isUninitialized() ) {
117118
LOG.trace( "Ignoring uninitialized proxy" );
@@ -122,9 +123,11 @@ public void onMerge(MergeEvent event, MergeContext copiedAlready) throws Hiberna
122123
}
123124
}
124125
else if ( isPersistentAttributeInterceptable( original ) ) {
125-
final PersistentAttributeInterceptor interceptor = asPersistentAttributeInterceptable( original ).$$_hibernate_getInterceptor();
126+
final PersistentAttributeInterceptor interceptor =
127+
asPersistentAttributeInterceptable( original ).$$_hibernate_getInterceptor();
126128
if ( interceptor instanceof EnhancementAsProxyLazinessInterceptor ) {
127-
final EnhancementAsProxyLazinessInterceptor proxyInterceptor = (EnhancementAsProxyLazinessInterceptor) interceptor;
129+
final EnhancementAsProxyLazinessInterceptor proxyInterceptor =
130+
(EnhancementAsProxyLazinessInterceptor) interceptor;
128131
LOG.trace( "Ignoring uninitialized enhanced-proxy" );
129132
event.setResult( source.load( proxyInterceptor.getEntityName(), proxyInterceptor.getIdentifier() ) );
130133
}

hibernate-core/src/main/java/org/hibernate/internal/SessionImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -864,8 +864,8 @@ public void delete(String entityName, Object object, boolean isCascadeDeleteEnab
864864

865865
@Override
866866
public void removeOrphanBeforeUpdates(String entityName, Object child) {
867-
// TODO: The removeOrphan concept is a temporary "hack" for HHH-6484. This should be removed once action/task
868-
// ordering is improved.
867+
// TODO: The removeOrphan concept is a temporary "hack" for HHH-6484.
868+
// This should be removed once action/task ordering is improved.
869869
final boolean traceEnabled = log.isTraceEnabled();
870870
if ( traceEnabled ) {
871871
logRemoveOrphanBeforeUpdates( "begin", entityName, child );

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

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -52,17 +52,16 @@ public static void upgradeLock(Object object, EntityEntry entry, LockOptions loc
5252
final LockMode requestedLockMode = lockOptions.getLockMode();
5353
if ( requestedLockMode.greaterThan( entry.getLockMode() ) ) {
5454
// Request is for a more restrictive lock than the lock already held
55+
final EntityPersister persister = entry.getPersister();
5556

5657
if ( entry.getStatus().isDeletedOrGone()) {
5758
throw new ObjectDeletedException(
5859
"attempted to lock a deleted instance",
5960
entry.getId(),
60-
entry.getPersister().getEntityName()
61+
persister.getEntityName()
6162
);
6263
}
6364

64-
final EntityPersister persister = entry.getPersister();
65-
6665
if ( LoaderLogging.LOADER_LOGGER.isTraceEnabled() ) {
6766
LoaderLogging.LOADER_LOGGER.tracef(
6867
"Locking `%s( %s )` in `%s` lock-mode",
@@ -77,7 +76,7 @@ public static void upgradeLock(Object object, EntityEntry entry, LockOptions loc
7776
Object ck = null;
7877
try {
7978
if ( cachingEnabled ) {
80-
EntityDataAccess cache = persister.getCacheAccessStrategy();
79+
final EntityDataAccess cache = persister.getCacheAccessStrategy();
8180
ck = cache.generateCacheKey( entry.getId(), persister, session.getFactory(), session.getTenantIdentifier() );
8281
lock = cache.lockItem( session, ck, entry.getVersion() );
8382
}
@@ -99,9 +98,8 @@ public static void upgradeLock(Object object, EntityEntry entry, LockOptions loc
9998

10099
if ( persister.isVersioned() && requestedLockMode == LockMode.PESSIMISTIC_FORCE_INCREMENT ) {
101100
// todo : should we check the current isolation mode explicitly?
102-
Object nextVersion = persister.forceVersionIncrement(
103-
entry.getId(), entry.getVersion(), false, session
104-
);
101+
final Object nextVersion =
102+
persister.forceVersionIncrement( entry.getId(), entry.getVersion(), false, session );
105103
entry.forceLocked( object, nextVersion );
106104
}
107105
else {

0 commit comments

Comments
 (0)