Package net.sf.basedb.core.hibernate

Class StatelessSessionWrapper

java.lang.Object

net.sf.basedb.core.hibernate.AbstractQueryCache

net.sf.basedb.core.hibernate.StatelessSessionWrapper

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, QueryProducer, SharedSessionContract, StatelessSession

public class StatelessSessionWrapper
extends AbstractQueryCache
implements StatelessSession

Wrapper around stateless Hibernate sessions that includes a query cache. This wrapper forwards all calls to the underlying real Hibernate session.

Since:

2.16

Author:

Nicklas

See Also:

Serialized Form

Last modified

$Date: 2019-09-26 15:49:09 +0200 (tors, 26 sep. 2019) $

Field Summary

Fields

Modifier and Type	Field	Description
private static long	serialVersionUID
private StatelessSession	session

Constructor Summary

Constructors

Constructor	Description
StatelessSessionWrapper(StatelessSession session)	Creates a new session wrapper

Method Summary

Modifier and Type	Method	Description
Transaction	beginTransaction()
void	cancelQuery()	Cancels the currently executing query in the same manner as Session.cancelQuery().
void	close()
Connection	connection()	Deprecated.
Criteria	createCriteria(Class persistentClass)	Deprecated.
Criteria	createCriteria(Class persistentClass, String alias)	Deprecated.
Criteria	createCriteria(String entityName)	Deprecated.
Criteria	createCriteria(String entityName, String alias)	Deprecated.
Query<?>	createNamedQuery(String queryName)
<R> Query<R>	createNamedQuery(String queryName, Class<R> returnType)
NativeQuery<?>	createNativeQuery(String queryString)
<R> NativeQuery<R>	createNativeQuery(String queryString, Class<R> resultClass)
NativeQuery<?>	createNativeQuery(String queryString, String resultSetMapping)
Query<?>	createQuery(String queryString)	If the same query has been executed before, return the cached instance, otherwise create a new query from the parent session and cache it.
<R> Query<R>	createQuery(String queryString, Class<R> resultClass)
Query	createQuery(javax.persistence.criteria.CriteriaDelete c)
<T> Query<T>	createQuery(javax.persistence.criteria.CriteriaQuery<T> c)
Query	createQuery(javax.persistence.criteria.CriteriaUpdate c)
NativeQuery<?>	createSQLQuery(String queryString)	If the same query has been executed before, return the cached instance, otherwise create a new query from the parent session and cache it.
ProcedureCall	createStoredProcedureCall(String name)
ProcedureCall	createStoredProcedureCall(String paramString, Class... paramArrayOfClass)
ProcedureCall	createStoredProcedureCall(String paramString, String... paramArrayOfString)
void	delete(Object entity)
void	delete(String entityName, Object entity)
Object	get(Class entityClass, Serializable id)
Object	get(Class entityClass, Serializable id, LockMode lockMode)
Object	get(String entityName, Serializable id)
Object	get(String entityName, Serializable id, LockMode lockMode)
Integer	getJdbcBatchSize()
NativeQuery<?>	getNamedNativeQuery(String queryName)
ProcedureCall	getNamedProcedureCall(String name)
Query<?>	getNamedQuery(String queryName)	If the same query has been executed before, return the cached instance, otherwise create a new query from the parent session and cache it.
StatelessSession	getParentSession()	Get the underlying parent session from Hibernate.
String	getTenantIdentifier()
Transaction	getTransaction()
Serializable	insert(Object entity)
Serializable	insert(String entityName, Object entity)
boolean	isConnected()
boolean	isOpen()
void	refresh(Object entity)
void	refresh(Object entity, LockMode lockMode)
void	refresh(String entityName, Object entity)
void	refresh(String entityName, Object entity, LockMode lockMode)
void	setJdbcBatchSize(Integer batchSize)
void	update(Object entity)
void	update(String entityName, Object entity)

Methods inherited from class net.sf.basedb.core.hibernate.AbstractQueryCache

cacheQuery, getCachedQuery, getCachedQuery

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.hibernate.query.QueryProducer

getNamedSQLQuery

Methods inherited from interface org.hibernate.SharedSessionContract

doReturningWork, doWork

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

session

private final StatelessSession session

Constructor Details

StatelessSessionWrapper

public StatelessSessionWrapper(StatelessSession session)

Creates a new session wrapper

Parameters:

session - The real Hibernate session

Method Details

getParentSession

public StatelessSession getParentSession()

Get the underlying parent session from Hibernate.

cancelQuery

public void cancelQuery()
                 throws HibernateException

Cancels the currently executing query in the same manner as Session.cancelQuery(). Since this method is not part of the StatelessSession interface this only works if the underlying parent session is the Hibernate implementation.

Throws:

HibernateException

beginTransaction

public Transaction beginTransaction()

Specified by:

beginTransaction in interface SharedSessionContract

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface SharedSessionContract

Specified by:

close in interface StatelessSession

connection

@Deprecated
public Connection connection()

Deprecated.

Specified by:

connection in interface StatelessSession

createCriteria

@Deprecated
public Criteria createCriteria(Class persistentClass,
String alias)

Deprecated.

Specified by:

createCriteria in interface SharedSessionContract

createCriteria

@Deprecated
public Criteria createCriteria(Class persistentClass)

Deprecated.

Specified by:

createCriteria in interface SharedSessionContract

createCriteria

@Deprecated
public Criteria createCriteria(String entityName,
String alias)

Deprecated.

Specified by:

createCriteria in interface SharedSessionContract

createCriteria

@Deprecated
public Criteria createCriteria(String entityName)

Deprecated.

Specified by:

createCriteria in interface SharedSessionContract

createQuery

public Query<?> createQuery(String queryString)
                     throws HibernateException

If the same query has been executed before, return the cached instance, otherwise create a new query from the parent session and cache it.

Specified by:

createQuery in interface QueryProducer

Specified by:

createQuery in interface SharedSessionContract

Throws:

HibernateException

createSQLQuery

public NativeQuery<?> createSQLQuery(String queryString)
                              throws HibernateException

If the same query has been executed before, return the cached instance, otherwise create a new query from the parent session and cache it.

Specified by:

createSQLQuery in interface QueryProducer

Specified by:

createSQLQuery in interface StatelessSession

Throws:

HibernateException

delete

public void delete(Object entity)

Specified by:

delete in interface StatelessSession

delete

public void delete(String entityName,
Object entity)

Specified by:

delete in interface StatelessSession

get

public Object get(Class entityClass,
Serializable id,
LockMode lockMode)

Specified by:

get in interface StatelessSession

get

public Object get(Class entityClass,
Serializable id)

Specified by:

get in interface StatelessSession

get

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

Specified by:

get in interface StatelessSession

get

public Object get(String entityName,
Serializable id)

Specified by:

get in interface StatelessSession

getNamedQuery

public Query<?> getNamedQuery(String queryName)
                       throws HibernateException

If the same query has been executed before, return the cached instance, otherwise create a new query from the parent session and cache it.

Specified by:

getNamedQuery in interface QueryProducer

Specified by:

getNamedQuery in interface SharedSessionContract

Throws:

HibernateException

getTransaction

public Transaction getTransaction()

Specified by:

getTransaction in interface SharedSessionContract

insert

public Serializable insert(Object entity)

Specified by:

insert in interface StatelessSession

insert

public Serializable insert(String entityName,
Object entity)

Specified by:

insert in interface StatelessSession

refresh

public void refresh(Object entity,
LockMode lockMode)

Specified by:

refresh in interface StatelessSession

refresh

public void refresh(Object entity)

Specified by:

refresh in interface StatelessSession

refresh

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

Specified by:

refresh in interface StatelessSession

refresh

public void refresh(String entityName,
Object entity)

Specified by:

refresh in interface StatelessSession

update

public void update(Object entity)

Specified by:

update in interface StatelessSession

update

public void update(String entityName,
Object entity)

Specified by:

update in interface StatelessSession

getTenantIdentifier

public String getTenantIdentifier()

Specified by:

getTenantIdentifier in interface SharedSessionContract

getNamedProcedureCall

public ProcedureCall getNamedProcedureCall(String name)

Specified by:

getNamedProcedureCall in interface SharedSessionContract

createStoredProcedureCall

public ProcedureCall createStoredProcedureCall(String name)

Specified by:

createStoredProcedureCall in interface SharedSessionContract

createStoredProcedureCall

public ProcedureCall createStoredProcedureCall(String paramString,
Class... paramArrayOfClass)

Specified by:

createStoredProcedureCall in interface SharedSessionContract

createStoredProcedureCall

public ProcedureCall createStoredProcedureCall(String paramString,
String... paramArrayOfString)

Specified by:

createStoredProcedureCall in interface SharedSessionContract

getJdbcBatchSize

public Integer getJdbcBatchSize()

Specified by:

getJdbcBatchSize in interface SharedSessionContract

isConnected

public boolean isConnected()

Specified by:

isConnected in interface SharedSessionContract

isOpen

public boolean isOpen()

Specified by:

isOpen in interface SharedSessionContract

setJdbcBatchSize

public void setJdbcBatchSize(Integer batchSize)

Specified by:

setJdbcBatchSize in interface SharedSessionContract

createNamedQuery

public <R> Query<R> createNamedQuery(String queryName,
Class<R> returnType)

Specified by:

createNamedQuery in interface QueryProducer

createNamedQuery

public Query<?> createNamedQuery(String queryName)

Specified by:

createNamedQuery in interface QueryProducer

createNativeQuery

public <R> NativeQuery<R> createNativeQuery(String queryString,
Class<R> resultClass)

Specified by:

createNativeQuery in interface QueryProducer

createNativeQuery

public NativeQuery<?> createNativeQuery(String queryString,
String resultSetMapping)

Specified by:

createNativeQuery in interface QueryProducer

createNativeQuery

public NativeQuery<?> createNativeQuery(String queryString)

Specified by:

createNativeQuery in interface QueryProducer

createQuery

public <R> Query<R> createQuery(String queryString,
Class<R> resultClass)

Specified by:

createQuery in interface QueryProducer

getNamedNativeQuery

public NativeQuery<?> getNamedNativeQuery(String queryName)

Specified by:

getNamedNativeQuery in interface QueryProducer

createQuery

public <T> Query<T> createQuery(javax.persistence.criteria.CriteriaQuery<T> c)

Specified by:

createQuery in interface QueryProducer

createQuery

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

Specified by:

createQuery in interface QueryProducer

createQuery

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

Specified by:

createQuery in interface QueryProducer