public class SessionBroker
extends org.eclipse.persistence.internal.sessions.DatabaseSessionImpl
Purpose: Provide a single view to a TopLink session that transparently accesses multple databases.
Responsibilities:
| Modifier and Type | Field and Description |
|---|---|
protected SessionBroker |
parent |
protected org.eclipse.persistence.internal.sequencing.Sequencing |
sequencing |
protected java.util.Map<java.lang.Class,java.lang.String> |
sessionNamesByClass |
protected java.util.Map<java.lang.String,org.eclipse.persistence.internal.sessions.AbstractSession> |
sessionsByName |
protected boolean |
shouldUseDescriptorAliases |
connectedTime, databaseEventListener, isLoggedIn, sequencingHome, serverPlatform, tuneraccessors, activeCommandThreads, attributeGroups, broker, commandManager, commitManager, defaultReferenceMode, deferredEvents, descriptors, eventManager, exceptionHandler, externalTransactionController, identityMapAccessor, injectionManager, integrityChecker, isConcurrent, isExecutingEvents, isFinalizersEnabled, isInBroker, isInProfile, isLoggingOff, isSynchronized, jpaQueriesProcessed, lastDescriptorAccessed, logSessionString, metadatalistener, multitenantContextProperties, name, numberOfActiveUnitsOfWork, objectsLockedForClone, partitioningPolicy, pessimisticLockTimeoutDefault, pessimisticLockTimeoutUnitDefault, platform, profiler, project, properties, queries, queryBuilder, queryTimeoutDefault, queryTimeoutUnitDefault, serializer, sessionLog, shouldCheckWriteLock, shouldOptimizeResultSetAccess, shouldPropagateChanges, staticMetamodelClasses, tablePerTenantDescriptors, tablePerTenantQueries, tolerateInvalidJPQL, transactionMutex, wasJTSTransactionInternallyStartedLOG_DEBUG, LOG_ERROR, LOG_INFO, LOG_WARNING| Modifier | Constructor and Description |
|---|---|
|
SessionBroker()
PUBLIC:
Create and return a session broker.
|
protected |
SessionBroker(java.util.Map sessionNames)
INTERNAL:
Create and return a session broker.
|
| Modifier and Type | Method and Description |
|---|---|
SessionBroker |
acquireClientSessionBroker()
PUBLIC:
Return a session broker that behaves as a client session broker.
|
SessionBroker |
acquireClientSessionBroker(java.util.Map<java.lang.String,ConnectionPolicy> connectionPolicies,
java.util.Map mapOfProperties)
PUBLIC:
Return a session broker that behaves as a client session broker.
|
Session |
acquireHistoricalSession(AsOfClause clause)
INTERNAL:
Acquires a special historical session for reading objects as of a past time.
|
org.eclipse.persistence.internal.sessions.UnitOfWorkImpl |
acquireUnitOfWork()
PUBLIC:
Return a unit of work for this session broker.
|
void |
addDescriptor(ClassDescriptor descriptor)
PUBLIC:
You cannot add a descriptor to a session broker, you must add it to its session.
|
void |
addDescriptors(Project project)
PUBLIC:
You cannot add a project to a session broker, you must add it to its session.
|
void |
addDescriptors(java.util.Vector descriptors)
PUBLIC:
You cannot add descriptors to a session broker, you must add them to its session.
|
void |
addSequence(Sequence sequence)
PUBLIC:
You cannot add a sequence to a session broker, you must add it to its session.
|
protected void |
basicBeginTransaction()
INTERNAL:
Begin the transaction on all child sessions.
|
protected void |
basicCommitTransaction()
INTERNAL:
Commit the transaction on all child sessions.
|
protected void |
basicRollbackTransaction()
INTERNAL:
Rollback the transaction on all child sessions.
|
boolean |
containsQuery(java.lang.String queryName)
PUBLIC:
Return true if the pre-defined query is defined on the session.
|
protected SessionBroker |
copySessionBroker()
INTERNAL:
Return a copy (not using clone) of a session broker.
|
java.util.Collection<org.eclipse.persistence.internal.databaseaccess.Accessor> |
getAccessors(Call call,
org.eclipse.persistence.internal.sessions.AbstractRecord translationRow,
DatabaseQuery query)
INTERNAL:
Return the low-level database accessors.
|
AsOfClause |
getAsOfClause()
ADVANCED:
Answers the past time this session is as of.
|
org.eclipse.persistence.internal.sessions.AbstractSession |
getExecutionSession(DatabaseQuery query)
INTERNAL:
Gets the session which this query will be executed on.
|
SessionBroker |
getParent()
INTERNAL:
Gets the parent SessionBroker.
|
org.eclipse.persistence.internal.databaseaccess.Platform |
getPlatform(java.lang.Class domainClass)
INTERNAL:
Return the platform for a particular class.
|
DatabaseQuery |
getQuery(java.lang.String name,
java.util.Vector arguments,
boolean shouldSearchParent)
PUBLIC:
Return the query from the session pre-defined queries with the given name and argument types.
|
org.eclipse.persistence.internal.sequencing.Sequencing |
getSequencing()
PUBLIC:
Return the Sequencing object used by the session.
|
protected org.eclipse.persistence.internal.sequencing.SequencingHome |
getSequencingHome()
PROTECTED:
Session broker doesn't have SequencingHome.
|
org.eclipse.persistence.internal.sessions.AbstractSession |
getSessionForClass(java.lang.Class domainClass)
INTERNAL:
Return the session to be used for the class.
|
org.eclipse.persistence.internal.sessions.AbstractSession |
getSessionForName(java.lang.String name)
INTERNAL:
Return the session by name.
|
protected org.eclipse.persistence.internal.sessions.AbstractSession |
getSessionForQuery(DatabaseQuery query)
INTERNAL:
Answers the session to be used for the given query.
|
protected java.util.Map<java.lang.Class,java.lang.String> |
getSessionNamesByClass()
INTERNAL:
Return sessions indexed by class, each class can only have one default session.
|
java.util.Map<java.lang.String,org.eclipse.persistence.internal.sessions.AbstractSession> |
getSessionsByName()
INTERNAL:
Return sessions indexed by name.
|
int |
howManySequencingCallbacks()
INTERNAL:
Returns a number of member sessions that require sequencing callback.
|
void |
initializeDescriptors()
INTERNAL:
Allow each descriptor to initialize any dependencies on this session.
|
void |
initializeIdentityMapAccessor()
INTERNAL:
Set up the IdentityMapManager.
|
void |
initializeSequencing()
ADVANCED:
Creates sequencing object for the session broker.
|
java.lang.Object |
internalExecuteQuery(DatabaseQuery query,
org.eclipse.persistence.internal.sessions.AbstractRecord row)
INTERNAL:
Return the results from exeucting the database query.
|
boolean |
isBroker()
INTERNAL:
Returns true if the session is a session Broker.
|
boolean |
isClientSessionBroker()
PUBLIC:
Return if this session is a client session broker.
|
boolean |
isConnected()
PUBLIC:
Return if all sessions are still connected to the database.
|
boolean |
isSequencingCallbackRequired()
INTERNAL:
Indicates whether SequencingCallback is required.
|
boolean |
isServerSessionBroker()
PUBLIC:
Return if this session is a server session broker.
|
boolean |
isSessionBroker()
INTERNAL:
Return if this session is a session broker.
|
void |
login()
PUBLIC:
Connect to the database using the predefined login.
|
void |
login(java.lang.String userName,
java.lang.String password)
PUBLIC:
Connect to the database using the predefined login.
|
void |
loginAndDetectDatasource()
PUBLIC:
Connect to the database using the predefined login.
|
void |
logout()
PUBLIC:
Disconnect from all databases.
|
void |
postLogin()
INTERNAL:
Rise postLogin events for member sessions and the SessionBroker.
|
void |
registerSession(java.lang.String name,
org.eclipse.persistence.internal.sessions.AbstractSession session)
PUBLIC:
Register the session under its name.
|
void |
registerSession(java.lang.String name,
Session session)
PUBLIC:
Register the session under its name.
|
void |
release()
PUBLIC:
Release the session.
|
void |
releaseJTSConnection()
INTERNAL:
Called in the end of beforeCompletion of external transaction sychronization listener.
|
java.lang.Object |
retryQuery(DatabaseQuery query,
org.eclipse.persistence.internal.sessions.AbstractRecord row,
DatabaseException databaseException,
int retryCount,
org.eclipse.persistence.internal.sessions.AbstractSession executionSession)
INTERNAL:
A query execution failed due to an invalid query.
|
void |
setExternalTransactionController(ExternalTransactionController externalTransactionController)
INTERNAL:
Used for JTS integration internally by ServerPlatform.
|
void |
setIntegrityChecker(IntegrityChecker integrityChecker)
PUBLIC:
set the integrityChecker.
|
void |
setLog(java.io.Writer log)
PUBLIC:
Set the message log.
|
void |
setProfiler(SessionProfiler profiler)
PUBLIC:
Set the profiler for the session.
|
void |
setSessionLog(SessionLog log)
PUBLIC:
Set the session log.
|
protected void |
setSessionNameByClass(java.util.HashMap sessionNameByClass)
INTERNAL:
Set sessions indexed by class, each class can only have one default session.
|
void |
setSessionsByName(java.util.Map sessionsByName)
INTERNAL:
Set sessions indexed by name.
|
void |
setShouldUseDescriptorAliases(boolean shouldUseDescriptorAliases)
PUBLIC:
Indicates whether descriptors should use aliasDescriptors map.
|
void |
setSynchronized(boolean synched)
INTERNAL:
Set isSynchronized flag to indicate that members of session broker are synchronized.
|
boolean |
shouldUseDescriptorAliases()
PUBLIC:
Indicates whether descriptors should use aliasDescriptors map.
|
void |
writesCompleted()
INTERNAL:
This method notifies the accessor that a particular sets of writes has
completed.
|
addDescriptors, addDescriptorsToSequencing, connect, disconnect, finalize, getConnectedTime, getDatabaseEventListener, getDatasourcePlatform, getPlatform, getReadLogin, getSequencingControl, getServerPlatform, getTuner, initializeConnectedTime, initializeDescriptorIfSessionAlive, initializeDescriptors, initializeDescriptors, initializeDescriptors, initializeDescriptors, isDatabaseSession, isLoggedIn, isProtectedSession, login, postConnectDatasource, preConnectDatasource, setDatabaseEventListener, setDatasourceAndInitialize, setOrDetectDatasource, setSequencingHome, setServerPlatform, setTuner, writeAllObjects, writeAllObjectsacquireNonSynchronizedUnitOfWork, acquireNonSynchronizedUnitOfWork, acquireRepeatableWriteUnitOfWork, acquireUnitOfWork, addAlias, addJPAQuery, addJPATablePerTenantQuery, addMultitenantContextProperty, addQuery, addQuery, addQuery, addStaticMetamodelClass, addTablePerTenantDescriptor, addTablePerTenantQuery, basicBeginTransaction, basicExecuteCall, beginExternalTransaction, beginTransaction, buildDefaultQueryBuilder, checkAndRefreshInvalidObject, checkHierarchyForDescriptor, cleanUpInjectionManager, clearDescriptors, clearIntegrityChecker, clearLastDescriptorAccessed, clearProfile, clone, commitExternalTransaction, commitTransaction, compareObjects, compareObjectsDontMatch, config, copy, copy, copyDescriptorNamedQueries, copyDescriptorsFromProject, copyInternal, copyObject, copyObject, copyReadOnlyClasses, createCloneQueryValueHolder, createCloneTransformationValueHolder, createInjectionManager, createProtectedInstanceFromCachedData, deferEvent, deleteAllObjects, deleteAllObjects, deleteObject, doesObjectExist, dontLogMessages, endOperationProfile, endOperationProfile, executeCall, executeDeferredEvents, executeNonSelectingCall, executeNonSelectingSQL, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeSelectingCall, executeSQL, fine, finer, finest, getAccessor, getAccessors, getActiveCommandThreads, getActiveSession, getActiveUnitOfWork, getAliasDescriptors, getAllQueries, getAttributeGroups, getBroker, getCacheKeyFromTargetSessionForMerge, getClassDescriptor, getClassDescriptor, getClassDescriptorForAlias, getCommandManager, getCommitManager, getDatasourceLogin, getDefaultReadOnlyClasses, getDefaultReferenceMode, getDescriptor, getDescriptor, getDescriptorForAlias, getDescriptors, getEventManager, getExceptionHandler, getExceptionHandlerClass, getExternalTransactionController, getId, getIdentityMapAccessor, getIdentityMapAccessorInstance, getInjectionManager, getIntegrityChecker, getJPAQueries, getJPATablePerTenantQueries, getLoader, getLog, getLogin, getLogLevel, getLogLevel, getLogSessionString, getMappedSuperclass, getMultitenantContextProperties, getName, getNextQueryId, getNextSequenceNumberValue, getNumberOfActiveUnitsOfWork, getParentIdentityMapSession, getParentIdentityMapSession, getParentIdentityMapSession, getPartitioningPolicy, getPessimisticLockTimeoutDefault, getPessimisticLockTimeoutUnitDefault, getProfiler, getProject, getProperties, getProperty, getQueries, getQuery, getQuery, getQuery, getQueryBuilder, getQueryTimeoutDefault, getQueryTimeoutUnitDefault, getRefreshMetadataListener, getRootSession, getSerializer, getSessionLog, getSessionTypeString, getStaticMetamodelClass, getTablePerTenantDescriptors, getTablePerTenantQueries, getTransactionMutex, handleException, handleSevere, hasBroker, hasCommitManager, hasDescriptor, hasEventManager, hasExceptionHandler, hasExternalTransactionController, hasProperties, hasTablePerTenantDescriptors, hasTablePerTenantQueries, incrementProfile, incrementProfile, info, insertObject, isClassReadOnly, isClassReadOnly, isClientSession, isConcurrent, isConsideredInvalid, isDistributedSession, isExclusiveConnectionRequired, isExclusiveIsolatedClientSession, isFinalizersEnabled, isHistoricalSession, isInBroker, isInProfile, isInTransaction, isIsolatedClientSession, isJPAQueriesProcessed, isLoggingOff, isRemoteSession, isRemoteUnitOfWork, isServerSession, isSynchronized, isUnitOfWork, keyFromObject, keyFromObject, load, load, log, log, log, log, log, log, log, log, log, log, logMessage, logMessage, logThrowable, postAcquireConnection, prepareDatabaseQuery, preReleaseConnection, priviledgedExecuteNonSelectingCall, priviledgedExecuteSelectingCall, processCommand, processJPAQueries, processJPAQuery, readAllObjects, readAllObjects, readAllObjects, readAllObjects, readObject, readObject, readObject, readObject, readObject, refreshAndLockObject, refreshAndLockObject, refreshObject, registerFinalizer, releaseConnectionAfterCall, releaseReadConnection, releaseUnitOfWork, removeProperty, removeQuery, removeQuery, retrieveCacheKey, retryTransaction, rollbackExternalTransaction, rollbackTransaction, setAccessor, setBroker, setCommandManager, setCommitManager, setDatasourceLogin, setDefaultReferenceMode, setEventManager, setExceptionHandler, setInjectionManager, setIsConcurrent, setIsFinalizersEnabled, setIsInBroker, setIsInProfile, setJPAQueriesProcessed, setLoggingOff, setLogin, setLogin, setLogLevel, setName, setNumberOfActiveUnitsOfWork, setPartitioningPolicy, setPessimisticLockTimeoutDefault, setPessimisticLockTimeoutUnitDefault, setProject, setProperties, setProperty, setQueries, setQueryBuilder, setQueryTimeoutDefault, setQueryTimeoutUnitDefault, setRefreshMetadataListener, setSerializer, setShouldOptimizeResultSetAccess, setShouldPropagateChanges, setTolerateInvalidJPQL, setTransactionMutex, setWasJTSTransactionInternallyStarted, severe, shouldDisplayData, shouldLog, shouldLogMessages, shouldLogMessages, shouldOptimizeResultSetAccess, shouldPropagateChanges, shouldTolerateInvalidJPQL, startOperationProfile, startOperationProfile, toString, unwrapObject, updateObject, updateProfile, updateTablePerTenantDescriptors, validateCache, validateQuery, verifyDelete, warning, wasJTSTransactionInternallyStarted, wrapObject, writeAllObjectsWithChangeSet, writeObjectequals, getClass, hashCode, notify, notifyAll, wait, wait, waitbeginTransaction, commitTransaction, deleteAllObjects, deleteObject, getCommandManager, insertObject, isInTransaction, refreshAndLockObject, refreshAndLockObject, rollbackTransaction, setCommandManager, setDatasourceLogin, setLogin, setShouldPropagateChanges, shouldPropagateChanges, updateObject, writeObjectacquireUnitOfWork, addJPAQuery, addQuery, clearIntegrityChecker, clearProfile, copy, copy, copyObject, copyObject, doesObjectExist, dontLogMessages, executeNonSelectingCall, executeNonSelectingSQL, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeSelectingCall, executeSQL, getActiveSession, getActiveUnitOfWork, getClassDescriptor, getClassDescriptor, getClassDescriptorForAlias, getDatasourceLogin, getDefaultReferenceMode, getDescriptor, getDescriptor, getDescriptorForAlias, getDescriptors, getEventManager, getExceptionHandler, getExternalTransactionController, getId, getIdentityMapAccessor, getIntegrityChecker, getJPAQueries, getLog, getLogin, getLogLevel, getLogLevel, getName, getNextSequenceNumberValue, getPartitioningPolicy, getProfiler, getProject, getProperties, getProperty, getQueries, getQuery, getQuery, getSerializer, getSessionLog, handleException, handleSevere, hasDescriptor, hasExceptionHandler, hasExternalTransactionController, isClientSession, isDistributedSession, isFinalizersEnabled, isInProfile, isRemoteSession, isRemoteUnitOfWork, isServerSession, isUnitOfWork, keyFromObject, log, logMessage, readAllObjects, readAllObjects, readAllObjects, readObject, readObject, readObject, readObject, refreshObject, removeProperty, removeQuery, setDefaultReferenceMode, setExceptionHandler, setIsFinalizersEnabled, setLogLevel, setName, setPartitioningPolicy, setProperty, setQueryTimeoutDefault, setQueryTimeoutUnitDefault, setSerializer, shouldLog, shouldLogMessages, validateCacheprotected SessionBroker parent
protected java.util.Map<java.lang.Class,java.lang.String> sessionNamesByClass
protected java.util.Map<java.lang.String,org.eclipse.persistence.internal.sessions.AbstractSession> sessionsByName
protected org.eclipse.persistence.internal.sequencing.Sequencing sequencing
protected boolean shouldUseDescriptorAliases
public SessionBroker()
protected SessionBroker(java.util.Map sessionNames)
public SessionBroker acquireClientSessionBroker()
public SessionBroker acquireClientSessionBroker(java.util.Map<java.lang.String,ConnectionPolicy> connectionPolicies, java.util.Map mapOfProperties)
connectionPolicies - maps session name to connectionPolicy to be used for this session;mapOfProperties - maps session name to properties to be used for this session.public Session acquireHistoricalSession(AsOfClause clause) throws ValidationException
acquireHistoricalSession in interface SessionacquireHistoricalSession in class org.eclipse.persistence.internal.sessions.AbstractSessionclause - Represents a valid snap shot time.ValidationException - if this
not a ClientSession, plain Session, or SessionBroker.AsOfClause,
Expression.asOf(org.eclipse.persistence.history.AsOfClause),
ObjectLevelReadQuery.setAsOfClause(org.eclipse.persistence.history.AsOfClause),
HistoryPolicypublic void releaseJTSConnection()
releaseJTSConnection in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplpublic org.eclipse.persistence.internal.sessions.UnitOfWorkImpl acquireUnitOfWork()
acquireUnitOfWork in interface SessionacquireUnitOfWork in class org.eclipse.persistence.internal.sessions.AbstractSessionUnitOfWorkImplpublic void addDescriptor(ClassDescriptor descriptor)
addDescriptor in interface DatabaseSessionaddDescriptor in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplDatabaseSession.addDescriptors(Collection),
DatabaseSession.addDescriptors(Project)public void addDescriptors(java.util.Vector descriptors)
throws ValidationException
ValidationExceptionpublic void addDescriptors(Project project) throws ValidationException
addDescriptors in interface DatabaseSessionaddDescriptors in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplValidationExceptionpublic void addSequence(Sequence sequence)
addSequence in interface DatabaseSessionaddSequence in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplDatabaseSession.addDescriptor(org.eclipse.persistence.descriptors.ClassDescriptor),
DatabaseSession.addDescriptors(java.util.Collection)protected void basicBeginTransaction()
throws DatabaseException
basicBeginTransaction in class org.eclipse.persistence.internal.sessions.AbstractSessionDatabaseExceptionprotected void basicCommitTransaction()
throws DatabaseException
basicCommitTransaction in class org.eclipse.persistence.internal.sessions.AbstractSessionDatabaseExceptionprotected void basicRollbackTransaction()
throws DatabaseException
basicRollbackTransaction in class org.eclipse.persistence.internal.sessions.AbstractSessionDatabaseExceptionpublic boolean containsQuery(java.lang.String queryName)
containsQuery in interface SessioncontainsQuery in class org.eclipse.persistence.internal.sessions.AbstractSessionprotected SessionBroker copySessionBroker()
public java.util.Collection<org.eclipse.persistence.internal.databaseaccess.Accessor> getAccessors(Call call, org.eclipse.persistence.internal.sessions.AbstractRecord translationRow, DatabaseQuery query)
getAccessors in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic AsOfClause getAsOfClause()
getAsOfClause in interface SessiongetAsOfClause in class org.eclipse.persistence.internal.sessions.AbstractSessionnull if no clause set, or this a regular session.AsOfClause,
acquireHistoricalSession(AsOfClause),
Expression.hasAsOfClause()public SessionBroker getParent()
getParent in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic org.eclipse.persistence.internal.sessions.AbstractSession getExecutionSession(DatabaseQuery query)
Since the execution session also knows the correct datasource platform to execute on, it is often used in the mappings where the platform is needed for type conversion, or where calls are translated.
Is also the session with the accessor. Will return a ClientSession if it is in transaction and has a write connection.
getExecutionSession in class org.eclipse.persistence.internal.sessions.AbstractSessionquery - may store session name or reference class for brokers casepublic org.eclipse.persistence.internal.databaseaccess.Platform getPlatform(java.lang.Class domainClass)
getPlatform in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplpublic DatabaseQuery getQuery(java.lang.String name, java.util.Vector arguments, boolean shouldSearchParent)
getQuery in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic org.eclipse.persistence.internal.sessions.AbstractSession getSessionForClass(java.lang.Class domainClass)
throws ValidationException
getSessionForClass in class org.eclipse.persistence.internal.sessions.AbstractSessionValidationExceptionpublic org.eclipse.persistence.internal.sessions.AbstractSession getSessionForName(java.lang.String name)
throws ValidationException
getSessionForName in class org.eclipse.persistence.internal.sessions.AbstractSessionValidationExceptionprotected org.eclipse.persistence.internal.sessions.AbstractSession getSessionForQuery(DatabaseQuery query)
protected java.util.Map<java.lang.Class,java.lang.String> getSessionNamesByClass()
public java.util.Map<java.lang.String,org.eclipse.persistence.internal.sessions.AbstractSession> getSessionsByName()
public void initializeDescriptors()
initializeDescriptors in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplpublic void initializeIdentityMapAccessor()
initializeIdentityMapAccessor in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic java.lang.Object internalExecuteQuery(DatabaseQuery query, org.eclipse.persistence.internal.sessions.AbstractRecord row) throws DatabaseException, QueryException
internalExecuteQuery in class org.eclipse.persistence.internal.sessions.AbstractSessionDatabaseExceptionQueryExceptionpublic boolean isBroker()
isBroker in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic boolean isClientSessionBroker()
public boolean isConnected()
isConnected in interface SessionisConnected in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic boolean isServerSessionBroker()
public boolean isSessionBroker()
isSessionBroker in interface SessionisSessionBroker in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic void login()
throws DatabaseException
login in interface DatabaseSessionlogin in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplDatabaseExceptionDatabaseSession.login(Login)public void loginAndDetectDatasource()
throws DatabaseException
loginAndDetectDatasource in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplDatabaseExceptionpublic void login(java.lang.String userName,
java.lang.String password)
throws DatabaseException
login in interface DatabaseSessionlogin in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplDatabaseExceptionpublic void logout()
throws DatabaseException
logout in interface DatabaseSessionlogout in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplEclipseLinkException - if a transaction is active, you must rollback any active transaction before logout.DatabaseException - the database will also raise an error if their is an active transaction,
or a general error occurs.public void postLogin()
postLogin in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplpublic void registerSession(java.lang.String name,
org.eclipse.persistence.internal.sessions.AbstractSession session)
public void registerSession(java.lang.String name,
Session session)
public void release()
public java.lang.Object retryQuery(DatabaseQuery query, org.eclipse.persistence.internal.sessions.AbstractRecord row, DatabaseException databaseException, int retryCount, org.eclipse.persistence.internal.sessions.AbstractSession executionSession)
retryQuery in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplpublic void setExternalTransactionController(ExternalTransactionController externalTransactionController)
setExternalTransactionController in interface DatabaseSessionsetExternalTransactionController in interface SessionsetExternalTransactionController in class org.eclipse.persistence.internal.sessions.AbstractSessionCustomServerPlatformpublic void setIntegrityChecker(IntegrityChecker integrityChecker)
setIntegrityChecker in interface SessionsetIntegrityChecker in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic void setSessionLog(SessionLog log)
setSessionLog in interface SessionsetSessionLog in class org.eclipse.persistence.internal.sessions.AbstractSessionAbstractSession.logMessage(java.lang.String)public void setLog(java.io.Writer log)
public void setProfiler(SessionProfiler profiler)
setProfiler in interface SessionsetProfiler in class org.eclipse.persistence.internal.sessions.AbstractSessionprotected void setSessionNameByClass(java.util.HashMap sessionNameByClass)
public void setSessionsByName(java.util.Map sessionsByName)
public void setSynchronized(boolean synched)
setSynchronized in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic void writesCompleted()
writesCompleted in class org.eclipse.persistence.internal.sessions.AbstractSessionpublic void initializeSequencing()
initializeSequencing in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplprotected org.eclipse.persistence.internal.sequencing.SequencingHome getSequencingHome()
getSequencingHome in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplpublic org.eclipse.persistence.internal.sequencing.Sequencing getSequencing()
getSequencing in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplpublic int howManySequencingCallbacks()
public boolean isSequencingCallbackRequired()
isSequencingCallbackRequired in class org.eclipse.persistence.internal.sessions.DatabaseSessionImplpublic boolean shouldUseDescriptorAliases()
public void setShouldUseDescriptorAliases(boolean shouldUseDescriptorAliases)