EclipseLink Core 4.0.2 · org.eclipse.persistence.internal.sessions.remote.RemoteSessionController

Modifier and Type	Field and Description
protected CommandManager	commandManager This is the Synchronization policy used to synchronize remote caches
protected boolean	isInEarlyTransaction Used to isolate queries to a unit of work in an early transaction.
protected boolean	isInTransaction Used to resolve transaction treading for client-side nested transaction where server uses many worker threads.
protected Map<ObjID, Cursor>	remoteCursors The original cursor (either CursoredStream or ScrollableCursor, before they were serialized; keyed by ID
protected Map<ObjID, ValueHolderInterface<T>>	remoteValueHolders The original remote value holders, before they were serialized; keyed by ID
protected AbstractSession	session This is a either a database session or a client session depending upon the setup.
protected UnitOfWorkImpl	unitOfWork Use the temporary unit of work to isolate queries after an early transaction.

Access	Constructor and Description
public	RemoteSessionController(AbstractSession session)

Method Summary

Modifier and Type	Method and Description
public Transporter	beginEarlyTransaction() Begin an early unit of work transaction.
public Transporter	beginTransaction() Begin a transaction on the database.
protected ObjectDescriptor	buildObjectDescriptor(Object object) build and return an object descriptor to be sent to the client
public Transporter	closeScrollableCursor(ObjID id) Used for closing scrolable cursor across RMI.
public Transporter	commitRootUnitOfWork(Transporter remoteTransporter) Remote unit of work after serialization is commited locally.
public Transporter	commitTransaction() Commit a transaction on the database.
public Transporter	cursoredStreamClose(Transporter remoteCursoredStreamOid) Used for closing cursored streams across RMI.
public Transporter	cursoredStreamNextpage(Transporter remoteCursoredId, int pageSize) Retrieve next page of objects from the remote cursored stream once, avoid page size round trips from the server to the client
public Transporter	cursoredStreamSize(Transporter remoteCursoredStreamOid) Return the wrapped cursored stream from the server
public Transporter	cursorSelectObjects(Transporter remoteTransporter) Returns a remote cursor stub in a transporter
public Transporter	executeNamedQuery(Transporter nameTransporter, Transporter classTransporter, Transporter argumentsTransporter) A named query after serialization is executed locally.
public Transporter	executeQuery(Transporter remoteTransporter) A remote query after serialization is executed locally.
public CommandManager	getCommandManager() INTERNAL: This method returns the command manager policy for this remote connection
public Transporter	getDefaultReadOnlyClasses() return the read-only classes
public Transporter	getDescriptor(Transporter remoteTransporter) Extract descriptor from the session
public Transporter	getDescriptorForAlias(Transporter remoteTransporter) Extract descriptor from the session
protected AbstractSession	getExecutionSession() Return the correct session for the transaction context.
public Transporter	getLogin() Get the associated session login.
protected Map<ObjID, Cursor>	getRemoteCursors() return the pre-remoted cursors
public Map<ObjID, ValueHolderInterface<T>>	getRemoteValueHolders() INTERNAL: return the pre-serialized remote value holders
public Transporter	getSequenceNumberNamed(Transporter remoteFunctionCall) INTERNAL: Get the value returned by remote function call
public AbstractSession	getSession() Get the associated server side session.
protected void	initialize(AbstractSession session) Initialize this RemoteSessionController with a session.
public Transporter	initializeIdentityMapsOnServerSession() Initalize all the server side identity maps.
public Transporter	instantiateRemoteValueHolderOnServer(Transporter remoteTransporter) The corresponding original value holder is instantiated.
protected boolean	isInTransaction()
public Transporter	processCommand(Transporter RemoteCommand The command to be executed on the remote session remoteCommand) INTERNAL: This method is intended to be used by by sessions that wish to execute a command on a remote session
public Map<K, V>	replaceValueHoldersIn(Object object) Traverse the specified object, replacing the standard value holders with remote value holders.
public void	replaceValueHoldersIn(Object object, Map<K, V> objectDescriptors) Traverse the specified object, replacing the standard value holders with remote value holders.
public Map<K, V>	replaceValueHoldersInAll(Object container, ContainerPolicy policy) Traverse the specified objects, replacing the standard value holders with remote value holders.
public Transporter	rollbackTransaction() Rollback a transaction on the database.
public void	saveRemoteValueHolder(RemoteValueHolder<T> remoteValueHolder) Save the pre-serialized version of the remote value holder so that it can be used when the serialized version (on the client) is instantiated and needs to come back to the server to get its "value".
public Transporter	scrollableCursorAbsolute(Transporter remoteScrollableCursorOid, int rows) Moves the cursor to the given row number in the result set
public Transporter	scrollableCursorAfterLast(Transporter remoteScrollableCursorOid) Moves the cursor to the end of the result set, just after the last row.
public Transporter	scrollableCursorBeforeFirst(Transporter remoteScrollableCursorOid) Moves the cursor to the front of the result set, just before the first row
public Transporter	scrollableCursorClose(Transporter remoteScrollableCursorOid) Used for closing cursored streams across RMI.
public Transporter	scrollableCursorCurrentIndex(Transporter remoteScrollableCursorOid) Retrieves the current row index number
public Transporter	scrollableCursorFirst(Transporter remoteScrollableCursorOid) Moves the cursor to the first row in the result set
public Transporter	scrollableCursorIsAfterLast(Transporter remoteScrollableCursorOid) Indicates whether the cursor is after the last row in the result set.
public Transporter	scrollableCursorIsBeforeFirst(Transporter remoteScrollableCursorOid) Indicates whether the cursor is before the first row in the result set.
public Transporter	scrollableCursorIsFirst(Transporter remoteScrollableCursorOid) Indicates whether the cursor is on the first row of the result set.
public Transporter	scrollableCursorIsLast(Transporter remoteScrollableCursorOid) Indicates whether the cursor is on the last row of the result set.
public Transporter	scrollableCursorLast(Transporter remoteScrollableCursorOid) Moves the cursor to the last row in the result set
public Transporter	scrollableCursorNextObject(Transporter remoteScrollableCursorOid) Retrieve next object from the scrollable cursor
public Transporter	scrollableCursorPreviousObject(Transporter remoteScrollableCursorOid) Retrieve previous object from the scrollable cursor
public Transporter	scrollableCursorRelative(Transporter remoteScrollableCursorOid, int rows) Moves the cursor to the given row number in the result set
public Transporter	scrollableCursorSize(Transporter remoteCursorOid) Return the scrollable cursor size from the server
protected void	setIsInTransaction(boolean isInTransaction)
protected void	setRemoteCursors(Map<ObjID, Cursor> remoteCursors) set the pre-remoted cursors
protected void	setRemoteValueHolders(Map<ObjID, ValueHolderInterface<T>> remoteValueHolders) set the pre-serialized remote value holders
protected void	setSession(AbstractSession session) Set the associated server side session.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

commandManager	back to summary
protected CommandManager commandManager This is the Synchronization policy used to synchronize remote caches

isInEarlyTransaction	back to summary
protected boolean isInEarlyTransaction Used to isolate queries to a unit of work in an early transaction.

isInTransaction	back to summary
protected boolean isInTransaction Used to resolve transaction treading for client-side nested transaction where server uses many worker threads.

remoteCursors	back to summary
protected Map<ObjID, Cursor> remoteCursors The original cursor (either CursoredStream or ScrollableCursor, before they were serialized; keyed by ID

remoteValueHolders	back to summary
protected Map<ObjID, ValueHolderInterface<T>> remoteValueHolders The original remote value holders, before they were serialized; keyed by ID

session	back to summary
protected AbstractSession session This is a either a database session or a client session depending upon the setup.

unitOfWork	back to summary
protected UnitOfWorkImpl unitOfWork Use the temporary unit of work to isolate queries after an early transaction.

RemoteSessionController	back to summary
public RemoteSessionController(AbstractSession session)

Method Detail

beginEarlyTransaction	back to summary
public Transporter beginEarlyTransaction() Begin an early unit of work transaction.

beginTransaction	back to summary
public Transporter beginTransaction() Begin a transaction on the database.

buildObjectDescriptor	back to summary
protected ObjectDescriptor buildObjectDescriptor(Object object) build and return an object descriptor to be sent to the client

closeScrollableCursor	back to summary
public Transporter closeScrollableCursor(ObjID id) Used for closing scrolable cursor across RMI.

commitRootUnitOfWork	back to summary
public Transporter commitRootUnitOfWork(Transporter remoteTransporter) Remote unit of work after serialization is commited locally.

commitTransaction	back to summary
public Transporter commitTransaction() Commit a transaction on the database.

cursoredStreamClose	back to summary
public Transporter cursoredStreamClose(Transporter remoteCursoredStreamOid) Used for closing cursored streams across RMI.

cursoredStreamNextpage	back to summary
public Transporter cursoredStreamNextpage(Transporter remoteCursoredId, int pageSize) Retrieve next page of objects from the remote cursored stream once, avoid page size round trips from the server to the client

cursoredStreamSize	back to summary
public Transporter cursoredStreamSize(Transporter remoteCursoredStreamOid) Return the wrapped cursored stream from the server

cursorSelectObjects	back to summary
public Transporter cursorSelectObjects(Transporter remoteTransporter) Returns a remote cursor stub in a transporter

executeNamedQuery	back to summary
public Transporter executeNamedQuery(Transporter nameTransporter, Transporter classTransporter, Transporter argumentsTransporter) A named query after serialization is executed locally.

executeQuery	back to summary
public Transporter executeQuery(Transporter remoteTransporter) A remote query after serialization is executed locally.

getCommandManager	back to summary
public CommandManager getCommandManager() INTERNAL: This method returns the command manager policy for this remote connection

getDefaultReadOnlyClasses	back to summary
public Transporter getDefaultReadOnlyClasses() return the read-only classes

getDescriptor	back to summary
public Transporter getDescriptor(Transporter remoteTransporter) Extract descriptor from the session

getDescriptorForAlias	back to summary
public Transporter getDescriptorForAlias(Transporter remoteTransporter) Extract descriptor from the session

getExecutionSession	back to summary
protected AbstractSession getExecutionSession() Return the correct session for the transaction context. If in an active transaction, a unit of work must be used to avoid putting uncommitted data into the cache, and to use the correct accessor for the queries.

getLogin	back to summary
public Transporter getLogin() Get the associated session login.

getRemoteCursors	back to summary
protected Map<ObjID, Cursor> getRemoteCursors() return the pre-remoted cursors

getRemoteValueHolders	back to summary
public Map<ObjID, ValueHolderInterface<T>> getRemoteValueHolders() INTERNAL: return the pre-serialized remote value holders

getSequenceNumberNamed	back to summary
public Transporter getSequenceNumberNamed(Transporter remoteFunctionCall) INTERNAL: Get the value returned by remote function call

getSession	back to summary
public AbstractSession getSession() Get the associated server side session.

initialize	back to summary
protected void initialize(AbstractSession session) Initialize this RemoteSessionController with a session. Clear the cached valueholders and cursors.

initializeIdentityMapsOnServerSession	back to summary
public Transporter initializeIdentityMapsOnServerSession() Initalize all the server side identity maps.

instantiateRemoteValueHolderOnServer	back to summary
public Transporter instantiateRemoteValueHolderOnServer(Transporter remoteTransporter) The corresponding original value holder is instantiated.

isInTransaction	back to summary
protected boolean isInTransaction()

processCommand	back to summary
public Transporter processCommand(Transporter remoteCommand) INTERNAL: This method is intended to be used by by sessions that wish to execute a command on a remote session Parameters remoteCommand:Transporter RemoteCommand The command to be executed on the remote session

processCommand

back to summary

public Transporter processCommand(Transporter remoteCommand)

INTERNAL: This method is intended to be used by by sessions that wish to execute a command on a remote session

Parameters

remoteCommand:Transporter: RemoteCommand The command to be executed on the remote session

replaceValueHoldersIn	back to summary
public Map<K, V> replaceValueHoldersIn(Object object) Traverse the specified object, replacing the standard value holders with remote value holders. And build up a collection of object descriptors.

replaceValueHoldersIn	back to summary
public void replaceValueHoldersIn(Object object, Map<K, V> objectDescriptors) Traverse the specified object, replacing the standard value holders with remote value holders. Add the resulting object descriptors to the "collecting parm".

replaceValueHoldersInAll	back to summary
public Map<K, V> replaceValueHoldersInAll(Object container, ContainerPolicy policy) Traverse the specified objects, replacing the standard value holders with remote value holders. And build up a collection of object descriptors.

rollbackTransaction	back to summary
public Transporter rollbackTransaction() Rollback a transaction on the database.

saveRemoteValueHolder	back to summary
public void saveRemoteValueHolder(RemoteValueHolder<T> remoteValueHolder) Save the pre-serialized version of the remote value holder so that it can be used when the serialized version (on the client) is instantiated and needs to come back to the server to get its "value".

scrollableCursorAbsolute	back to summary
public Transporter scrollableCursorAbsolute(Transporter remoteScrollableCursorOid, int rows) Moves the cursor to the given row number in the result set

scrollableCursorAfterLast	back to summary
public Transporter scrollableCursorAfterLast(Transporter remoteScrollableCursorOid) Moves the cursor to the end of the result set, just after the last row.

scrollableCursorBeforeFirst	back to summary
public Transporter scrollableCursorBeforeFirst(Transporter remoteScrollableCursorOid) Moves the cursor to the front of the result set, just before the first row

scrollableCursorClose	back to summary
public Transporter scrollableCursorClose(Transporter remoteScrollableCursorOid) Used for closing cursored streams across RMI.

scrollableCursorCurrentIndex	back to summary
public Transporter scrollableCursorCurrentIndex(Transporter remoteScrollableCursorOid) Retrieves the current row index number

scrollableCursorFirst	back to summary
public Transporter scrollableCursorFirst(Transporter remoteScrollableCursorOid) Moves the cursor to the first row in the result set

scrollableCursorIsAfterLast	back to summary
public Transporter scrollableCursorIsAfterLast(Transporter remoteScrollableCursorOid) Indicates whether the cursor is after the last row in the result set.

scrollableCursorIsBeforeFirst	back to summary
public Transporter scrollableCursorIsBeforeFirst(Transporter remoteScrollableCursorOid) Indicates whether the cursor is before the first row in the result set.

scrollableCursorIsFirst	back to summary
public Transporter scrollableCursorIsFirst(Transporter remoteScrollableCursorOid) Indicates whether the cursor is on the first row of the result set.

scrollableCursorIsLast	back to summary
public Transporter scrollableCursorIsLast(Transporter remoteScrollableCursorOid) Indicates whether the cursor is on the last row of the result set.

scrollableCursorLast	back to summary
public Transporter scrollableCursorLast(Transporter remoteScrollableCursorOid) Moves the cursor to the last row in the result set

scrollableCursorNextObject	back to summary
public Transporter scrollableCursorNextObject(Transporter remoteScrollableCursorOid) Retrieve next object from the scrollable cursor

scrollableCursorPreviousObject	back to summary
public Transporter scrollableCursorPreviousObject(Transporter remoteScrollableCursorOid) Retrieve previous object from the scrollable cursor

scrollableCursorRelative	back to summary
public Transporter scrollableCursorRelative(Transporter remoteScrollableCursorOid, int rows) Moves the cursor to the given row number in the result set

scrollableCursorSize	back to summary
public Transporter scrollableCursorSize(Transporter remoteCursorOid) Return the scrollable cursor size from the server

setIsInTransaction	back to summary
protected void setIsInTransaction(boolean isInTransaction)

setRemoteCursors	back to summary
protected void setRemoteCursors(Map<ObjID, Cursor> remoteCursors) set the pre-remoted cursors

setRemoteValueHolders	back to summary
protected void setRemoteValueHolders(Map<ObjID, ValueHolderInterface<T>> remoteValueHolders) set the pre-serialized remote value holders

setSession	back to summary
protected void setSession(AbstractSession session) Set the associated server side session.

public Class RemoteSessionController

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail