org.apache.ignite.internal.processors.query.h2

Class CommandProcessor

java.lang.Object

org.apache.ignite.internal.sql.SqlCommandProcessor

org.apache.ignite.internal.processors.query.h2.CommandProcessor

public class CommandProcessor
extends SqlCommandProcessor

Processor responsible for execution of all non-SELECT and non-DML commands.

Field Summary

Fields inherited from class org.apache.ignite.internal.sql.SqlCommandProcessor

ctx, log

Constructor Summary

Constructors

Constructor and Description
CommandProcessor(GridKernalContext ctx, H2SchemaManager schemaMgr, IgniteH2Indexing idx) Constructor.

Method Summary

Modifier and Type	Method and Description
static boolean	isCommand(org.h2.command.Prepared cmd)
static boolean	isCommandNoOp(org.h2.command.Prepared cmd)
boolean	isCommandSupported(SqlCommand cmd)
CommandResult	runCommand(String sql, SqlCommand cmdNative, GridSqlStatement cmdH2, QueryParameters params, @Nullable SqlClientContext cliCtx, long qryId) Execute command.
FieldsQueryCursor<List<?>>	runNativeCommand(String sql, SqlCommand cmdNative, QueryParameters params, @Nullable SqlClientContext cliCtx, Long qryId) Execute native command.

Methods inherited from class org.apache.ignite.internal.sql.SqlCommandProcessor

finishActiveTxIfNecessary, runCommand

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandProcessor

public CommandProcessor(GridKernalContext ctx,
                        H2SchemaManager schemaMgr,
                        IgniteH2Indexing idx)

Constructor.

Parameters:

ctx - Kernal context.

schemaMgr - Schema manager.

Method Detail

runCommand

public CommandResult runCommand(String sql,
                                SqlCommand cmdNative,
                                GridSqlStatement cmdH2,
                                QueryParameters params,
                                @Nullable
                                @Nullable SqlClientContext cliCtx,
                                long qryId)
                         throws IgniteCheckedException

Execute command.

Parameters:

sql - SQL.

cmdNative - Native command (if any).

cmdH2 - H2 command (if any).

params - Parameters.

cliCtx - Client context.

qryId - Running query ID.

Returns:

Result.

Throws:

IgniteCheckedException

runNativeCommand

public FieldsQueryCursor<List<?>> runNativeCommand(String sql,
                                                   SqlCommand cmdNative,
                                                   QueryParameters params,
                                                   @Nullable
                                                   @Nullable SqlClientContext cliCtx,
                                                   Long qryId)
                                            throws IgniteCheckedException

Execute native command.

Parameters:

sql - SQL.

cmdNative - Native command.

params - Parameters.

cliCtx - Client context.

qryId - Running query ID.

Returns:

Result.

Throws:

IgniteCheckedException

isCommandSupported

public boolean isCommandSupported(SqlCommand cmd)

Overrides:

isCommandSupported in class SqlCommandProcessor

isCommand

public static boolean isCommand(org.h2.command.Prepared cmd)

Parameters:

cmd - Statement.

Returns:

Whether cmd is a DDL statement we're able to handle.

isCommandNoOp

public static boolean isCommandNoOp(org.h2.command.Prepared cmd)

Parameters:

cmd - Statement.

Returns:

Whether cmd is a no-op.