com.orientechnologies.orient.server

Class OConnectionBinaryExecutor

java.lang.Object

com.orientechnologies.orient.server.OConnectionBinaryExecutor

All Implemented Interfaces:

OBinaryRequestExecutor

public final class OConnectionBinaryExecutor
extends Object
implements OBinaryRequestExecutor

Constructor Summary

Constructors

Constructor and Description
OConnectionBinaryExecutor(OClientConnection connection, OServer server)
OConnectionBinaryExecutor(OClientConnection connection, OServer server, HandshakeInfo handshakeInfo)

Method Summary

Modifier and Type	Method and Description
OBinaryResponse	closeQuery(OCloseQueryRequest oQueryRequest)
OBinaryResponse	executeAddCluster(OAddClusterRequest request)
OBinaryResponse	executeBatchOperations(OBatchOperationsRequest request)
OBinaryResponse	executeBeginTransaction(OBeginTransactionRequest request)
OBinaryResponse	executeBeginTransaction38(OBeginTransaction38Request request)
OBinaryResponse	executeCeilingPosition(OCeilingPhysicalPositionsRequest request)
OBinaryResponse	executeCleanOutRecord(OCleanOutRecordRequest request)
OBinaryResponse	executeClose(OCloseRequest request)
OBinaryResponse	executeClusterDataRange(OGetClusterDataRangeRequest request)
OBinaryResponse	executeCommand(OCommandRequest request)
OBinaryResponse	executeCommit(OCommitRequest request)
OBinaryResponse	executeCommit37(OCommit37Request request)
OBinaryResponse	executeCommit38(OCommit38Request request)
OBinaryResponse	executeConnect(OConnectRequest request)
OBinaryResponse	executeConnect37(OConnect37Request request)
OBinaryResponse	executeCountCluster(OCountRequest request)
OBinaryResponse	executeCountRecords(OCountRecordsRequest request)
OBinaryResponse	executeCreateDatabase(OCreateDatabaseRequest request)
OBinaryResponse	executeCreateRecord(OCreateRecordRequest request)
OBinaryResponse	executeDatabaseOpen(OOpenRequest request)
OBinaryResponse	executeDatabaseOpen37(OOpen37Request request)
OBinaryResponse	executeDBReload(OReloadRequest request)
OBinaryResponse	executeDBReload(OReloadRequest37 request)
OBinaryResponse	executeDeleteRecord(ODeleteRecordRequest request)
OBinaryResponse	executeDistributedConnect(ODistributedConnectRequest request)
OBinaryResponse	executeDistributedStatus(ODistributedStatusRequest request)
OBinaryResponse	executeDropCluster(ODropClusterRequest request)
OBinaryResponse	executeDropDatabase(ODropDatabaseRequest request)
OBinaryResponse	executeExistDatabase(OExistsDatabaseRequest request)
OBinaryResponse	executeExperimental(OExperimentalRequest request)
OBinaryResponse	executeFetchTransaction(OFetchTransactionRequest request)
OBinaryResponse	executeFetchTransaction38(OFetchTransaction38Request request)
OBinaryResponse	executeFloorPosition(OFloorPhysicalPositionsRequest request)
OBinaryResponse	executeFreezeDatabase(OFreezeDatabaseRequest request)
OBinaryResponse	executeGetGlobalConfiguration(OGetGlobalConfigurationRequest request)
OBinaryResponse	executeGetRecordMetadata(OGetRecordMetadataRequest request)
OBinaryResponse	executeGetSize(OGetSizeRequest request)
OBinaryResponse	executeHigherPosition(OHigherPhysicalPositionsRequest request)
OBinaryResponse	executeImport(OImportRequest request)
OBinaryResponse	executeIncrementalBackup(OIncrementalBackupRequest request)
OListDatabasesResponse	executeListDatabases(OListDatabasesRequest request)
OBinaryResponse	executeListGlobalConfigurations(OListGlobalConfigurationsRequest request)
OBinaryResponse	executeLockRecord(OLockRecordRequest request)
OBinaryResponse	executeLowerPosition(OLowerPhysicalPositionsRequest request)
OBinaryResponse	executeQuery(OQueryRequest request)
OBinaryResponse	executeQueryNextPage(OQueryNextPageRequest request)
OBinaryResponse	executeReadRecord(OReadRecordRequest request)
OBinaryResponse	executeReadRecordIfNotLastest(OReadRecordIfVersionIsNotLatestRequest request)
OBinaryResponse	executeReleaseDatabase(OReleaseDatabaseRequest request)
OBinaryResponse	executeReopen(OReopenRequest request)
OBinaryResponse	executeRollback(ORollbackTransactionRequest request)
OBinaryResponse	executeSBTFetchEntriesMajor(OSBTFetchEntriesMajorRequest request)
OBinaryResponse	executeSBTFirstKey(OSBTFirstKeyRequest request)
OBinaryResponse	executeSBTGet(OSBTGetRequest request)
OBinaryResponse	executeSBTGetRealSize(OSBTGetRealBagSizeRequest request)
OBinaryResponse	executeSBTreeCreate(OSBTCreateTreeRequest request)
OBinaryResponse	executeServerInfo(OServerInfoRequest request)
OBinaryResponse	executeSetGlobalConfig(OSetGlobalConfigurationRequest request)
OBinaryResponse	executeShutdown(OShutdownRequest request)
OBinaryResponse	executeSubscribe(OSubscribeRequest request)
OBinaryResponse	executeSubscribeDistributedConfiguration(OSubscribeDistributedConfigurationRequest request)
OBinaryResponse	executeSubscribeFunctions(OSubscribeFunctionsRequest request)
OBinaryResponse	executeSubscribeIndexManager(OSubscribeIndexManagerRequest request)
OBinaryResponse	executeSubscribeLiveQuery(OSubscribeLiveQueryRequest request)
OBinaryResponse	executeSubscribeSchema(OSubscribeSchemaRequest request)
OBinaryResponse	executeSubscribeSequences(OSubscribeSequencesRequest request)
OBinaryResponse	executeSubscribeStorageConfiguration(OSubscribeStorageConfigurationRequest request)
OBinaryResponse	executeUnlockRecord(OUnlockRecordRequest request)
OBinaryResponse	executeUnsubscribe(OUnsubscribeRequest request)
OBinaryResponse	executeUnsubscribeLiveQuery(OUnsubscribeLiveQueryRequest request)
OBinaryResponse	executeUpdateRecord(OUpdateRecordRequest request)
static byte[]	getRecordBytes(OClientConnection connection, ORecord iRecord)

Methods inherited from class java.lang.Object

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

Constructor Detail

OConnectionBinaryExecutor

public OConnectionBinaryExecutor(OClientConnection connection,
                                 OServer server)

OConnectionBinaryExecutor

public OConnectionBinaryExecutor(OClientConnection connection,
                                 OServer server,
                                 HandshakeInfo handshakeInfo)

Method Detail

executeListDatabases

public OListDatabasesResponse executeListDatabases(OListDatabasesRequest request)

Specified by:

executeListDatabases in interface OBinaryRequestExecutor

executeServerInfo

public OBinaryResponse executeServerInfo(OServerInfoRequest request)

Specified by:

executeServerInfo in interface OBinaryRequestExecutor

executeDBReload

public OBinaryResponse executeDBReload(OReloadRequest request)

Specified by:

executeDBReload in interface OBinaryRequestExecutor

executeDBReload

public OBinaryResponse executeDBReload(OReloadRequest37 request)

Specified by:

executeDBReload in interface OBinaryRequestExecutor

executeCreateDatabase

public OBinaryResponse executeCreateDatabase(OCreateDatabaseRequest request)

Specified by:

executeCreateDatabase in interface OBinaryRequestExecutor

executeClose

public OBinaryResponse executeClose(OCloseRequest request)

Specified by:

executeClose in interface OBinaryRequestExecutor

executeExistDatabase

public OBinaryResponse executeExistDatabase(OExistsDatabaseRequest request)

Specified by:

executeExistDatabase in interface OBinaryRequestExecutor

executeDropDatabase

public OBinaryResponse executeDropDatabase(ODropDatabaseRequest request)

Specified by:

executeDropDatabase in interface OBinaryRequestExecutor

executeGetSize

public OBinaryResponse executeGetSize(OGetSizeRequest request)

Specified by:

executeGetSize in interface OBinaryRequestExecutor

executeCountRecords

public OBinaryResponse executeCountRecords(OCountRecordsRequest request)

Specified by:

executeCountRecords in interface OBinaryRequestExecutor

executeDistributedStatus

public OBinaryResponse executeDistributedStatus(ODistributedStatusRequest request)

Specified by:

executeDistributedStatus in interface OBinaryRequestExecutor

executeCountCluster

public OBinaryResponse executeCountCluster(OCountRequest request)

Specified by:

executeCountCluster in interface OBinaryRequestExecutor

executeClusterDataRange

public OBinaryResponse executeClusterDataRange(OGetClusterDataRangeRequest request)

Specified by:

executeClusterDataRange in interface OBinaryRequestExecutor

executeAddCluster

public OBinaryResponse executeAddCluster(OAddClusterRequest request)

Specified by:

executeAddCluster in interface OBinaryRequestExecutor

executeDropCluster

public OBinaryResponse executeDropCluster(ODropClusterRequest request)

Specified by:

executeDropCluster in interface OBinaryRequestExecutor

executeGetRecordMetadata

public OBinaryResponse executeGetRecordMetadata(OGetRecordMetadataRequest request)

Specified by:

executeGetRecordMetadata in interface OBinaryRequestExecutor

executeReadRecord

public OBinaryResponse executeReadRecord(OReadRecordRequest request)

Specified by:

executeReadRecord in interface OBinaryRequestExecutor

executeReadRecordIfNotLastest

public OBinaryResponse executeReadRecordIfNotLastest(OReadRecordIfVersionIsNotLatestRequest request)

Specified by:

executeReadRecordIfNotLastest in interface OBinaryRequestExecutor

executeCreateRecord

public OBinaryResponse executeCreateRecord(OCreateRecordRequest request)

Specified by:

executeCreateRecord in interface OBinaryRequestExecutor

executeUpdateRecord

public OBinaryResponse executeUpdateRecord(OUpdateRecordRequest request)

Specified by:

executeUpdateRecord in interface OBinaryRequestExecutor

executeDeleteRecord

public OBinaryResponse executeDeleteRecord(ODeleteRecordRequest request)

Specified by:

executeDeleteRecord in interface OBinaryRequestExecutor

executeHigherPosition

public OBinaryResponse executeHigherPosition(OHigherPhysicalPositionsRequest request)

Specified by:

executeHigherPosition in interface OBinaryRequestExecutor

executeCeilingPosition

public OBinaryResponse executeCeilingPosition(OCeilingPhysicalPositionsRequest request)

Specified by:

executeCeilingPosition in interface OBinaryRequestExecutor

executeLowerPosition

public OBinaryResponse executeLowerPosition(OLowerPhysicalPositionsRequest request)

Specified by:

executeLowerPosition in interface OBinaryRequestExecutor

executeFloorPosition

public OBinaryResponse executeFloorPosition(OFloorPhysicalPositionsRequest request)

Specified by:

executeFloorPosition in interface OBinaryRequestExecutor

executeCommand

public OBinaryResponse executeCommand(OCommandRequest request)

Specified by:

executeCommand in interface OBinaryRequestExecutor

executeBatchOperations

public OBinaryResponse executeBatchOperations(OBatchOperationsRequest request)

Specified by:

executeBatchOperations in interface OBinaryRequestExecutor

executeCommit

public OBinaryResponse executeCommit(OCommitRequest request)

Specified by:

executeCommit in interface OBinaryRequestExecutor

executeGetGlobalConfiguration

public OBinaryResponse executeGetGlobalConfiguration(OGetGlobalConfigurationRequest request)

Specified by:

executeGetGlobalConfiguration in interface OBinaryRequestExecutor

executeListGlobalConfigurations

public OBinaryResponse executeListGlobalConfigurations(OListGlobalConfigurationsRequest request)

Specified by:

executeListGlobalConfigurations in interface OBinaryRequestExecutor

executeFreezeDatabase

public OBinaryResponse executeFreezeDatabase(OFreezeDatabaseRequest request)

Specified by:

executeFreezeDatabase in interface OBinaryRequestExecutor

executeReleaseDatabase

public OBinaryResponse executeReleaseDatabase(OReleaseDatabaseRequest request)

Specified by:

executeReleaseDatabase in interface OBinaryRequestExecutor

executeCleanOutRecord

public OBinaryResponse executeCleanOutRecord(OCleanOutRecordRequest request)

Specified by:

executeCleanOutRecord in interface OBinaryRequestExecutor

executeSBTreeCreate

public OBinaryResponse executeSBTreeCreate(OSBTCreateTreeRequest request)

Specified by:

executeSBTreeCreate in interface OBinaryRequestExecutor

executeSBTGet

public OBinaryResponse executeSBTGet(OSBTGetRequest request)

Specified by:

executeSBTGet in interface OBinaryRequestExecutor

executeSBTFirstKey

public OBinaryResponse executeSBTFirstKey(OSBTFirstKeyRequest request)

Specified by:

executeSBTFirstKey in interface OBinaryRequestExecutor

executeSBTFetchEntriesMajor

public OBinaryResponse executeSBTFetchEntriesMajor(OSBTFetchEntriesMajorRequest request)

Specified by:

executeSBTFetchEntriesMajor in interface OBinaryRequestExecutor

executeSBTGetRealSize

public OBinaryResponse executeSBTGetRealSize(OSBTGetRealBagSizeRequest request)

Specified by:

executeSBTGetRealSize in interface OBinaryRequestExecutor

executeIncrementalBackup

public OBinaryResponse executeIncrementalBackup(OIncrementalBackupRequest request)

Specified by:

executeIncrementalBackup in interface OBinaryRequestExecutor

executeImport

public OBinaryResponse executeImport(OImportRequest request)

Specified by:

executeImport in interface OBinaryRequestExecutor

executeConnect

public OBinaryResponse executeConnect(OConnectRequest request)

Specified by:

executeConnect in interface OBinaryRequestExecutor

executeConnect37

public OBinaryResponse executeConnect37(OConnect37Request request)

Specified by:

executeConnect37 in interface OBinaryRequestExecutor

executeDatabaseOpen

public OBinaryResponse executeDatabaseOpen(OOpenRequest request)

Specified by:

executeDatabaseOpen in interface OBinaryRequestExecutor

executeDatabaseOpen37

public OBinaryResponse executeDatabaseOpen37(OOpen37Request request)

Specified by:

executeDatabaseOpen37 in interface OBinaryRequestExecutor

executeShutdown

public OBinaryResponse executeShutdown(OShutdownRequest request)

Specified by:

executeShutdown in interface OBinaryRequestExecutor

executeReopen

public OBinaryResponse executeReopen(OReopenRequest request)

Specified by:

executeReopen in interface OBinaryRequestExecutor

executeSetGlobalConfig

public OBinaryResponse executeSetGlobalConfig(OSetGlobalConfigurationRequest request)

Specified by:

executeSetGlobalConfig in interface OBinaryRequestExecutor

getRecordBytes

public static byte[] getRecordBytes(OClientConnection connection,
                                    ORecord iRecord)

executeQuery

public OBinaryResponse executeQuery(OQueryRequest request)

Specified by:

executeQuery in interface OBinaryRequestExecutor

closeQuery

public OBinaryResponse closeQuery(OCloseQueryRequest oQueryRequest)

Specified by:

closeQuery in interface OBinaryRequestExecutor

executeQueryNextPage

public OBinaryResponse executeQueryNextPage(OQueryNextPageRequest request)

Specified by:

executeQueryNextPage in interface OBinaryRequestExecutor

executeBeginTransaction

public OBinaryResponse executeBeginTransaction(OBeginTransactionRequest request)

Specified by:

executeBeginTransaction in interface OBinaryRequestExecutor

executeBeginTransaction38

public OBinaryResponse executeBeginTransaction38(OBeginTransaction38Request request)

Specified by:

executeBeginTransaction38 in interface OBinaryRequestExecutor

executeCommit37

public OBinaryResponse executeCommit37(OCommit37Request request)

Specified by:

executeCommit37 in interface OBinaryRequestExecutor

executeCommit38

public OBinaryResponse executeCommit38(OCommit38Request request)

Specified by:

executeCommit38 in interface OBinaryRequestExecutor

executeFetchTransaction

public OBinaryResponse executeFetchTransaction(OFetchTransactionRequest request)

Specified by:

executeFetchTransaction in interface OBinaryRequestExecutor

executeFetchTransaction38

public OBinaryResponse executeFetchTransaction38(OFetchTransaction38Request request)

Specified by:

executeFetchTransaction38 in interface OBinaryRequestExecutor

executeRollback

public OBinaryResponse executeRollback(ORollbackTransactionRequest request)

Specified by:

executeRollback in interface OBinaryRequestExecutor

executeSubscribe

public OBinaryResponse executeSubscribe(OSubscribeRequest request)

Specified by:

executeSubscribe in interface OBinaryRequestExecutor

executeUnsubscribe

public OBinaryResponse executeUnsubscribe(OUnsubscribeRequest request)

Specified by:

executeUnsubscribe in interface OBinaryRequestExecutor

executeSubscribeDistributedConfiguration

public OBinaryResponse executeSubscribeDistributedConfiguration(OSubscribeDistributedConfigurationRequest request)

Specified by:

executeSubscribeDistributedConfiguration in interface OBinaryRequestExecutor

executeSubscribeStorageConfiguration

public OBinaryResponse executeSubscribeStorageConfiguration(OSubscribeStorageConfigurationRequest request)

Specified by:

executeSubscribeStorageConfiguration in interface OBinaryRequestExecutor

executeSubscribeSchema

public OBinaryResponse executeSubscribeSchema(OSubscribeSchemaRequest request)

Specified by:

executeSubscribeSchema in interface OBinaryRequestExecutor

executeSubscribeIndexManager

public OBinaryResponse executeSubscribeIndexManager(OSubscribeIndexManagerRequest request)

Specified by:

executeSubscribeIndexManager in interface OBinaryRequestExecutor

executeSubscribeFunctions

public OBinaryResponse executeSubscribeFunctions(OSubscribeFunctionsRequest request)

Specified by:

executeSubscribeFunctions in interface OBinaryRequestExecutor

executeSubscribeSequences

public OBinaryResponse executeSubscribeSequences(OSubscribeSequencesRequest request)

Specified by:

executeSubscribeSequences in interface OBinaryRequestExecutor

executeUnsubscribeLiveQuery

public OBinaryResponse executeUnsubscribeLiveQuery(OUnsubscribeLiveQueryRequest request)

Specified by:

executeUnsubscribeLiveQuery in interface OBinaryRequestExecutor

executeSubscribeLiveQuery

public OBinaryResponse executeSubscribeLiveQuery(OSubscribeLiveQueryRequest request)

Specified by:

executeSubscribeLiveQuery in interface OBinaryRequestExecutor

executeDistributedConnect

public OBinaryResponse executeDistributedConnect(ODistributedConnectRequest request)

Specified by:

executeDistributedConnect in interface OBinaryRequestExecutor

executeExperimental

public OBinaryResponse executeExperimental(OExperimentalRequest request)

Specified by:

executeExperimental in interface OBinaryRequestExecutor

executeLockRecord

public OBinaryResponse executeLockRecord(OLockRecordRequest request)

Specified by:

executeLockRecord in interface OBinaryRequestExecutor

executeUnlockRecord

public OBinaryResponse executeUnlockRecord(OUnlockRecordRequest request)

Specified by:

executeUnlockRecord in interface OBinaryRequestExecutor