
public class OCommandExecutorSQLDelegate extends OCommandExecutorSQLAbstract implements OCommandDistributedReplicateRequest
OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE, OCommandDistributedReplicateRequest.DISTRIBUTED_RESULT_MGMT, OCommandDistributedReplicateRequest.QUORUM_TYPE| Modifier and Type | Field and Description |
|---|---|
protected OCommandExecutor |
delegate |
CLASS_PREFIX, CLUSTER_PREFIX, DEFAULT_PARAM_USER, DICTIONARY_PREFIX, INDEX_PREFIX, INDEX_VALUES_ASC_PREFIX, INDEX_VALUES_DESC_PREFIX, INDEX_VALUES_PREFIX, KEYWORD_FROM, KEYWORD_KEY, KEYWORD_LET, KEYWORD_LIMIT, KEYWORD_LOCK, KEYWORD_OFFSET, KEYWORD_RETURN, KEYWORD_RID, KEYWORD_SKIP, KEYWORD_TIMEOUT, KEYWORD_UNSAFE, KEYWORD_WHERE, METADATA_DATABASE, METADATA_INDEXMGR, METADATA_PREFIX, METADATA_SCHEMA, METADATA_STORAGE, preParsedStatement, timeoutMs, timeoutStrategycontext, limit, parameters, progressListenerparserText, parserTextUpperCase| Constructor and Description |
|---|
OCommandExecutorSQLDelegate() |
| Modifier and Type | Method and Description |
|---|---|
Object |
execute(Map<Object,Object> iArgs)
Execute the requested command parsed previously.
|
OCommandContext |
getContext() |
OCommandExecutor |
getDelegate() |
long |
getDistributedTimeout()
Returns the distributed timeout in milliseconds.
|
String |
getFetchPlan() |
Set<String> |
getInvolvedClusters()
Returns the involved clusters.
|
OCommandDistributedReplicateRequest.QUORUM_TYPE |
getQuorumType()
Returns the quorum type for the command:
NONE: no quorum
READ: configured Read quorum
WRITE: configured Write quorum
ALL: all nodes
|
String |
getSyntax() |
boolean |
isCacheable()
Returns true if the command results can be cached.
|
boolean |
isIdempotent()
Returns true if the command doesn't change the database, otherwise false.
|
OCommandExecutorSQLDelegate |
parse(OCommandRequest iCommand)
Parse the request.
|
String |
toString() |
bindDefaultContextVariables, checkClusterAccess, decodeClassName, getDistributedExecutionMode, getInvolvedClustersOfClasses, getInvolvedClustersOfClusters, getInvolvedClustersOfIndex, parseLock, parseTimeout, preParse, throwParsingException, throwParsingException, throwSyntaxErrorExceptioncheckInterruption, checkInterruption, getDatabase, getDistributedResultManagement, getLimit, getParameters, getProgressListener, getSecurityOperationType, getUndoCommand, init, involveSchema, isDistributedExecutingOnLocalNodeFirst, isLocalExecution, mergeResults, setContext, setLimit, setProgressListener, upperCasegetLastWordLength, getWordStatic, nextWord, nextWord, parseOptionalWord, parserGetCurrentChar, parserGetCurrentPosition, parserGetLastSeparator, parserGetLastWord, parserGetPreviousPosition, parserGoBack, parserIsEnded, parserMoveCurrentPosition, parserNextChars, parserNextWord, parserNextWord, parserNextWord, parserOptionalKeyword, parserOptionalWord, parserRequiredKeyword, parserRequiredWord, parserRequiredWord, parserRequiredWord, parserSetCurrentPosition, parserSetEndOfText, parserSetLastSeparator, parserSkipWhiteSpacesclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetDistributedExecutionMode, getDistributedResultManagement, getUndoCommand, isDistributedExecutingOnLocalNodeFirstprotected OCommandExecutor delegate
public OCommandExecutorSQLDelegate parse(OCommandRequest iCommand)
OCommandExecutorparse in interface OCommandExecutoriCommand - Command request implementation.#execute(Mappublic long getDistributedTimeout()
OCommandDistributedReplicateRequestgetDistributedTimeout in interface OCommandDistributedReplicateRequestgetDistributedTimeout in interface OCommandExecutorgetDistributedTimeout in class OCommandExecutorAbstractpublic Object execute(Map<Object,Object> iArgs)
OCommandExecutorexecute in interface OCommandExecutoriArgs - Optional variable arguments to pass to the command.OCommandExecutor.parse(OCommandRequest)public OCommandContext getContext()
getContext in interface OCommandExecutorgetContext in class OCommandExecutorAbstractpublic String toString()
toString in class OCommandExecutorAbstractpublic String getSyntax()
getSyntax in interface OCommandExecutorgetSyntax in class OBaseParserpublic String getFetchPlan()
getFetchPlan in interface OCommandExecutorgetFetchPlan in class OCommandExecutorAbstractpublic boolean isIdempotent()
OCommandExecutorisIdempotent in interface OCommandExecutorisIdempotent in class OCommandExecutorSQLAbstractpublic OCommandExecutor getDelegate()
public boolean isCacheable()
OCommandExecutorisCacheable in interface OCommandExecutorisCacheable in class OCommandExecutorAbstractpublic OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
OCommandDistributedReplicateRequestgetQuorumType in interface OCommandDistributedReplicateRequestpublic Set<String> getInvolvedClusters()
OCommandExecutorgetInvolvedClusters in interface OCommandExecutorgetInvolvedClusters in class OCommandExecutorAbstractCopyright © 2009–2025 OrientDB. All rights reserved.