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

Class IgniteH2Indexing

java.lang.Object

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

All Implemented Interfaces:

GridQueryIndexing

public class IgniteH2Indexing
extends Object
implements GridQueryIndexing

Indexing implementation based on H2 database engine. In this implementation main query language is SQL, fulltext indexing can be performed using Lucene.

For each registered GridQueryTypeDescriptor this SPI will create respective SQL table with '_key' and '_val' fields for key and value, and fields from GridQueryTypeDescriptor.fields(). For each table it will create indexes declared in GridQueryTypeDescriptor.indexes().

Field Summary

Fields

Modifier and Type	Field and Description
protected GridKernalContext	ctx
static List<GridQueryFieldMetadata>	UPDATE_RESULT_META Dummy metadata for update result.
protected CacheQueryObjectValueContext	valCtx Cache object value context.

Constructor Summary

Constructors

Constructor and Description
IgniteH2Indexing()

Method Summary

Methods

Modifier and Type	Method and Description
void	awaitForReadyTopologyVersion(AffinityTopologyVersion topVer)
IndexingQueryFilter	backupFilter(AffinityTopologyVersion topVer, int[] parts)
void	bindParameters(PreparedStatement stmt, Collection<Object> params) Binds parameters to prepared statement.
GridSpinBusyLock	busyLock()
void	cancelAllQueries()
void	cancelQueries(Collection<Long> queries)
List<Integer>	collectCacheIds(Integer mainCacheId, GridCacheTwoStepQuery twoStepQry) Collect cache identifiers from two-step query.
Connection	connectionForSchema(String schema)
GridH2IndexBase	createSortedIndex(String name, GridH2Table tbl, boolean pk, List<org.h2.table.IndexColumn> cols, int inlineSize) Create sorted index.
GridH2Table	dataTable(QueryTable tbl) Find table by it's identifier.
GridH2Table	dataTable(String schemaName, String tblName) Find table by name in given schema.
GridH2Table	dataTableForIndex(String schemaName, String idxName) Find table for index.
void	dynamicAddColumn(String schemaName, String tblName, List<QueryField> cols, boolean ifTblExists, boolean ifColNotExists)
void	dynamicIndexCreate(String schemaName, String tblName, QueryIndexDescriptorImpl idxDesc, boolean ifNotExists, SchemaIndexCacheVisitor cacheVisitor)
void	dynamicIndexDrop(String schemaName, String idxName, boolean ifExists)
ResultSet	executeSqlQueryWithTimer(Connection conn, String sql, Collection<Object> params, boolean useStmtCache, int timeoutMillis, GridQueryCancel cancel) Executes sql query and prints warning if query is too slow..
void	executeStatement(String schema, String sql)
boolean	isInsertStatement(PreparedStatement nativeStmt)
GridKernalContext	kernalContext()
UpdateResult	mapDistributedUpdate(String schemaName, SqlFieldsQuery fldsQry, IndexingQueryFilter filter, GridQueryCancel cancel, boolean local) Run DML request from other node.
GridMapQueryExecutor	mapQueryExecutor()
void	markForRebuildFromHash(String cacheName)
CacheObjectValueContext	objectContext()
void	onDisconnected(IgniteFuture<?> reconnectFut)
PreparedStatement	prepareNativeStatement(String schemaName, String sql)
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>>	queryDistributedSql(String schemaName, String cacheName, SqlQuery qry, boolean keepBinary, int mainCacheId)
List<FieldsQueryCursor<List<?>>>	queryDistributedSqlFields(String schemaName, SqlFieldsQuery qry, boolean keepBinary, GridQueryCancel cancel, Integer mainCacheId, boolean failOnMultipleStmts)
<K,V> QueryCursor<javax.cache.Cache.Entry<K,V>>	queryLocalSql(String schemaName, String cacheName, SqlQuery qry, IndexingQueryFilter filter, boolean keepBinary)
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>>	queryLocalSql(String schemaName, String cacheName, String qry, String alias, Collection<Object> params, String type, IndexingQueryFilter filter, GridQueryCancel cancel) Executes regular query.
FieldsQueryCursor<List<?>>	queryLocalSqlFields(String schemaName, SqlFieldsQuery qry, boolean keepBinary, IndexingQueryFilter filter, GridQueryCancel cancel)
GridQueryFieldsResult	queryLocalSqlFields(String schemaName, String qry, Collection<Object> params, IndexingQueryFilter filter, boolean enforceJoinOrder, int timeout, GridQueryCancel cancel) Queries individual fields (generally used by JDBC drivers).
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>>	queryLocalText(String schemaName, String cacheName, String qry, String typeName, IndexingQueryFilter filters)
AffinityTopologyVersion	readyTopologyVersion()
void	rebuildIndexesFromHash(String cacheName) Rebuild indexes from hash index.
GridReduceQueryExecutor	reduceQueryExecutor()
void	registerCache(String cacheName, String schemaName, GridCacheContext<?,?> cctx)
boolean	registerType(GridCacheContext cctx, GridQueryTypeDescriptor type) Registers new class description.
void	remove(String cacheName, GridQueryTypeDescriptor type, KeyCacheObject key, int partId, CacheObject val, GridCacheVersion ver)
void	removeDataTable(GridH2Table h2Tbl)
Collection<GridRunningQueryInfo>	runningQueries(long duration)
String	schema(String cacheName)
boolean	send(Object topic, int topicOrd, Collection<ClusterNode> nodes, Message msg, IgniteBiClosure<ClusterNode,Message,Message> specialize, IgniteInClosure2X<ClusterNode,Message> locNodeHnd, byte plc, boolean runLocParallel)
void	start(GridKernalContext ctx, GridSpinBusyLock busyLock)
void	stop()
void	store(String cacheName, GridQueryTypeDescriptor type, KeyCacheObject k, int partId, CacheObject v, GridCacheVersion ver, long expirationTime, long link)
long	streamUpdateQuery(String schemaName, String qry, Object[] params, IgniteDataStreamer<?,?> streamer)
void	unregisterCache(String cacheName, boolean destroy)

Methods inherited from class java.lang.Object

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

Field Detail

UPDATE_RESULT_META

public static final List<GridQueryFieldMetadata> UPDATE_RESULT_META

Dummy metadata for update result.

ctx

protected volatile GridKernalContext ctx

valCtx

protected CacheQueryObjectValueContext valCtx

Cache object value context.

Constructor Detail

IgniteH2Indexing

public IgniteH2Indexing()

Method Detail

kernalContext

public GridKernalContext kernalContext()

Returns:

Kernal context.

connectionForSchema

public Connection connectionForSchema(String schema)

Parameters:

schema - Schema.

Returns:

Connection.

prepareNativeStatement

public PreparedStatement prepareNativeStatement(String schemaName,
                                       String sql)
                                         throws SQLException

Specified by:

prepareNativeStatement in interface GridQueryIndexing

Throws:

SQLException

executeStatement

public void executeStatement(String schema,
                    String sql)
                      throws IgniteCheckedException

Parameters:

schema - Schema

sql - SQL statement.

Throws:

IgniteCheckedException - If failed.

store

public void store(String cacheName,
         GridQueryTypeDescriptor type,
         KeyCacheObject k,
         int partId,
         CacheObject v,
         GridCacheVersion ver,
         long expirationTime,
         long link)
           throws IgniteCheckedException

Specified by:

store in interface GridQueryIndexing

Throws:

IgniteCheckedException

remove

public void remove(String cacheName,
          GridQueryTypeDescriptor type,
          KeyCacheObject key,
          int partId,
          CacheObject val,
          GridCacheVersion ver)
            throws IgniteCheckedException

Specified by:

remove in interface GridQueryIndexing

Throws:

IgniteCheckedException

dynamicIndexCreate

public void dynamicIndexCreate(String schemaName,
                      String tblName,
                      QueryIndexDescriptorImpl idxDesc,
                      boolean ifNotExists,
                      SchemaIndexCacheVisitor cacheVisitor)
                        throws IgniteCheckedException

Specified by:

dynamicIndexCreate in interface GridQueryIndexing

Throws:

IgniteCheckedException

dynamicIndexDrop

public void dynamicIndexDrop(String schemaName,
                    String idxName,
                    boolean ifExists)
                      throws IgniteCheckedException

Specified by:

dynamicIndexDrop in interface GridQueryIndexing

Throws:

IgniteCheckedException

dynamicAddColumn

public void dynamicAddColumn(String schemaName,
                    String tblName,
                    List<QueryField> cols,
                    boolean ifTblExists,
                    boolean ifColNotExists)
                      throws IgniteCheckedException

Specified by:

dynamicAddColumn in interface GridQueryIndexing

Throws:

IgniteCheckedException

createSortedIndex

public GridH2IndexBase createSortedIndex(String name,
                                GridH2Table tbl,
                                boolean pk,
                                List<org.h2.table.IndexColumn> cols,
                                int inlineSize)

Create sorted index.

Parameters:

name - Index name,

tbl - Table.

pk - Primary key flag.

cols - Columns.

Returns:

Index.

queryLocalText

public <K,V> GridCloseableIterator<IgniteBiTuple<K,V>> queryLocalText(String schemaName,
                                                             String cacheName,
                                                             String qry,
                                                             String typeName,
                                                             IndexingQueryFilter filters)
                                                         throws IgniteCheckedException

Specified by:

queryLocalText in interface GridQueryIndexing

Throws:

IgniteCheckedException

queryLocalSqlFields

public GridQueryFieldsResult queryLocalSqlFields(String schemaName,
                                        String qry,
                                        @Nullable
                                        Collection<Object> params,
                                        IndexingQueryFilter filter,
                                        boolean enforceJoinOrder,
                                        int timeout,
                                        GridQueryCancel cancel)
                                          throws IgniteCheckedException

Queries individual fields (generally used by JDBC drivers).

Parameters:

schemaName - Schema name.

qry - Query.

params - Query parameters.

filter - Cache name and key filter.

enforceJoinOrder - Enforce join order of tables in the query.

timeout - Query timeout in milliseconds.

cancel - Query cancel.

Returns:

Query result.

Throws:

IgniteCheckedException - If failed.

streamUpdateQuery

public long streamUpdateQuery(String schemaName,
                     String qry,
                     @Nullable
                     Object[] params,
                     IgniteDataStreamer<?,?> streamer)
                       throws IgniteCheckedException

Specified by:

streamUpdateQuery in interface GridQueryIndexing

Throws:

IgniteCheckedException

executeSqlQueryWithTimer

public ResultSet executeSqlQueryWithTimer(Connection conn,
                                 String sql,
                                 @Nullable
                                 Collection<Object> params,
                                 boolean useStmtCache,
                                 int timeoutMillis,
                                 @Nullable
                                 GridQueryCancel cancel)
                                   throws IgniteCheckedException

Executes sql query and prints warning if query is too slow..

Parameters:

conn - Connection,

sql - Sql query.

params - Parameters.

useStmtCache - If true uses stmt cache.

cancel - Query cancel.

Returns:

Result.

Throws:

IgniteCheckedException - If failed.

bindParameters

public void bindParameters(PreparedStatement stmt,
                  @Nullable
                  Collection<Object> params)
                    throws IgniteCheckedException

Binds parameters to prepared statement.

Parameters:

stmt - Prepared statement.

params - Parameters collection.

Throws:

IgniteCheckedException - If failed.

queryLocalSqlFields

public FieldsQueryCursor<List<?>> queryLocalSqlFields(String schemaName,
                                             SqlFieldsQuery qry,
                                             boolean keepBinary,
                                             IndexingQueryFilter filter,
                                             GridQueryCancel cancel)
                                               throws IgniteCheckedException

Specified by:

queryLocalSqlFields in interface GridQueryIndexing

Throws:

IgniteCheckedException

queryLocalSql

public <K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> queryLocalSql(String schemaName,
                                                            String cacheName,
                                                            SqlQuery qry,
                                                            IndexingQueryFilter filter,
                                                            boolean keepBinary)
                                                        throws IgniteCheckedException

Specified by:

queryLocalSql in interface GridQueryIndexing

Throws:

IgniteCheckedException

queryLocalSql

public <K,V> GridCloseableIterator<IgniteBiTuple<K,V>> queryLocalSql(String schemaName,
                                                            String cacheName,
                                                            String qry,
                                                            String alias,
                                                            @Nullable
                                                            Collection<Object> params,
                                                            String type,
                                                            IndexingQueryFilter filter,
                                                            GridQueryCancel cancel)
                                                        throws IgniteCheckedException

Executes regular query.

Parameters:

schemaName - Schema name.

cacheName - Cache name.

qry - Query.

alias - Table alias.

params - Query parameters.

type - Query return type.

filter - Cache name and key filter. @return Queried rows.

Throws:

IgniteCheckedException - If failed.

queryDistributedSql

public <K,V> QueryCursor<javax.cache.Cache.Entry<K,V>> queryDistributedSql(String schemaName,
                                                                  String cacheName,
                                                                  SqlQuery qry,
                                                                  boolean keepBinary,
                                                                  int mainCacheId)

Specified by:

queryDistributedSql in interface GridQueryIndexing

queryDistributedSqlFields

public List<FieldsQueryCursor<List<?>>> queryDistributedSqlFields(String schemaName,
                                                         SqlFieldsQuery qry,
                                                         boolean keepBinary,
                                                         GridQueryCancel cancel,
                                                         @Nullable
                                                         Integer mainCacheId,
                                                         boolean failOnMultipleStmts)

Specified by:

queryDistributedSqlFields in interface GridQueryIndexing

mapDistributedUpdate

public UpdateResult mapDistributedUpdate(String schemaName,
                                SqlFieldsQuery fldsQry,
                                IndexingQueryFilter filter,
                                GridQueryCancel cancel,
                                boolean local)
                                  throws IgniteCheckedException

Run DML request from other node.

Parameters:

schemaName - Schema name.

fldsQry - Query.

filter - Filter.

cancel - Cancel state.

local - Locality flag.

Returns:

Update result.

Throws:

IgniteCheckedException - if failed.

registerType

public boolean registerType(GridCacheContext cctx,
                   GridQueryTypeDescriptor type)
                     throws IgniteCheckedException

Registers new class description. This implementation doesn't support type reregistration.

Specified by:

registerType in interface GridQueryIndexing

Parameters:

type - Type description.

Throws:

IgniteCheckedException - In case of error.

dataTable

public GridH2Table dataTable(String schemaName,
                    String tblName)

Find table by name in given schema.

Parameters:

schemaName - Schema name.

tblName - Table name.

Returns:

Table or null if none found.

dataTable

public GridH2Table dataTable(QueryTable tbl)

Find table by it's identifier.

Parameters:

tbl - Identifier.

Returns:

Table or null if none found.

removeDataTable

public void removeDataTable(GridH2Table h2Tbl)

Parameters:

h2Tbl - Remove data table.

dataTableForIndex

public GridH2Table dataTableForIndex(String schemaName,
                            String idxName)

Find table for index.

Parameters:

schemaName - Schema name.

idxName - Index name.

Returns:

Table or null if index is not found.

schema

public String schema(String cacheName)

Specified by:

schema in interface GridQueryIndexing

isInsertStatement

public boolean isInsertStatement(PreparedStatement nativeStmt)

Specified by:

isInsertStatement in interface GridQueryIndexing

rebuildIndexesFromHash

public void rebuildIndexesFromHash(String cacheName)
                            throws IgniteCheckedException

Rebuild indexes from hash index.

Specified by:

rebuildIndexesFromHash in interface GridQueryIndexing

Parameters:

cacheName - Cache name.

Throws:

IgniteCheckedException - If failed.

markForRebuildFromHash

public void markForRebuildFromHash(String cacheName)

Specified by:

markForRebuildFromHash in interface GridQueryIndexing

busyLock

public GridSpinBusyLock busyLock()

Returns:

Busy lock.

mapQueryExecutor

public GridMapQueryExecutor mapQueryExecutor()

Returns:

Map query executor.

reduceQueryExecutor

public GridReduceQueryExecutor reduceQueryExecutor()

Returns:

Reduce query executor.

start

public void start(GridKernalContext ctx,
         GridSpinBusyLock busyLock)
           throws IgniteCheckedException

Specified by:

start in interface GridQueryIndexing

Throws:

IgniteCheckedException

objectContext

public CacheObjectValueContext objectContext()

Returns:

Value object context.

send

public boolean send(Object topic,
           int topicOrd,
           Collection<ClusterNode> nodes,
           Message msg,
           @Nullable
           IgniteBiClosure<ClusterNode,Message,Message> specialize,
           @Nullable
           IgniteInClosure2X<ClusterNode,Message> locNodeHnd,
           byte plc,
           boolean runLocParallel)

Parameters:

topic - Topic.

topicOrd - Topic ordinal for GridTopic.

nodes - Nodes.

msg - Message.

specialize - Optional closure to specialize message for each node.

locNodeHnd - Handler for local node.

plc - Policy identifying the executor service which will process message.

runLocParallel - Run local handler in parallel thread.

Returns:

true If all messages sent successfully.

stop

public void stop()
          throws IgniteCheckedException

Specified by:

stop in interface GridQueryIndexing

Throws:

IgniteCheckedException

registerCache

public void registerCache(String cacheName,
                 String schemaName,
                 GridCacheContext<?,?> cctx)
                   throws IgniteCheckedException

Specified by:

registerCache in interface GridQueryIndexing

Throws:

IgniteCheckedException

unregisterCache

public void unregisterCache(String cacheName,
                   boolean destroy)

Specified by:

unregisterCache in interface GridQueryIndexing

backupFilter

public IndexingQueryFilter backupFilter(@Nullable
                               AffinityTopologyVersion topVer,
                               @Nullable
                               int[] parts)

Specified by:

backupFilter in interface GridQueryIndexing

readyTopologyVersion

public AffinityTopologyVersion readyTopologyVersion()

Returns:

Ready topology version.

awaitForReadyTopologyVersion

public void awaitForReadyTopologyVersion(AffinityTopologyVersion topVer)
                                  throws IgniteCheckedException

Parameters:

topVer - Topology version.

Throws:

IgniteCheckedException - If failed.

onDisconnected

public void onDisconnected(IgniteFuture<?> reconnectFut)

Specified by:

onDisconnected in interface GridQueryIndexing

runningQueries

public Collection<GridRunningQueryInfo> runningQueries(long duration)

Specified by:

runningQueries in interface GridQueryIndexing

cancelQueries

public void cancelQueries(Collection<Long> queries)

Specified by:

cancelQueries in interface GridQueryIndexing

cancelAllQueries

public void cancelAllQueries()

Specified by:

cancelAllQueries in interface GridQueryIndexing

collectCacheIds

public List<Integer> collectCacheIds(@Nullable
                            Integer mainCacheId,
                            GridCacheTwoStepQuery twoStepQry)

Collect cache identifiers from two-step query.

Parameters:

mainCacheId - Id of main cache.

twoStepQry - Two-step query.

Returns:

Result.