public class RMIConnection
extends org.eclipse.persistence.internal.sessions.remote.RemoteConnection
| Constructor and Description |
|---|
RMIConnection(RMIRemoteSessionController controller)
PUBLIC:
The connection must be create from the server-side session controllers stub.
|
| Modifier and Type | Method and Description |
|---|---|
void |
beginEarlyTransaction()
INTERNAL:
Begin an early unit of work transaction.
|
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,
DistributedSession 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
|
Vector |
getDefaultReadOnlyClasses()
INTERNAL
Return the read-only classes
|
ClassDescriptor |
getDescriptor(Class domainClass)
INTERNAL:
Return the table descriptor specified for the class.
|
ClassDescriptor |
getDescriptorForAlias(String alias)
INTERNAL:
Return the table descriptor specified for the alias.
|
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,
DistributedSession session)
Retrieve next object from the remote scrollable cursor
|
Object |
scrollableCursorPreviousObject(ObjID remoteScrollableCursorOid,
ReadQuery query,
DistributedSession 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
|
public RMIConnection(RMIRemoteSessionController controller)
createRemoteSession()public void processCommand(org.eclipse.persistence.internal.sessions.remote.RemoteCommand command)
processCommand in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectioncommand - RemoteCOmmand Contains a command that will be executed on the remote sessionRemoteCommandpublic void beginTransaction()
beginTransaction in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic void beginEarlyTransaction()
beginEarlyTransaction in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic 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.RemoteConnectionpublic void commitTransaction()
commitTransaction in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic Session createRemoteSession()
createRemoteSession in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic void cursoredStreamClose(ObjID remoteCursoredStreamOid)
cursoredStreamClose in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic Vector cursoredStreamNextPage(org.eclipse.persistence.internal.sessions.remote.RemoteCursoredStream remoteCursoredStream, ReadQuery query, DistributedSession session, int pageSize)
cursoredStreamNextPage in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic int cursoredStreamSize(ObjID remoteCursoredStreamID)
cursoredStreamSize in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic org.eclipse.persistence.internal.sessions.remote.RemoteCursoredStream cursorSelectObjects(CursoredStreamPolicy policy, DistributedSession session)
cursorSelectObjects in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic org.eclipse.persistence.internal.sessions.remote.RemoteScrollableCursor cursorSelectObjects(ScrollableCursorPolicy policy, DistributedSession session)
cursorSelectObjects in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic Vector getDefaultReadOnlyClasses()
getDefaultReadOnlyClasses in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic ClassDescriptor getDescriptor(Class domainClass)
getDescriptor in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic ClassDescriptor getDescriptorForAlias(String alias)
getDescriptorForAlias in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic Login getLogin()
getLogin in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic RMIRemoteSessionController getRemoteSessionController()
public Object getSequenceNumberNamed(Object remoteFunctionCall)
getSequenceNumberNamed in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic void initializeIdentityMapsOnServerSession()
initializeIdentityMapsOnServerSession in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic 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.RemoteConnectionpublic org.eclipse.persistence.internal.sessions.remote.Transporter remoteExecute(DatabaseQuery query)
remoteExecute in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic org.eclipse.persistence.internal.sessions.remote.Transporter remoteExecuteNamedQuery(String name, Class javaClass, Vector arguments)
remoteExecuteNamedQuery in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic void rollbackTransaction()
rollbackTransaction in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic boolean scrollableCursorAbsolute(ObjID remoteScrollableCursorOid, int rows)
scrollableCursorAbsolute in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic void scrollableCursorAfterLast(ObjID remoteScrollableCursorOid)
scrollableCursorAfterLast in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic void scrollableCursorBeforeFirst(ObjID remoteScrollableCursorOid)
scrollableCursorBeforeFirst in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic void scrollableCursorClose(ObjID remoteScrollableCursorOid)
scrollableCursorClose in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic int scrollableCursorCurrentIndex(ObjID remoteScrollableCursorOid)
scrollableCursorCurrentIndex in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic boolean scrollableCursorFirst(ObjID remoteScrollableCursorOid)
scrollableCursorFirst in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic boolean scrollableCursorIsAfterLast(ObjID remoteScrollableCursorOid)
scrollableCursorIsAfterLast in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic boolean scrollableCursorIsBeforeFirst(ObjID remoteScrollableCursorOid)
scrollableCursorIsBeforeFirst in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic boolean scrollableCursorIsFirst(ObjID remoteScrollableCursorOid)
scrollableCursorIsFirst in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic boolean scrollableCursorIsLast(ObjID remoteScrollableCursorOid)
scrollableCursorIsLast in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic boolean scrollableCursorLast(ObjID remoteScrollableCursorOid)
scrollableCursorLast in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic Object scrollableCursorNextObject(ObjID remoteScrollableCursorOid, ReadQuery query, DistributedSession session)
scrollableCursorNextObject in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic Object scrollableCursorPreviousObject(ObjID remoteScrollableCursorOid, ReadQuery query, DistributedSession session)
scrollableCursorPreviousObject in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic boolean scrollableCursorRelative(ObjID remoteScrollableCursorOid, int rows)
scrollableCursorRelative in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic int scrollableCursorSize(ObjID cursorId)
scrollableCursorSize in class org.eclipse.persistence.internal.sessions.remote.RemoteConnectionpublic void setRemoteSessionController(RMIRemoteSessionController remoteSessionController)
Copyright © 2007–2021 Eclipse.org - EclipseLink Project. All rights reserved.