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, resultSet, START_OFFSET, statementId, throwable

Constructor Summary

Constructors

Constructor and Description
DruidJdbcPreparedStatement(String connectionId, int statementId, PreparedStatement stmt, long maxRowCount)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

DruidJdbcPreparedStatement

public DruidJdbcPreparedStatement(String connectionId,
                                  int statementId,
                                  PreparedStatement stmt,
                                  long maxRowCount)

Method Detail

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 Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractDruidJdbcStatement