com.goldencode.p2j.persist.orm

Class SessionFactory

java.lang.Object

com.goldencode.p2j.persist.orm.SessionFactory

public class SessionFactory
extends java.lang.Object

Allows a "closed" session to be reclaimed. Each Persistence context has a session which can be reclaimed after it is closed, allowing for better caching of active buffers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	SessionFactory.PersistenceConsumer<T> Functional Interface that is able to throw PersistenceException.
static class	SessionFactory.SessionCloseThread A thread used to manage SessionFactory reclaimable sessions and close any sessions that have exceeded their lifespan.

Field Summary

Fields

Modifier and Type	Field and Description
private static boolean	enabled If the session reclaiming is enabled/disabled.
private static CentralLogger	LOG Logger.
private Session	reclaimable The session that can be reclaimed.
private java.lang.Long	timestamp Timestamp representing when each of the reclaimable sessions was added.

Constructor Summary

Constructors

Constructor and Description
SessionFactory() Constructor that registers the SessionFactory in a Daemon Thread that manages session closing.

Method Summary

Modifier and Type	Method and Description
Session	create(Database database, DmoVersioning dmoVersion, SessionFactory.PersistenceConsumer<Session> initialize, java.lang.String tenantId) Reclaims a session if one is available or create a new one with the given parameters.
void	expire() Method used to close a session that can't be reclaimed.
boolean	isEnabled() Return a boolean value that tells if the session reclaiming is enabled/disabled.
void	markReclaimable(Session session) Mark a session as being reclaimable.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final CentralLogger LOG

Logger.

enabled

private static boolean enabled

If the session reclaiming is enabled/disabled.

reclaimable

private Session reclaimable

The session that can be reclaimed.

timestamp

private java.lang.Long timestamp

Timestamp representing when each of the reclaimable sessions was added.

Constructor Detail

SessionFactory

public SessionFactory()

Constructor that registers the SessionFactory in a Daemon Thread that manages session closing.

Method Detail

isEnabled

public boolean isEnabled()

Return a boolean value that tells if the session reclaiming is enabled/disabled.

Returns:

true if session reclaiming is enabled, false otherwise.

create

public Session create(Database database,
                      DmoVersioning dmoVersion,
                      SessionFactory.PersistenceConsumer<Session> initialize,
                      java.lang.String tenantId)
               throws PersistenceException

Reclaims a session if one is available or create a new one with the given parameters.

Parameters:

database - The database used for creating the session

dmoVersion - The DMO version tracker

initialize - Initialization lambda used to associate records with a new session when it is created and not reclaimed.

tenantId - The id of the tenant for which the session is created.

Returns:

If a session can be reclaimed, the reclaimable Session object is returned. Otherwise a new session is created using the Database and DmoVersioning object provided.

Throws:

PersistenceException - If there is an error getting a JDBC connection from the data source.

markReclaimable

public void markReclaimable(Session session)

Mark a session as being reclaimable.

Parameters:

session - The session that is marked as reclaimable.

expire

public void expire()

Method used to close a session that can't be reclaimed. A session can't be reclaimed when it's lifespan expires.