com.orientechnologies.orient.core.sql

Class OCommandExecutorSQLAbstract

java.lang.Object

com.orientechnologies.common.parser.OBaseParser

com.orientechnologies.orient.core.command.OCommandExecutorAbstract

com.orientechnologies.orient.core.sql.OCommandExecutorSQLAbstract

All Implemented Interfaces:

OCommandExecutor

Direct Known Subclasses:

OCommandExecutorSQLAlterClass, OCommandExecutorSQLAlterCluster, OCommandExecutorSQLAlterDatabase, OCommandExecutorSQLAlterProperty, OCommandExecutorSQLAlterSequence, OCommandExecutorSQLCreateClass, OCommandExecutorSQLCreateCluster, OCommandExecutorSQLCreateFunction, OCommandExecutorSQLCreateIndex, OCommandExecutorSQLCreateLink, OCommandExecutorSQLCreateProperty, OCommandExecutorSQLCreateSequence, OCommandExecutorSQLCreateUser, OCommandExecutorSQLDelegate, OCommandExecutorSQLDelete, OCommandExecutorSQLDeleteVertex, OCommandExecutorSQLDropClass, OCommandExecutorSQLDropCluster, OCommandExecutorSQLDropIndex, OCommandExecutorSQLDropProperty, OCommandExecutorSQLDropSequence, OCommandExecutorSQLDropUser, OCommandExecutorSQLHARemoveServer, OCommandExecutorSQLHAStatus, OCommandExecutorSQLHASyncCluster, OCommandExecutorSQLHASyncDatabase, OCommandExecutorSQLLiveUnsubscribe, OCommandExecutorSQLOptimizeDatabase, OCommandExecutorSQLPermissionAbstract, OCommandExecutorSQLRebuildIndex, OCommandExecutorSQLResultsetAbstract, OCommandExecutorSQLSetAware, OCommandExecutorSQLTruncateClass, OCommandExecutorSQLTruncateCluster, OCommandExecutorSQLTruncateRecord

public abstract class OCommandExecutorSQLAbstract
extends OCommandExecutorAbstract

SQL abstract Command Executor implementation.

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
static String	CLASS_PREFIX
static String	CLUSTER_PREFIX
static String	DEFAULT_PARAM_USER
static String	DICTIONARY_PREFIX
static String	INDEX_PREFIX
static String	INDEX_VALUES_ASC_PREFIX
static String	INDEX_VALUES_DESC_PREFIX
static String	INDEX_VALUES_PREFIX
static String	KEYWORD_FROM
static String	KEYWORD_KEY
static String	KEYWORD_LET
static String	KEYWORD_LIMIT
static String	KEYWORD_LOCK
static String	KEYWORD_OFFSET
static String	KEYWORD_RETURN
static String	KEYWORD_RID
static String	KEYWORD_SKIP
static String	KEYWORD_TIMEOUT
static String	KEYWORD_UNSAFE
static String	KEYWORD_WHERE
static String	METADATA_DATABASE
static String	METADATA_INDEXMGR
static String	METADATA_PREFIX
static String	METADATA_SCHEMA
static String	METADATA_STORAGE
protected OStatement	preParsedStatement
protected long	timeoutMs
protected OCommandContext.TIMEOUT_STRATEGY	timeoutStrategy

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
OCommandExecutorSQLAbstract()

Method Summary

Modifier and Type	Method and Description
protected void	bindDefaultContextVariables()
protected boolean	checkClusterAccess(ODatabaseDocument db, String iClusterName)
protected String	decodeClassName(String s)
OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE	getDistributedExecutionMode() The command is replicated
protected Set<String>	getInvolvedClustersOfClasses(Collection<String> iClassNames)
protected Set<String>	getInvolvedClustersOfClusters(Collection<String> iClusterNames)
protected Set<String>	getInvolvedClustersOfIndex(String iIndexName)
boolean	isIdempotent() Returns true if the command doesn't change the database, otherwise false.
protected String	parseLock() Parses the lock keyword if found.
protected boolean	parseTimeout(String w) Parses the timeout keyword if found.
protected String	preParse(String queryText, OCommandRequest iRequest)
protected void	throwParsingException(String iText)
protected void	throwParsingException(String iText, Exception e)
protected void	throwSyntaxErrorException(String iText) Throws a syntax error exception.

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

execute, getSyntax, parse

Field Detail

KEYWORD_FROM

public static final String KEYWORD_FROM

See Also:

Constant Field Values

KEYWORD_LET

public static final String KEYWORD_LET

See Also:

Constant Field Values

KEYWORD_WHERE

public static final String KEYWORD_WHERE

See Also:

Constant Field Values

KEYWORD_LIMIT

public static final String KEYWORD_LIMIT

See Also:

Constant Field Values

KEYWORD_SKIP

public static final String KEYWORD_SKIP

See Also:

Constant Field Values

KEYWORD_OFFSET

public static final String KEYWORD_OFFSET

See Also:

Constant Field Values

KEYWORD_TIMEOUT

public static final String KEYWORD_TIMEOUT

See Also:

Constant Field Values

KEYWORD_LOCK

public static final String KEYWORD_LOCK

See Also:

Constant Field Values

KEYWORD_RETURN

public static final String KEYWORD_RETURN

See Also:

Constant Field Values

KEYWORD_KEY

public static final String KEYWORD_KEY

See Also:

Constant Field Values

KEYWORD_RID

public static final String KEYWORD_RID

See Also:

Constant Field Values

CLUSTER_PREFIX

public static final String CLUSTER_PREFIX

See Also:

Constant Field Values

CLASS_PREFIX

public static final String CLASS_PREFIX

See Also:

Constant Field Values

INDEX_PREFIX

public static final String INDEX_PREFIX

See Also:

Constant Field Values

KEYWORD_UNSAFE

public static final String KEYWORD_UNSAFE

See Also:

Constant Field Values

INDEX_VALUES_PREFIX

public static final String INDEX_VALUES_PREFIX

See Also:

Constant Field Values

INDEX_VALUES_ASC_PREFIX

public static final String INDEX_VALUES_ASC_PREFIX

See Also:

Constant Field Values

INDEX_VALUES_DESC_PREFIX

public static final String INDEX_VALUES_DESC_PREFIX

See Also:

Constant Field Values

DICTIONARY_PREFIX

public static final String DICTIONARY_PREFIX

See Also:

Constant Field Values

METADATA_PREFIX

public static final String METADATA_PREFIX

See Also:

Constant Field Values

METADATA_SCHEMA

public static final String METADATA_SCHEMA

See Also:

Constant Field Values

METADATA_INDEXMGR

public static final String METADATA_INDEXMGR

See Also:

Constant Field Values

METADATA_STORAGE

public static final String METADATA_STORAGE

See Also:

Constant Field Values

METADATA_DATABASE

public static final String METADATA_DATABASE

See Also:

Constant Field Values

DEFAULT_PARAM_USER

public static final String DEFAULT_PARAM_USER

See Also:

Constant Field Values

timeoutMs

protected long timeoutMs

timeoutStrategy

protected OCommandContext.TIMEOUT_STRATEGY timeoutStrategy

preParsedStatement

protected OStatement preParsedStatement

Constructor Detail

OCommandExecutorSQLAbstract

public OCommandExecutorSQLAbstract()

Method Detail

getDistributedExecutionMode

public OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE getDistributedExecutionMode()

The command is replicated

Returns:

isIdempotent

public boolean isIdempotent()

Description copied from interface: OCommandExecutor

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

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.

throwParsingException

protected void throwParsingException(String iText)

throwParsingException

protected void throwParsingException(String iText,
                                     Exception e)

parseTimeout

protected boolean parseTimeout(String w)
                        throws OCommandSQLParsingException

Parses the timeout keyword if found.

Throws:

OCommandSQLParsingException

parseLock

protected String parseLock()
                    throws OCommandSQLParsingException

Parses the lock keyword if found.

Throws:

OCommandSQLParsingException

getInvolvedClustersOfClasses

protected Set<String> getInvolvedClustersOfClasses(Collection<String> iClassNames)

getInvolvedClustersOfClusters

protected Set<String> getInvolvedClustersOfClusters(Collection<String> iClusterNames)

getInvolvedClustersOfIndex

protected Set<String> getInvolvedClustersOfIndex(String iIndexName)

checkClusterAccess

protected boolean checkClusterAccess(ODatabaseDocument db,
                                     String iClusterName)

bindDefaultContextVariables

protected void bindDefaultContextVariables()

preParse

protected String preParse(String queryText,
                          OCommandRequest iRequest)

decodeClassName

protected String decodeClassName(String s)