Package org.apache.ignite.client.handler

Class JdbcQueryEventHandlerImpl

java.lang.Object

org.apache.ignite.client.handler.JdbcQueryEventHandlerImpl

All Implemented Interfaces:

org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

public class JdbcQueryEventHandlerImpl
extends Object
implements org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

Jdbc query event handler implementation.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ClientResourceRegistry	resources	Client registry resources.
static final Set<org.apache.ignite.internal.sql.engine.SqlQueryType>	SELECT_STATEMENT_QUERIES	SqlQueryTypes allowed in JDBC select statements.
static final Set<org.apache.ignite.internal.sql.engine.SqlQueryType>	UPDATE_STATEMENT_QUERIES	SqlQueryTypes allowed in JDBC update statements.
static final Set<org.apache.ignite.internal.sql.engine.SqlQueryType>	ZERO_UPDATE_COUNT_QUERIES	SqlQueryTypes types that return 0 in executeUpdate and execute / getUpdateCount.

Constructor Summary

Constructors

Constructor	Description
JdbcQueryEventHandlerImpl(org.apache.ignite.internal.sql.engine.QueryProcessor processor, JdbcMetadataCatalog meta, ClientResourceRegistry resources, org.apache.ignite.internal.tx.TxManager txManager)	Constructor.

Method Summary

Modifier and Type	Method	Description
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcBatchExecuteResult>	batchAsync(long connectionId, org.apache.ignite.internal.jdbc.proto.event.JdbcBatchExecuteRequest req)
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcBatchExecuteResult>	batchPrepStatementAsync(long connectionId, org.apache.ignite.internal.jdbc.proto.event.JdbcBatchPreparedStmntRequest req)
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcQueryCancelResult>	cancelAsync(long connectionId, long correlationToken)
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcMetaColumnsResult>	columnsMetaAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcMetaColumnsRequest req)
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcConnectResult>	connect(ZoneId timeZoneId, String username)
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcFinishTxResult>	finishTxAsync(long connectionId, boolean commit)
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcMetaPrimaryKeysResult>	primaryKeysMetaAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcMetaPrimaryKeysRequest req)
CompletableFuture<? extends org.apache.ignite.internal.jdbc.proto.event.Response>	queryAsync(long connectionId, org.apache.ignite.internal.jdbc.proto.event.JdbcQueryExecuteRequest req)
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcMetaSchemasResult>	schemasMetaAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcMetaSchemasRequest req)
CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcMetaTablesResult>	tablesMetaAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcMetaTablesRequest req)

Methods inherited from class java.lang.Object

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

Field Details

UPDATE_STATEMENT_QUERIES

public static final Set<org.apache.ignite.internal.sql.engine.SqlQueryType> UPDATE_STATEMENT_QUERIES

SqlQueryTypes allowed in JDBC update statements.

SELECT_STATEMENT_QUERIES

public static final Set<org.apache.ignite.internal.sql.engine.SqlQueryType> SELECT_STATEMENT_QUERIES

SqlQueryTypes allowed in JDBC select statements.

ZERO_UPDATE_COUNT_QUERIES

public static final Set<org.apache.ignite.internal.sql.engine.SqlQueryType> ZERO_UPDATE_COUNT_QUERIES

SqlQueryTypes types that return 0 in executeUpdate and execute / getUpdateCount.

resources

protected final ClientResourceRegistry resources

Client registry resources.

Constructor Details

JdbcQueryEventHandlerImpl

public JdbcQueryEventHandlerImpl(org.apache.ignite.internal.sql.engine.QueryProcessor processor,
 JdbcMetadataCatalog meta,
 ClientResourceRegistry resources,
 org.apache.ignite.internal.tx.TxManager txManager)

Constructor.

Parameters:

processor - Processor.

meta - JdbcMetadataInfo.

resources - Client resources.

txManager - Transaction manager.

Method Details

connect

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcConnectResult> connect(ZoneId timeZoneId,
 String username)

Specified by:

connect in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

queryAsync

public CompletableFuture<? extends org.apache.ignite.internal.jdbc.proto.event.Response> queryAsync(long connectionId,
 org.apache.ignite.internal.jdbc.proto.event.JdbcQueryExecuteRequest req)

Specified by:

queryAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

batchAsync

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcBatchExecuteResult> batchAsync(long connectionId,
 org.apache.ignite.internal.jdbc.proto.event.JdbcBatchExecuteRequest req)

Specified by:

batchAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

batchPrepStatementAsync

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcBatchExecuteResult> batchPrepStatementAsync(long connectionId,
 org.apache.ignite.internal.jdbc.proto.event.JdbcBatchPreparedStmntRequest req)

Specified by:

batchPrepStatementAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

tablesMetaAsync

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcMetaTablesResult> tablesMetaAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcMetaTablesRequest req)

Specified by:

tablesMetaAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

columnsMetaAsync

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcMetaColumnsResult> columnsMetaAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcMetaColumnsRequest req)

Specified by:

columnsMetaAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

schemasMetaAsync

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcMetaSchemasResult> schemasMetaAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcMetaSchemasRequest req)

Specified by:

schemasMetaAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

primaryKeysMetaAsync

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcMetaPrimaryKeysResult> primaryKeysMetaAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcMetaPrimaryKeysRequest req)

Specified by:

primaryKeysMetaAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

finishTxAsync

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcFinishTxResult> finishTxAsync(long connectionId,
 boolean commit)

Specified by:

finishTxAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler

cancelAsync

public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcQueryCancelResult> cancelAsync(long connectionId,
 long correlationToken)

Specified by:

cancelAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryEventHandler