org.hibernate.jpa.spi

Class AbstractEntityManagerImpl

java.lang.Object

org.hibernate.jpa.spi.AbstractEntityManagerImpl

All Implemented Interfaces:

java.io.Serializable, javax.persistence.EntityManager, HibernateEntityManager, HibernateEntityManagerFactoryAware, HibernateEntityManagerImplementor

Direct Known Subclasses:

AbstractEntityManagerImpl

public abstract class AbstractEntityManagerImpl
extends java.lang.Object
implements HibernateEntityManagerImplementor, java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractEntityManagerImpl.TupleBuilderTransformer

Nested classes/interfaces inherited from interface org.hibernate.jpa.spi.HibernateEntityManagerImplementor

HibernateEntityManagerImplementor.QueryOptions

Field Summary

Fields

Modifier and Type	Field and Description
protected TransactionImpl	tx

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEntityManagerImpl(EntityManagerFactoryImpl entityManagerFactory, javax.persistence.PersistenceContextType type, javax.persistence.SynchronizationType synchronizationType, javax.persistence.spi.PersistenceUnitTransactionType transactionType, java.util.Map properties)

Method Summary

Modifier and Type	Method and Description
protected void	applySavedSettings(NamedQueryDefinition namedQueryDefinition, QueryImpl jpaQuery)
protected abstract void	checkOpen()
void	clear()
boolean	contains(java.lang.Object entity)
java.lang.RuntimeException	convert(HibernateException e) Converts a Hibernate-specific exception into a JPA-specified exception; note that the JPA sepcification makes use of exceptions outside its exception hierarchy, though they are all runtime exceptions.
java.lang.RuntimeException	convert(HibernateException e, LockOptions lockOptions) Converts a Hibernate-specific exception into a JPA-specified exception; note that the JPA sepcification makes use of exceptions outside its exception hierarchy, though they are all runtime exceptions.
java.lang.RuntimeException	convert(java.lang.RuntimeException e)
java.lang.RuntimeException	convert(java.lang.RuntimeException e, LockOptions lockOptions)
protected QueryImpl	createNamedJpqlQuery(NamedQueryDefinition namedQueryDefinition, java.lang.Class resultType)
javax.persistence.Query	createNamedQuery(java.lang.String name)
<T> javax.persistence.TypedQuery<T>	createNamedQuery(java.lang.String name, java.lang.Class<T> resultClass)
protected QueryImpl	createNamedSqlQuery(NamedSQLQueryDefinition namedQueryDefinition, java.lang.Class resultType)
javax.persistence.StoredProcedureQuery	createNamedStoredProcedureQuery(java.lang.String name)
javax.persistence.Query	createNativeQuery(java.lang.String sqlString)
javax.persistence.Query	createNativeQuery(java.lang.String sqlString, java.lang.Class resultClass)
javax.persistence.Query	createNativeQuery(java.lang.String sqlString, java.lang.String resultSetMapping)
javax.persistence.Query	createQuery(javax.persistence.criteria.CriteriaDelete criteriaDelete)
<T> javax.persistence.TypedQuery<T>	createQuery(javax.persistence.criteria.CriteriaQuery<T> criteriaQuery)
javax.persistence.Query	createQuery(javax.persistence.criteria.CriteriaUpdate criteriaUpdate)
javax.persistence.Query	createQuery(java.lang.String jpaqlString)
<T> javax.persistence.TypedQuery<T>	createQuery(java.lang.String jpaqlString, java.lang.Class<T> resultClass)
<T> QueryImpl<T>	createQuery(java.lang.String jpaqlString, java.lang.Class<T> resultClass, javax.persistence.criteria.Selection selection, HibernateEntityManagerImplementor.QueryOptions queryOptions) Used during "compiling" a JPA criteria query.
javax.persistence.StoredProcedureQuery	createStoredProcedureQuery(java.lang.String procedureName)
javax.persistence.StoredProcedureQuery	createStoredProcedureQuery(java.lang.String procedureName, java.lang.Class... resultClasses)
javax.persistence.StoredProcedureQuery	createStoredProcedureQuery(java.lang.String procedureName, java.lang.String... resultSetMappings)
protected CriteriaCompiler	criteriaCompiler()
void	detach(java.lang.Object entity)
CacheMode	determineAppropriateLocalCacheMode(java.util.Map<java.lang.String,java.lang.Object> localProperties)
<A> A	find(java.lang.Class<A> entityClass, java.lang.Object primaryKey)
<A> A	find(java.lang.Class<A> entityClass, java.lang.Object primaryKey, javax.persistence.LockModeType lockModeType)
<A> A	find(java.lang.Class<A> entityClass, java.lang.Object primaryKey, javax.persistence.LockModeType lockModeType, java.util.Map<java.lang.String,java.lang.Object> properties)
<T> T	find(java.lang.Class<T> entityClass, java.lang.Object primaryKey, java.util.Map<java.lang.String,java.lang.Object> properties)
void	flush()
javax.persistence.criteria.CriteriaBuilder	getCriteriaBuilder()
java.lang.Object	getDelegate() returns the underlying session
EntityManagerFactoryImpl	getEntityManagerFactory()
HibernateEntityManagerFactory	getFactory() Get access to the Hibernate extended EMF contract.
javax.persistence.FlushModeType	getFlushMode() Hibernate can be set in various flush modes that are unknown to JPA 2.0.
javax.persistence.LockModeType	getLockMode(java.lang.Object entity)
LockOptions	getLockRequest(javax.persistence.LockModeType lockModeType, java.util.Map<java.lang.String,java.lang.Object> properties) Convert from JPA 2 LockModeType & properties into LockOptions
javax.persistence.metamodel.Metamodel	getMetamodel()
java.util.Map<java.lang.String,java.lang.Object>	getProperties()
protected abstract Session	getRawSession() Deprecated. Deprecated in favor of getRawSession()
<T> T	getReference(java.lang.Class<T> entityClass, java.lang.Object primaryKey)
abstract Session	getSession() return a Session
javax.persistence.SynchronizationType	getSynchronizationType()
javax.persistence.EntityTransaction	getTransaction()
javax.persistence.spi.PersistenceUnitTransactionType	getTransactionType()
void	handlePersistenceException(javax.persistence.PersistenceException e) Handles marking for rollback and other such operations that need to occur depending on the type of exception being handled.
protected EntityManagerFactoryImpl	internalGetEntityManagerFactory()
protected abstract Session	internalGetSession() Return a Session without any validation checks.
boolean	isJoinedToTransaction()
boolean	isTransactionInProgress() Provides access to whether a transaction is currently in progress.
void	joinTransaction()
void	lock(java.lang.Object entity, javax.persistence.LockModeType lockMode)
void	lock(java.lang.Object entity, javax.persistence.LockModeType lockModeType, java.util.Map<java.lang.String,java.lang.Object> properties)
void	markForRollbackOnly() Used to mark a transaction for rollback only (when that is the JPA spec defined behavior).
<A> A	merge(A entity)
void	persist(java.lang.Object entity)
protected void	postInit()
void	refresh(java.lang.Object entity)
void	refresh(java.lang.Object entity, javax.persistence.LockModeType lockModeType)
void	refresh(java.lang.Object entity, javax.persistence.LockModeType lockModeType, java.util.Map<java.lang.String,java.lang.Object> properties)
void	refresh(java.lang.Object entity, java.util.Map<java.lang.String,java.lang.Object> properties)
void	remove(java.lang.Object entity)
protected void	resultClassChecking(java.lang.Class resultType, NamedSQLQueryDefinition namedQueryDefinition)
protected void	resultClassChecking(java.lang.Class resultClass, Query hqlQuery)
void	setFlushMode(javax.persistence.FlushModeType flushModeType)
void	setProperty(java.lang.String s, java.lang.Object o)
void	throwPersistenceException(HibernateException e) Delegates to HibernateEntityManagerImplementor.convert(org.hibernate.HibernateException, org.hibernate.LockOptions) and then throws the given exception.
void	throwPersistenceException(javax.persistence.PersistenceException e) Delegates to HibernateEntityManagerImplementor.handlePersistenceException(javax.persistence.PersistenceException) and then throws the given exception.
<T> T	unwrap(java.lang.Class<T> clazz)
protected QueryImpl	wrapAsJpaQuery(NamedQueryDefinition namedQueryDefinition, Query hibQuery)
javax.persistence.PersistenceException	wrapLockException(HibernateException e, LockOptions lockOptions)
javax.persistence.PersistenceException	wrapStaleStateException(StaleStateException e)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hibernate.jpa.spi.HibernateEntityManagerImplementor

checkOpen

Methods inherited from interface javax.persistence.EntityManager

close, createEntityGraph, createEntityGraph, getEntityGraph, getEntityGraphs, isOpen

Field Detail

tx

protected transient TransactionImpl tx

Constructor Detail

AbstractEntityManagerImpl

protected AbstractEntityManagerImpl(EntityManagerFactoryImpl entityManagerFactory,
                                    javax.persistence.PersistenceContextType type,
                                    javax.persistence.SynchronizationType synchronizationType,
                                    javax.persistence.spi.PersistenceUnitTransactionType transactionType,
                                    java.util.Map properties)

Method Detail

getTransactionType

public javax.persistence.spi.PersistenceUnitTransactionType getTransactionType()

getSynchronizationType

public javax.persistence.SynchronizationType getSynchronizationType()

postInit

protected void postInit()

createQuery

public javax.persistence.Query createQuery(java.lang.String jpaqlString)

Specified by:

createQuery in interface javax.persistence.EntityManager

checkOpen

protected abstract void checkOpen()

createQuery

public <T> javax.persistence.TypedQuery<T> createQuery(java.lang.String jpaqlString,
                                                       java.lang.Class<T> resultClass)

Specified by:

createQuery in interface javax.persistence.EntityManager

resultClassChecking

protected void resultClassChecking(java.lang.Class resultClass,
                                   Query hqlQuery)

createQuery

public <T> QueryImpl<T> createQuery(java.lang.String jpaqlString,
                                    java.lang.Class<T> resultClass,
                                    javax.persistence.criteria.Selection selection,
                                    HibernateEntityManagerImplementor.QueryOptions queryOptions)

Description copied from interface: HibernateEntityManagerImplementor

Used during "compiling" a JPA criteria query.

Specified by:

createQuery in interface HibernateEntityManagerImplementor

Type Parameters:

T - The query type

Parameters:

jpaqlString - The criteria query rendered as a JPA QL string

resultClass - The result type (the type expected in the result list)

selection - The selection(s)

queryOptions - The options to use to build the query.

Returns:

The typed query

criteriaCompiler

protected CriteriaCompiler criteriaCompiler()

createQuery

public <T> javax.persistence.TypedQuery<T> createQuery(javax.persistence.criteria.CriteriaQuery<T> criteriaQuery)

Specified by:

createQuery in interface javax.persistence.EntityManager

createQuery

public javax.persistence.Query createQuery(javax.persistence.criteria.CriteriaUpdate criteriaUpdate)

Specified by:

createQuery in interface javax.persistence.EntityManager

createQuery

public javax.persistence.Query createQuery(javax.persistence.criteria.CriteriaDelete criteriaDelete)

Specified by:

createQuery in interface javax.persistence.EntityManager

createNamedQuery

public javax.persistence.Query createNamedQuery(java.lang.String name)

Specified by:

createNamedQuery in interface javax.persistence.EntityManager

createNamedJpqlQuery

protected QueryImpl createNamedJpqlQuery(NamedQueryDefinition namedQueryDefinition,
                                         java.lang.Class resultType)

wrapAsJpaQuery

protected QueryImpl wrapAsJpaQuery(NamedQueryDefinition namedQueryDefinition,
                                   Query hibQuery)

applySavedSettings

protected void applySavedSettings(NamedQueryDefinition namedQueryDefinition,
                                  QueryImpl jpaQuery)

createNamedSqlQuery

protected QueryImpl createNamedSqlQuery(NamedSQLQueryDefinition namedQueryDefinition,
                                        java.lang.Class resultType)

resultClassChecking

protected void resultClassChecking(java.lang.Class resultType,
                                   NamedSQLQueryDefinition namedQueryDefinition)

createNamedQuery

public <T> javax.persistence.TypedQuery<T> createNamedQuery(java.lang.String name,
                                                            java.lang.Class<T> resultClass)

Specified by:

createNamedQuery in interface javax.persistence.EntityManager

createNativeQuery

public javax.persistence.Query createNativeQuery(java.lang.String sqlString)

Specified by:

createNativeQuery in interface javax.persistence.EntityManager

createNativeQuery

public javax.persistence.Query createNativeQuery(java.lang.String sqlString,
                                                 java.lang.Class resultClass)

Specified by:

createNativeQuery in interface javax.persistence.EntityManager

createNativeQuery

public javax.persistence.Query createNativeQuery(java.lang.String sqlString,
                                                 java.lang.String resultSetMapping)

Specified by:

createNativeQuery in interface javax.persistence.EntityManager

createNamedStoredProcedureQuery

public javax.persistence.StoredProcedureQuery createNamedStoredProcedureQuery(java.lang.String name)

Specified by:

createNamedStoredProcedureQuery in interface javax.persistence.EntityManager

createStoredProcedureQuery

public javax.persistence.StoredProcedureQuery createStoredProcedureQuery(java.lang.String procedureName)

Specified by:

createStoredProcedureQuery in interface javax.persistence.EntityManager

createStoredProcedureQuery

public javax.persistence.StoredProcedureQuery createStoredProcedureQuery(java.lang.String procedureName,
                                                                         java.lang.Class... resultClasses)

Specified by:

createStoredProcedureQuery in interface javax.persistence.EntityManager

createStoredProcedureQuery

public javax.persistence.StoredProcedureQuery createStoredProcedureQuery(java.lang.String procedureName,
                                                                         java.lang.String... resultSetMappings)

Specified by:

createStoredProcedureQuery in interface javax.persistence.EntityManager

getReference

public <T> T getReference(java.lang.Class<T> entityClass,
                          java.lang.Object primaryKey)

Specified by:

getReference in interface javax.persistence.EntityManager

find

public <A> A find(java.lang.Class<A> entityClass,
                  java.lang.Object primaryKey)

Specified by:

find in interface javax.persistence.EntityManager

find

public <T> T find(java.lang.Class<T> entityClass,
                  java.lang.Object primaryKey,
                  java.util.Map<java.lang.String,java.lang.Object> properties)

Specified by:

find in interface javax.persistence.EntityManager

find

public <A> A find(java.lang.Class<A> entityClass,
                  java.lang.Object primaryKey,
                  javax.persistence.LockModeType lockModeType)

Specified by:

find in interface javax.persistence.EntityManager

find

public <A> A find(java.lang.Class<A> entityClass,
                  java.lang.Object primaryKey,
                  javax.persistence.LockModeType lockModeType,
                  java.util.Map<java.lang.String,java.lang.Object> properties)

Specified by:

find in interface javax.persistence.EntityManager

determineAppropriateLocalCacheMode

public CacheMode determineAppropriateLocalCacheMode(java.util.Map<java.lang.String,java.lang.Object> localProperties)

persist

public void persist(java.lang.Object entity)

Specified by:

persist in interface javax.persistence.EntityManager

merge

public <A> A merge(A entity)

Specified by:

merge in interface javax.persistence.EntityManager

remove

public void remove(java.lang.Object entity)

Specified by:

remove in interface javax.persistence.EntityManager

refresh

public void refresh(java.lang.Object entity)

Specified by:

refresh in interface javax.persistence.EntityManager

refresh

public void refresh(java.lang.Object entity,
                    java.util.Map<java.lang.String,java.lang.Object> properties)

Specified by:

refresh in interface javax.persistence.EntityManager

refresh

public void refresh(java.lang.Object entity,
                    javax.persistence.LockModeType lockModeType)

Specified by:

refresh in interface javax.persistence.EntityManager

refresh

public void refresh(java.lang.Object entity,
                    javax.persistence.LockModeType lockModeType,
                    java.util.Map<java.lang.String,java.lang.Object> properties)

Specified by:

refresh in interface javax.persistence.EntityManager

contains

public boolean contains(java.lang.Object entity)

Specified by:

contains in interface javax.persistence.EntityManager

getLockMode

public javax.persistence.LockModeType getLockMode(java.lang.Object entity)

Specified by:

getLockMode in interface javax.persistence.EntityManager

setProperty

public void setProperty(java.lang.String s,
                        java.lang.Object o)

Specified by:

setProperty in interface javax.persistence.EntityManager

getProperties

public java.util.Map<java.lang.String,java.lang.Object> getProperties()

Specified by:

getProperties in interface javax.persistence.EntityManager

flush

public void flush()

Specified by:

flush in interface javax.persistence.EntityManager

getSession

public abstract Session getSession()

return a Session

Specified by:

getSession in interface HibernateEntityManager

Returns:

The session

Throws:

java.lang.IllegalStateException - if the entity manager is closed

getRawSession

@Deprecated
protected abstract Session getRawSession()

Deprecated. Deprecated in favor of getRawSession()

Return a Session (even if the entity manager is closed).

Returns:

A session.

internalGetSession

protected abstract Session internalGetSession()

Return a Session without any validation checks.

Returns:

A session.

getTransaction

public javax.persistence.EntityTransaction getTransaction()

Specified by:

getTransaction in interface javax.persistence.EntityManager

getEntityManagerFactory

public EntityManagerFactoryImpl getEntityManagerFactory()

Specified by:

getEntityManagerFactory in interface javax.persistence.EntityManager

internalGetEntityManagerFactory

protected EntityManagerFactoryImpl internalGetEntityManagerFactory()

getFactory

public HibernateEntityManagerFactory getFactory()

Description copied from interface: HibernateEntityManagerFactoryAware

Get access to the Hibernate extended EMF contract.

Specified by:

getFactory in interface HibernateEntityManagerFactoryAware

Returns:

The Hibernate EMF contract for this EM.

getCriteriaBuilder

public javax.persistence.criteria.CriteriaBuilder getCriteriaBuilder()

Specified by:

getCriteriaBuilder in interface javax.persistence.EntityManager

getMetamodel

public javax.persistence.metamodel.Metamodel getMetamodel()

Specified by:

getMetamodel in interface javax.persistence.EntityManager

setFlushMode

public void setFlushMode(javax.persistence.FlushModeType flushModeType)

Specified by:

setFlushMode in interface javax.persistence.EntityManager

clear

public void clear()

Specified by:

clear in interface javax.persistence.EntityManager

detach

public void detach(java.lang.Object entity)

Specified by:

detach in interface javax.persistence.EntityManager

getFlushMode

public javax.persistence.FlushModeType getFlushMode()

Hibernate can be set in various flush modes that are unknown to JPA 2.0. This method can then return null. If it returns null, do em.unwrap(Session.class).getFlushMode() to get the Hibernate flush mode

Specified by:

getFlushMode in interface javax.persistence.EntityManager

lock

public void lock(java.lang.Object entity,
                 javax.persistence.LockModeType lockMode)

Specified by:

lock in interface javax.persistence.EntityManager

lock

public void lock(java.lang.Object entity,
                 javax.persistence.LockModeType lockModeType,
                 java.util.Map<java.lang.String,java.lang.Object> properties)

Specified by:

lock in interface javax.persistence.EntityManager

getLockRequest

public LockOptions getLockRequest(javax.persistence.LockModeType lockModeType,
                                  java.util.Map<java.lang.String,java.lang.Object> properties)

Description copied from interface: HibernateEntityManagerImplementor

Convert from JPA 2 LockModeType & properties into LockOptions

Specified by:

getLockRequest in interface HibernateEntityManagerImplementor

Parameters:

lockModeType - is the requested lock type

properties - are the lock properties

Returns:

the LockOptions

isTransactionInProgress

public boolean isTransactionInProgress()

Description copied from interface: HibernateEntityManagerImplementor

Provides access to whether a transaction is currently in progress.

Specified by:

isTransactionInProgress in interface HibernateEntityManagerImplementor

Returns:

True if a transaction is considered currently in progress; false otherwise.

unwrap

public <T> T unwrap(java.lang.Class<T> clazz)

Specified by:

unwrap in interface javax.persistence.EntityManager

markForRollbackOnly

public void markForRollbackOnly()

Description copied from interface: HibernateEntityManagerImplementor

Used to mark a transaction for rollback only (when that is the JPA spec defined behavior).

Specified by:

markForRollbackOnly in interface HibernateEntityManagerImplementor

isJoinedToTransaction

public boolean isJoinedToTransaction()

Specified by:

isJoinedToTransaction in interface javax.persistence.EntityManager

joinTransaction

public void joinTransaction()

Specified by:

joinTransaction in interface javax.persistence.EntityManager

getDelegate

public java.lang.Object getDelegate()

returns the underlying session

Specified by:

getDelegate in interface javax.persistence.EntityManager

handlePersistenceException

public void handlePersistenceException(javax.persistence.PersistenceException e)

Description copied from interface: HibernateEntityManagerImplementor

Handles marking for rollback and other such operations that need to occur depending on the type of exception being handled.

Specified by:

handlePersistenceException in interface HibernateEntityManagerImplementor

Parameters:

e - The exception being handled.

throwPersistenceException

public void throwPersistenceException(javax.persistence.PersistenceException e)

Description copied from interface: HibernateEntityManagerImplementor

Delegates to HibernateEntityManagerImplementor.handlePersistenceException(javax.persistence.PersistenceException) and then throws the given exception.

Specified by:

throwPersistenceException in interface HibernateEntityManagerImplementor

Parameters:

e - The exception being handled and finally thrown.

convert

public java.lang.RuntimeException convert(HibernateException e)

Description copied from interface: HibernateEntityManagerImplementor

Converts a Hibernate-specific exception into a JPA-specified exception; note that the JPA sepcification makes use of exceptions outside its exception hierarchy, though they are all runtime exceptions.

Any appropriate/needed calls to HibernateEntityManagerImplementor.handlePersistenceException(javax.persistence.PersistenceException) are also made.

Specified by:

convert in interface HibernateEntityManagerImplementor

Parameters:

e - The Hibernate excepton.

Returns:

The JPA-specified exception

convert

public java.lang.RuntimeException convert(java.lang.RuntimeException e)

convert

public java.lang.RuntimeException convert(java.lang.RuntimeException e,
                                          LockOptions lockOptions)

convert

public java.lang.RuntimeException convert(HibernateException e,
                                          LockOptions lockOptions)

Description copied from interface: HibernateEntityManagerImplementor

Converts a Hibernate-specific exception into a JPA-specified exception; note that the JPA sepcification makes use of exceptions outside its exception hierarchy, though they are all runtime exceptions.

Any appropriate/needed calls to HibernateEntityManagerImplementor.handlePersistenceException(javax.persistence.PersistenceException) are also made.

Specified by:

convert in interface HibernateEntityManagerImplementor

Parameters:

e - The Hibernate excepton.

lockOptions - The lock options in effect at the time of exception (can be null)

Returns:

The JPA-specified exception

throwPersistenceException

public void throwPersistenceException(HibernateException e)

Description copied from interface: HibernateEntityManagerImplementor

Delegates to HibernateEntityManagerImplementor.convert(org.hibernate.HibernateException, org.hibernate.LockOptions) and then throws the given exception.

Specified by:

throwPersistenceException in interface HibernateEntityManagerImplementor

Parameters:

e - The exception being handled and finally thrown.

wrapStaleStateException

public javax.persistence.PersistenceException wrapStaleStateException(StaleStateException e)

Specified by:

wrapStaleStateException in interface HibernateEntityManagerImplementor

wrapLockException

public javax.persistence.PersistenceException wrapLockException(HibernateException e,
                                                                LockOptions lockOptions)