public abstract class RemoteConnection
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
RemoteConnection() |
Modifier and Type | Method and Description |
---|---|
abstract void |
beginEarlyTransaction()
Begin an early unit of work transaction.
|
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,
DistributedSession 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.
|
void |
fixObjectReferences(Transporter remoteCursoredStream,
ObjectLevelReadQuery query,
DistributedSession session)
INTERNAL:
An object has been serialized from the server to the remote client.
|
abstract java.util.Vector |
getDefaultReadOnlyClasses()
INTERNAL:
Get the read-only classes
|
abstract ClassDescriptor |
getDescriptor(java.lang.Class domainClass)
Get descriptor
|
abstract ClassDescriptor |
getDescriptorForAlias(java.lang.String alias)
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.
|
DistributedSession |
getSession() |
void |
initialize(DistributedSession session)
Allow the connection to initialize an setting in the session.
|
abstract void |
initializeIdentityMapsOnServerSession() |
abstract Transporter |
instantiateRemoteValueHolderOnServer(RemoteValueHolder remoteValueHolder)
Instantiated remote value holder.
|
boolean |
isConnected() |
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,
DistributedSession session)
Retrieve next object from the remote scrollable cursor
|
abstract java.lang.Object |
scrollableCursorPreviousObject(java.rmi.server.ObjID remoteScrollableCursorOid,
ReadQuery query,
DistributedSession 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.
|
void |
setSession(DistributedSession session) |
public abstract void processCommand(RemoteCommand remoteCommand)
remoteTransporter
- Transporter This transporter contains the RemoteDispatcher of the calling
server.public void initialize(DistributedSession session)
public DistributedSession getSession()
public void setSession(DistributedSession session)
public boolean isConnected()
public abstract void beginTransaction()
public abstract void beginEarlyTransaction()
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, DistributedSession 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 ClassDescriptor getDescriptorForAlias(java.lang.String alias)
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, DistributedSession session)
public abstract java.lang.Object scrollableCursorPreviousObject(java.rmi.server.ObjID remoteScrollableCursorOid, ReadQuery query, DistributedSession 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()
public void fixObjectReferences(Transporter remoteCursoredStream, ObjectLevelReadQuery query, DistributedSession session)
EclipseLink 2.6.3, "build v20160428-59c81c5" API Reference