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

Implementation Note:

The StatelessSessionImpl is not an EventSource and does not make use of the usual eventing infrastructure to implement persistence operations. It does raise pre- and post- events for the benefit of integration, however. Since it performs all operations synchronously, it does not maintain an ActionQueue. Therefore, it cannot, unfortunately, reuse the various EntityAction subtypes. This is a pity, since it results in some code duplication. On the other hand, a StatelessSession is easier to debug and understand. A StatelessSession does hold state in a long-lived PersistenceContext, but it does temporarily keep state within an instance of StatefulPersistenceContext while processing the results of a given query.

Nested Class Summary

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

LobCreationContext.Callback<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final MultiIdLoadOptions	MULTI_ID_LOAD_OPTIONS

Fields inherited from class org.hibernate.internal.AbstractSharedSessionContract

closed, 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.
boolean	autoFlushIfRequired(Set<String> querySpaces, boolean skipPreFlush)	detect in-memory changes, determine if the changes are to tables named in the query and, if so, complete execution the flush
void	autoPreFlush()
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<?> entities)	Delete multiple records.
void	fetch(Object association)	Fetch an association or collection that's configured for lazy loading.
protected void	firePostDelete(Object entity, Object id, EntityPersister persister)
protected void	firePostInsert(Object entity, Object id, Object[] state, EntityPersister persister)
protected void	firePostRecreate(PersistentCollection<?> collection, Object id, String entityName, Object owner)
protected void	firePostRemove(PersistentCollection<?> collection, Object id, String entityName, Object owner)
protected void	firePostUpdate(Object entity, Object id, Object[] state, EntityPersister persister)
protected void	firePostUpdate(PersistentCollection<?> collection, Object id, String entityName, Object owner)
protected void	firePostUpsert(Object entity, Object id, Object[] state, EntityPersister persister)
protected boolean	firePreDelete(Object entity, Object id, EntityPersister persister)
protected boolean	firePreInsert(Object entity, Object id, Object[] state, EntityPersister persister)
protected void	firePreRecreate(PersistentCollection<?> collection, Object id, String entityName, Object owner)
protected void	firePreRemove(PersistentCollection<?> collection, Object id, String entityName, Object owner)
protected boolean	firePreUpdate(Object entity, Object id, Object[] state, EntityPersister persister)
protected void	firePreUpdate(PersistentCollection<?> collection, Object id, String entityName, Object owner)
protected boolean	firePreUpsert(Object entity, Object id, Object[] state, EntityPersister persister)
void	flush()	Flush this session.
void	flushBeforeTransactionCompletion()
protected void	forEachOwnedCollection(Object entity, Object key, EntityPersister persister, BiConsumer<CollectionPersister,PersistentCollection<?>> action)
<T> T	get(EntityGraph<T> graph, Object id)	Retrieve a record, fetching associations specified by the given EntityGraph, which is interpreted as a load graph.
<T> T	get(EntityGraph<T> graph, Object id, LockMode lockMode)	Retrieve a record, fetching associations specified by the given EntityGraph, which is interpreted as a load graph, and obtaining the specified lock mode.
<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.
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 entity)	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.
FlushMode	getHibernateFlushMode()	Get the current FlushMode for this session.
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(EntityGraph<T> entityGraph, List<?> ids)	Retrieve multiple rows, returning instances of the root entity of the given EntityGraph with the fetched associations specified by the graph, 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.
<T> List<T>	getMultiple(EntityGraph<T> entityGraph, GraphSemantic graphSemantic, List<?> ids)	Retrieve multiple rows, returning instances of the root entity of the given EntityGraph with the fetched associations specified by the graph, 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.
<T> List<T>	getMultiple(Class<T> entityClass, List<?> 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.
<T> List<T>	getMultiple(Class<T> entityClass, List<?> ids, LockMode lockMode)	Retrieve multiple rows, obtaining the specified lock mode, and 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.
protected Object	idToUpsert(Object entity, EntityPersister persister)
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<?> entities)	Insert multiple records.
Object	instantiate(String entityName, Object id)	Deprecated.
Object	instantiate(EntityPersister persister, Object id)	Instantiate the entity class of the given EntityPersister, initializing the new instance with the given identifier.
protected PersistentCollection<?>	instantiateEmpty(Object key, CollectionPersister descriptor)
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.
protected Object	internalLoadGet(String entityName, Object id, PersistenceContext persistenceContext)
boolean	isAutoCloseSessionEnabled()
boolean	isDefaultReadOnly()	Are entities and proxies loaded by this session read-only by default?
boolean	isIdentifierRollbackEnabled()
boolean	isTransactionInProgress()	Does this session have an active Hibernate transaction, or is it associated with a JTA transaction currently in progress?
Object	loadFromSecondLevelCache(EntityPersister persister, EntityKey entityKey, Object instanceToLoad, LockMode lockMode)	Attempts to load the entity from the second-level cache.
void	lock(String entityName, Object child, LockOptions lockOptions)	Cascade the lock operation to the given child entity.
protected Object	lockCacheItem(Object id, Object previousVersion, EntityPersister persister)
protected Object	lockCacheItem(Object key, CollectionPersister persister)
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	registerProcess(AfterTransactionCompletionProcess process)	Registers the given process for execution after transaction completion.
protected void	removeCacheItem(Object ck, CollectionPersister persister)
protected void	removeCacheItem(Object ck, EntityPersister persister)
boolean	shouldAutoClose()
boolean	shouldAutoJoinTransaction()	Indicates whether an active transaction should be automatically joined.
<T> T	unwrap(Class<T> type)	Return an object of the specified type to allow access to a provider-specific API.
void	update(Object entity)	Update a record.
void	update(String entityName, Object entity)	Update a record.
void	updateMultiple(List<?> 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<?> 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.
protected Object	versionToUpsert(Object entity, EntityPersister persister, Object[] state)
protected PersistentCollection<?>	wrap(CollectionPersister descriptor, Object collection, Object owner)

Methods inherited from class org.hibernate.internal.AbstractSharedSessionContract

accessTransaction, addSharedSessionTransactionObserver, afterObtainConnection, applyQuerySettingsAndHints, applyQuerySettingsAndHints, beforeReleaseConnection, beginTransaction, buildNamedQuery, checkMutationQuery, checkOpen, checkResultType, checkSelectionQuery, checkTransactionNeededForUpdateOperation, checkTransactionSynchStatus, cleanupOnClose, close, createCriteriaQuery, createEntityGraph, createEntityGraph, createEntityGraph, createMutationQuery, createMutationQuery, createMutationQuery, createMutationQuery, createNamedMutationQuery, createNamedQuery, createNamedQuery, createNamedSelectionQuery, createNamedSelectionQuery, createNamedStoredProcedureQuery, createNativeMutationQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQuery, createNativeQueryImplementor, createNativeQueryImplementor, createNativeQueryImplementor, createQuery, createQuery, createQuery, createQuery, createQuery, createQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery, createSelectionQuery, createSqmQueryImplementor, createSqmQueryImplementor, createSqmQueryImplementor, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureCall, createStoredProcedureQuery, createStoredProcedureQuery, createStoredProcedureQuery, delayedAfterCompletion, disableFilter, doReturningWork, doWork, enableFilter, execute, generateEntityKey, getCacheMode, getCacheTransactionSynchronization, getConfiguredJdbcBatchSize, getCriteriaBuilder, getCurrentTransaction, getDialect, getEnabledFilter, getEntityGraph, getEntityGraphs, getEntityNameResolver, getEventListenerManager, getEventMonitor, getExceptionConverter, getFactory, getInterceptor, getJdbcBatchSize, getJdbcConnectionAccess, getJdbcCoordinator, getJdbcServices, getJdbcSessionContext, getJdbcTimeZone, getJsonFormatMapper, getLobCreator, getNamedNativeQuery, getNamedNativeQuery, getNamedProcedureCall, getNamedQuery, getNativeJdbcParametersIgnored, getPreferredSqlTypeCodeForBoolean, getResultSetMappingMemento, getSessionAssociationMarkers, getSessionFactory, getSessionIdentifier, getSessionToken, getTenantIdentifier, getTenantIdentifierValue, getTransaction, getTransactionCoordinator, getTypeConfiguration, getXmlFormatMapper, interpretHql, isClosed, isConnected, isCriteriaCopyTreeEnabled, isCriteriaPlanCacheEnabled, isJoinedToTransaction, isOpen, isOpenOrWaitingForAutoClose, joinTransaction, markForRollbackOnly, prepareForAutoClose, prepareForQueryExecution, pulseTransactionCoordinator, removeSharedSessionTransactionObserver, requireCollectionPersister, requireEntityPersister, requireEntityPersister, setCacheMode, setClosed, setCriteriaCopyTreeEnabled, setCriteriaPlanCacheEnabled, 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

getEventManager, getSqlExceptionHelper

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

fromContext

Methods inherited from interface org.hibernate.query.QueryProducer

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

Methods inherited from interface org.hibernate.SharedSessionContract

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

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

asEventSource, asSessionImplementor, asStatelessSession, autoFlushIfRequired, bestGuessEntityName, checkOpen, getSession, isEventSource, isSessionImplementor, isStatelessSession

Methods inherited from interface org.hibernate.StatelessSession

close

Field Details

MULTI_ID_LOAD_OPTIONS

public static final MultiIdLoadOptions MULTI_ID_LOAD_OPTIONS

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).

getHibernateFlushMode

public FlushMode getHibernateFlushMode()

Description copied from interface: SharedSessionContractImplementor

Get the current FlushMode for this session.

Specified by:

getHibernateFlushMode in interface QueryProducerImplementor

Specified by:

getHibernateFlushMode in interface SharedSessionContractImplementor

Returns:

The flush mode

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<?> 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<?> 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<?> 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<?> 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

versionToUpsert

protected Object versionToUpsert(Object entity,
 EntityPersister persister,
 Object[] state)

idToUpsert

protected Object idToUpsert(Object entity,
 EntityPersister persister)

firePreInsert

protected boolean firePreInsert(Object entity,
 Object id,
 Object[] state,
 EntityPersister persister)

firePreUpdate

protected boolean firePreUpdate(Object entity,
 Object id,
 Object[] state,
 EntityPersister persister)

firePreUpsert

protected boolean firePreUpsert(Object entity,
 Object id,
 Object[] state,
 EntityPersister persister)

firePreDelete

protected boolean firePreDelete(Object entity,
 Object id,
 EntityPersister persister)

firePostInsert

protected void firePostInsert(Object entity,
 Object id,
 Object[] state,
 EntityPersister persister)

firePostUpdate

protected void firePostUpdate(Object entity,
 Object id,
 Object[] state,
 EntityPersister persister)

firePostUpsert

protected void firePostUpsert(Object entity,
 Object id,
 Object[] state,
 EntityPersister persister)

firePostDelete

protected void firePostDelete(Object entity,
 Object id,
 EntityPersister persister)

firePreRecreate

protected void firePreRecreate(PersistentCollection<?> collection,
 Object id,
 String entityName,
 Object owner)

firePreUpdate

protected void firePreUpdate(PersistentCollection<?> collection,
 Object id,
 String entityName,
 Object owner)

firePreRemove

protected void firePreRemove(PersistentCollection<?> collection,
 Object id,
 String entityName,
 Object owner)

firePostRecreate

protected void firePostRecreate(PersistentCollection<?> collection,
 Object id,
 String entityName,
 Object owner)

firePostUpdate

protected void firePostUpdate(PersistentCollection<?> collection,
 Object id,
 String entityName,
 Object owner)

firePostRemove

protected void firePostRemove(PersistentCollection<?> collection,
 Object id,
 String entityName,
 Object owner)

forEachOwnedCollection

protected void forEachOwnedCollection(Object entity,
 Object key,
 EntityPersister persister,
 BiConsumer<CollectionPersister,PersistentCollection<?>> action)

instantiateEmpty

protected PersistentCollection<?> instantiateEmpty(Object key,
 CollectionPersister descriptor)

wrap

protected PersistentCollection<?> wrap(CollectionPersister descriptor,
 Object collection,
 Object owner)

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, or null if there is no instance with the given id

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, or null if there is no instance with the given id

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, or null if there is no instance with the given id

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, or null if there is no instance with the given id

get

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

Description copied from interface: StatelessSession

Retrieve a record, fetching associations specified by the given EntityGraph, which is interpreted as a load graph.

Specified by:

get in interface StatelessSession

Parameters:

graph - The EntityGraph, interpreted as a load graph

id - The id of the entity to retrieve

Returns:

a detached entity instance, or null if there is no instance with the given id

get

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

Description copied from interface: StatelessSession

Retrieve a record, fetching associations specified by the given EntityGraph, which is interpreted as a load graph, and obtaining the specified lock mode.

Specified by:

get in interface StatelessSession

Parameters:

graph - The EntityGraph, interpreted as a load graph

id - The id of the entity to retrieve

lockMode - The lock mode to apply to the entity

Returns:

a detached entity instance, or null if there is no instance with the given id

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, or null if there is no instance with the given id

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, or null if there is no instance with the given id

getMultiple

public <T> List<T> getMultiple(Class<T> entityClass,
 List<?> ids,
 LockMode lockMode)

Description copied from interface: StatelessSession

Retrieve multiple rows, obtaining the specified lock mode, and 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

lockMode - The lock mode to apply to the entities

Returns:

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

getMultiple

public <T> List<T> getMultiple(EntityGraph<T> entityGraph,
 List<?> ids)

Description copied from interface: StatelessSession

Retrieve multiple rows, returning instances of the root entity of the given EntityGraph with the fetched associations specified by the graph, 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:

entityGraph - The EntityGraph, interpreted as a load graph

ids - The ids of the entities to retrieve

Returns:

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

getMultiple

public <T> List<T> getMultiple(EntityGraph<T> entityGraph,
 GraphSemantic graphSemantic,
 List<?> ids)

Description copied from interface: StatelessSession

Retrieve multiple rows, returning instances of the root entity of the given EntityGraph with the fetched associations specified by the graph, 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:

entityGraph - The EntityGraph

graphSemantic - a GraphSemantic specifying how the graph should be interpreted

ids - The ids of the entities to retrieve

Returns:

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

getMultiple

public <T> List<T> getMultiple(Class<T> entityClass,
 List<?> 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)

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

initializeCollection

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

Description copied from interface: SharedSessionContractImplementor

Initialize the given collection (if not already initialized).

Specified by:

initializeCollection in interface SharedSessionContractImplementor

instantiate

@Deprecated
public Object instantiate(String entityName,
 Object id)

Deprecated.

Description copied from interface: SharedSessionContractImplementor

Instantiate the entity class, initializing with the given identifier.

Specified by:

instantiate in interface SharedSessionContractImplementor

instantiate

public Object instantiate(EntityPersister persister,
 Object id)

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

internalLoad

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

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

internalLoadGet

protected Object internalLoadGet(String entityName,
 Object id,
 PersistenceContext persistenceContext)

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)

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

isAutoCloseSessionEnabled

public boolean isAutoCloseSessionEnabled()

shouldAutoClose

public boolean shouldAutoClose()

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

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)

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

getEntityPersister

public EntityPersister getEntityPersister(String entityName,
 Object entity)

Description copied from interface: SharedSessionContractImplementor

Get the EntityPersister for the given entity instance.

Specified by:

getEntityPersister in interface SharedSessionContractImplementor

Parameters:

entityName - optional entity name

entity - the entity instance

getEntityUsingInterceptor

public Object getEntityUsingInterceptor(EntityKey key)

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

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

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

isIdentifierRollbackEnabled

public boolean isIdentifierRollbackEnabled()

Specified by:

isIdentifierRollbackEnabled in interface SharedSessionContractImplementor

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

autoPreFlush

public void autoPreFlush()

Specified by:

autoPreFlush 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,
 boolean skipPreFlush)

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.

skipPreFlush - see AutoFlushEvent.isSkipPreFlush()

Returns:

true if flush is required, false otherwise.

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

lockCacheItem

protected Object lockCacheItem(Object id,
 Object previousVersion,
 EntityPersister persister)

removeCacheItem

protected void removeCacheItem(Object ck,
 EntityPersister persister)

lockCacheItem

protected Object lockCacheItem(Object key,
 CollectionPersister persister)

removeCacheItem

protected void removeCacheItem(Object ck,
 CollectionPersister persister)

registerProcess

public void registerProcess(AfterTransactionCompletionProcess process)

Description copied from interface: SharedSessionContractImplementor

Registers the given process for execution after transaction completion.

Specified by:

registerProcess in interface SharedSessionContractImplementor

Parameters:

process - The process to register

lock

public void lock(String entityName,
 Object child,
 LockOptions lockOptions)

Description copied from interface: SharedSessionContractImplementor

Cascade the lock operation to the given child entity.

Specified by:

lock in interface SharedSessionContractImplementor

loadFromSecondLevelCache

public Object loadFromSecondLevelCache(EntityPersister persister,
 EntityKey entityKey,
 Object instanceToLoad,
 LockMode lockMode)

Description copied from interface: SharedSessionContractImplementor

Attempts to load the entity from the second-level cache.

Specified by:

loadFromSecondLevelCache in interface SharedSessionContractImplementor

Parameters:

persister - The persister for the entity being requested for load

entityKey - The entity key

instanceToLoad - The instance that is being initialized, or null

lockMode - The lock mode

Returns:

The entity from the second-level cache, or null.

unwrap

public <T> T unwrap(Class<T> type)

Description copied from interface: SharedSessionContract

Return an object of the specified type to allow access to a provider-specific API.

Specified by:

unwrap in interface SharedSessionContract

Parameters:

type - the class of the object to be returned. This is usually either the underlying class implementing SharedSessionContract or an interface it implements.

Returns:

an instance of the specified class