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 and Description
protected String	connectionId
protected DruidJdbcResultSet	resultSet
static long	START_OFFSET
protected int	statementId
protected Throwable	throwable

Constructor Summary

Constructors

Constructor and Description
AbstractDruidJdbcStatement(String connectionId, int statementId)

Method Summary

Modifier and Type	Method and 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()
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 Detail

START_OFFSET

public static final long START_OFFSET

See Also:

Constant Field Values

connectionId

protected final String connectionId

statementId

protected final int statementId

throwable

protected Throwable throwable

resultSet

protected DruidJdbcResultSet resultSet

Constructor Detail

AbstractDruidJdbcStatement

public AbstractDruidJdbcStatement(String connectionId,
                                  int statementId)

Method Detail

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 Closeable

Specified by:

close in interface AutoCloseable

getConnectionId

public String getConnectionId()

getStatementId

public int getStatementId()