Package org.apache.druid.sql.avatica

Class DruidJdbcPreparedStatement

java.lang.Object

org.apache.druid.sql.avatica.AbstractDruidJdbcStatement

org.apache.druid.sql.avatica.DruidJdbcPreparedStatement

All Implemented Interfaces:

Closeable, AutoCloseable

public class DruidJdbcPreparedStatement
extends AbstractDruidJdbcStatement

The Druid implementation of the server-side representation of the JDBC PreparedStatement class. A prepared statement can be prepared once with a query, then executed any number of times, typically with parameter values. No parameters are provided during prepare, though we do learn the parameter definitions passed back to the client and used by Avatica for serialization. Each execution produces a DruidJdbcResultSet. Only one execution is active at a time.

Field Summary

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

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

Constructor Summary

Constructors

Constructor	Description
DruidJdbcPreparedStatement(String connectionId, int statementId, PreparedStatement stmt, long maxRowCount, DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)

Method Summary

Modifier and Type	Method	Description
void	close()
void	execute(List<org.apache.calcite.avatica.remote.TypedValue> parameters)
org.apache.calcite.avatica.Meta.Signature	getSignature()
void	prepare()

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

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

Constructor Details

DruidJdbcPreparedStatement

public DruidJdbcPreparedStatement(String connectionId,
 int statementId,
 PreparedStatement stmt,
 long maxRowCount,
 DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)

Method Details

prepare

public void prepare()

getSignature

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

Specified by:

getSignature in class AbstractDruidJdbcStatement

execute

public void execute(List<org.apache.calcite.avatica.remote.TypedValue> parameters)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class AbstractDruidJdbcStatement