Package org.apache.druid.sql.avatica

Class AbstractDruidJdbcStatement

java.lang.Object

org.apache.druid.sql.avatica.AbstractDruidJdbcStatement

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

DruidJdbcPreparedStatement, DruidJdbcStatement

public abstract class AbstractDruidJdbcStatement
extends Object
implements Closeable

Common implementation for the JDBC Statement and PreparedStatement implementations in Druid. Statement use DruidJdbcResultSet objects to iterate through rows: zero or one may be open at any time, and a single statement supports multiple result sets concurrently. Druid closes the result set after the last batch in compliance with this note on page 137 of the JDBC 4.1 specification:

Some JDBC driver implementations may also implicitly close the ResultSet when the ResultSet type is TYPE_FORWARD_ONLY and the next method of ResultSet returns false.

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	connectionId
protected final DruidJdbcResultSet.ResultFetcherFactory	fetcherFactory
protected DruidJdbcResultSet	resultSet
protected SqlQueryPlus	sqlQuery
static final long	START_OFFSET
protected final int	statementId
protected Throwable	throwable

Constructor Summary

Constructors

Constructor	Description
AbstractDruidJdbcStatement(String connectionId, int statementId, DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)

Method Summary

Modifier and Type	Method	Description
void	close()
void	closeResultSet()
static List<org.apache.calcite.avatica.ColumnMetaData>	createColumnMetaData(org.apache.calcite.rel.type.RelDataType rowType)
protected static org.apache.calcite.avatica.Meta.Signature	createSignature(PrepareResult prepareResult, String sql)
String	getConnectionId()
long	getCurrentOffset()
abstract org.apache.calcite.avatica.Meta.Signature	getSignature()
SqlQueryPlus	getSqlQuery()
int	getStatementId()
boolean	isDone()
org.apache.calcite.avatica.Meta.Frame	nextFrame(long fetchOffset, int fetchMaxRowCount)
protected DruidJdbcResultSet	requireResultSet()

Methods inherited from class java.lang.Object

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

Field Details

START_OFFSET

public static final long START_OFFSET

See Also:

• Constant Field Values

connectionId

protected final String connectionId

statementId

protected final int statementId

fetcherFactory

protected final DruidJdbcResultSet.ResultFetcherFactory fetcherFactory

throwable

protected Throwable throwable

resultSet

protected DruidJdbcResultSet resultSet

sqlQuery

protected SqlQueryPlus sqlQuery

Constructor Details

AbstractDruidJdbcStatement

public AbstractDruidJdbcStatement(String connectionId,
 int statementId,
 DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)

Method Details

createSignature

protected static org.apache.calcite.avatica.Meta.Signature createSignature(PrepareResult prepareResult,
 String sql)

createColumnMetaData

public static List<org.apache.calcite.avatica.ColumnMetaData> createColumnMetaData(org.apache.calcite.rel.type.RelDataType rowType)

nextFrame

public org.apache.calcite.avatica.Meta.Frame nextFrame(long fetchOffset,
 int fetchMaxRowCount)

getSignature

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

closeResultSet

public void closeResultSet()

requireResultSet

protected DruidJdbcResultSet requireResultSet()

getCurrentOffset

public long getCurrentOffset()

isDone

public boolean isDone()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getConnectionId

public String getConnectionId()

getStatementId

public int getStatementId()

getSqlQuery

public SqlQueryPlus getSqlQuery()