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.

Field Summary

Fields

Modifier and Type	Field and Description
protected QueryContext	queryContext

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

connectionId, resultSet, START_OFFSET, statementId, throwable

Constructor Summary

Constructors

Constructor and Description
DruidJdbcStatement(String connectionId, int statementId, QueryContext queryContext, SqlStatementFactory lifecycleFactory)

Method Summary

Modifier and Type	Method and 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, getStatementId, isDone, nextFrame, requireResultSet

Methods inherited from class java.lang.Object

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

Field Detail

queryContext

protected final QueryContext queryContext

Constructor Detail

DruidJdbcStatement

public DruidJdbcStatement(String connectionId,
                          int statementId,
                          QueryContext queryContext,
                          SqlStatementFactory lifecycleFactory)

Method Detail

execute

public void execute(SqlQueryPlus queryPlus,
                    long maxRowCount)

getSignature

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

Specified by:

getSignature in class AbstractDruidJdbcStatement