br.com.sankhya.jape.core

Class JapeSession

java.lang.Object

br.com.sankhya.jape.core.JapeSession

All Implemented Interfaces:

java.io.Serializable

public class JapeSession
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JapeSession.CanceledTransactionException
static interface	JapeSession.InterruptionType
static interface	JapeSession.KNOWN_RUNTIME_PROPERTIES
static interface	JapeSession.NewTXBody
static interface	JapeSession.NoTXBody
static class	JapeSession.OpenProperties
static interface	JapeSession.Properties
class	JapeSession.SessionHandle
static class	JapeSession.StackTraceInfo
static class	JapeSession.SuspendHandle
static interface	JapeSession.TXBlock
static interface	JapeSession.TXBlockRedoable
static class	JapeSession.TXCacheEntry

Field Summary

Fields

Modifier and Type	Field and Description
static int	HIGH_PRIORITY
static int	LOW_PRIORITY
static int	NORMAL_PRIORITY

Method Summary

Modifier and Type	Method and Description
void	addCloseListener(java.lang.Runnable r)
void	addPessimisticLockEntity(java.lang.String fullEntityName)
void	addToLoadOnFindCache(EntityMetaData entity, java.util.Map data)
void	addTxProperty(java.lang.String name, java.lang.Object value)
javax.transaction.Transaction	beginTransaction()
boolean	canReuseJDBCConnection()
boolean	canTimeout()
void	cleanContextTransaction()
static void	close() Deprecated. Devemos usar o método 'close' do handle de sessão.
static void	close(JapeSession.SessionHandle hnd)
static void	closeNow()
void	doAfterCloseDelayed()
void	dumpSession(java.lang.StringBuffer buf)
boolean	enlist(EntityPrimaryKey key, EntityContainer container)
boolean	equals(java.lang.Object obj)
static void	execEnsuringTX(JapeSession.TXBlock txblk)
static java.lang.Object	execWithAutonomousTX(JapeSession.NewTXBody r)
static java.lang.Object	execWithNoTX(JapeSession.NoTXBody r)
static JapeSession.StackTraceInfo	generateStackTraceInfo(java.lang.Thread t)
long	getCloseTime()
static JapeSession	getCurrentSession()
java.lang.String	getCurrentStackTrace()
java.util.Map	getFromLoadOnFindCache(EntityMetaData entity)
static JapeSession.TXCacheEntry	getFromTXCache(java.lang.String key)
int	getInterruptionType()
JapeSession.OpenProperties	getOpenProperties()
java.lang.Thread	getOwnerThread()
int	getPriorityLevel()
static java.util.Map	getProperties()
static java.lang.Object	getProperty(java.lang.String name)
static java.lang.Object	getProperty(java.lang.String name, java.lang.Object defaultValue)
static java.math.BigDecimal	getPropertyAsBigDecimal(java.lang.String name)
static java.lang.Boolean	getPropertyAsBoolean(java.lang.String name, java.lang.Object defaultValue)
static java.lang.String	getPropertyAsString(java.lang.String name)
static java.lang.Object	getRequiredProperty(java.lang.String name)
static java.math.BigDecimal	getRequiredPropertyAsBigDecimal(java.lang.String name)
static java.lang.Boolean	getRequiredPropertyAsBoolean(java.lang.String name)
int	getRowVersionOnSession(java.lang.String table, EntityPrimaryKey key)
java.lang.Object	getRuntimeConfig(java.lang.String entityName, java.lang.String propName, java.lang.Object def)
java.lang.String	getSessionGlobalID()
SessionManager.SessionInfo	getSessionInfo()
long	getSessionTimeout()
java.lang.String	getStackTraceID()
long	getStartTime()
JapeSession.SessionHandle	getTopMostHandle()
java.util.Set<java.lang.String>	getTurnOffCalculatedFields(java.lang.String entityName)
java.lang.Object	getTxProperty(java.lang.String name)
java.lang.String	getUid()
java.lang.Integer	getUpdateCounterForEntity(java.lang.String entityName, EntityPrimaryKey key)
java.util.Collection	getVOsLoadedOnThisSession(java.lang.String entityName, java.lang.Object pk)
static boolean	hasCurrentSession()
int	hashCode()
boolean	hasTimedout()
boolean	hasTransaction()
void	ignoreInsertionEntityEvents(java.lang.String entityName)
void	incrementRowVersionOnSession(java.lang.String table, EntityPrimaryKey key) Registra um update na tabela.
void	interrupt()
void	interrupt(int type)
boolean	isEnlisted(EntityPrimaryKey pk, EntityContainer container)
boolean	isFakeTransaction()
boolean	isInternalOpen()
boolean	isInterrupted()
void	markAsTimedout()
boolean	mustIgnoreInsertionEvents(java.lang.String entityName)
static JapeSession.SessionHandle	open()
static JapeSession.SessionHandle	open(boolean internalOpen)
static JapeSession.SessionHandle	open(JapeSession.OpenProperties op)
static JapeSession.SessionHandle	open(java.lang.String userID)
static JapeSession.SessionHandle	open(java.lang.String userID, boolean internalOpen, java.lang.String globalID)
static java.sql.Connection	openJDBCConnection(java.lang.String dsName, javax.sql.DataSource ds)
static java.sql.Connection	openJDBCConnection(java.lang.String dsName, javax.sql.DataSource ds, boolean bindNewConnectionToSession)
static JapeSession.SessionHandle	openWithGlobalID(java.lang.String globalID)
static void	putOnTXCache(java.lang.String key, java.lang.Object value)
static void	putProperty(java.lang.String name, java.lang.Object value)
void	registryAsUnpluggedVO(java.lang.String entityName, DynamicVO vo) Método utilitário para remover uma referencia de VO da lista de sincronização automática.
void	registryTXLockUnlocker(java.lang.Runnable r)
void	registryUpdateForEntity(java.lang.String entityName, EntityPrimaryKey key) Registra um update na entidade.
void	registryVOLoad(java.lang.String entityName, DynamicVO vo) Registra a carga de todos os VOs carregados nesta sessão CASO tenhamos uma TX ativa.
void	releaseLocksForcibly()
void	setRuntimeConfig(java.lang.String entityName, java.lang.String propName, java.lang.Object value)
void	setSessionInfo(SessionManager.SessionInfo sessionInfo)
static JapeSession.SuspendHandle	suspend()
javax.transaction.Transaction	suspendCurrentTransaction()
void	thisSessionIsWaitingFor(java.util.Collection otherSessions, java.lang.String resourceName)
void	thisSessionIsWaitingFor(JapeSession otherSession, java.lang.String msg)
void	thisSessionIsWaitingForNothing()
java.lang.String	toString()
void	turnOffCalculatedFieldByGroup(java.lang.String entityName, java.lang.String groupName)
boolean	usePessimisticLock(java.lang.String fullEntityName)

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Detail

LOW_PRIORITY

public static int LOW_PRIORITY

NORMAL_PRIORITY

public static int NORMAL_PRIORITY

HIGH_PRIORITY

public static int HIGH_PRIORITY

Method Detail

isFakeTransaction

public boolean isFakeTransaction()

interrupt

public void interrupt()

interrupt

public void interrupt(int type)

getInterruptionType

public int getInterruptionType()

isInterrupted

public boolean isInterrupted()

getRuntimeConfig

public java.lang.Object getRuntimeConfig(java.lang.String entityName,
                                         java.lang.String propName,
                                         java.lang.Object def)

suspend

public static JapeSession.SuspendHandle suspend()
                                         throws java.lang.Exception

Throws:

java.lang.Exception

execEnsuringTX

public static void execEnsuringTX(JapeSession.TXBlock txblk)
                           throws java.lang.Exception

Throws:

java.lang.Exception

turnOffCalculatedFieldByGroup

public void turnOffCalculatedFieldByGroup(java.lang.String entityName,
                                          java.lang.String groupName)

getTurnOffCalculatedFields

public java.util.Set<java.lang.String> getTurnOffCalculatedFields(java.lang.String entityName)

execWithNoTX

public static java.lang.Object execWithNoTX(JapeSession.NoTXBody r)
                                     throws java.lang.Exception

Throws:

java.lang.Exception

execWithAutonomousTX

public static java.lang.Object execWithAutonomousTX(JapeSession.NewTXBody r)
                                             throws java.lang.Exception

Throws:

java.lang.Exception

setRuntimeConfig

public void setRuntimeConfig(java.lang.String entityName,
                             java.lang.String propName,
                             java.lang.Object value)

markAsTimedout

public void markAsTimedout()

hasTimedout

public boolean hasTimedout()

getSessionTimeout

public long getSessionTimeout()

ignoreInsertionEntityEvents

public void ignoreInsertionEntityEvents(java.lang.String entityName)

mustIgnoreInsertionEvents

public boolean mustIgnoreInsertionEvents(java.lang.String entityName)

dumpSession

public void dumpSession(java.lang.StringBuffer buf)

getUpdateCounterForEntity

public java.lang.Integer getUpdateCounterForEntity(java.lang.String entityName,
                                                   EntityPrimaryKey key)

registryVOLoad

public void registryVOLoad(java.lang.String entityName,
                           DynamicVO vo)

Registra a carga de todos os VOs carregados nesta sessão CASO tenhamos uma TX ativa. Esse registro é usado para sincronizar os VOs em caso de atualizações via setValueObject.

getVOsLoadedOnThisSession

public java.util.Collection getVOsLoadedOnThisSession(java.lang.String entityName,
                                                      java.lang.Object pk)

registryAsUnpluggedVO

public void registryAsUnpluggedVO(java.lang.String entityName,
                                  DynamicVO vo)

Método utilitário para remover uma referencia de VO da lista de sincronização automática. Desta forma, esse VO não será atualizado conforme o estado da entidade mudar.

registryUpdateForEntity

public void registryUpdateForEntity(java.lang.String entityName,
                                    EntityPrimaryKey key)

Registra um update na entidade. Desta forma podemos evitar que versões antigas de VOs carregados na mesma sessão sejam usados para UPDATE.

Parameters:

entityName -

key -

incrementRowVersionOnSession

public void incrementRowVersionOnSession(java.lang.String table,
                                         EntityPrimaryKey key)

Registra um update na tabela. Desta forma, a partir do momento que uma linha é carregada nesta sessão, ela só será recarregada em caso de updates

Parameters:

entityName -

key -

getRowVersionOnSession

public int getRowVersionOnSession(java.lang.String table,
                                  EntityPrimaryKey key)

canTimeout

public boolean canTimeout()

registryTXLockUnlocker

public void registryTXLockUnlocker(java.lang.Runnable r)

addCloseListener

public void addCloseListener(java.lang.Runnable r)

addPessimisticLockEntity

public void addPessimisticLockEntity(java.lang.String fullEntityName)

usePessimisticLock

public boolean usePessimisticLock(java.lang.String fullEntityName)

addToLoadOnFindCache

public void addToLoadOnFindCache(EntityMetaData entity,
                                 java.util.Map data)

getFromLoadOnFindCache

public java.util.Map getFromLoadOnFindCache(EntityMetaData entity)

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

close

public static void close()

Deprecated. Devemos usar o método 'close' do handle de sessão.

close

public static void close(JapeSession.SessionHandle hnd)

getCurrentSession

public static JapeSession getCurrentSession()

getProperties

public static java.util.Map getProperties()

getFromTXCache

public static JapeSession.TXCacheEntry getFromTXCache(java.lang.String key)

putOnTXCache

public static void putOnTXCache(java.lang.String key,
                                java.lang.Object value)

getProperty

public static java.lang.Object getProperty(java.lang.String name)

getProperty

public static java.lang.Object getProperty(java.lang.String name,
                                           java.lang.Object defaultValue)

getPropertyAsString

public static java.lang.String getPropertyAsString(java.lang.String name)

getPropertyAsBigDecimal

public static java.math.BigDecimal getPropertyAsBigDecimal(java.lang.String name)

getPropertyAsBoolean

public static java.lang.Boolean getPropertyAsBoolean(java.lang.String name,
                                                     java.lang.Object defaultValue)

getRequiredProperty

public static java.lang.Object getRequiredProperty(java.lang.String name)

getRequiredPropertyAsBigDecimal

public static java.math.BigDecimal getRequiredPropertyAsBigDecimal(java.lang.String name)

getRequiredPropertyAsBoolean

public static java.lang.Boolean getRequiredPropertyAsBoolean(java.lang.String name)

hasCurrentSession

public static boolean hasCurrentSession()

beginTransaction

public javax.transaction.Transaction beginTransaction()
                                               throws java.lang.Exception

Throws:

java.lang.Exception

canReuseJDBCConnection

public boolean canReuseJDBCConnection()

cleanContextTransaction

public void cleanContextTransaction()
                             throws java.lang.Exception

Throws:

java.lang.Exception

enlist

public boolean enlist(EntityPrimaryKey key,
                      EntityContainer container)

getCloseTime

public long getCloseTime()

getPriorityLevel

public int getPriorityLevel()

getSessionInfo

public SessionManager.SessionInfo getSessionInfo()

getStartTime

public long getStartTime()

getUid

public java.lang.String getUid()

isInternalOpen

public boolean isInternalOpen()

open

public static JapeSession.SessionHandle open()

open

public static JapeSession.SessionHandle open(boolean internalOpen)

open

public static JapeSession.SessionHandle open(java.lang.String userID)

openWithGlobalID

public static JapeSession.SessionHandle openWithGlobalID(java.lang.String globalID)

open

public static JapeSession.SessionHandle open(java.lang.String userID,
                                             boolean internalOpen,
                                             java.lang.String globalID)

getOpenProperties

public JapeSession.OpenProperties getOpenProperties()

open

public static JapeSession.SessionHandle open(JapeSession.OpenProperties op)

openJDBCConnection

public static java.sql.Connection openJDBCConnection(java.lang.String dsName,
                                                     javax.sql.DataSource ds)
                                              throws java.lang.Exception

Throws:

java.lang.Exception

openJDBCConnection

public static java.sql.Connection openJDBCConnection(java.lang.String dsName,
                                                     javax.sql.DataSource ds,
                                                     boolean bindNewConnectionToSession)
                                              throws java.lang.Exception

Throws:

java.lang.Exception

putProperty

public static void putProperty(java.lang.String name,
                               java.lang.Object value)

generateStackTraceInfo

public static JapeSession.StackTraceInfo generateStackTraceInfo(java.lang.Thread t)

thisSessionIsWaitingForNothing

public void thisSessionIsWaitingForNothing()

thisSessionIsWaitingFor

public void thisSessionIsWaitingFor(JapeSession otherSession,
                                    java.lang.String msg)

thisSessionIsWaitingFor

public void thisSessionIsWaitingFor(java.util.Collection otherSessions,
                                    java.lang.String resourceName)

getCurrentStackTrace

public java.lang.String getCurrentStackTrace()

closeNow

public static void closeNow()

hasTransaction

public boolean hasTransaction()

isEnlisted

public boolean isEnlisted(EntityPrimaryKey pk,
                          EntityContainer container)

setSessionInfo

public void setSessionInfo(SessionManager.SessionInfo sessionInfo)

suspendCurrentTransaction

public javax.transaction.Transaction suspendCurrentTransaction()
                                                        throws java.lang.Exception

Throws:

java.lang.Exception

releaseLocksForcibly

public void releaseLocksForcibly()

doAfterCloseDelayed

public void doAfterCloseDelayed()

getTopMostHandle

public JapeSession.SessionHandle getTopMostHandle()

getOwnerThread

public java.lang.Thread getOwnerThread()

addTxProperty

public void addTxProperty(java.lang.String name,
                          java.lang.Object value)

getTxProperty

public java.lang.Object getTxProperty(java.lang.String name)

getStackTraceID

public java.lang.String getStackTraceID()

getSessionGlobalID

public java.lang.String getSessionGlobalID()