Package com.orientechnologies.orient.core.command

Class OCommandExecutorAbstract

java.lang.Object

com.orientechnologies.common.parser.OBaseParser

com.orientechnologies.orient.core.command.OCommandExecutorAbstract

All Implemented Interfaces:

OCommandExecutor

Direct Known Subclasses:

OCommandExecutorFunction, OCommandExecutorScript, OCommandExecutorSQLAbstract, OCommandGremlinExecutor

public abstract class OCommandExecutorAbstract
extends OBaseParser
implements OCommandExecutor

Abstract implementation of Executor Command interface.

Author:

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

Field Summary

Fields

Modifier and Type	Field	Description
protected OCommandContext	context
protected int	limit
protected Map<Object,Object>	parameters
protected OProgressListener	progressListener

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

parserText, parserTextUpperCase

Constructor Summary

Constructors

Constructor	Description
OCommandExecutorAbstract()

Method Summary

Modifier and Type	Method	Description
protected boolean	checkInterruption()
static boolean	checkInterruption(OCommandContext iContext)
OCommandContext	getContext()
static ODatabaseDocumentInternal	getDatabase()
OCommandDistributedReplicateRequest.DISTRIBUTED_RESULT_MGMT	getDistributedResultManagement()
long	getDistributedTimeout()
String	getFetchPlan()
Set<String>	getInvolvedClusters()	Returns the involved clusters.
int	getLimit()
Map<Object,Object>	getParameters()
OProgressListener	getProgressListener()
int	getSecurityOperationType()	Returns the security operation type use to check about security.
String	getUndoCommand()
OCommandExecutorAbstract	init(OCommandRequestText iRequest)
boolean	involveSchema()
boolean	isCacheable()	Returns true if the command results can be cached.
boolean	isDistributedExecutingOnLocalNodeFirst()
boolean	isLocalExecution()	Returns true if the command must be executed on local node on distributed configuration.
Object	mergeResults(Map<String,Object> results)
void	setContext(OCommandContext iContext)
<RET extends OCommandExecutor> RET	setLimit(int iLimit)
<RET extends OCommandExecutor> RET	setProgressListener(OProgressListener progressListener)	Set the listener invoked while the command is executing.
String	toString()

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, throwSyntaxErrorException

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.OCommandExecutor

execute, getSyntax, isIdempotent, parse

Field Details

progressListener

protected OProgressListener progressListener

limit

protected int limit

parameters

protected Map<Object,Object> parameters

context

protected OCommandContext context

Constructor Details

OCommandExecutorAbstract

public OCommandExecutorAbstract()

Method Details

getDatabase

public static ODatabaseDocumentInternal getDatabase()

init

public OCommandExecutorAbstract init(OCommandRequestText iRequest)

toString

public String toString()

Overrides:

toString in class Object

getProgressListener

public OProgressListener getProgressListener()

setProgressListener

public <RET extends OCommandExecutor> RET setProgressListener(OProgressListener progressListener)

Description copied from interface: OCommandExecutor

Set the listener invoked while the command is executing.

Specified by:

setProgressListener in interface OCommandExecutor

Parameters:

progressListener - OProgressListener implementation

Returns:

getUndoCommand

public String getUndoCommand()

getDistributedTimeout

public long getDistributedTimeout()

Specified by:

getDistributedTimeout in interface OCommandExecutor

getLimit

public int getLimit()

setLimit

public <RET extends OCommandExecutor> RET setLimit(int iLimit)

Specified by:

setLimit in interface OCommandExecutor

getParameters

public Map<Object,Object> getParameters()

Specified by:

getParameters in interface OCommandExecutor

getFetchPlan

public String getFetchPlan()

Specified by:

getFetchPlan in interface OCommandExecutor

getContext

public OCommandContext getContext()

Specified by:

getContext in interface OCommandExecutor

setContext

public void setContext(OCommandContext iContext)

Specified by:

setContext in interface OCommandExecutor

getInvolvedClusters

public Set<String> getInvolvedClusters()

Description copied from interface: OCommandExecutor

Returns the involved clusters.

Specified by:

getInvolvedClusters in interface OCommandExecutor

getSecurityOperationType

public int getSecurityOperationType()

Description copied from interface: OCommandExecutor

Returns the security operation type use to check about security.

Specified by:

getSecurityOperationType in interface OCommandExecutor

Returns:

See Also:

• PERMISSION_*

involveSchema

public boolean involveSchema()

Specified by:

involveSchema in interface OCommandExecutor

checkInterruption

protected boolean checkInterruption()

checkInterruption

public static boolean checkInterruption(OCommandContext iContext)

getDistributedResultManagement

public OCommandDistributedReplicateRequest.DISTRIBUTED_RESULT_MGMT getDistributedResultManagement()

isLocalExecution

public boolean isLocalExecution()

Description copied from interface: OCommandExecutor

Returns true if the command must be executed on local node on distributed configuration.

Specified by:

isLocalExecution in interface OCommandExecutor

isCacheable

public boolean isCacheable()

Description copied from interface: OCommandExecutor

Returns true if the command results can be cached.

Specified by:

isCacheable in interface OCommandExecutor

mergeResults

public Object mergeResults(Map<String,Object> results)
                    throws Exception

Specified by:

mergeResults in interface OCommandExecutor

Throws:

Exception

isDistributedExecutingOnLocalNodeFirst

public boolean isDistributedExecutingOnLocalNodeFirst()