Package org.apache.druid.sql.avatica

Class DruidJdbcStatement

java.lang.Object

org.apache.druid.sql.avatica.AbstractDruidJdbcStatement

org.apache.druid.sql.avatica.DruidJdbcStatement

All Implemented Interfaces:

Closeable, AutoCloseable

public class DruidJdbcStatement
extends AbstractDruidJdbcStatement

Represents Druid's version of the JDBC Statement class: can be executed multiple times, one after another, producing a DruidJdbcResultSet for each execution. Thread safe, but only when accessed sequentially by different request threads: not designed for concurrent access as JDBC does not support concurrent actions on the same statement.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,Object>	defaultContext
protected final Map<String,Object>	queryContext

Fields inherited from class org.apache.druid.sql.avatica.AbstractDruidJdbcStatement

connectionId, fetcherFactory, resultSet, sqlQuery, START_OFFSET, statementId, throwable

Constructor Summary

Constructors

Constructor	Description
DruidJdbcStatement(String connectionId, int statementId, Map<String,Object> queryContext, Map<String,Object> defaultContext, SqlStatementFactory lifecycleFactory, DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)

Method Summary

Modifier and Type	Method	Description
void	execute(SqlQueryPlus queryPlus, long maxRowCount)
org.apache.calcite.avatica.Meta.Signature	getSignature()

Methods inherited from class org.apache.druid.sql.avatica.AbstractDruidJdbcStatement

close, closeResultSet, createColumnMetaData, createSignature, getConnectionId, getCurrentOffset, getSqlQuery, getStatementId, isDone, nextFrame, requireResultSet

Methods inherited from class java.lang.Object

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

Field Details

queryContext

protected final Map<String,Object> queryContext

defaultContext

protected final Map<String,Object> defaultContext

Constructor Details

DruidJdbcStatement

public DruidJdbcStatement(String connectionId,
 int statementId,
 Map<String,Object> queryContext,
 Map<String,Object> defaultContext,
 SqlStatementFactory lifecycleFactory,
 DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)

Method Details

execute

public void execute(SqlQueryPlus queryPlus,
 long maxRowCount)

getSignature

public org.apache.calcite.avatica.Meta.Signature getSignature()

Specified by:

getSignature in class AbstractDruidJdbcStatement