public class CORBAConnection extends RemoteConnection
Constructor and Description |
---|
CORBAConnection(CORBARemoteSessionController controller)
PUBLIC:
The connection must be create from the server-side session controllers stub.
|
Modifier and Type | Method and Description |
---|---|
void |
beginEarlyTransaction()
INTERNAL:
Begin a transaction on the database.
|
void |
beginTransaction()
INTERNAL:
Begin a transaction on the database.
|
RemoteUnitOfWork |
commitRootUnitOfWork(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(java.rmi.server.ObjID remoteCursoredStreamOid)
Used for closing cursored streams across RMI.
|
java.util.Vector |
cursoredStreamNextPage(RemoteCursoredStream remoteCursoredStream,
ReadQuery query,
DistributedSession session,
int pageSize)
Retrieve next page size of objects from the remote cursored stream
|
int |
cursoredStreamSize(java.rmi.server.ObjID remoteCursoredStreamID)
Return the cursored stream size
|
RemoteCursoredStream |
cursorSelectObjects(CursoredStreamPolicy policy,
DistributedSession session)
INTERNAL:
Returns remote cursor stream
|
RemoteScrollableCursor |
cursorSelectObjects(ScrollableCursorPolicy policy,
DistributedSession session)
INTERNAL:
Returns remote cursor stream
|
java.util.Vector |
getDefaultReadOnlyClasses()
INTERNAL
Return the read-only classes
|
ClassDescriptor |
getDescriptor(java.lang.Class domainClass)
INTERNAL:
Return the table descriptor specified for the class.
|
ClassDescriptor |
getDescriptorForAlias(java.lang.Class domainClass)
INTERNAL:
Return the table descriptor specified for the alias.
|
ClassDescriptor |
getDescriptorForAlias(java.lang.String alias)
INTERNAL:
Return the table descriptor specified for the alias.
|
Login |
getLogin()
INTERNAL:
Return the table descriptor specified for the class.
|
CORBARemoteSessionController |
getRemoteSessionController()
INTERNAL:
Return the remote session controller
|
java.lang.Object |
getSequenceNumberNamed(java.lang.Object remoteFunctionCall)
INTERNAL:
Perform remote function call
|
void |
initializeIdentityMapsOnServerSession()
INTERNAL:
Reset the cache on the server-side session.
|
Transporter |
instantiateRemoteValueHolderOnServer(RemoteValueHolder remoteValueHolder)
INTERNAL:
Instantiate remote value holder on the server
|
void |
processCommand(RemoteCommand command)
ADVANCED:
This method will send the command to the remote session for processing
|
Transporter |
remoteExecute(DatabaseQuery query)
INTERNAL:
Execute the query on the server.
|
Transporter |
remoteExecuteNamedQuery(java.lang.String name,
java.lang.Class javaClass,
java.util.Vector arguments)
INTERNAL:
Execute query remotely.
|
void |
rollbackTransaction()
INTERNAL:
Rollback a transaction on the database.
|
boolean |
scrollableCursorAbsolute(java.rmi.server.ObjID remoteScrollableCursorOid,
int rows)
Moves the cursor to the given row number in the result set
|
void |
scrollableCursorAfterLast(java.rmi.server.ObjID remoteScrollableCursorOid)
Moves the cursor to the end of the result set, just after the last row.
|
void |
scrollableCursorBeforeFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
Moves the cursor to the front of the result set, just before the first row
|
void |
scrollableCursorClose(java.rmi.server.ObjID remoteScrollableCursorOid)
Used for closing scrollable cursor across RMI.
|
int |
scrollableCursorCurrentIndex(java.rmi.server.ObjID remoteScrollableCursorOid)
Retrieves the current row index number
|
boolean |
scrollableCursorFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
Moves the cursor to the first row in the result set
|
boolean |
scrollableCursorIsAfterLast(java.rmi.server.ObjID remoteScrollableCursorOid)
Indicates whether the cursor is after the last row in the result set.
|
boolean |
scrollableCursorIsBeforeFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
Indicates whether the cursor is before the first row in the result set.
|
boolean |
scrollableCursorIsFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
Indicates whether the cursor is on the first row of the result set.
|
boolean |
scrollableCursorIsLast(java.rmi.server.ObjID remoteScrollableCursorOid)
Indicates whether the cursor is on the last row of the result set.
|
boolean |
scrollableCursorLast(java.rmi.server.ObjID remoteScrollableCursorOid)
Moves the cursor to the last row in the result set
|
java.lang.Object |
scrollableCursorNextObject(java.rmi.server.ObjID remoteScrollableCursorOid,
ReadQuery query,
DistributedSession session)
Retrieve next object from the remote scrollable cursor
|
java.lang.Object |
scrollableCursorPreviousObject(java.rmi.server.ObjID remoteScrollableCursorOid,
ReadQuery query,
DistributedSession session)
Retrieve previous object from the remote scrollable cursor
|
boolean |
scrollableCursorRelative(java.rmi.server.ObjID remoteScrollableCursorOid,
int rows)
Moves the cursor to the given row number in the result set
|
int |
scrollableCursorSize(java.rmi.server.ObjID cursorId)
Return the scrollable cursor size
|
void |
setRemoteSessionController(CORBARemoteSessionController remoteSessionController)
INTERNAL:
Set remote session controller
|
fixObjectReferences, getServiceName, getSession, initialize, isConnected, release, setServiceName, setSession
public CORBAConnection(CORBARemoteSessionController controller)
createRemoteSession()
public void processCommand(RemoteCommand command)
processCommand
in class RemoteConnection
command
- RemoteCommand Contains a command that will be executed on the remote sessionRemoteCommand
public void beginTransaction()
beginTransaction
in class RemoteConnection
public void beginEarlyTransaction()
beginEarlyTransaction
in class RemoteConnection
public RemoteUnitOfWork commitRootUnitOfWork(RemoteUnitOfWork theRemoteUnitOfWork)
commitRootUnitOfWork
in class RemoteConnection
public void commitTransaction()
commitTransaction
in class RemoteConnection
public Session createRemoteSession()
createRemoteSession
in class RemoteConnection
public void cursoredStreamClose(java.rmi.server.ObjID remoteCursoredStreamOid)
cursoredStreamClose
in class RemoteConnection
public java.util.Vector cursoredStreamNextPage(RemoteCursoredStream remoteCursoredStream, ReadQuery query, DistributedSession session, int pageSize)
cursoredStreamNextPage
in class RemoteConnection
public int cursoredStreamSize(java.rmi.server.ObjID remoteCursoredStreamID)
cursoredStreamSize
in class RemoteConnection
public RemoteCursoredStream cursorSelectObjects(CursoredStreamPolicy policy, DistributedSession session)
cursorSelectObjects
in class RemoteConnection
public RemoteScrollableCursor cursorSelectObjects(ScrollableCursorPolicy policy, DistributedSession session)
cursorSelectObjects
in class RemoteConnection
public ClassDescriptor getDescriptor(java.lang.Class domainClass)
getDescriptor
in class RemoteConnection
public ClassDescriptor getDescriptorForAlias(java.lang.String alias)
getDescriptorForAlias
in class RemoteConnection
public ClassDescriptor getDescriptorForAlias(java.lang.Class domainClass)
public java.util.Vector getDefaultReadOnlyClasses()
getDefaultReadOnlyClasses
in class RemoteConnection
public Login getLogin()
getLogin
in class RemoteConnection
public CORBARemoteSessionController getRemoteSessionController()
public java.lang.Object getSequenceNumberNamed(java.lang.Object remoteFunctionCall)
getSequenceNumberNamed
in class RemoteConnection
public void initializeIdentityMapsOnServerSession()
initializeIdentityMapsOnServerSession
in class RemoteConnection
public Transporter instantiateRemoteValueHolderOnServer(RemoteValueHolder remoteValueHolder)
instantiateRemoteValueHolderOnServer
in class RemoteConnection
public Transporter remoteExecute(DatabaseQuery query)
remoteExecute
in class RemoteConnection
public Transporter remoteExecuteNamedQuery(java.lang.String name, java.lang.Class javaClass, java.util.Vector arguments)
remoteExecuteNamedQuery
in class RemoteConnection
public void rollbackTransaction()
rollbackTransaction
in class RemoteConnection
public boolean scrollableCursorAbsolute(java.rmi.server.ObjID remoteScrollableCursorOid, int rows)
scrollableCursorAbsolute
in class RemoteConnection
public void scrollableCursorAfterLast(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorAfterLast
in class RemoteConnection
public void scrollableCursorBeforeFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorBeforeFirst
in class RemoteConnection
public void scrollableCursorClose(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorClose
in class RemoteConnection
public int scrollableCursorCurrentIndex(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorCurrentIndex
in class RemoteConnection
public boolean scrollableCursorFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorFirst
in class RemoteConnection
public boolean scrollableCursorIsAfterLast(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorIsAfterLast
in class RemoteConnection
public boolean scrollableCursorIsBeforeFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorIsBeforeFirst
in class RemoteConnection
public boolean scrollableCursorIsFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorIsFirst
in class RemoteConnection
public boolean scrollableCursorIsLast(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorIsLast
in class RemoteConnection
public boolean scrollableCursorLast(java.rmi.server.ObjID remoteScrollableCursorOid)
scrollableCursorLast
in class RemoteConnection
public java.lang.Object scrollableCursorNextObject(java.rmi.server.ObjID remoteScrollableCursorOid, ReadQuery query, DistributedSession session)
scrollableCursorNextObject
in class RemoteConnection
public java.lang.Object scrollableCursorPreviousObject(java.rmi.server.ObjID remoteScrollableCursorOid, ReadQuery query, DistributedSession session)
scrollableCursorPreviousObject
in class RemoteConnection
public boolean scrollableCursorRelative(java.rmi.server.ObjID remoteScrollableCursorOid, int rows)
scrollableCursorRelative
in class RemoteConnection
public int scrollableCursorSize(java.rmi.server.ObjID cursorId)
scrollableCursorSize
in class RemoteConnection
public void setRemoteSessionController(CORBARemoteSessionController remoteSessionController)
EclipseLink 2.6.3, "build v20160428-59c81c5" API Reference