Package com.orientechnologies.orient.core.sql

Class OCommandExecutorSQLInsert

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

com.orientechnologies.orient.core.sql.OCommandExecutorSQLInsert

All Implemented Interfaces:

OCommandDistributedReplicateRequest, OCommandExecutor, OCommandResultListener

public class OCommandExecutorSQLInsert
extends OCommandExecutorSQLSetAware
implements OCommandDistributedReplicateRequest, OCommandResultListener

SQL INSERT command.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com), Johann Sorel (Geomatys)

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_INSERT
protected static final String	KEYWORD_RETURN

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

content, KEYWORD_CONTENT, KEYWORD_SET, parameterCounter

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_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
OCommandExecutorSQLInsert()

Method Summary

Modifier and Type	Method	Description
void	end()	Called at the end of processing.
Object	execute(Map<Object,Object> iArgs)	Execute the INSERT and return the ODocument object created.
OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE	getDistributedExecutionMode()	The command is replicated
Set<String>	getInvolvedClusters()	Returns the involved clusters.
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
Object	getResult()
String	getSyntax()
OCommandExecutorSQLInsert	parse(OCommandRequest iRequest)	Parse the request.
protected void	parseReturn(Boolean subQueryExpected)	Parses the returning keyword if found.
protected void	parseValues()
protected Object	prepareReturnItem(ODocument item)
protected Object	prepareReturnResult(List<ODocument> res)
boolean	result(Object iRecord)	This method is called for each result.
protected void	saveRecord(ORecord rec)

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

convertValue, extractClassFromTarget, getDistributedTimeout, getFieldValueCountingParameters, parseContent, parseJSON, parseSetFields

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

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

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

checkInterruption, checkInterruption, getContext, getDatabase, getDistributedResultManagement, getFetchPlan, getLimit, getParameters, getProgressListener, getSecurityOperationType, getUndoCommand, init, involveSchema, isCacheable, isDistributedExecutingOnLocalNodeFirst, isLocalExecution, mergeResults, 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 com.orientechnologies.orient.core.command.OCommandDistributedReplicateRequest

getDistributedResultManagement, getDistributedTimeout, getUndoCommand, isDistributedExecutingOnLocalNodeFirst

Field Details

KEYWORD_INSERT

public static final String KEYWORD_INSERT

See Also:

• Constant Field Values

KEYWORD_RETURN

protected static final String KEYWORD_RETURN

See Also:

• Constant Field Values

Constructor Details

OCommandExecutorSQLInsert

public OCommandExecutorSQLInsert()

Method Details

parse

public OCommandExecutorSQLInsert parse(OCommandRequest iRequest)

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:

iRequest - Command request implementation.

Returns:

See Also:

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

execute

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

Execute the INSERT and return the ODocument object created.

Specified by:

execute in interface OCommandExecutor

Parameters:

iArgs - Optional variable arguments to pass to the command.

Returns:

See Also:

• OCommandExecutor.parse(OCommandRequest)

getDistributedExecutionMode

public OCommandDistributedReplicateRequest.DISTRIBUTED_EXECUTION_MODE getDistributedExecutionMode()

Description copied from class: OCommandExecutorSQLAbstract

The command is replicated

Specified by:

getDistributedExecutionMode in interface OCommandDistributedReplicateRequest

Overrides:

getDistributedExecutionMode in class OCommandExecutorSQLAbstract

getInvolvedClusters

public Set<String> getInvolvedClusters()

Description copied from interface: OCommandExecutor

Returns the involved clusters.

Specified by:

getInvolvedClusters in interface OCommandExecutor

Overrides:

getInvolvedClusters in class OCommandExecutorAbstract

getSyntax

public String getSyntax()

Specified by:

getSyntax in interface OCommandExecutor

Overrides:

getSyntax in class OBaseParser

result

public boolean result(Object iRecord)

Description copied from interface: OCommandResultListener

This method is called for each result.

Specified by:

result in interface OCommandResultListener

Parameters:

iRecord - Current record

Returns:

True to continue the query, otherwise false

end

public void end()

Description copied from interface: OCommandResultListener

Called at the end of processing. This is useful to clean-up local attributes.

Specified by:

end in interface OCommandResultListener

prepareReturnResult

protected Object prepareReturnResult(List<ODocument> res)

prepareReturnItem

protected Object prepareReturnItem(ODocument item)

saveRecord

protected void saveRecord(ORecord rec)

parseValues

protected void parseValues()

parseReturn

protected void parseReturn(Boolean subQueryExpected)
                    throws OCommandSQLParsingException

Parses the returning keyword if found.

Throws:

OCommandSQLParsingException

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

getResult

public Object getResult()

Specified by:

getResult in interface OCommandResultListener