|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.eclipse.persistence.internal.sessions.remote.RemoteConnection
org.eclipse.persistence.sessions.remote.rmi.RMIConnection
public class RMIConnection
This class exists on on the client side which talks to remote session controller through RMI connection.
Constructor Summary | |
---|---|
RMIConnection(RMIRemoteSessionController controller)
PUBLIC: The connection must be create from the server-side session controllers stub. |
Method Summary | |
---|---|
void |
beginTransaction()
INTERNAL: Begin a transaction on the database. |
org.eclipse.persistence.internal.sessions.remote.RemoteUnitOfWork |
commitRootUnitOfWork(org.eclipse.persistence.internal.sessions.remote.RemoteUnitOfWork theRemoteUnitOfWork)
INTERNAL: Commit root unit of work from the client side to the server side. |
void |
commitTransaction()
INTERNAL: Commit a transaction on the database. |
Session |
createRemoteSession()
PUBLIC: Returns a remote session. |
void |
cursoredStreamClose(ObjID remoteCursoredStreamOid)
Used for closing cursored streams across RMI. |
Vector |
cursoredStreamNextPage(org.eclipse.persistence.internal.sessions.remote.RemoteCursoredStream remoteCursoredStream,
ReadQuery query,
RemoteSession session,
int pageSize)
Retrieve next page size of objects from the remote cursored stream |
int |
cursoredStreamSize(ObjID remoteCursoredStreamID)
Return the cursored stream size |
org.eclipse.persistence.internal.sessions.remote.RemoteCursoredStream |
cursorSelectObjects(CursoredStreamPolicy policy,
DistributedSession session)
INTERNAL: Returns remote cursor stream |
org.eclipse.persistence.internal.sessions.remote.RemoteScrollableCursor |
cursorSelectObjects(ScrollableCursorPolicy policy,
DistributedSession session)
INTERNAL: Returns remote cursor stream |
void |
fixObjectReferences(org.eclipse.persistence.internal.sessions.remote.Transporter remoteCursoredStream,
ObjectLevelReadQuery query,
RemoteSession session)
INTERNAL: An object has been serialized from the server to the remote client. |
Vector |
getDefaultReadOnlyClasses()
INTERNAL Return the read-only classes |
ClassDescriptor |
getDescriptor(Class domainClass)
INTERNAL: Return the table descriptor specified for the class. |
Login |
getLogin()
INTERNAL: Return the table descriptor specified for the class. |
RMIRemoteSessionController |
getRemoteSessionController()
INTERNAL: Return the remote session controller |
Object |
getSequenceNumberNamed(Object remoteFunctionCall)
INTERNAL: Perform remote function call |
void |
initializeIdentityMapsOnServerSession()
INTERNAL: Reset the cache on the server-side session. |
org.eclipse.persistence.internal.sessions.remote.Transporter |
instantiateRemoteValueHolderOnServer(org.eclipse.persistence.internal.sessions.remote.RemoteValueHolder remoteValueHolder)
INTERNAL: Instantiate remote value holder on the server |
void |
processCommand(org.eclipse.persistence.internal.sessions.remote.RemoteCommand command)
ADVANCED: This method will send the command to the remote session for processing |
org.eclipse.persistence.internal.sessions.remote.Transporter |
remoteExecute(DatabaseQuery query)
INTERNAL: Execute the query on the server. |
org.eclipse.persistence.internal.sessions.remote.Transporter |
remoteExecuteNamedQuery(String name,
Class javaClass,
Vector arguments)
INTERNAL: Execute query remotely. |
void |
rollbackTransaction()
INTERNAL: Rollback a transaction on the database. |
boolean |
scrollableCursorAbsolute(ObjID remoteScrollableCursorOid,
int rows)
Moves the cursor to the given row number in the result set |
void |
scrollableCursorAfterLast(ObjID remoteScrollableCursorOid)
Moves the cursor to the end of the result set, just after the last row. |
void |
scrollableCursorBeforeFirst(ObjID remoteScrollableCursorOid)
Moves the cursor to the front of the result set, just before the first row |
void |
scrollableCursorClose(ObjID remoteScrollableCursorOid)
Used for closing scrollable cursor across RMI. |
int |
scrollableCursorCurrentIndex(ObjID remoteScrollableCursorOid)
Retrieves the current row index number |
boolean |
scrollableCursorFirst(ObjID remoteScrollableCursorOid)
Moves the cursor to the first row in the result set |
boolean |
scrollableCursorIsAfterLast(ObjID remoteScrollableCursorOid)
Indicates whether the cursor is after the last row in the result set. |
boolean |
scrollableCursorIsBeforeFirst(ObjID remoteScrollableCursorOid)
Indicates whether the cursor is before the first row in the result set. |
boolean |
scrollableCursorIsFirst(ObjID remoteScrollableCursorOid)
Indicates whether the cursor is on the first row of the result set. |
boolean |
scrollableCursorIsLast(ObjID remoteScrollableCursorOid)
Indicates whether the cursor is on the last row of the result set. |
boolean |
scrollableCursorLast(ObjID remoteScrollableCursorOid)
Moves the cursor to the last row in the result set |
Object |
scrollableCursorNextObject(ObjID remoteScrollableCursorOid,
ReadQuery query,
RemoteSession session)
Retrieve next object from the remote scrollable cursor |
Object |
scrollableCursorPreviousObject(ObjID remoteScrollableCursorOid,
ReadQuery query,
RemoteSession session)
Retrieve previous object from the remote scrollable cursor |
boolean |
scrollableCursorRelative(ObjID remoteScrollableCursorOid,
int rows)
Moves the cursor to the given row number in the result set |
int |
scrollableCursorSize(ObjID cursorId)
Return the scrollable cursor size |
void |
setRemoteSessionController(RMIRemoteSessionController remoteSessionController)
INTERNAL: Set remote session controller |
Methods inherited from class org.eclipse.persistence.internal.sessions.remote.RemoteConnection |
---|
getServiceName, release, setServiceName |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RMIConnection(RMIRemoteSessionController controller)
createRemoteSession();
Method Detail |
---|
public void processCommand(org.eclipse.persistence.internal.sessions.remote.RemoteCommand command)
processCommand
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
command
- RemoteCOmmand Contains a command that will be executed on the remote sessionorg.eclipse.persistence.internal.RemoteCommand
public void beginTransaction()
beginTransaction
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public org.eclipse.persistence.internal.sessions.remote.RemoteUnitOfWork commitRootUnitOfWork(org.eclipse.persistence.internal.sessions.remote.RemoteUnitOfWork theRemoteUnitOfWork)
commitRootUnitOfWork
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void commitTransaction()
commitTransaction
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public Session createRemoteSession()
createRemoteSession
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void cursoredStreamClose(ObjID remoteCursoredStreamOid)
cursoredStreamClose
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public Vector cursoredStreamNextPage(org.eclipse.persistence.internal.sessions.remote.RemoteCursoredStream remoteCursoredStream, ReadQuery query, RemoteSession session, int pageSize)
cursoredStreamNextPage
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public int cursoredStreamSize(ObjID remoteCursoredStreamID)
cursoredStreamSize
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public org.eclipse.persistence.internal.sessions.remote.RemoteCursoredStream cursorSelectObjects(CursoredStreamPolicy policy, DistributedSession session)
cursorSelectObjects
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public org.eclipse.persistence.internal.sessions.remote.RemoteScrollableCursor cursorSelectObjects(ScrollableCursorPolicy policy, DistributedSession session)
cursorSelectObjects
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void fixObjectReferences(org.eclipse.persistence.internal.sessions.remote.Transporter remoteCursoredStream, ObjectLevelReadQuery query, RemoteSession session)
public Vector getDefaultReadOnlyClasses()
getDefaultReadOnlyClasses
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public ClassDescriptor getDescriptor(Class domainClass)
getDescriptor
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public Login getLogin()
getLogin
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public RMIRemoteSessionController getRemoteSessionController()
public Object getSequenceNumberNamed(Object remoteFunctionCall)
getSequenceNumberNamed
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void initializeIdentityMapsOnServerSession()
initializeIdentityMapsOnServerSession
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public org.eclipse.persistence.internal.sessions.remote.Transporter instantiateRemoteValueHolderOnServer(org.eclipse.persistence.internal.sessions.remote.RemoteValueHolder remoteValueHolder)
instantiateRemoteValueHolderOnServer
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public org.eclipse.persistence.internal.sessions.remote.Transporter remoteExecute(DatabaseQuery query)
remoteExecute
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public org.eclipse.persistence.internal.sessions.remote.Transporter remoteExecuteNamedQuery(String name, Class javaClass, Vector arguments)
remoteExecuteNamedQuery
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void rollbackTransaction()
rollbackTransaction
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public boolean scrollableCursorAbsolute(ObjID remoteScrollableCursorOid, int rows)
scrollableCursorAbsolute
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void scrollableCursorAfterLast(ObjID remoteScrollableCursorOid)
scrollableCursorAfterLast
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void scrollableCursorBeforeFirst(ObjID remoteScrollableCursorOid)
scrollableCursorBeforeFirst
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void scrollableCursorClose(ObjID remoteScrollableCursorOid)
scrollableCursorClose
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public int scrollableCursorCurrentIndex(ObjID remoteScrollableCursorOid)
scrollableCursorCurrentIndex
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public boolean scrollableCursorFirst(ObjID remoteScrollableCursorOid)
scrollableCursorFirst
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public boolean scrollableCursorIsAfterLast(ObjID remoteScrollableCursorOid)
scrollableCursorIsAfterLast
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public boolean scrollableCursorIsBeforeFirst(ObjID remoteScrollableCursorOid)
scrollableCursorIsBeforeFirst
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public boolean scrollableCursorIsFirst(ObjID remoteScrollableCursorOid)
scrollableCursorIsFirst
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public boolean scrollableCursorIsLast(ObjID remoteScrollableCursorOid)
scrollableCursorIsLast
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public boolean scrollableCursorLast(ObjID remoteScrollableCursorOid)
scrollableCursorLast
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public Object scrollableCursorNextObject(ObjID remoteScrollableCursorOid, ReadQuery query, RemoteSession session)
scrollableCursorNextObject
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public Object scrollableCursorPreviousObject(ObjID remoteScrollableCursorOid, ReadQuery query, RemoteSession session)
scrollableCursorPreviousObject
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public boolean scrollableCursorRelative(ObjID remoteScrollableCursorOid, int rows)
scrollableCursorRelative
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public int scrollableCursorSize(ObjID cursorId)
scrollableCursorSize
in class org.eclipse.persistence.internal.sessions.remote.RemoteConnection
public void setRemoteSessionController(RMIRemoteSessionController remoteSessionController)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |