org.eclipse.persistence.sessions.remote
public abstract class DistributedSession extends org.eclipse.persistence.internal.sessions.AbstractSession
LOG_DEBUG, LOG_ERROR, LOG_INFO, LOG_WARNING
Constructor and Description |
---|
DistributedSession(org.eclipse.persistence.internal.sessions.remote.RemoteConnection remoteConnection)
PUBLIC:
Creates a DistributedSession.
|
Modifier and Type | Method and Description |
---|---|
abstract org.eclipse.persistence.internal.sessions.UnitOfWorkImpl |
acquireUnitOfWork()
PUBLIC:
Return a unit of work for this session.
|
void |
beginTransaction()
PUBLIC:
Start a transaction on the server.
|
void |
commitTransaction()
PUBLIC:
Commit a transaction on the server.
|
org.eclipse.persistence.internal.sessions.remote.RemoteCursoredStream |
cursorSelectObjects(CursoredStreamPolicy policy)
INTERNAL:
Return remote cursor stream.
|
org.eclipse.persistence.internal.sessions.remote.RemoteScrollableCursor |
cursorSelectObjects(ScrollableCursorPolicy policy)
INTERNAL:
Return remote scrollable cursor
|
abstract Object |
executeQuery(DatabaseQuery query)
Execute the database query.
|
Object |
executeQuery(DatabaseQuery query,
org.eclipse.persistence.internal.sessions.AbstractRecord row)
INTERNAL:
Execute the database query.
|
Object |
executeQuery(String queryName)
PUBLIC:
Execute the pre-defined query by name and return the result.
|
Object |
executeQuery(String queryName,
Class domainClass)
PUBLIC:
Execute the pre-defined query by name and return the result.
|
Object |
executeQuery(String queryName,
Class domainClass,
Vector argumentValues)
PUBLIC:
Execute the pre-defined query by name and return the result.
|
Object |
executeQuery(String queryName,
Vector argumentValues)
PUBLIC:
Execute the pre-defined query by name and return the result.
|
Vector |
getDefaultReadOnlyClasses()
INTERNAL:
CR#2751
Returns the set of read-only classes for the receiver.
|
ClassDescriptor |
getDescriptor(Class domainClass)
INTERNAL:
Return the table descriptor specified for the class.
|
ClassDescriptor |
getDescriptorCorrespondingTo(ClassDescriptor descriptor)
INTERNAL:
Return the descriptor.
|
abstract Object |
getObjectCorrespondingTo(Object serverSideDomainObject,
Map objectDescriptors,
Map processedObjects,
ObjectLevelReadQuery query)
INTERNAL:
Return the corresponding objects from the remote session for the objects read from the server.
|
abstract Object |
getObjectsCorrespondingToAll(Object serverSideDomainObjects,
Map objectDescriptors,
Map processedObjects,
ObjectLevelReadQuery query,
org.eclipse.persistence.internal.queries.ContainerPolicy containerPolicy)
INTERNAL:
Return the corresponding objects from the remote session for the objects read from the server.
|
org.eclipse.persistence.internal.sessions.remote.RemoteConnection |
getRemoteConnection()
INTERNAL:
Return the remote connection.
|
boolean |
hasCorrespondingDescriptor(ClassDescriptor descriptor)
INTERNAL:
Checks if the descriptor exists or not.
|
void |
initializeIdentityMapAccessor()
INTERNAL:
Set up the IdentityMapManager.
|
abstract Object |
instantiateRemoteValueHolderOnServer(org.eclipse.persistence.internal.sessions.remote.RemoteValueHolder remoteValueHolder)
INTERNAL:
This will instantiate value holder on the server.
|
boolean |
isConnected()
PUBLIC:
Return if this session is connected to the server.
|
boolean |
isDistributedSession()
INTERNAL:
Return if this session is a distributed session.
|
boolean |
isRemoteSession()
INTERNAL:
Return if this session is a remote session.
|
void |
privilegedAddDescriptor(ClassDescriptor descriptor)
INTERNAL:
You cannot add descriptors to a remote session.
|
void |
release()
PUBLIC:
Logout the session, close the remote connection and release the hold resources
|
void |
rollbackTransaction()
PUBLIC:
Rollback a transaction on the server.
|
String |
toString()
PUBLIC:
Avoid printing the accessor and platform.
|
acquireHistoricalSession, acquireNonSynchronizedUnitOfWork, acquireNonSynchronizedUnitOfWork, acquireUnitOfWork, addAlias, addJPAQuery, addQuery, addStaticMetamodelClass, beginExternalTransaction, clearDescriptors, clearIntegrityChecker, clearLastDescriptorAccessed, clearProfile, clone, commitExternalTransaction, compareObjects, compareObjectsDontMatch, config, containsQuery, copy, copy, copyDescriptorNamedQueries, copyInternal, copyObject, copyObject, copyReadOnlyClasses, deleteAllObjects, deleteAllObjects, deleteObject, doesObjectExist, dontLogMessages, endOperationProfile, endOperationProfile, executeCall, executeNonSelectingCall, executeNonSelectingSQL, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeSelectingCall, executeSQL, fine, finer, finest, getAccessor, getAccessor, getAccessor, getActiveCommandThreads, getActiveSession, getActiveUnitOfWork, getAliasDescriptors, getAllQueries, getAsOfClause, getBroker, getClassDescriptor, getClassDescriptor, getClassDescriptorForAlias, getCommandManager, getCommitManager, getDatasourceLogin, getDatasourcePlatform, getDefaultReferenceMode, getDescriptor, getDescriptorForAlias, getDescriptors, getEventManager, getExceptionHandler, getExceptionHandlerClass, getExecutionSession, getExternalTransactionController, getId, getIdentityMapAccessor, getIdentityMapAccessorInstance, getIntegrityChecker, getJPAQueries, getLoader, getLog, getLogin, getLogLevel, getLogLevel, getLogSessionString, getName, getNextQueryId, getNextSequenceNumberValue, getNumberOfActiveUnitsOfWork, getParent, getParentIdentityMapSession, getParentIdentityMapSession, getPessimisticLockTimeoutDefault, getPlatform, getPlatform, getProfiler, getProject, getProperties, getProperty, getQueries, getQuery, getQuery, getQuery, getQueryTimeoutDefault, getRootSession, getSequencing, getServerPlatform, getSessionForClass, getSessionLog, getSessionTypeString, getStaticMetamodelClass, getTransactionMutex, handleException, handleSevere, hasBroker, hasCommitManager, hasDescriptor, hasEventManager, hasExceptionHandler, hasExternalTransactionController, hasProperties, incrementProfile, info, insertObject, internalExecuteQuery, isBroker, isClassReadOnly, isClassReadOnly, isClientSession, isDatabaseSession, isExclusiveConnectionRequired, isExclusiveIsolatedClientSession, isFinalizersEnabled, isHistoricalSession, isInBroker, isInProfile, isInTransaction, isIsolatedClientSession, isLoggingOff, isRemoteUnitOfWork, isServerSession, isSessionBroker, isSynchronized, isUnitOfWork, keyFromObject, keyFromObject, load, log, log, log, log, log, log, log, log, log, log, logMessage, logMessage, logThrowable, postConnectExternalConnection, preDisconnectExternalConnection, prepareDatabaseQuery, processCommand, processJPAQueries, readAllObjects, readAllObjects, readAllObjects, readAllObjects, readObject, readObject, readObject, readObject, readObject, refreshAndLockObject, refreshAndLockObject, refreshObject, registerFinalizer, releaseJTSConnection, releaseReadConnection, releaseUnitOfWork, removeProperty, removeQuery, removeQuery, setAccessor, setBroker, setCommandManager, setCommitManager, setDatasourceLogin, setDefaultReferenceMode, setEventManager, setExceptionHandler, setExternalTransactionController, setIntegrityChecker, setIsFinalizersEnabled, setIsInBroker, setIsInProfile, setLog, setLogin, setLogin, setLogLevel, setName, setPessimisticLockTimeoutDefault, setProfiler, setProject, setProperties, setProperty, setQueryTimeoutDefault, setSessionLog, setShouldPropagateChanges, setSynchronized, setWasJTSTransactionInternallyStarted, severe, shouldLog, shouldLogMessages, shouldLogMessages, shouldPropagateChanges, startOperationProfile, startOperationProfile, unwrapObject, updateObject, updateProfile, validateCache, validateQuery, verifyDelete, warning, wasJTSTransactionInternallyStarted, wrapObject, writeObject, writesCompleted
public DistributedSession(org.eclipse.persistence.internal.sessions.remote.RemoteConnection remoteConnection)
remoteConnection
- remote session requires a remote connection. This must be accessed remotely from the client through RMI or CORBA.public abstract org.eclipse.persistence.internal.sessions.UnitOfWorkImpl acquireUnitOfWork()
acquireUnitOfWork
in interface Session
acquireUnitOfWork
in class org.eclipse.persistence.internal.sessions.AbstractSession
UnitOfWorkImpl
public void beginTransaction()
beginTransaction
in class org.eclipse.persistence.internal.sessions.AbstractSession
AbstractSession.isInTransaction()
public void commitTransaction()
commitTransaction
in class org.eclipse.persistence.internal.sessions.AbstractSession
public org.eclipse.persistence.internal.sessions.remote.RemoteCursoredStream cursorSelectObjects(CursoredStreamPolicy policy)
public org.eclipse.persistence.internal.sessions.remote.RemoteScrollableCursor cursorSelectObjects(ScrollableCursorPolicy policy)
public Object executeQuery(String queryName) throws DatabaseException
executeQuery
in interface Session
executeQuery
in class org.eclipse.persistence.internal.sessions.AbstractSession
DatabaseException
AbstractSession.addQuery(String, DatabaseQuery)
public Object executeQuery(String queryName, Class domainClass) throws DatabaseException
executeQuery
in interface Session
executeQuery
in class org.eclipse.persistence.internal.sessions.AbstractSession
DatabaseException
DescriptorQueryManager.addQuery(String, DatabaseQuery)
public Object executeQuery(String queryName, Class domainClass, Vector argumentValues) throws DatabaseException
executeQuery
in class org.eclipse.persistence.internal.sessions.AbstractSession
DatabaseException
DescriptorQueryManager.addQuery(String, DatabaseQuery)
public Object executeQuery(String queryName, Vector argumentValues) throws DatabaseException
executeQuery
in class org.eclipse.persistence.internal.sessions.AbstractSession
DatabaseException
AbstractSession.addQuery(String, DatabaseQuery)
public abstract Object executeQuery(DatabaseQuery query)
executeQuery
in interface Session
executeQuery
in class org.eclipse.persistence.internal.sessions.AbstractSession
DatabaseQuery
public Object executeQuery(DatabaseQuery query, org.eclipse.persistence.internal.sessions.AbstractRecord row)
executeQuery
in class org.eclipse.persistence.internal.sessions.AbstractSession
public Vector getDefaultReadOnlyClasses()
getDefaultReadOnlyClasses
in class org.eclipse.persistence.internal.sessions.AbstractSession
org.eclipse.persistence.sessions.Project#setDefaultReadOnlyClasses(Vector)
public ClassDescriptor getDescriptor(Class domainClass)
getDescriptor
in interface Session
getDescriptor
in class org.eclipse.persistence.internal.sessions.AbstractSession
public ClassDescriptor getDescriptorCorrespondingTo(ClassDescriptor descriptor)
public abstract Object getObjectCorrespondingTo(Object serverSideDomainObject, Map objectDescriptors, Map processedObjects, ObjectLevelReadQuery query)
public abstract Object getObjectsCorrespondingToAll(Object serverSideDomainObjects, Map objectDescriptors, Map processedObjects, ObjectLevelReadQuery query, org.eclipse.persistence.internal.queries.ContainerPolicy containerPolicy)
public org.eclipse.persistence.internal.sessions.remote.RemoteConnection getRemoteConnection()
public boolean hasCorrespondingDescriptor(ClassDescriptor descriptor)
public void initializeIdentityMapAccessor()
initializeIdentityMapAccessor
in class org.eclipse.persistence.internal.sessions.AbstractSession
public abstract Object instantiateRemoteValueHolderOnServer(org.eclipse.persistence.internal.sessions.remote.RemoteValueHolder remoteValueHolder)
public boolean isConnected()
isConnected
in interface Session
isConnected
in class org.eclipse.persistence.internal.sessions.AbstractSession
public boolean isDistributedSession()
isDistributedSession
in interface Session
isDistributedSession
in class org.eclipse.persistence.internal.sessions.AbstractSession
public boolean isRemoteSession()
isRemoteSession
in interface Session
isRemoteSession
in class org.eclipse.persistence.internal.sessions.AbstractSession
public void privilegedAddDescriptor(ClassDescriptor descriptor)
public void rollbackTransaction()
rollbackTransaction
in class org.eclipse.persistence.internal.sessions.AbstractSession
public String toString()
toString
in class org.eclipse.persistence.internal.sessions.AbstractSession