/*
 * Hibernate, Relational Persistence for Idiomatic Java
 *
 * License: GNU Lesser General Public License (LGPL), version 2.1 or later
 * See the lgpl.txt file in the root directory or http://www.gnu.org/licenses/lgpl-2.1.html
 */
package org.hibernate.cache.spi.access;

import org.hibernate.cache.CacheException;
import org.hibernate.engine.spi.SessionFactoryImplementor;
import org.hibernate.engine.spi.SharedSessionContractImplementor;
import org.hibernate.persister.entity.EntityPersister;

Contract for managing transactional and concurrent access to cached entity data. The expected call sequences related to various operations are:

There is another usage pattern that is used to invalidate entries after performing "bulk" HQL/SQL operations: CachedDomainDataAccess.lockRegion -> CachedDomainDataAccess.removeAll -> CachedDomainDataAccess.unlockRegion
Author:Gavin King, Steve Ebersole
/** * Contract for managing transactional and concurrent access to cached entity * data. The expected call sequences related to various operations are:<ul> * <li><b>INSERTS</b> : {@link #insert} -> {@link #afterInsert}</li> * <li><b>UPDATES</b> : {@link #lockItem} -> {@link #update} -> {@link #afterUpdate}</li> * <li><b>DELETES</b> : {@link #lockItem} -> {@link #remove} -> {@link #unlockItem}</li> * <li><b>LOADS</b> : {@link #putFromLoad}</li> * </ul> * <p/> * There is another usage pattern that is used to invalidate entries * after performing "bulk" HQL/SQL operations: * {@link #lockRegion} -> {@link #removeAll} -> {@link #unlockRegion} * * @author Gavin King * @author Steve Ebersole */
public interface EntityDataAccess extends CachedDomainDataAccess {
To create instances of keys for this region, Hibernate will invoke this method exclusively so that generated implementations can generate optimised keys.
Params:
  • id – the primary identifier of the entity
  • rootEntityDescriptor – Hierarchy for which a key is being generated
  • factory – a reference to the current SessionFactory
  • tenantIdentifier – the tenant id, or null if multi-tenancy is not being used.
Returns:a key which can be used to identify this entity on this same region todo (6.0) : the access for an entity knows the entity hierarchy and the factory. why pass them in?
/** * To create instances of keys for this region, Hibernate will invoke this method * exclusively so that generated implementations can generate optimised keys. * @param id the primary identifier of the entity * @param rootEntityDescriptor Hierarchy for which a key is being generated * @param factory a reference to the current SessionFactory * @param tenantIdentifier the tenant id, or null if multi-tenancy is not being used. * @return a key which can be used to identify this entity on this same region * * todo (6.0) : the access for an entity knows the entity hierarchy and the factory. why pass them in? */
Object generateCacheKey( Object id, EntityPersister rootEntityDescriptor, SessionFactoryImplementor factory, String tenantIdentifier);
Performs reverse operation to generateCacheKey
Params:
Returns:original id passed to generateCacheKey
/** * Performs reverse operation to {@link #generateCacheKey} * * @param cacheKey key previously returned from {@link #generateCacheKey} * @return original id passed to {@link #generateCacheKey} */
Object getCacheKeyId(Object cacheKey);
Called afterQuery an item has been inserted (beforeQuery the transaction completes), instead of calling evict(). This method is used by "synchronous" concurrency strategies.
Params:
  • session – Current session
  • key – The item key
  • value – The item
  • version – The item's version value
Throws:
Returns:Were the contents of the cache actual changed by this operation?
/** * Called afterQuery an item has been inserted (beforeQuery the transaction completes), * instead of calling evict(). * This method is used by "synchronous" concurrency strategies. * * @param session Current session * @param key The item key * @param value The item * @param version The item's version value * @return Were the contents of the cache actual changed by this operation? * @throws CacheException Propagated from underlying cache provider */
boolean insert(SharedSessionContractImplementor session, Object key, Object value, Object version);
Called afterQuery an item has been inserted (afterQuery the transaction completes), instead of calling release(). This method is used by "asynchronous" concurrency strategies.
Params:
  • session – Current session
  • key – The item key
  • value – The item
  • version – The item's version value
Throws:
Returns:Were the contents of the cache actual changed by this operation?
/** * Called afterQuery an item has been inserted (afterQuery the transaction completes), * instead of calling release(). * This method is used by "asynchronous" concurrency strategies. * * @param session Current session * @param key The item key * @param value The item * @param version The item's version value * @return Were the contents of the cache actual changed by this operation? * @throws CacheException Propagated from underlying cache provider */
boolean afterInsert(SharedSessionContractImplementor session, Object key, Object value, Object version);
Called afterQuery an item has been updated (beforeQuery the transaction completes), instead of calling evict(). This method is used by "synchronous" concurrency strategies.
Params:
  • session – Current session
  • key – The item key
  • value – The item
  • currentVersion – The item's current version value
  • previousVersion – The item's previous version value
Throws:
Returns:Were the contents of the cache actual changed by this operation?
/** * Called afterQuery an item has been updated (beforeQuery the transaction completes), * instead of calling evict(). This method is used by "synchronous" concurrency * strategies. * * * @param session Current session * @param key The item key * @param value The item * @param currentVersion The item's current version value * @param previousVersion The item's previous version value * @return Were the contents of the cache actual changed by this operation? * @throws CacheException Propagated from underlying cache provider */
boolean update( SharedSessionContractImplementor session, Object key, Object value, Object currentVersion, Object previousVersion);
Called afterQuery an item has been updated (afterQuery the transaction completes), instead of calling release(). This method is used by "asynchronous" concurrency strategies.
Params:
  • session – Current session
  • key – The item key
  • value – The item
  • currentVersion – The item's current version value
  • previousVersion – The item's previous version value
  • lock – The lock previously obtained from CachedDomainDataAccess.lockItem
Throws:
Returns:Were the contents of the cache actual changed by this operation?
/** * Called afterQuery an item has been updated (afterQuery the transaction completes), * instead of calling release(). This method is used by "asynchronous" * concurrency strategies. * * @param session Current session * @param key The item key * @param value The item * @param currentVersion The item's current version value * @param previousVersion The item's previous version value * @param lock The lock previously obtained from {@link #lockItem} * @return Were the contents of the cache actual changed by this operation? * @throws CacheException Propagated from underlying cache provider */
boolean afterUpdate( SharedSessionContractImplementor session, Object key, Object value, Object currentVersion, Object previousVersion, SoftLock lock); }