Hibernate
/
hibernate-orm
mirror of https://github.com/hibernate/hibernate-orm
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

expose some methods of EntityDeleteAction to HR

This commit is contained in:
Gavin 2023-04-10 01:43:15 +02:00 committed by Gavin King
parent 49fb2dce8a
commit af25660720
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
hibernate-core/src/main/java/org/hibernate/action/internal/EntityDeleteAction.java
View File

@ -145,7 +145,7 @@ public class EntityDeleteAction extends EntityAction {
} }
} }
private Object getCurrentVersion() { protected Object getCurrentVersion() {
return getPersister().isVersionPropertyGenerated() return getPersister().isVersionPropertyGenerated()
// skip if we're deleting an unloaded proxy, no need for the version // skip if we're deleting an unloaded proxy, no need for the version
&& isInstanceLoaded() && isInstanceLoaded()
@ -156,7 +156,7 @@ public class EntityDeleteAction extends EntityAction {
: version; : version;
} }
private void postDeleteLoaded( protected void postDeleteLoaded(
Object id, Object id,
EntityPersister persister, EntityPersister persister,
SharedSessionContractImplementor session, SharedSessionContractImplementor session,
@ -171,7 +171,7 @@ public class EntityDeleteAction extends EntityAction {
throw new AssertionFailure( "possible non-threadsafe access to session" ); throw new AssertionFailure( "possible non-threadsafe access to session" );
} }
entry.postDelete(); entry.postDelete();
EntityKey key = entry.getEntityKey(); final EntityKey key = entry.getEntityKey();
persistenceContext.removeEntity( key ); persistenceContext.removeEntity( key );
persistenceContext.removeProxy( key ); persistenceContext.removeProxy( key );
removeCacheItem( ck ); removeCacheItem( ck );
@ -179,9 +179,9 @@ public class EntityDeleteAction extends EntityAction {
postDelete(); postDelete();
} }
private void postDeleteUnloaded(Object id, EntityPersister persister, SharedSessionContractImplementor session, Object ck) { protected void postDeleteUnloaded(Object id, EntityPersister persister, SharedSessionContractImplementor session, Object ck) {
final PersistenceContext persistenceContext = session.getPersistenceContextInternal(); final PersistenceContext persistenceContext = session.getPersistenceContextInternal();
EntityKey key = session.generateEntityKey( id, persister ); final EntityKey key = session.generateEntityKey( id, persister );
if ( !persistenceContext.containsDeletedUnloadedEntityKey( key ) ) { if ( !persistenceContext.containsDeletedUnloadedEntityKey( key ) ) {
throw new AssertionFailure( "deleted proxy should be for an unloaded entity: " + key ); throw new AssertionFailure( "deleted proxy should be for an unloaded entity: " + key );
} }
@ -257,12 +257,17 @@ public class EntityDeleteAction extends EntityAction {
return false; return false;
} }
private Object lockCacheItem() { protected Object lockCacheItem() {
final EntityPersister persister = getPersister(); final EntityPersister persister = getPersister();
if ( persister.canWriteToCache() ) { if ( persister.canWriteToCache() ) {
final EntityDataAccess cache = persister.getCacheAccessStrategy(); final EntityDataAccess cache = persister.getCacheAccessStrategy();
final SharedSessionContractImplementor session = getSession(); final SharedSessionContractImplementor session = getSession();
Object ck = cache.generateCacheKey( getId(), persister, session.getFactory(), session.getTenantIdentifier() ); final Object ck = cache.generateCacheKey(
getId(),
persister,
session.getFactory(),
session.getTenantIdentifier()
);
lock = cache.lockItem( session, ck, getCurrentVersion() ); lock = cache.lockItem( session, ck, getCurrentVersion() );
return ck; return ck;
} }
@ -271,7 +276,7 @@ public class EntityDeleteAction extends EntityAction {
} }
} }
private void unlockCacheItem() { protected void unlockCacheItem() {
final EntityPersister persister = getPersister(); final EntityPersister persister = getPersister();
if ( persister.canWriteToCache() ) { if ( persister.canWriteToCache() ) {
final EntityDataAccess cache = persister.getCacheAccessStrategy(); final EntityDataAccess cache = persister.getCacheAccessStrategy();
@ -286,7 +291,7 @@ public class EntityDeleteAction extends EntityAction {
} }
} }
private void removeCacheItem(Object ck) { protected void removeCacheItem(Object ck) {
final EntityPersister persister = getPersister(); final EntityPersister persister = getPersister();
if ( persister.canWriteToCache() ) { if ( persister.canWriteToCache() ) {
persister.getCacheAccessStrategy().remove( getSession(), ck ); persister.getCacheAccessStrategy().remove( getSession(), ck );