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, timeoutStrategy
context, limit, parameters, progressListener
parserText, 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, throwSyntaxErrorException
checkInterruption, checkInterruption, getDatabase, getDistributedResultManagement, getLimit, getParameters, getProgressListener, getSecurityOperationType, getUndoCommand, init, involveSchema, isDistributedExecutingOnLocalNodeFirst, isLocalExecution, mergeResults, setContext, setLimit, setProgressListener, upperCase
getLastWordLength, 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, parserSkipWhiteSpaces
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getDistributedExecutionMode, getDistributedResultManagement, getUndoCommand, isDistributedExecutingOnLocalNodeFirst
protected OCommandExecutor delegate
public OCommandExecutorSQLDelegate parse(OCommandRequest iCommand)
OCommandExecutor
parse
in interface OCommandExecutor
iCommand
- Command request implementation.#execute(Map
public long getDistributedTimeout()
OCommandDistributedReplicateRequest
getDistributedTimeout
in interface OCommandDistributedReplicateRequest
getDistributedTimeout
in interface OCommandExecutor
getDistributedTimeout
in class OCommandExecutorAbstract
public Object execute(Map<Object,Object> iArgs)
OCommandExecutor
execute
in interface OCommandExecutor
iArgs
- Optional variable arguments to pass to the command.OCommandExecutor.parse(OCommandRequest)
public OCommandContext getContext()
getContext
in interface OCommandExecutor
getContext
in class OCommandExecutorAbstract
public String toString()
toString
in class OCommandExecutorAbstract
public String getSyntax()
getSyntax
in interface OCommandExecutor
getSyntax
in class OBaseParser
public String getFetchPlan()
getFetchPlan
in interface OCommandExecutor
getFetchPlan
in class OCommandExecutorAbstract
public boolean isIdempotent()
OCommandExecutor
isIdempotent
in interface OCommandExecutor
isIdempotent
in class OCommandExecutorSQLAbstract
public OCommandExecutor getDelegate()
public boolean isCacheable()
OCommandExecutor
isCacheable
in interface OCommandExecutor
isCacheable
in class OCommandExecutorAbstract
public OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()
OCommandDistributedReplicateRequest
getQuorumType
in interface OCommandDistributedReplicateRequest
public Set<String> getInvolvedClusters()
OCommandExecutor
getInvolvedClusters
in interface OCommandExecutor
getInvolvedClusters
in class OCommandExecutorAbstract
Copyright © 2009–2020 OrientDB. All rights reserved.