public abstract class RemoteConnection
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
RemoteConnection() |
Modifier and Type | Method and Description |
---|---|
abstract void |
beginTransaction()
Begin a transaction on the database.
|
abstract RemoteUnitOfWork |
commitRootUnitOfWork(RemoteUnitOfWork remoteUnitOfWork)
Commit remote unit of work
|
abstract void |
commitTransaction()
Commit a transaction on the database.
|
abstract Session |
createRemoteSession()
Returns remote client session.
|
abstract void |
cursoredStreamClose(java.rmi.server.ObjID id)
Used for closing cursored streams across RMI.
|
abstract java.util.Vector |
cursoredStreamNextPage(RemoteCursoredStream remoteCursoredStream,
ReadQuery query,
RemoteSession session,
int pageSize)
Retrieve next page size of objects from the remote cursored stream
|
abstract int |
cursoredStreamSize(java.rmi.server.ObjID remoteCursoredStreamID)
Return the cursored stream size
|
abstract RemoteCursoredStream |
cursorSelectObjects(CursoredStreamPolicy policy,
DistributedSession session)
Get remote cursor stream.
|
abstract RemoteScrollableCursor |
cursorSelectObjects(ScrollableCursorPolicy policy,
DistributedSession session)
Get remote cursor stream.
|
abstract java.util.Vector |
getDefaultReadOnlyClasses()
INTERNAL:
Get the read-only classes
|
abstract ClassDescriptor |
getDescriptor(java.lang.Class domainClass)
Get descriptor
|
abstract Login |
getLogin()
Return the login informaiton from the server.
|
abstract java.lang.Object |
getSequenceNumberNamed(java.lang.Object remoteFunctionCall)
INTERNAL:
Perform remote function call
|
java.lang.String |
getServiceName()
ADVANCED:
This method is used to get the globally unique identifier for this connection.
|
abstract void |
initializeIdentityMapsOnServerSession() |
abstract Transporter |
instantiateRemoteValueHolderOnServer(RemoteValueHolder remoteValueHolder)
Instantiated remote value holder.
|
abstract void |
processCommand(RemoteCommand remoteCommand)
INTERNAL:
This method is intended to be used by newly connecting nodes to notify the
other nodes in a distributed system to send changes to this calling server
|
void |
release()
PUBLIC:
Release the connection resource.
|
abstract Transporter |
remoteExecute(DatabaseQuery query)
Execute query remotely.
|
abstract Transporter |
remoteExecuteNamedQuery(java.lang.String name,
java.lang.Class javaClass,
java.util.Vector arguments)
Execute query remotely.
|
abstract void |
rollbackTransaction()
Rollback a transaction on the database.
|
abstract boolean |
scrollableCursorAbsolute(java.rmi.server.ObjID remoteScrollableCursorOid,
int rows)
Moves the cursor to the given row number in the result set
|
abstract void |
scrollableCursorAfterLast(java.rmi.server.ObjID remoteScrollableCursorOid)
Moves the cursor to the end of the result set, just after the last row.
|
abstract void |
scrollableCursorBeforeFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
Moves the cursor to the front of the result set, just before the first row
|
abstract void |
scrollableCursorClose(java.rmi.server.ObjID remoteScrollableCursorOid)
Used for closing scrolable cursor across RMI.
|
abstract int |
scrollableCursorCurrentIndex(java.rmi.server.ObjID remoteScrollableCursorOid)
Retrieves the current row index number
|
abstract boolean |
scrollableCursorFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
Moves the cursor to the first row in the result set
|
abstract boolean |
scrollableCursorIsAfterLast(java.rmi.server.ObjID remoteScrollableCursorOid)
Indicates whether the cursor is after the last row in the result set.
|
abstract boolean |
scrollableCursorIsBeforeFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
Indicates whether the cursor is before the first row in the result set.
|
abstract boolean |
scrollableCursorIsFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
Indicates whether the cursor is on the first row of the result set.
|
abstract boolean |
scrollableCursorIsLast(java.rmi.server.ObjID remoteScrollableCursorOid)
Indicates whether the cursor is on the last row of the result set.
|
abstract boolean |
scrollableCursorLast(java.rmi.server.ObjID remoteScrollableCursorOid)
Moves the cursor to the last row in the result set
|
abstract java.lang.Object |
scrollableCursorNextObject(java.rmi.server.ObjID remoteScrollableCursorOid,
ReadQuery query,
RemoteSession session)
Retrieve next object from the remote scrollable cursor
|
abstract java.lang.Object |
scrollableCursorPreviousObject(java.rmi.server.ObjID remoteScrollableCursorOid,
ReadQuery query,
RemoteSession session)
Retrieve previous object from the remote scrollable cursor
|
abstract boolean |
scrollableCursorRelative(java.rmi.server.ObjID remoteScrollableCursorOid,
int rows)
Moves the cursor a relative number of rows, either positive or negative.
|
abstract int |
scrollableCursorSize(java.rmi.server.ObjID cursorId)
Return the scrollable cursor size
|
void |
setServiceName(java.lang.String newServiceName)
ADVANCED:
This method is used to set the globally unique identifier for this connection.
|
public abstract void processCommand(RemoteCommand remoteCommand)
remoteTransporter
- Transporter This transporter contains the RemoteDispatcher of the calling
server.public abstract void beginTransaction()
public abstract RemoteUnitOfWork commitRootUnitOfWork(RemoteUnitOfWork remoteUnitOfWork)
public abstract void commitTransaction()
public abstract Session createRemoteSession()
public abstract void cursoredStreamClose(java.rmi.server.ObjID id)
public abstract java.util.Vector cursoredStreamNextPage(RemoteCursoredStream remoteCursoredStream, ReadQuery query, RemoteSession session, int pageSize)
public abstract int cursoredStreamSize(java.rmi.server.ObjID remoteCursoredStreamID)
public abstract RemoteCursoredStream cursorSelectObjects(CursoredStreamPolicy policy, DistributedSession session)
public abstract RemoteScrollableCursor cursorSelectObjects(ScrollableCursorPolicy policy, DistributedSession session)
public abstract java.util.Vector getDefaultReadOnlyClasses()
public abstract ClassDescriptor getDescriptor(java.lang.Class domainClass)
public abstract Login getLogin()
public abstract java.lang.Object getSequenceNumberNamed(java.lang.Object remoteFunctionCall)
public java.lang.String getServiceName()
public abstract void initializeIdentityMapsOnServerSession()
public abstract Transporter instantiateRemoteValueHolderOnServer(RemoteValueHolder remoteValueHolder)
public abstract Transporter remoteExecute(DatabaseQuery query)
public abstract Transporter remoteExecuteNamedQuery(java.lang.String name, java.lang.Class javaClass, java.util.Vector arguments)
public abstract void rollbackTransaction()
public abstract boolean scrollableCursorAbsolute(java.rmi.server.ObjID remoteScrollableCursorOid, int rows)
public abstract void scrollableCursorAfterLast(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract void scrollableCursorBeforeFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract void scrollableCursorClose(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract int scrollableCursorCurrentIndex(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract boolean scrollableCursorFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract boolean scrollableCursorIsAfterLast(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract boolean scrollableCursorIsBeforeFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract boolean scrollableCursorIsFirst(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract boolean scrollableCursorIsLast(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract boolean scrollableCursorLast(java.rmi.server.ObjID remoteScrollableCursorOid)
public abstract java.lang.Object scrollableCursorNextObject(java.rmi.server.ObjID remoteScrollableCursorOid, ReadQuery query, RemoteSession session)
public abstract java.lang.Object scrollableCursorPreviousObject(java.rmi.server.ObjID remoteScrollableCursorOid, ReadQuery query, RemoteSession session)
public abstract boolean scrollableCursorRelative(java.rmi.server.ObjID remoteScrollableCursorOid, int rows)
public abstract int scrollableCursorSize(java.rmi.server.ObjID cursorId)
public void setServiceName(java.lang.String newServiceName)
newServiceName
- java.lang.Stringpublic void release()
EclipseLink 2.4.2, "build v20130514-5956486" API Reference