Package com.orientechnologies.orient.core.sql

Class OCommandExecutorSQLLiveSelect

java.lang.Object

com.orientechnologies.common.parser.OBaseParser

com.orientechnologies.orient.core.command.OCommandExecutorAbstract

com.orientechnologies.orient.core.sql.OCommandExecutorSQLAbstract

com.orientechnologies.orient.core.sql.OCommandExecutorSQLResultsetAbstract

com.orientechnologies.orient.core.sql.OCommandExecutorSQLSelect

com.orientechnologies.orient.core.sql.OCommandExecutorSQLLiveSelect

All Implemented Interfaces:

OCommandDistributedReplicateRequest, OCommandExecutor, OLiveQueryListener, OIterableRecordSource, OTemporaryRidGenerator, Iterable<OIdentifiable>

public class OCommandExecutorSQLLiveSelect
extends OCommandExecutorSQLSelect
implements OLiveQueryListener

Author:

Luigi Dell'Aquila (l.dellaquila-(at)-orientdb.com)

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	Description
static final String	KEYWORD_LIVE_SELECT

Fields inherited from class com.orientechnologies.orient.core.sql.OCommandExecutorSQLSelect

KEYWORD_ASC, KEYWORD_BY, KEYWORD_DESC, KEYWORD_FETCHPLAN, KEYWORD_FOREACH, KEYWORD_GROUP, KEYWORD_NOCACHE, KEYWORD_ORDER, KEYWORD_SELECT, KEYWORD_UNWIND

Fields inherited from class com.orientechnologies.orient.core.sql.OCommandExecutorSQLResultsetAbstract

compiledFilter, KEYWORD_FROM_2FIND, KEYWORD_LET_2FIND, lazyIteration, let, parsedTarget, request, resultCount, serialTempRID, skip, target, tempResult

Fields inherited from class com.orientechnologies.orient.core.sql.OCommandExecutorSQLAbstract

CLASS_PREFIX, CLUSTER_PREFIX, DEFAULT_PARAM_USER, DICTIONARY_PREFIX, INDEX_PREFIX, INDEX_VALUES_ASC_PREFIX, INDEX_VALUES_DESC_PREFIX, INDEX_VALUES_PREFIX, KEYWORD_FROM, KEYWORD_KEY, KEYWORD_LET, KEYWORD_LIMIT, KEYWORD_LOCK, KEYWORD_OFFSET, KEYWORD_RETURN, KEYWORD_RID, KEYWORD_SKIP, KEYWORD_TIMEOUT, KEYWORD_UNSAFE, KEYWORD_WHERE, METADATA_DATABASE, METADATA_DISTRIBUTED, METADATA_INDEXMGR, METADATA_PREFIX, METADATA_SCHEMA, METADATA_STORAGE, preParsedStatement, timeoutMs, 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	Description
OCommandExecutorSQLLiveSelect()

Method Summary

Modifier and Type	Method	Description
protected void	execInSeparateDatabase(OCallable iCallback)
Object	execute(Map<Object,Object> iArgs)	Execute the requested command parsed previously.
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
void	onLiveResult(ORecordOperation iOp)
void	onLiveResultEnd()
OCommandExecutorSQLSelect	parse(OCommandRequest iRequest)	Compile the filter conditions only the first time.

Methods inherited from class com.orientechnologies.orient.core.sql.OCommandExecutorSQLSelect

addResult, assignTarget, createProjectionFromDefinition, executeSearch, executeSearchRecord, extractProjectionNameSubstringEndPosition, getFetchPlan, getInvolvedClusters, getProjectionDefinition, getProjectionGroup, getProjections, getSyntax, getTemporaryRIDCounter, handleResult, hasGroupBy, initContext, isAnyFunctionAggregates, isUseCache, iterator, iterator, optimizeExecution, parseFetchplan, parseGroupBy, parseNoCache, parseOrderBy, parseProjections, parseUnwind, reportTip, revertProfiler, revertSubclassesProfiler, searchInClasses, setFetchLimit, setFetchPlan, setGroupByFields, setNoCache, setOrderedFields, setParallel, setProjectionDefinition, setProjections

Methods inherited from class com.orientechnologies.orient.core.sql.OCommandExecutorSQLResultsetAbstract

applyLimitAndSkip, assignLetClauses, evaluateRecord, filter, getDistributedExecutionMode, getDistributedResultManagement, getRange, getResult, getResultInstance, getTarget, isCacheable, isIdempotent, isLazyIteration, mergeResults, optimize, optimizeBranch, optimizeFunction, parseLet, parseLimit, parseSkip, pushResult, searchInClasses, searchInClasses, searchInClusters, setCompiledFilter, setLazyIteration, setParsedTarget, setRequest, setTarget

Methods inherited from class com.orientechnologies.orient.core.sql.OCommandExecutorSQLAbstract

bindDefaultContextVariables, checkClusterAccess, decodeClassName, getInvolvedClustersOfClasses, getInvolvedClustersOfClusters, getInvolvedClustersOfIndex, parseLock, parseTimeout, preParse, throwParsingException, throwParsingException, throwSyntaxErrorException

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

checkInterruption, checkInterruption, getContext, getDatabase, getDistributedTimeout, getLimit, getParameters, getProgressListener, getSecurityOperationType, getUndoCommand, init, involveSchema, isDistributedExecutingOnLocalNodeFirst, isLocalExecution, setContext, setLimit, setProgressListener, toString

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

getLastWordLength, 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 java.lang.Iterable

forEach, spliterator

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

getDistributedTimeout, getUndoCommand, isDistributedExecutingOnLocalNodeFirst

Field Details

KEYWORD_LIVE_SELECT

public static final String KEYWORD_LIVE_SELECT

See Also:

• Constant Field Values

Constructor Details

OCommandExecutorSQLLiveSelect

public OCommandExecutorSQLLiveSelect()

Method Details

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

Overrides:

execute in class OCommandExecutorSQLSelect

Parameters:

iArgs - Optional variable arguments to pass to the command.

Returns:

See Also:

• OCommandExecutor.parse(OCommandRequest)

onLiveResult

public void onLiveResult(ORecordOperation iOp)

Specified by:

onLiveResult in interface OLiveQueryListener

execInSeparateDatabase

protected void execInSeparateDatabase(OCallable iCallback)

onLiveResultEnd

public void onLiveResultEnd()

Specified by:

onLiveResultEnd in interface OLiveQueryListener

parse

public OCommandExecutorSQLSelect parse(OCommandRequest iRequest)

Description copied from class: OCommandExecutorSQLSelect

Compile the filter conditions only the first time.

Specified by:

parse in interface OCommandExecutor

Overrides:

parse in class OCommandExecutorSQLSelect

Parameters:

iRequest - Command request implementation.

Returns:

See Also:

• #execute(Map<Object, Object>...)

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

Overrides:

getQuorumType in class OCommandExecutorSQLSelect