Package com.orientechnologies.orient.client.remote.message

Class OCommandRequest

java.lang.Object

com.orientechnologies.orient.client.remote.message.OCommandRequest

All Implemented Interfaces:

OBinaryRequest<OCommandResponse>

public final class OCommandRequest
extends Object
implements OBinaryRequest<OCommandResponse>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	OCommandRequest.OCommand
class	OCommandRequest.OLQuery
class	OCommandRequest.OQuery
class	OCommandRequest.OScript

Constructor Summary

Constructors

Constructor	Description
OCommandRequest()

Method Summary

Modifier and Type	Method	Description
protected OCommandRequest.OCommand	commandFromStream(OMemoryStream buffer, ORecordSerializer serializer)
protected void	commandToStream(OMemoryStream buffer, OCommandRequest.OCommand cmd)
OCommandResponse	createResponse()
protected Map<Object,Object>	deserializeQueryParameters(byte[] paramBuffer, ORecordSerializer serializer)
OBinaryResponse	execute(OBinaryRequestExecutor executor)
void	fromStream(byte[] iStream, ORecordSerializer serializer)	Re-Create any object if the class has a public constructor that accepts a String as unique parameter.
byte	getCommand()
String	getDescription()
OCommandRequest.OLQuery	getLiveQuery()
OCommandRequest.OQuery	getQuery()
OCommandRequest.OCommand	getQueryCommand()
OCommandRequest.OScript	getScript()
boolean	isAsynch()
boolean	isLive()
protected OCommandRequest.OLQuery	liveQueryFromStream(OMemoryStream buffer, ORecordSerializer serializer)
protected OCommandRequest.OQuery	queryFromStream(OMemoryStream buffer, ORecordSerializer serializer)
void	read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer)
protected OCommandRequest.OScript	scriptFromStream(OMemoryStream buffer, ORecordSerializer serializer)
void	scriptToStream(OMemoryStream buffer, OCommandRequest.OScript script)
protected byte[]	serializeQueryParameters(Map<Object,Object> params)
byte[]	toStream()	Serialize the class name size + class name + object content
void	write(OChannelDataOutput network, ORemoteClientSession session)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.orientechnologies.orient.client.remote.OBinaryRequest

requireDatabaseSession, requiredServerRole, requireServerUser

Constructor Details

OCommandRequest

public OCommandRequest()

Method Details

write

public void write(OChannelDataOutput network,
 ORemoteClientSession session)
           throws IOException

Specified by:

write in interface OBinaryRequest<OCommandResponse>

Throws:

IOException

read

public void read(OChannelDataInput channel,
 int protocolVersion,
 ORecordSerializer serializer)
          throws IOException

Specified by:

read in interface OBinaryRequest<OCommandResponse>

Throws:

IOException

fromStream

public void fromStream(byte[] iStream,
 ORecordSerializer serializer)
                throws IOException

Re-Create any object if the class has a public constructor that accepts a String as unique parameter.

Throws:

IOException

toStream

public byte[] toStream()
                throws IOException

Serialize the class name size + class name + object content

Throws:

IOException

serializeQueryParameters

protected byte[] serializeQueryParameters(Map<Object,Object> params)

queryFromStream

protected OCommandRequest.OQuery queryFromStream(OMemoryStream buffer,
 ORecordSerializer serializer)

liveQueryFromStream

protected OCommandRequest.OLQuery liveQueryFromStream(OMemoryStream buffer,
 ORecordSerializer serializer)

deserializeQueryParameters

protected Map<Object,Object> deserializeQueryParameters(byte[] paramBuffer,
 ORecordSerializer serializer)

scriptFromStream

protected OCommandRequest.OScript scriptFromStream(OMemoryStream buffer,
 ORecordSerializer serializer)

commandFromStream

protected OCommandRequest.OCommand commandFromStream(OMemoryStream buffer,
 ORecordSerializer serializer)

scriptToStream

public void scriptToStream(OMemoryStream buffer,
 OCommandRequest.OScript script)
                    throws OSerializationException

Throws:

OSerializationException

commandToStream

protected void commandToStream(OMemoryStream buffer,
 OCommandRequest.OCommand cmd)

getCommand

public byte getCommand()

Specified by:

getCommand in interface OBinaryRequest<OCommandResponse>

getQueryCommand

public OCommandRequest.OCommand getQueryCommand()

getScript

public OCommandRequest.OScript getScript()

getLiveQuery

public OCommandRequest.OLQuery getLiveQuery()

getDescription

public String getDescription()

Specified by:

getDescription in interface OBinaryRequest<OCommandResponse>

getQuery

public OCommandRequest.OQuery getQuery()

isAsynch

public boolean isAsynch()

isLive

public boolean isLive()

createResponse

public OCommandResponse createResponse()

Specified by:

createResponse in interface OBinaryRequest<OCommandResponse>

execute

public OBinaryResponse execute(OBinaryRequestExecutor executor)

Specified by:

execute in interface OBinaryRequest<OCommandResponse>