JdbcQueryCursorHandlerImpl

java.lang.Object

org.apache.ignite.client.handler.JdbcQueryCursorHandlerImpl

All Implemented Interfaces:: org.apache.ignite.internal.jdbc.proto.JdbcQueryCursorHandler

public class JdbcQueryCursorHandlerImpl extends Object implements org.apache.ignite.internal.jdbc.proto.JdbcQueryCursorHandler

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>

ZERO_UPDATE_COUNT_QUERIES

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

Modifier and Type

Method

Description

CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcQueryCloseResult>

closeAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcQueryCloseRequest req)

CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcQueryFetchResult>

fetchAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcFetchQueryResultsRequest req)

CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcQuerySingleResult>

getMoreResultsAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcFetchQueryResultsRequest req)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- 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.
Method Details
- fetchAsync
  
  public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcQueryFetchResult> fetchAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcFetchQueryResultsRequest req)
  
  Specified by:
  
  fetchAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryCursorHandler
- getMoreResultsAsync
  
  public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcQuerySingleResult> getMoreResultsAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcFetchQueryResultsRequest req)
  
  Specified by:
  
  getMoreResultsAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryCursorHandler
- closeAsync
  
  public CompletableFuture<org.apache.ignite.internal.jdbc.proto.event.JdbcQueryCloseResult> closeAsync(org.apache.ignite.internal.jdbc.proto.event.JdbcQueryCloseRequest req)
  
  Specified by:
  
  closeAsync in interface org.apache.ignite.internal.jdbc.proto.JdbcQueryCursorHandler