public abstract class CacheInterceptor
extends java.lang.Object
implements org.eclipse.persistence.internal.identitymaps.IdentityMap
Purpose: Define a class through which Cache access can be intercepted.
Description: EclipseLink makes extensive use of caching functionality. This class provides the mechanism for intercepting the cache access. Once intercepted applications can allow the process to continue by calling the method on the class attribute targetIdentityMap as described in the API javadocs or redirect the process entirely. * As with IdentityMaps an entire class inheritance hierarchy will share the same interceptor.
To implement a CacheInterceptor users should subclass this class implementing those methods they wish to intercept.
Configuration: Interceptors may be added to a session by using a Session or Descriptor customizer to set the class name of the interceptor on the target ClassDescriptor through the method setCacheInterceptorClass(Class).
| Modifier and Type | Field and Description |
|---|---|
protected org.eclipse.persistence.internal.sessions.AbstractSession |
interceptedSession |
protected org.eclipse.persistence.internal.identitymaps.IdentityMap |
targetIdentityMap
This attribute stores the actual IdentityMap as configured by the user.
|
| Constructor and Description |
|---|
CacheInterceptor(org.eclipse.persistence.internal.identitymaps.IdentityMap targetIdentityMap,
org.eclipse.persistence.internal.sessions.AbstractSession interceptedSession) |
| Modifier and Type | Method and Description |
|---|---|
org.eclipse.persistence.internal.identitymaps.CacheKey |
acquireDeferredLock(java.lang.Object primaryKey,
boolean isCacheCheckComplete)
Acquire a deferred lock on the object.
|
org.eclipse.persistence.internal.identitymaps.CacheKey |
acquireLock(java.lang.Object primaryKey,
boolean forMerge,
boolean isCacheCheckComplete)
Acquire an active lock on the object.
|
org.eclipse.persistence.internal.identitymaps.CacheKey |
acquireLockNoWait(java.lang.Object primaryKey,
boolean forMerge)
Acquire an active lock on the object, if not already locked.
|
org.eclipse.persistence.internal.identitymaps.CacheKey |
acquireLockWithWait(java.lang.Object primaryKey,
boolean forMerge,
int wait)
Acquire an active lock on the object, if not already locked.
|
org.eclipse.persistence.internal.identitymaps.CacheKey |
acquireReadLockOnCacheKey(java.lang.Object primaryKey)
Acquire a read lock on the object.
|
org.eclipse.persistence.internal.identitymaps.CacheKey |
acquireReadLockOnCacheKeyNoWait(java.lang.Object primaryKey)
Acquire a read lock on the object, if not already locked.
|
abstract java.lang.Object |
clone()
Clone the map and all of the CacheKeys.
|
void |
collectLocks(java.util.HashMap threadList)
Add all locked CacheKeys to the map grouped by thread.
|
boolean |
containsKey(java.lang.Object primaryKey)
Return true if an CacheKey with the primary key is in the map.
|
protected abstract CacheKeyInterceptor |
createCacheKeyInterceptor(org.eclipse.persistence.internal.identitymaps.CacheKey wrappedCacheKey) |
java.util.Enumeration |
elements()
Allow for the cache to be iterated on.
|
java.lang.Object |
get(java.lang.Object primaryKey)
Return the object cached in the identity map or null if it could not be found.
|
abstract java.util.Map<java.lang.Object,org.eclipse.persistence.internal.identitymaps.CacheKey> |
getAllCacheKeysFromIdentityMapWithEntityPK(java.lang.Object[] pkList,
ClassDescriptor descriptor,
org.eclipse.persistence.internal.sessions.AbstractSession session)
ADVANCED:
Using a list of Entity PK this method will attempt to bulk load the entire list from the cache.
|
abstract java.util.Map<java.lang.Object,java.lang.Object> |
getAllFromIdentityMapWithEntityPK(java.lang.Object[] pkList,
ClassDescriptor descriptor,
org.eclipse.persistence.internal.sessions.AbstractSession session)
ADVANCED:
Using a list of Entity PK this method will attempt to bulk load the entire list from the cache.
|
org.eclipse.persistence.internal.identitymaps.CacheKey |
getCacheKey(java.lang.Object primaryKey,
boolean forMerge)
Get the cache key (with object) for the primary key.
|
org.eclipse.persistence.internal.identitymaps.CacheKey |
getCacheKeyForLock(java.lang.Object primaryKey)
Get the cache key (with object) for the primary key.
|
ClassDescriptor |
getDescriptor()
Return the descriptor that this is the map for.
|
java.lang.Class |
getDescriptorClass()
Return the class that this is the map for.
|
int |
getMaxSize() |
int |
getSize()
Return the number of CacheKeys in the IdentityMap.
|
int |
getSize(java.lang.Class myClass,
boolean recurse)
Return the number of actual objects of type myClass in the IdentityMap.
|
org.eclipse.persistence.internal.identitymaps.IdentityMap |
getTargetIdenttyMap()
Return the instance of the IdentityMap that this intercpetor is wrapping.
|
java.lang.Object |
getWrapper(java.lang.Object primaryKey)
Get the wrapper object from the cache key associated with the given primary key,
this is used for EJB2.
|
java.lang.Object |
getWriteLockValue(java.lang.Object primaryKey)
Get the write lock value from the cache key associated to the primarykey.
|
java.util.Enumeration |
keys()
Allow for the CacheKeys to be iterated on.
|
java.util.Enumeration |
keys(boolean checkReadLocks)
Allow for the CacheKeys to be iterated on. - value should be true
if readloacks are to be used, false otherwise.
|
void |
lazyRelationshipLoaded(java.lang.Object rootEntity,
ValueHolderInterface valueHolder,
ForeignReferenceMapping mapping)
Notify the cache that a lazy relationship has been triggered in the object
and the cache may need to be updated
|
org.eclipse.persistence.internal.identitymaps.CacheKey |
put(java.lang.Object primaryKey,
java.lang.Object object,
java.lang.Object writeLockValue,
long readTime)
Store the object in the cache at its primary key.
|
java.lang.Object |
remove(org.eclipse.persistence.internal.identitymaps.CacheKey cacheKey)
Remove the CacheKey from the map.
|
java.lang.Object |
remove(java.lang.Object primaryKey,
java.lang.Object object)
Remove the CacheKey with the primaryKey from the map.
|
void |
setDescriptor(ClassDescriptor descriptor)
Set the descriptor that this is the map for.
|
void |
setWrapper(java.lang.Object primaryKey,
java.lang.Object wrapper)
Update the wrapper object in the CacheKey associated with the given primaryKey,
this is used for EJB2.
|
void |
setWriteLockValue(java.lang.Object primaryKey,
java.lang.Object writeLockValue)
Update the write lock value of the CacheKey associated with the given primaryKey.
|
java.lang.String |
toString() |
void |
updateMaxSize(int maxSize)
This method will be used to update the max cache size, any objects exceeding the max cache size will
be remove from the cache.
|
protected org.eclipse.persistence.internal.identitymaps.IdentityMap targetIdentityMap
protected org.eclipse.persistence.internal.sessions.AbstractSession interceptedSession
public CacheInterceptor(org.eclipse.persistence.internal.identitymaps.IdentityMap targetIdentityMap,
org.eclipse.persistence.internal.sessions.AbstractSession interceptedSession)
public org.eclipse.persistence.internal.identitymaps.CacheKey acquireDeferredLock(java.lang.Object primaryKey,
boolean isCacheCheckComplete)
acquireDeferredLock in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic org.eclipse.persistence.internal.identitymaps.CacheKey acquireLock(java.lang.Object primaryKey,
boolean forMerge,
boolean isCacheCheckComplete)
acquireLock in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic org.eclipse.persistence.internal.identitymaps.CacheKey acquireLockNoWait(java.lang.Object primaryKey,
boolean forMerge)
acquireLockNoWait in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic org.eclipse.persistence.internal.identitymaps.CacheKey acquireLockWithWait(java.lang.Object primaryKey,
boolean forMerge,
int wait)
acquireLockWithWait in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic org.eclipse.persistence.internal.identitymaps.CacheKey acquireReadLockOnCacheKey(java.lang.Object primaryKey)
acquireReadLockOnCacheKey in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic org.eclipse.persistence.internal.identitymaps.CacheKey acquireReadLockOnCacheKeyNoWait(java.lang.Object primaryKey)
acquireReadLockOnCacheKeyNoWait in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic void collectLocks(java.util.HashMap threadList)
collectLocks in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic abstract java.lang.Object clone()
clone in interface org.eclipse.persistence.internal.identitymaps.IdentityMapclone in class java.lang.Objectpublic boolean containsKey(java.lang.Object primaryKey)
containsKey in interface org.eclipse.persistence.internal.identitymaps.IdentityMapprimaryKey - is the primary key for the object to search for.protected abstract CacheKeyInterceptor createCacheKeyInterceptor(org.eclipse.persistence.internal.identitymaps.CacheKey wrappedCacheKey)
public java.util.Enumeration elements()
elements in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic java.lang.Object get(java.lang.Object primaryKey)
get in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic abstract java.util.Map<java.lang.Object,java.lang.Object> getAllFromIdentityMapWithEntityPK(java.lang.Object[] pkList,
ClassDescriptor descriptor,
org.eclipse.persistence.internal.sessions.AbstractSession session)
getAllFromIdentityMapWithEntityPK in interface org.eclipse.persistence.internal.identitymaps.IdentityMappkList - List of Entity PKs to extract from the cacheClassDescriptor - Descriptor type to be retrieved.QueryExceptionpublic abstract java.util.Map<java.lang.Object,org.eclipse.persistence.internal.identitymaps.CacheKey> getAllCacheKeysFromIdentityMapWithEntityPK(java.lang.Object[] pkList,
ClassDescriptor descriptor,
org.eclipse.persistence.internal.sessions.AbstractSession session)
getAllCacheKeysFromIdentityMapWithEntityPK in interface org.eclipse.persistence.internal.identitymaps.IdentityMappkList - List of Entity PKs to extract from the cacheClassDescriptor - Descriptor type to be retrieved.QueryExceptionpublic org.eclipse.persistence.internal.identitymaps.CacheKey getCacheKey(java.lang.Object primaryKey,
boolean forMerge)
getCacheKey in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic org.eclipse.persistence.internal.identitymaps.CacheKey getCacheKeyForLock(java.lang.Object primaryKey)
getCacheKeyForLock in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic ClassDescriptor getDescriptor()
getDescriptor in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic java.lang.Class getDescriptorClass()
getDescriptorClass in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic int getMaxSize()
getMaxSize in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic int getSize()
getSize in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic int getSize(java.lang.Class myClass,
boolean recurse)
getSize in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic org.eclipse.persistence.internal.identitymaps.IdentityMap getTargetIdenttyMap()
public java.lang.Object getWrapper(java.lang.Object primaryKey)
getWrapper in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic java.lang.Object getWriteLockValue(java.lang.Object primaryKey)
getWriteLockValue in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic java.util.Enumeration keys()
keys in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic java.util.Enumeration keys(boolean checkReadLocks)
keys in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic void lazyRelationshipLoaded(java.lang.Object rootEntity,
ValueHolderInterface valueHolder,
ForeignReferenceMapping mapping)
lazyRelationshipLoaded in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic org.eclipse.persistence.internal.identitymaps.CacheKey put(java.lang.Object primaryKey,
java.lang.Object object,
java.lang.Object writeLockValue,
long readTime)
put in interface org.eclipse.persistence.internal.identitymaps.IdentityMapprimaryKey - is the primary key for the object.object - is the domain object to cache.writeLockValue - is the current write lock value of object, if null the version is ignored.public java.lang.Object remove(java.lang.Object primaryKey,
java.lang.Object object)
remove in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic java.lang.Object remove(org.eclipse.persistence.internal.identitymaps.CacheKey cacheKey)
remove in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic void updateMaxSize(int maxSize)
updateMaxSize in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic void setDescriptor(ClassDescriptor descriptor)
setDescriptor in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic void setWrapper(java.lang.Object primaryKey,
java.lang.Object wrapper)
setWrapper in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic void setWriteLockValue(java.lang.Object primaryKey,
java.lang.Object writeLockValue)
setWriteLockValue in interface org.eclipse.persistence.internal.identitymaps.IdentityMappublic java.lang.String toString()
toString in interface org.eclipse.persistence.internal.identitymaps.IdentityMaptoString in class java.lang.Object