public abstract class DistributedSession extends AbstractSession
LOG_DEBUG, LOG_ERROR, LOG_INFO, LOG_WARNING
Constructor and Description |
---|
DistributedSession(RemoteConnection remoteConnection)
PUBLIC:
Creates a DistributedSession.
|
Modifier and Type | Method and Description |
---|---|
abstract 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.
|
RemoteCursoredStream |
cursorSelectObjects(CursoredStreamPolicy policy)
INTERNAL:
Return remote cursor stream.
|
RemoteScrollableCursor |
cursorSelectObjects(ScrollableCursorPolicy policy)
INTERNAL:
Return remote scrollable cursor
|
abstract java.lang.Object |
executeQuery(DatabaseQuery query)
Execute the database query.
|
java.lang.Object |
executeQuery(DatabaseQuery query,
AbstractRecord row)
INTERNAL:
Execute the database query.
|
java.lang.Object |
executeQuery(java.lang.String queryName)
PUBLIC:
Execute the pre-defined query by name and return the result.
|
java.lang.Object |
executeQuery(java.lang.String queryName,
java.lang.Class domainClass)
PUBLIC:
Execute the pre-defined query by name and return the result.
|
java.lang.Object |
executeQuery(java.lang.String queryName,
java.lang.Class domainClass,
java.util.Vector argumentValues)
PUBLIC:
Execute the pre-defined query by name and return the result.
|
java.lang.Object |
executeQuery(java.lang.String queryName,
java.util.Vector argumentValues)
PUBLIC:
Execute the pre-defined query by name and return the result.
|
java.util.Vector |
getDefaultReadOnlyClasses()
INTERNAL:
CR#2751
Returns the set of read-only classes for the receiver.
|
ClassDescriptor |
getDescriptor(java.lang.Class domainClass)
INTERNAL:
Return the table descriptor specified for the class.
|
ClassDescriptor |
getDescriptorCorrespondingTo(ClassDescriptor descriptor)
INTERNAL:
Return the descriptor.
|
abstract java.lang.Object |
getObjectCorrespondingTo(java.lang.Object serverSideDomainObject,
java.util.Map objectDescriptors,
java.util.Map processedObjects,
ObjectLevelReadQuery query)
INTERNAL:
Return the corresponding objects from the remote session for the objects read from the server.
|
abstract java.lang.Object |
getObjectsCorrespondingToAll(java.lang.Object serverSideDomainObjects,
java.util.Map objectDescriptors,
java.util.Map processedObjects,
ObjectLevelReadQuery query,
ContainerPolicy containerPolicy)
INTERNAL:
Return the corresponding objects from the remote session for the objects read from the server.
|
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 java.lang.Object |
instantiateRemoteValueHolderOnServer(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.
|
java.lang.String |
toString()
PUBLIC:
Avoid printing the accessor and platform.
|
acquireHistoricalSession, acquireNonSynchronizedUnitOfWork, acquireNonSynchronizedUnitOfWork, acquireUnitOfWork, addAlias, addJPAQuery, addMultitenantContextProperty, addQuery, addStaticMetamodelClass, basicExecuteCall, beginExternalTransaction, checkAndRefreshInvalidObject, clearDescriptors, clearIntegrityChecker, clearLastDescriptorAccessed, clearProfile, clone, commitExternalTransaction, compareObjects, compareObjectsDontMatch, config, containsQuery, copy, copy, copyDescriptorNamedQueries, copyDescriptorsFromProject, copyInternal, copyObject, copyObject, copyReadOnlyClasses, createCloneQueryValueHolder, createCloneTransformationValueHolder, createProtectedInstanceFromCachedData, deferEvent, deleteAllObjects, deleteAllObjects, deleteObject, doesObjectExist, dontLogMessages, endOperationProfile, endOperationProfile, executeCall, executeDeferredEvents, executeNonSelectingCall, executeNonSelectingSQL, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeQuery, executeSelectingCall, executeSQL, fine, finer, finest, getAccessor, getAccessors, getAccessors, getActiveCommandThreads, getActiveSession, getActiveUnitOfWork, getAliasDescriptors, getAllQueries, getAsOfClause, getAttributeGroups, 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, getMappedSuperclass, getMultitenantContextProperties, getName, getNextQueryId, getNextSequenceNumberValue, getNumberOfActiveUnitsOfWork, getParent, getParentIdentityMapSession, getParentIdentityMapSession, getParentIdentityMapSession, getPartitioningPolicy, getPessimisticLockTimeoutDefault, getPlatform, getPlatform, getProfiler, getProject, getProperties, getProperty, getQueries, getQuery, getQuery, getQuery, getQuery, getQueryBuilder, getQueryTimeoutDefault, getRefreshMetadataListener, getRootSession, getSequencing, getServerPlatform, getSessionForClass, getSessionForName, getSessionLog, getSessionTypeString, getStaticMetamodelClass, getTablePerTenantDescriptors, getTransactionMutex, handleException, handleSevere, hasBroker, hasCommitManager, hasDescriptor, hasEventManager, hasExceptionHandler, hasExternalTransactionController, hasProperties, hasTablePerTenantDescriptors, incrementProfile, incrementProfile, info, insertObject, internalExecuteQuery, isBroker, isClassReadOnly, isClassReadOnly, isClientSession, isConsideredInvalid, isDatabaseSession, isExclusiveConnectionRequired, isExclusiveIsolatedClientSession, isFinalizersEnabled, isHistoricalSession, isInBroker, isInProfile, isInTransaction, isIsolatedClientSession, isLoggingOff, isProtectedSession, isRemoteUnitOfWork, isServerSession, isSessionBroker, isSynchronized, isUnitOfWork, keyFromObject, keyFromObject, load, log, log, log, log, log, log, log, log, log, log, logMessage, logMessage, logThrowable, postAcquireConnection, prepareDatabaseQuery, preReleaseConnection, priviledgedExecuteNonSelectingCall, priviledgedExecuteSelectingCall, processCommand, processJPAQueries, readAllObjects, readAllObjects, readAllObjects, readAllObjects, readObject, readObject, readObject, readObject, readObject, refreshAndLockObject, refreshAndLockObject, refreshObject, registerFinalizer, releaseJTSConnection, releaseReadConnection, releaseUnitOfWork, removeProperty, removeQuery, removeQuery, retrieveCacheKey, retryQuery, retryTransaction, setAccessor, setBroker, setCommandManager, setCommitManager, setDatasourceLogin, setDefaultReferenceMode, setEventManager, setExceptionHandler, setExternalTransactionController, setIntegrityChecker, setIsFinalizersEnabled, setIsInBroker, setIsInProfile, setLog, setLogin, setLogin, setLogLevel, setName, setPartitioningPolicy, setPessimisticLockTimeoutDefault, setProfiler, setProject, setProperties, setProperty, setQueryTimeoutDefault, setRefreshMetadataListener, setSessionLog, setShouldPropagateChanges, setSynchronized, setWasJTSTransactionInternallyStarted, severe, shouldDisplayData, shouldLog, shouldLogMessages, shouldLogMessages, shouldPropagateChanges, startOperationProfile, startOperationProfile, unwrapObject, updateObject, updateProfile, updateTablePerTenantDescriptors, validateCache, validateQuery, verifyDelete, warning, wasJTSTransactionInternallyStarted, wrapObject, writeObject, writesCompleted
public DistributedSession(RemoteConnection remoteConnection)
remoteConnection
- remote session requires a remote connection. This must be accessed remotely from the client through RMI or CORBA.public abstract UnitOfWorkImpl acquireUnitOfWork()
acquireUnitOfWork
in interface Session
acquireUnitOfWork
in class AbstractSession
UnitOfWorkImpl
public void beginTransaction()
beginTransaction
in class AbstractSession
AbstractSession.isInTransaction()
public void commitTransaction()
commitTransaction
in class AbstractSession
public RemoteCursoredStream cursorSelectObjects(CursoredStreamPolicy policy)
public RemoteScrollableCursor cursorSelectObjects(ScrollableCursorPolicy policy)
public java.lang.Object executeQuery(java.lang.String queryName) throws DatabaseException
executeQuery
in interface Session
executeQuery
in class AbstractSession
DatabaseException
AbstractSession.addQuery(String, DatabaseQuery)
public java.lang.Object executeQuery(java.lang.String queryName, java.lang.Class domainClass) throws DatabaseException
executeQuery
in interface Session
executeQuery
in class AbstractSession
DatabaseException
DescriptorQueryManager.addQuery(String, DatabaseQuery)
public java.lang.Object executeQuery(java.lang.String queryName, java.lang.Class domainClass, java.util.Vector argumentValues) throws DatabaseException
executeQuery
in class AbstractSession
DatabaseException
DescriptorQueryManager.addQuery(String, DatabaseQuery)
public java.lang.Object executeQuery(java.lang.String queryName, java.util.Vector argumentValues) throws DatabaseException
executeQuery
in class AbstractSession
DatabaseException
AbstractSession.addQuery(String, DatabaseQuery)
public abstract java.lang.Object executeQuery(DatabaseQuery query)
executeQuery
in interface Session
executeQuery
in class AbstractSession
DatabaseQuery
public java.lang.Object executeQuery(DatabaseQuery query, AbstractRecord row)
executeQuery
in class AbstractSession
public java.util.Vector getDefaultReadOnlyClasses()
getDefaultReadOnlyClasses
in class AbstractSession
org.eclipse.persistence.sessions.Project#setDefaultReadOnlyClasses(Vector)
public ClassDescriptor getDescriptor(java.lang.Class domainClass)
getDescriptor
in interface Session
getDescriptor
in class AbstractSession
public ClassDescriptor getDescriptorCorrespondingTo(ClassDescriptor descriptor)
public abstract java.lang.Object getObjectCorrespondingTo(java.lang.Object serverSideDomainObject, java.util.Map objectDescriptors, java.util.Map processedObjects, ObjectLevelReadQuery query)
public abstract java.lang.Object getObjectsCorrespondingToAll(java.lang.Object serverSideDomainObjects, java.util.Map objectDescriptors, java.util.Map processedObjects, ObjectLevelReadQuery query, ContainerPolicy containerPolicy)
public RemoteConnection getRemoteConnection()
public boolean hasCorrespondingDescriptor(ClassDescriptor descriptor)
public void initializeIdentityMapAccessor()
initializeIdentityMapAccessor
in class AbstractSession
public abstract java.lang.Object instantiateRemoteValueHolderOnServer(RemoteValueHolder remoteValueHolder)
public boolean isConnected()
isConnected
in interface Session
isConnected
in class AbstractSession
public boolean isDistributedSession()
isDistributedSession
in interface Session
isDistributedSession
in class AbstractSession
public boolean isRemoteSession()
isRemoteSession
in interface Session
isRemoteSession
in class AbstractSession
public void privilegedAddDescriptor(ClassDescriptor descriptor)
public void rollbackTransaction()
rollbackTransaction
in class AbstractSession
public java.lang.String toString()
toString
in class AbstractSession
public void release()
release
in interface Session
release
in class AbstractSession
EclipseLink 2.4.2, "build v20130514-5956486" API Reference