com.orientechnologies.orient.core.sql.parser

Class OMatchStatement

java.lang.Object

com.orientechnologies.orient.core.sql.parser.SimpleNode

com.orientechnologies.orient.core.sql.parser.OStatement

com.orientechnologies.orient.core.sql.parser.OMatchStatement

All Implemented Interfaces:

OCommandExecutor, OIterableRecordSource, Node

public class OMatchStatement
extends OStatement
implements OCommandExecutor, OIterableRecordSource

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OMatchStatement.EdgeTraversal
static class	OMatchStatement.MatchExecutionPlan

Field Summary

Fields

Modifier and Type	Field and Description
static String	KEYWORD_MATCH
protected OLimit	limit
protected List<OMatchExpression>	matchExpressions
protected com.orientechnologies.orient.core.sql.parser.Pattern	pattern
protected List<OIdentifier>	returnAliases
protected List<OExpression>	returnItems

Fields inherited from class com.orientechnologies.orient.core.sql.parser.OStatement

CUSTOM_STRICT_SQL

Fields inherited from class com.orientechnologies.orient.core.sql.parser.SimpleNode

children, firstToken, id, lastToken, parent, parser, value

Constructor Summary

Constructors

Constructor and Description
OMatchStatement()
OMatchStatement(int id)
OMatchStatement(OrientSql p, int id)

Method Summary

Modifier and Type	Method and Description
Object	execute(Map<Object,Object> iArgs) this method works statefully, using request and context variables from current Match statement.
Object	execute(OSQLAsynchQuery<ODocument> request, OCommandContext context, OProgressListener progressListener) executes the match statement.
OCommandContext	getContext()
long	getDistributedTimeout()
String	getFetchPlan()
Set<String>	getInvolvedClusters() Returns the involved clusters.
Map<Object,Object>	getParameters()
protected Object	getResult(OSQLAsynchQuery<ODocument> request)
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.
Iterator<OIdentifiable>	iterator(Map<Object,Object> iArgs)
Object	jjtAccept(OrientSqlVisitor visitor, Object data) Accept the visitor.
Object	mergeResults(Map<String,Object> results)
<RET extends OCommandExecutor> RET	parse(OCommandRequest iRequest) this method parses the statement
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.
void	toString(Map<Object,Object> params, StringBuilder builder)

Methods inherited from class com.orientechnologies.orient.core.sql.parser.OStatement

toString, validate

Methods inherited from class com.orientechnologies.orient.core.sql.parser.SimpleNode

childrenAccept, dump, getDatabase, getValue, jjtAddChild, jjtClose, jjtGetChild, jjtGetFirstToken, jjtGetLastToken, jjtGetNumChildren, jjtGetParent, jjtGetValue, jjtOpen, jjtSetFirstToken, jjtSetLastToken, jjtSetParent, jjtSetValue, toString

Methods inherited from class java.lang.Object

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

Field Detail

KEYWORD_MATCH

public static final String KEYWORD_MATCH

See Also:

Constant Field Values

matchExpressions

protected List<OMatchExpression> matchExpressions

returnItems

protected List<OExpression> returnItems

returnAliases

protected List<OIdentifier> returnAliases

limit

protected OLimit limit

pattern

protected com.orientechnologies.orient.core.sql.parser.Pattern pattern

Constructor Detail

OMatchStatement

public OMatchStatement()

OMatchStatement

public OMatchStatement(int id)

OMatchStatement

public OMatchStatement(OrientSql p,
                       int id)

Method Detail

jjtAccept

public Object jjtAccept(OrientSqlVisitor visitor,
                        Object data)

Accept the visitor. *

Specified by:

jjtAccept in interface Node

Overrides:

jjtAccept in class OStatement

parse

public <RET extends OCommandExecutor> RET parse(OCommandRequest iRequest)

this method parses the statement

Specified by:

parse in interface OCommandExecutor

Type Parameters:

RET -

Parameters:

iRequest - Command request implementation.

Returns:

See Also:

#execute(Map...)

execute

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

this method works statefully, using request and context variables from current Match statement. This method will be deprecated in next releases

Specified by:

execute in interface OCommandExecutor

Parameters:

iArgs - Optional variable arguments to pass to the command.

Returns:

See Also:

OCommandExecutor.parse(OCommandRequest)

execute

public Object execute(OSQLAsynchQuery<ODocument> request,
                      OCommandContext context,
                      OProgressListener progressListener)

executes the match statement. This is the preferred execute() method and it has to be used as the default one in the future. This method works in stateless mode

Overrides:

execute in class OStatement

Parameters:

request -

context -

Returns:

getResult

protected Object getResult(OSQLAsynchQuery<ODocument> request)

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

toString

public void toString(Map<Object,Object> params,
                     StringBuilder builder)

Overrides:

toString in class OStatement

iterator

public Iterator<OIdentifiable> iterator(Map<Object,Object> iArgs)

Specified by:

iterator in interface OIterableRecordSource