com.orientechnologies.orient.core.command.script

Class OCommandExecutorScript

java.lang.Object

com.orientechnologies.common.parser.OBaseParser

com.orientechnologies.orient.core.command.OCommandExecutorAbstract

com.orientechnologies.orient.core.command.script.OCommandExecutorScript

All Implemented Interfaces:

OCommandDistributedReplicateRequest, OCommandExecutor, OTemporaryRidGenerator

public class OCommandExecutorScript
extends OCommandExecutorAbstract
implements OCommandDistributedReplicateRequest, OTemporaryRidGenerator

Executes Script Commands.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

See Also:

OCommandScript

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.core.command.OCommandDistributedReplicateRequest

OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE, OCommandDistributedReplicateRequest.DISTRIBUTED_RESULT_MGMT, OCommandDistributedReplicateRequest.QUORUM_TYPE

Field Summary

Fields

Modifier and Type	Field and Description
protected OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE	executionMode
protected OCommandScript	request
protected AtomicInteger	serialTempRID

Fields inherited from class com.orientechnologies.orient.core.command.OCommandExecutorAbstract

context, limit, parameters, progressListener

Fields inherited from class com.orientechnologies.common.parser.OBaseParser

parserText, parserTextUpperCase

Constructor Summary

Constructors

Constructor and Description
OCommandExecutorScript()

Method Summary

Modifier and Type	Method and Description
Object	execute(Map<Object,Object> iArgs) Execute the requested command parsed previously.
Object	executeInContext(OCommandContext iContext, Map<Object,Object> iArgs)
protected Object	executeJsr223Script(String language, OCommandContext iContext, Map<Object,Object> iArgs)
protected Object	executeSQL()
protected Object	executeSQLScript(String iText, ODatabaseDocument db)
OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE	getDistributedExecutionMode() Returns the execution mode when distributed configuration is active: LOCAL: executed on local node only REPLICATE: executed on all the nodes and expect the same result SHARDED: executed on all the involved nodes and merge results
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
int	getTemporaryRIDCounter(OCommandContext iContext)
boolean	isIdempotent() Returns true if the command doesn't change the database, otherwise false.
OCommandExecutorScript	parse(OCommandRequest iRequest) Parse the request.
protected void	throwSyntaxErrorException(String iText) Throws a syntax error exception.
protected void	waitForNextRetry() Wait before to retry

Methods inherited from class com.orientechnologies.orient.core.command.OCommandExecutorAbstract

checkInterruption, checkInterruption, getContext, getDatabase, getDistributedResultManagement, getDistributedTimeout, getFetchPlan, getInvolvedClusters, getLimit, getParameters, getProgressListener, getSecurityOperationType, getUndoCommand, init, involveSchema, isCacheable, isDistributedExecutingOnLocalNodeFirst, isLocalExecution, mergeResults, setContext, setLimit, setProgressListener, toString, upperCase

Methods inherited from class com.orientechnologies.common.parser.OBaseParser

getLastWordLength, getSyntax, 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

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.core.command.OCommandDistributedReplicateRequest

getDistributedResultManagement, getDistributedTimeout, getUndoCommand, isDistributedExecutingOnLocalNodeFirst

Methods inherited from interface com.orientechnologies.orient.core.command.OCommandExecutor

getSyntax

Field Detail

request

protected OCommandScript request

executionMode

protected OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE executionMode

serialTempRID

protected AtomicInteger serialTempRID

Constructor Detail

OCommandExecutorScript

public OCommandExecutorScript()

Method Detail

parse

public OCommandExecutorScript parse(OCommandRequest iRequest)

Description copied from interface: OCommandExecutor

Parse the request. Once parsed the command can be executed multiple times by using the execute() method.

Specified by:

parse in interface OCommandExecutor

Parameters:

iRequest - Command request implementation.

Returns:

See Also:

#execute(Map...)

getDistributedExecutionMode

public OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE getDistributedExecutionMode()

Description copied from interface: OCommandDistributedReplicateRequest

Returns the execution mode when distributed configuration is active:

• LOCAL: executed on local node only
• REPLICATE: executed on all the nodes and expect the same result
• SHARDED: executed on all the involved nodes and merge results

Specified by:

getDistributedExecutionMode in interface OCommandDistributedReplicateRequest

execute

public Object execute(Map<Object,Object> iArgs)

Description copied from interface: OCommandExecutor

Execute the requested command parsed previously.

Specified by:

execute in interface OCommandExecutor

Parameters:

iArgs - Optional variable arguments to pass to the command.

Returns:

See Also:

OCommandExecutor.parse(OCommandRequest)

executeInContext

public Object executeInContext(OCommandContext iContext,
                               Map<Object,Object> iArgs)

isIdempotent

public boolean isIdempotent()

Description copied from interface: OCommandExecutor

Returns true if the command doesn't change the database, otherwise false.

Specified by:

isIdempotent in interface OCommandExecutor

executeJsr223Script

protected Object executeJsr223Script(String language,
                                     OCommandContext iContext,
                                     Map<Object,Object> iArgs)

executeSQL

protected Object executeSQL()

throwSyntaxErrorException

protected void throwSyntaxErrorException(String iText)

Description copied from class: OBaseParser

Throws a syntax error exception.

Specified by:

throwSyntaxErrorException in class OBaseParser

Parameters:

iText - Text about the problem.

executeSQLScript

protected Object executeSQLScript(String iText,
                                  ODatabaseDocument db)
                           throws IOException

Throws:

IOException

waitForNextRetry

protected void waitForNextRetry()

Wait before to retry

getQuorumType

public OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()

Description copied from interface: OCommandDistributedReplicateRequest

Returns the quorum type for the command:

• NONE: no quorum
• READ: configured Read quorum
• WRITE: configured Write quorum
• ALL: all nodes

Specified by:

getQuorumType in interface OCommandDistributedReplicateRequest

getTemporaryRIDCounter

public int getTemporaryRIDCounter(OCommandContext iContext)

Specified by:

getTemporaryRIDCounter in interface OTemporaryRidGenerator