com.orientechnologies.orient.core.sql

Class OCommandExecutorToOStatementWrapper

java.lang.Object

com.orientechnologies.orient.core.sql.OCommandExecutorToOStatementWrapper

All Implemented Interfaces:

OCommandExecutor

public class OCommandExecutorToOStatementWrapper
extends Object
implements OCommandExecutor

Wrapper for OPrifileStorageStatement command (for compatibility with the old executor architecture, this component should be removed)

Author:

Luigi Dell'Aquila

Field Summary

Fields

Modifier and Type	Field and Description
protected OSQLAsynchQuery<ODocument>	request
protected OStatement	statement

Constructor Summary

Constructors

Constructor and Description
OCommandExecutorToOStatementWrapper()

Method Summary

Modifier and Type	Method and Description
Object	execute(Map<Object,Object> iArgs) Execute the requested command parsed previously.
OCommandContext	getContext()
static ODatabaseDocumentInternal	getDatabase()
long	getDistributedTimeout()
String	getFetchPlan()
Set<String>	getInvolvedClusters() Returns the involved clusters.
Map<Object,Object>	getParameters()
int	getSecurityOperationType() Returns the security operation type use to check about security.
String	getSyntax()
boolean	involveSchema()
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.
boolean	isLocalExecution() Returns true if the command must be executed on local node on distributed configuration.
Object	mergeResults(Map<String,Object> results)
OCommandExecutorToOStatementWrapper	parse(OCommandRequest iCommand) Parse the request.
void	setContext(OCommandContext context)
<RET extends OCommandExecutor> RET	setLimit(int iLimit)
<RET extends OCommandExecutor> RET	setProgressListener(OProgressListener progressListener) Set the listener invoked while the command is executing.

Methods inherited from class java.lang.Object

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

Field Detail

request

protected OSQLAsynchQuery<ODocument> request

statement

protected OStatement statement

Constructor Detail

OCommandExecutorToOStatementWrapper

public OCommandExecutorToOStatementWrapper()

Method Detail

parse

public OCommandExecutorToOStatementWrapper parse(OCommandRequest iCommand)

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:

iCommand - Command request implementation.

Returns:

See Also:

#execute(Map...)

getDatabase

public static ODatabaseDocumentInternal getDatabase()

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)

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:

setLimit

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

Specified by:

setLimit in interface OCommandExecutor

getFetchPlan

public String getFetchPlan()

Specified by:

getFetchPlan in interface OCommandExecutor

getParameters

public Map<Object,Object> getParameters()

Specified by:

getParameters in interface OCommandExecutor

getContext

public OCommandContext getContext()

Specified by:

getContext in interface OCommandExecutor

setContext

public void setContext(OCommandContext context)

Specified by:

setContext in interface OCommandExecutor

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

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

getSyntax

public String getSyntax()

Specified by:

getSyntax in interface OCommandExecutor

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

getDistributedTimeout

public long getDistributedTimeout()

Specified by:

getDistributedTimeout in interface OCommandExecutor

mergeResults

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

Specified by:

mergeResults in interface OCommandExecutor

Throws:

Exception