Class OCommandRequest
java.lang.Object
com.orientechnologies.orient.client.remote.message.OCommandRequest
- All Implemented Interfaces:
OBinaryRequest<OCommandResponse>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionclassclassclassclass -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected OCommandRequest.OCommandcommandFromStream(OMemoryStream buffer, ORecordSerializer serializer) protected voidcommandToStream(OMemoryStream buffer, OCommandRequest.OCommand cmd) deserializeQueryParameters(byte[] paramBuffer, ORecordSerializer serializer) execute(OBinaryRequestExecutor executor) voidfromStream(byte[] iStream, ORecordSerializer serializer) Re-Create any object if the class has a public constructor that accepts a String as unique parameter.bytegetQuery()booleanisAsynch()booleanisLive()protected OCommandRequest.OLQueryliveQueryFromStream(OMemoryStream buffer, ORecordSerializer serializer) protected OCommandRequest.OQueryqueryFromStream(OMemoryStream buffer, ORecordSerializer serializer) voidread(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer) protected OCommandRequest.OScriptscriptFromStream(OMemoryStream buffer, ORecordSerializer serializer) voidscriptToStream(OMemoryStream buffer, OCommandRequest.OScript script) protected byte[]serializeQueryParameters(Map<Object, Object> params) byte[]toStream()Serialize the class name size + class name + object contentvoidwrite(OChannelDataOutput network, ORemoteClientSession session) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface com.orientechnologies.orient.client.remote.OBinaryRequest
requireDatabaseSession, requiredServerRole, requireServerUser
-
Constructor Details
-
OCommandRequest
public OCommandRequest()
-
-
Method Details
-
write
- Specified by:
writein interfaceOBinaryRequest<OCommandResponse>- Throws:
IOException
-
read
public void read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer) throws IOException - Specified by:
readin interfaceOBinaryRequest<OCommandResponse>- Throws:
IOException
-
fromStream
Re-Create any object if the class has a public constructor that accepts a String as unique parameter.- Throws:
IOException
-
toStream
Serialize the class name size + class name + object content- Throws:
IOException
-
serializeQueryParameters
-
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
-
getCommand
public byte getCommand()- Specified by:
getCommandin interfaceOBinaryRequest<OCommandResponse>
-
getQueryCommand
-
getScript
-
getLiveQuery
-
getDescription
- Specified by:
getDescriptionin interfaceOBinaryRequest<OCommandResponse>
-
getQuery
-
isAsynch
public boolean isAsynch() -
isLive
public boolean isLive() -
createResponse
- Specified by:
createResponsein interfaceOBinaryRequest<OCommandResponse>
-
execute
- Specified by:
executein interfaceOBinaryRequest<OCommandResponse>
-