Package org.hibernate.internal

Class StatelessSessionImpl

java.lang.Object

org.hibernate.internal.AbstractSharedSessionContract

org.hibernate.internal.StatelessSessionImpl

All Implemented Interfaces:

Serializable, AutoCloseable, LobCreationContext, SharedSessionContractImplementor, QueryProducer, QueryProducerImplementor, JdbcSessionOwner, TransactionCoordinatorBuilder.Options, SharedSessionContract, StatelessSession, JavaType.CoercionContext, WrapperOptions

public class StatelessSessionImpl
extends AbstractSharedSessionContract
implements StatelessSession

Concrete implementation of the StatelessSession API.

Exposes two interfaces:

• StatelessSession to the application, and
• SharedSessionContractImplementor (an SPI interface) to other subsystems.

This class is not thread-safe.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.hibernate.engine.jdbc.LobCreationContext

LobCreationContext.Callback<T>

Field Summary

Fields inherited from class org.hibernate.internal.AbstractSharedSessionContract

closed, fastSessionServices, waitingForAutoClose

Constructor Summary

Constructors

Constructor	Description
StatelessSessionImpl(SessionFactoryImpl factory, SessionCreationOptions options)

Method Summary

Modifier and Type	Method	Description
void	afterOperation(boolean success)	Check if there is a Hibernate or JTA transaction in progress and, if there is not, flush if necessary, making sure that the connection has been committed (if it is not in autocommit mode), and finally run the after completion processing.
void	afterScrollOperation()	Called after each operation on a ScrollableResults, providing an opportunity for a stateless session to clear its temporary persistence context.
void	afterTransactionBegin()	An after-begin callback from the coordinator to its owner.
void	afterTransactionCompletion(boolean successful, boolean delayed)	An after-completion callback to the owner.
StatelessSession	asStatelessSession()	Cast this object to StatelessSession, if possible.
boolean	autoFlushIfRequired(Set<String> querySpaces)	detect in-memory changes, determine if the changes are to tables named in the query and, if so, complete execution the flush
void	beforeTransactionCompletion()	A before-completion callback to the owner.
String	bestGuessEntityName(Object object)	Obtain the best estimate of the entity name of the given entity instance, which is not involved in an association, by also considering information held in the proxy, and whether the object is already associated with this session.
void	delete(Object entity)	Delete a record.
void	delete(String entityName, Object entity)	Delete a record.
void	deleteMultiple(List<Object> entities)	Delete multiple records.
void	fetch(Object association)	Fetch an association or collection that's configured for lazy loading.
void	flush()	Flush this session.
void	flushBeforeTransactionCompletion()
<T> T	get(EntityGraph<T> graph, GraphSemantic graphSemantic, Object id)	Retrieve a record, fetching associations specified by the given EntityGraph.
<T> T	get(EntityGraph<T> graph, GraphSemantic graphSemantic, Object id, LockMode lockMode)	Retrieve a record, fetching associations specified by the given EntityGraph, and obtaining the specified lock mode.
<T> T	get(Class<T> entityClass, Object id)	Retrieve a record.
<T> T	get(Class<T> entityClass, Object id, LockMode lockMode)	Retrieve a record, obtaining the specified lock mode.
Object	get(String entityName, Object id)	Retrieve a record.
Object	get(String entityName, Object id, LockMode lockMode)	Retrieve a record, obtaining the specified lock mode.
CacheMode	getCacheMode()	Get the current CacheMode for this session.
Object	getContextEntityIdentifier(Object object)	Return the identifier of the persistent object, or null if it is not associated with this session.
EntityPersister	getEntityPersister(String entityName, Object object)	Get the EntityPersister for the given entity instance.
Object	getEntityUsingInterceptor(EntityKey key)	Get the entity instance associated with the given EntityKey, calling the Interceptor if necessary.
Object	getIdentifier(Object entity)	Return the identifier value of the given entity, which may be detached.
LoadQueryInfluencers	getLoadQueryInfluencers()	Get the LoadQueryInfluencers associated with this session.
<T> List<T>	getMultiple(Class<T> entityClass, List<Object> ids)	Retrieve multiple rows, returning entity instances in a list where the position of an instance in the list matches the position of its identifier in the given array, and the list contains a null value if there is no persistent instance matching a given identifier.
PersistenceContext	getPersistenceContext()	Get the persistence context for this session.
PersistenceContext	getPersistenceContextInternal()	Similar to SharedSessionContractImplementor.getPersistenceContext(), with two differences: this version performs better as it allows for inlining and probably better prediction, and it skips some checks of the current state of the session.
String	guessEntityName(Object entity)	Obtain an estimate of the entity name of the given entity instance, which is not involved in an association, using only the EntityNameResolver.
Object	immediateLoad(String entityName, Object id)	Load an instance immediately.
void	initializeCollection(PersistentCollection<?> collection, boolean writing)	Initialize the given collection (if not already initialized).
Object	insert(Object entity)	Insert a record.
Object	insert(String entityName, Object entity)	Insert a record.
void	insertMultiple(List<Object> entities)	Insert multiple records.
Object	instantiate(String entityName, Object id)	Instantiate the entity class, initializing with the given identifier.
Object	instantiate(EntityPersister persister, Object id)	Instantiate the entity class of the given EntityPersister, initializing the new instance with the given identifier.
Object	internalLoad(String entityName, Object id, boolean eager, boolean nullable)	Obtain an entity instance with the given id, without checking if it was deleted or scheduled for deletion.
boolean	isAutoCloseSessionEnabled()	Is auto-close at transaction completion enabled?
boolean	isDefaultReadOnly()	Are entities and proxies loaded by this session read-only by default?
boolean	isStatelessSession()	Does this object implement StatelessSession?
boolean	isTransactionInProgress()	Does this session have an active Hibernate transaction, or is it associated with a JTA transaction currently in progress?
void	refresh(Object entity)	Refresh the entity instance state from the database.
void	refresh(Object entity, LockMode lockMode)	Refresh the entity instance state from the database.
void	refresh(String entityName, Object entity)	Refresh the entity instance state from the database.
void	refresh(String entityName, Object entity, LockMode lockMode)	Refresh the entity instance state from the database.
void	setAutoClear(boolean enabled)	Enable or disable automatic cache clearing from after transaction completion.
void	setCacheMode(CacheMode cm)	Set the current CacheMode for this session.
void	setDefaultReadOnly(boolean readOnly)
void	setHibernateFlushMode(FlushMode flushMode)	Set the current FlushMode for this session.
boolean	shouldAutoClose()	Should this session be automatically closed after the current transaction completes?
boolean	shouldAutoJoinTransaction()	Indicates whether an active transaction should be automatically joined.
void	update(Object entity)	Update a record.
void	update(String entityName, Object entity)	Update a record.
void	updateMultiple(List<Object> entities)	Update multiple records.
void	upsert(Object entity)	Use a SQL merge into statement to perform an upsert, that is, to insert the record if it does not exist, or update it if it already exists.
void	upsert(String entityName, Object entity)	Use a SQL merge into statement to perform an upsert.
void	upsertMultiple(List<Object> entities)	Perform an upsert, that is, to insert the record if it does not exist, or update the record if it already exists, for each given record.

Methods inherited from class org.hibernate.internal.AbstractSharedSessionContract

accessTransaction, addResultType, addSharedSessionTransactionObserver, applyQuerySettingsAndHints, applyQuerySettingsAndHints, beginTransaction, buildNamedQuery, buildNamedQuery, checkMutationQuery, checkOpen, checkOpenOrWaitingForAutoClose, checkResultType, checkSelectionQuery, checkTransactionNeededForUpdateOperation, checkTransactionSynchStatus, cleanupOnClose, close, createCriteriaQuery, createEntityGraph, createEntityGraph, createEntityGraph, createMutationQuery, createMutationQuery, createMutationQuery, createMutationQuery, createMutationQuery, createNamedMutationQuery, createNamedQuery, createNamedQuery, createNamedSelectionQuery, createNamedSelectionQuery, createNamedStoredProcedureQuery, createNativeMutationQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQueryImplementor, createNativeQueryImplementor, createQuery, createQuery, createQuery, createQuery, createQuery, createQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery, createSqmQueryImplementor, createSqmQueryImplementor, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureQuery, createStoredProcedureQuery, createStoredProcedureQuery, delayedAfterCompletion, disableFilter, doReturningWork, doWork, enableFilter, execute, generateEntityKey, getCacheTransactionSynchronization, getConfiguredJdbcBatchSize, getCriteriaBuilder, getCurrentTransaction, getDialect, getEnabledFilter, getEntityGraph, getEntityGraphs, getEntityNameResolver, getEventListenerManager, getEventManager, getExceptionConverter, getFactory, getFlushMode, getHibernateFlushMode, getInterceptor, getJdbcBatchSize, getJdbcConnectionAccess, getJdbcCoordinator, getJdbcServices, getJdbcSessionContext, getJdbcTimeZone, getJsonFormatMapper, getLobCreator, getNamedNativeQuery, getNamedNativeQuery, getNamedProcedureCall, getNamedQuery, getNativeJdbcParametersIgnored, getPreferredSqlTypeCodeForBoolean, getResultSetMappingMemento, getSessionFactory, getSessionIdentifier, getSessionToken, getTenantIdentifier, getTenantIdentifierValue, getTransaction, getTransactionCoordinator, getTypeConfiguration, getXmlFormatMapper, interpretHql, isClosed, isConnected, isCriteriaCopyTreeEnabled, isJoinedToTransaction, isOpen, isOpenOrWaitingForAutoClose, joinTransaction, markForRollbackOnly, prepareForAutoClose, prepareForQueryExecution, pulseTransactionCoordinator, removeSharedSessionTransactionObserver, setClosed, setCriteriaCopyTreeEnabled, setJdbcBatchSize, setNativeJdbcParametersIgnored, setUpMultitenancy, shouldCloseJdbcCoordinatorOnClose, startTransactionBoundary, useStreamForLobBinding

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.hibernate.resource.jdbc.spi.JdbcSessionOwner

getSqlExceptionHelper

Methods inherited from interface org.hibernate.engine.jdbc.LobCreationContext

fromContext

Methods inherited from interface org.hibernate.query.QueryProducer

createMutationQuery, createMutationQuery, createNamedSelectionQuery, createNamedSelectionQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery

Methods inherited from interface org.hibernate.SharedSessionContract

beginTransaction, createEntityGraph, createEntityGraph, createEntityGraph, createNamedStoredProcedureQuery, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureQuery, createStoredProcedureQuery, createStoredProcedureQuery, disableFilter, doReturningWork, doWork, enableFilter, getCriteriaBuilder, getEnabledFilter, getEntityGraph, getEntityGraphs, getJdbcBatchSize, getNamedProcedureCall, getTenantIdentifier, getTenantIdentifierValue, getTransaction, isConnected, isJoinedToTransaction, isOpen, joinTransaction, setJdbcBatchSize

Methods inherited from interface org.hibernate.engine.spi.SharedSessionContractImplementor

asEventSource, asSessionImplementor, autoFlushIfRequired, autoPreFlush, bestGuessEntityName, checkOpen, getSession, isEventSource, isSessionImplementor

Methods inherited from interface org.hibernate.StatelessSession

close

Constructor Details

StatelessSessionImpl

public StatelessSessionImpl(SessionFactoryImpl factory,
 SessionCreationOptions options)

Method Details

shouldAutoJoinTransaction

public boolean shouldAutoJoinTransaction()

Description copied from interface: TransactionCoordinatorBuilder.Options

Indicates whether an active transaction should be automatically joined. Only relevant for JTA-based TransactionCoordinator instances.

Specified by:

shouldAutoJoinTransaction in interface TransactionCoordinatorBuilder.Options

Overrides:

shouldAutoJoinTransaction in class AbstractSharedSessionContract

Returns:

true indicates the active transaction should be auto joined; false indicates it should not (until TransactionCoordinator.explicitJoin() is called).

insert

public Object insert(Object entity)

Description copied from interface: StatelessSession

Insert a record.

If the entity @Id field is declared to be generated, for example, if it is annotated @GeneratedValue, the id is generated and assigned to the given instance.

The PostPersist callback will be triggered if the operation is successful.

Specified by:

insert in interface StatelessSession

Parameters:

entity - a new transient instance

Returns:

The identifier of the inserted entity

insertMultiple

public void insertMultiple(List<Object> entities)

Description copied from interface: StatelessSession

Insert multiple records.

Specified by:

insertMultiple in interface StatelessSession

Parameters:

entities - a list of transient instances to be inserted

insert

public Object insert(String entityName,
 Object entity)

Description copied from interface: StatelessSession

Insert a record.

The PostPersist callback will be triggered if the operation is successful.

Specified by:

insert in interface StatelessSession

Parameters:

entityName - The entityName for the entity to be inserted

entity - a new transient instance

Returns:

the identifier of the instance

delete

public void delete(Object entity)

Description copied from interface: StatelessSession

Delete a record.

The PostRemove callback will be triggered if the operation is successful.

Specified by:

delete in interface StatelessSession

Parameters:

entity - a detached entity instance

deleteMultiple

public void deleteMultiple(List<Object> entities)

Description copied from interface: StatelessSession

Delete multiple records.

Specified by:

deleteMultiple in interface StatelessSession

Parameters:

entities - a list of detached instances to be deleted

delete

public void delete(String entityName,
 Object entity)

Description copied from interface: StatelessSession

Delete a record.

The PostRemove callback will be triggered if the operation is successful.

Specified by:

delete in interface StatelessSession

Parameters:

entityName - The entityName for the entity to be deleted

entity - a detached entity instance

update

public void update(Object entity)

Description copied from interface: StatelessSession

Update a record.

The PostUpdate callback will be triggered if the operation is successful.

Specified by:

update in interface StatelessSession

Parameters:

entity - a detached entity instance

updateMultiple

public void updateMultiple(List<Object> entities)

Description copied from interface: StatelessSession

Update multiple records.

Specified by:

updateMultiple in interface StatelessSession

Parameters:

entities - a list of detached instances to be updated

update

public void update(String entityName,
 Object entity)

Description copied from interface: StatelessSession

Update a record.

The PostUpdate callback will be triggered if the operation is successful.

Specified by:

update in interface StatelessSession

Parameters:

entityName - The entityName for the entity to be updated

entity - a detached entity instance

upsert

public void upsert(Object entity)

Description copied from interface: StatelessSession

Use a SQL merge into statement to perform an upsert, that is, to insert the record if it does not exist, or update it if it already exists.

This method never performs id generation, and does not accept an entity instance with a null identifier. When id generation is required, use StatelessSession.insert(Object).

On the other hand, upsert() does accept an entity instance with an assigned identifier value, even if the entity @Id field is declared to be generated, for example, if it is annotated @GeneratedValue. Thus, this method may be used to import data from an external source.

Specified by:

upsert in interface StatelessSession

Parameters:

entity - a detached entity instance, or a new instance with an assigned identifier

upsertMultiple

public void upsertMultiple(List<Object> entities)

Description copied from interface: StatelessSession

Perform an upsert, that is, to insert the record if it does not exist, or update the record if it already exists, for each given record.

Specified by:

upsertMultiple in interface StatelessSession

Parameters:

entities - a list of detached instances and new instances with assigned identifiers

upsert

public void upsert(String entityName,
 Object entity)

Description copied from interface: StatelessSession

Use a SQL merge into statement to perform an upsert.

Specified by:

upsert in interface StatelessSession

Parameters:

entityName - The entityName for the entity to be merged

entity - a detached entity instance

get

public <T> T get(Class<T> entityClass,
 Object id)

Description copied from interface: StatelessSession

Retrieve a record.

Specified by:

get in interface StatelessSession

Parameters:

entityClass - The class of the entity to retrieve

id - The id of the entity to retrieve

Returns:

a detached entity instance

get

public <T> T get(Class<T> entityClass,
 Object id,
 LockMode lockMode)

Description copied from interface: StatelessSession

Retrieve a record, obtaining the specified lock mode.

Specified by:

get in interface StatelessSession

Parameters:

entityClass - The class of the entity to retrieve

id - The id of the entity to retrieve

lockMode - The lock mode to apply to the entity

Returns:

a detached entity instance

get

public Object get(String entityName,
 Object id)

Description copied from interface: StatelessSession

Retrieve a record.

Specified by:

get in interface StatelessSession

Parameters:

entityName - The name of the entity to retrieve

id - The id of the entity to retrieve

Returns:

a detached entity instance

get

public Object get(String entityName,
 Object id,
 LockMode lockMode)

Description copied from interface: StatelessSession

Retrieve a record, obtaining the specified lock mode.

Specified by:

get in interface StatelessSession

Parameters:

entityName - The name of the entity to retrieve

id - The id of the entity to retrieve

lockMode - The lock mode to apply to the entity

Returns:

a detached entity instance

get

public <T> T get(EntityGraph<T> graph,
 GraphSemantic graphSemantic,
 Object id)

Description copied from interface: StatelessSession

Retrieve a record, fetching associations specified by the given EntityGraph.

Specified by:

get in interface StatelessSession

Parameters:

graph - The EntityGraph

graphSemantic - a GraphSemantic specifying how the graph should be interpreted

id - The id of the entity to retrieve

Returns:

a detached entity instance

get

public <T> T get(EntityGraph<T> graph,
 GraphSemantic graphSemantic,
 Object id,
 LockMode lockMode)

Description copied from interface: StatelessSession

Retrieve a record, fetching associations specified by the given EntityGraph, and obtaining the specified lock mode.

Specified by:

get in interface StatelessSession

Parameters:

graph - The EntityGraph

graphSemantic - a GraphSemantic specifying how the graph should be interpreted

id - The id of the entity to retrieve

lockMode - The lock mode to apply to the entity

Returns:

a detached entity instance

getMultiple

public <T> List<T> getMultiple(Class<T> entityClass,
 List<Object> ids)

Description copied from interface: StatelessSession

Retrieve multiple rows, returning entity instances in a list where the position of an instance in the list matches the position of its identifier in the given array, and the list contains a null value if there is no persistent instance matching a given identifier.

Specified by:

getMultiple in interface StatelessSession

Parameters:

entityClass - The class of the entity to retrieve

ids - The ids of the entities to retrieve

Returns:

an ordered list of detached entity instances, with null elements representing missing entities

refresh

public void refresh(Object entity)

Description copied from interface: StatelessSession

Refresh the entity instance state from the database.

Specified by:

refresh in interface StatelessSession

Parameters:

entity - The entity to be refreshed.

refresh

public void refresh(String entityName,
 Object entity)

Description copied from interface: StatelessSession

Refresh the entity instance state from the database.

Specified by:

refresh in interface StatelessSession

Parameters:

entityName - The entityName for the entity to be refreshed.

entity - The entity to be refreshed.

refresh

public void refresh(Object entity,
 LockMode lockMode)

Description copied from interface: StatelessSession

Refresh the entity instance state from the database.

Specified by:

refresh in interface StatelessSession

Parameters:

entity - The entity to be refreshed.

lockMode - The LockMode to be applied.

refresh

public void refresh(String entityName,
 Object entity,
 LockMode lockMode)

Description copied from interface: StatelessSession

Refresh the entity instance state from the database.

Specified by:

refresh in interface StatelessSession

Parameters:

entityName - The entityName for the entity to be refreshed.

entity - The entity to be refreshed.

lockMode - The LockMode to be applied.

immediateLoad

public Object immediateLoad(String entityName,
 Object id)
                     throws HibernateException

Description copied from interface: SharedSessionContractImplementor

Load an instance immediately. This method is only called when lazily initializing a proxy. Do not return the proxy.

Specified by:

immediateLoad in interface SharedSessionContractImplementor

Throws:

HibernateException

initializeCollection

public void initializeCollection(PersistentCollection<?> collection,
 boolean writing)
                          throws HibernateException

Description copied from interface: SharedSessionContractImplementor

Initialize the given collection (if not already initialized).

Specified by:

initializeCollection in interface SharedSessionContractImplementor

Throws:

HibernateException

instantiate

public Object instantiate(String entityName,
 Object id)
                   throws HibernateException

Description copied from interface: SharedSessionContractImplementor

Instantiate the entity class, initializing with the given identifier.

Specified by:

instantiate in interface SharedSessionContractImplementor

Throws:

HibernateException

instantiate

public Object instantiate(EntityPersister persister,
 Object id)
                   throws HibernateException

Description copied from interface: SharedSessionContractImplementor

Instantiate the entity class of the given EntityPersister, initializing the new instance with the given identifier.

This is more efficient than SharedSessionContractImplementor.instantiate(String, Object), but not always interchangeable, since a single persister might be responsible for multiple types.

Specified by:

instantiate in interface SharedSessionContractImplementor

Throws:

HibernateException

internalLoad

public Object internalLoad(String entityName,
 Object id,
 boolean eager,
 boolean nullable)
                    throws HibernateException

Description copied from interface: SharedSessionContractImplementor

Obtain an entity instance with the given id, without checking if it was deleted or scheduled for deletion.

• When nullable = false, this method may create a new proxy or return an existing proxy; if it does not exist, an exception is thrown.
• When nullable = true, the method does not create new proxies, though it might return an existing proxy; if it does not exist, a null value is returned.

When eager = true, the object is eagerly fetched from the database.

Specified by:

internalLoad in interface SharedSessionContractImplementor

Throws:

HibernateException

fetch

public void fetch(Object association)

Description copied from interface: StatelessSession

Fetch an association or collection that's configured for lazy loading.

 Book book = session.get(Book.class, isbn);  // book is immediately detached
 session.fetch(book.getAuthors());           // fetch the associated authors
 book.getAuthors().forEach(author -> ... );  // iterate the collection
 

Warning: this operation in a stateless session is quite sensitive to data aliasing effects and should be used with great care. It's usually better to fetch associations using eager join fetching.

Specified by:

fetch in interface StatelessSession

Parameters:

association - a lazy-loaded association

See Also:

• Hibernate.initialize(Object)

getIdentifier

public Object getIdentifier(Object entity)
                     throws HibernateException

Description copied from interface: StatelessSession

Return the identifier value of the given entity, which may be detached.

Specified by:

getIdentifier in interface StatelessSession

Parameters:

entity - a persistent instance associated with this session

Returns:

the identifier

Throws:

HibernateException

isAutoCloseSessionEnabled

public boolean isAutoCloseSessionEnabled()

Description copied from interface: SharedSessionContractImplementor

Is auto-close at transaction completion enabled?

Specified by:

isAutoCloseSessionEnabled in interface SharedSessionContractImplementor

See Also:

• TransactionSettings.AUTO_CLOSE_SESSION
• SessionFactoryOptions.isAutoCloseSessionEnabled()

shouldAutoClose

public boolean shouldAutoClose()

Description copied from interface: SharedSessionContractImplementor

Should this session be automatically closed after the current transaction completes?

Specified by:

shouldAutoClose in interface SharedSessionContractImplementor

bestGuessEntityName

public String bestGuessEntityName(Object object)

Description copied from interface: SharedSessionContractImplementor

Obtain the best estimate of the entity name of the given entity instance, which is not involved in an association, by also considering information held in the proxy, and whether the object is already associated with this session.

Specified by:

bestGuessEntityName in interface SharedSessionContractImplementor

getCacheMode

public CacheMode getCacheMode()

Description copied from interface: SharedSessionContractImplementor

Get the current CacheMode for this session.

Specified by:

getCacheMode in interface QueryProducerImplementor

Specified by:

getCacheMode in interface SharedSessionContractImplementor

Overrides:

getCacheMode in class AbstractSharedSessionContract

setCacheMode

public void setCacheMode(CacheMode cm)

Description copied from interface: SharedSessionContractImplementor

Set the current CacheMode for this session.

Specified by:

setCacheMode in interface SharedSessionContractImplementor

Overrides:

setCacheMode in class AbstractSharedSessionContract

setHibernateFlushMode

public void setHibernateFlushMode(FlushMode flushMode)

Description copied from interface: SharedSessionContractImplementor

Set the current FlushMode for this session.

The flush mode determines the points at which the session is flushed. Flushing is the process of synchronizing the underlying persistent store with persistable state held in memory.

For a logically "read-only" session, it's reasonable to set the session flush mode to FlushMode.MANUAL at the start of the session (in order skip some work and gain some extra performance).

Specified by:

setHibernateFlushMode in interface SharedSessionContractImplementor

Overrides:

setHibernateFlushMode in class AbstractSharedSessionContract

Parameters:

flushMode - the new flush mode

getContextEntityIdentifier

public Object getContextEntityIdentifier(Object object)

Description copied from interface: SharedSessionContractImplementor

Return the identifier of the persistent object, or null if it is not associated with this session.

Specified by:

getContextEntityIdentifier in interface SharedSessionContractImplementor

guessEntityName

public String guessEntityName(Object entity)
                       throws HibernateException

Description copied from interface: SharedSessionContractImplementor

Obtain an estimate of the entity name of the given entity instance, which is not involved in an association, using only the EntityNameResolver.

Specified by:

guessEntityName in interface SharedSessionContractImplementor

Throws:

HibernateException

getEntityPersister

public EntityPersister getEntityPersister(String entityName,
 Object object)
                                   throws HibernateException

Description copied from interface: SharedSessionContractImplementor

Get the EntityPersister for the given entity instance.

Specified by:

getEntityPersister in interface SharedSessionContractImplementor

Parameters:

entityName - optional entity name

object - the entity instance

Throws:

HibernateException

getEntityUsingInterceptor

public Object getEntityUsingInterceptor(EntityKey key)
                                 throws HibernateException

Description copied from interface: SharedSessionContractImplementor

Get the entity instance associated with the given EntityKey, calling the Interceptor if necessary.

Specified by:

getEntityUsingInterceptor in interface SharedSessionContractImplementor

Throws:

HibernateException

getPersistenceContext

public PersistenceContext getPersistenceContext()

Description copied from interface: SharedSessionContractImplementor

Get the persistence context for this session.

See SharedSessionContractImplementor.getPersistenceContextInternal() for a faster alternative.

Specified by:

getPersistenceContext in interface SharedSessionContractImplementor

setAutoClear

public void setAutoClear(boolean enabled)

Description copied from interface: SharedSessionContractImplementor

Enable or disable automatic cache clearing from after transaction completion.

Specified by:

setAutoClear in interface SharedSessionContractImplementor

isDefaultReadOnly

public boolean isDefaultReadOnly()

Description copied from interface: SharedSessionContractImplementor

Are entities and proxies loaded by this session read-only by default?

Specified by:

isDefaultReadOnly in interface SharedSessionContractImplementor

setDefaultReadOnly

public void setDefaultReadOnly(boolean readOnly)
                        throws HibernateException

Throws:

HibernateException

afterOperation

public void afterOperation(boolean success)

Description copied from interface: SharedSessionContractImplementor

Check if there is a Hibernate or JTA transaction in progress and, if there is not, flush if necessary, making sure that the connection has been committed (if it is not in autocommit mode), and finally run the after completion processing.

Specified by:

afterOperation in interface SharedSessionContractImplementor

Parameters:

success - true if the operation a success

afterScrollOperation

public void afterScrollOperation()

Description copied from interface: SharedSessionContractImplementor

Called after each operation on a ScrollableResults, providing an opportunity for a stateless session to clear its temporary persistence context. For a stateful session, this method does nothing.

Specified by:

afterScrollOperation in interface SharedSessionContractImplementor

flush

public void flush()

Description copied from interface: SharedSessionContractImplementor

Flush this session.

Specified by:

flush in interface SharedSessionContractImplementor

getLoadQueryInfluencers

public LoadQueryInfluencers getLoadQueryInfluencers()

Description copied from interface: SharedSessionContractImplementor

Get the LoadQueryInfluencers associated with this session.

Specified by:

getLoadQueryInfluencers in interface SharedSessionContractImplementor

Returns:

the LoadQueryInfluencers associated with this session; should never be null.

getPersistenceContextInternal

public PersistenceContext getPersistenceContextInternal()

Description copied from interface: SharedSessionContractImplementor

Similar to SharedSessionContractImplementor.getPersistenceContext(), with two differences:

1. this version performs better as it allows for inlining and probably better prediction, and
2. it skips some checks of the current state of the session.

Choose wisely: performance is important, but correctness comes first.

Specified by:

getPersistenceContextInternal in interface SharedSessionContractImplementor

Returns:

the PersistenceContext associated to this session.

autoFlushIfRequired

public boolean autoFlushIfRequired(Set<String> querySpaces)
                            throws HibernateException

Description copied from interface: SharedSessionContractImplementor

detect in-memory changes, determine if the changes are to tables named in the query and, if so, complete execution the flush

Specified by:

autoFlushIfRequired in interface SharedSessionContractImplementor

Parameters:

querySpaces - the tables named in the query.

Returns:

true if flush is required, false otherwise.

Throws:

HibernateException

afterTransactionBegin

public void afterTransactionBegin()

Description copied from interface: JdbcSessionOwner

An after-begin callback from the coordinator to its owner.

Specified by:

afterTransactionBegin in interface JdbcSessionOwner

beforeTransactionCompletion

public void beforeTransactionCompletion()

Description copied from interface: JdbcSessionOwner

A before-completion callback to the owner.

Specified by:

beforeTransactionCompletion in interface JdbcSessionOwner

Overrides:

beforeTransactionCompletion in class AbstractSharedSessionContract

afterTransactionCompletion

public void afterTransactionCompletion(boolean successful,
 boolean delayed)

Description copied from interface: JdbcSessionOwner

An after-completion callback to the owner.

Specified by:

afterTransactionCompletion in interface JdbcSessionOwner

Overrides:

afterTransactionCompletion in class AbstractSharedSessionContract

Parameters:

successful - Was the transaction successful?

delayed - Is this a delayed after transaction completion call (aka after a timeout)?

isTransactionInProgress

public boolean isTransactionInProgress()

Description copied from interface: SharedSessionContractImplementor

Does this session have an active Hibernate transaction, or is it associated with a JTA transaction currently in progress?

Specified by:

isTransactionInProgress in interface SharedSessionContractImplementor

Overrides:

isTransactionInProgress in class AbstractSharedSessionContract

flushBeforeTransactionCompletion

public void flushBeforeTransactionCompletion()

Specified by:

flushBeforeTransactionCompletion in interface JdbcSessionOwner

asStatelessSession

public StatelessSession asStatelessSession()

Description copied from interface: SharedSessionContractImplementor

Cast this object to StatelessSession, if possible.

Specified by:

asStatelessSession in interface SharedSessionContractImplementor

isStatelessSession

public boolean isStatelessSession()

Description copied from interface: SharedSessionContractImplementor

Does this object implement StatelessSession?

Specified by:

isStatelessSession in interface SharedSessionContractImplementor