org.apache.ignite.internal.sql

Class SqlCommandProcessor

java.lang.Object

org.apache.ignite.internal.sql.SqlCommandProcessor

public class SqlCommandProcessor
extends Object

Processor responsible for execution of native Ignite commands.

Field Summary

Fields

Modifier and Type	Field and Description
protected GridKernalContext	ctx Kernal context.
protected IgniteLogger	log Logger.
protected GridQuerySchemaManager	schemaMgr Schema manager.

Constructor Summary

Constructors

Constructor and Description
SqlCommandProcessor(GridKernalContext ctx, GridQuerySchemaManager schemaMgr) Constructor.

Method Summary

Modifier and Type	Method and Description
protected static void	ensureDdlSupported(GridCacheContextInfo<?,?> cctxInfo) Check if cache supports DDL statement.
protected void	finishActiveTxIfNecessary() Commits active transaction if exists.
boolean	isCommandSupported(SqlCommand cmd)
@Nullable FieldsQueryCursor<List<?>>	runCommand(SqlCommand cmdNative) Execute command.

Methods inherited from class java.lang.Object

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

Field Detail

ctx

protected final GridKernalContext ctx

Kernal context.

log

protected final IgniteLogger log

Logger.

schemaMgr

protected final GridQuerySchemaManager schemaMgr

Schema manager.

Constructor Detail

SqlCommandProcessor

public SqlCommandProcessor(GridKernalContext ctx,
                           GridQuerySchemaManager schemaMgr)

Constructor.

Parameters:

ctx - Kernal context.

schemaMgr - Schema manager.

Method Detail

runCommand

@Nullable
public @Nullable FieldsQueryCursor<List<?>> runCommand(SqlCommand cmdNative)

Execute command.

Parameters:

cmdNative - Native command.

Returns:

Result.

isCommandSupported

public boolean isCommandSupported(SqlCommand cmd)

Returns:

True if command is supported by this command processor.

finishActiveTxIfNecessary

protected void finishActiveTxIfNecessary()
                                  throws IgniteCheckedException

Commits active transaction if exists.

Throws:

IgniteCheckedException - If failed.

ensureDdlSupported

protected static void ensureDdlSupported(GridCacheContextInfo<?,?> cctxInfo)
                                  throws IgniteSQLException

Check if cache supports DDL statement.

Parameters:

cctxInfo - Cache context info.

Throws:

IgniteSQLException - If failed.