org.apache.arrow.driver.jdbc

Class ArrowFlightPreparedStatement

java.lang.Object

org.apache.calcite.avatica.AvaticaStatement

org.apache.calcite.avatica.AvaticaPreparedStatement

org.apache.arrow.driver.jdbc.ArrowFlightPreparedStatement

All Implemented Interfaces:

AutoCloseable, ParameterMetaData, PreparedStatement, Statement, Wrapper, ArrowFlightInfoStatement

public class ArrowFlightPreparedStatement
extends org.apache.calcite.avatica.AvaticaPreparedStatement
implements ArrowFlightInfoStatement

Arrow Flight JBCS's implementation PreparedStatement.

Field Summary

Fields inherited from class org.apache.calcite.avatica.AvaticaPreparedStatement

parameterValueBatch, slots

Fields inherited from class org.apache.calcite.avatica.AvaticaStatement

cancelFlag, closed, closeOnCompletion, connection, DEFAULT_FETCH_SIZE, handle, maxRowCount, openResultSet, updateCount

Fields inherited from interface java.sql.Statement

CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO

Fields inherited from interface java.sql.ParameterMetaData

parameterModeIn, parameterModeInOut, parameterModeOut, parameterModeUnknown, parameterNoNulls, parameterNullable, parameterNullableUnknown

Method Summary

Modifier and Type	Method and Description
void	close()
FlightInfo	executeFlightInfoQuery() Executes the query this Statement is holding.
ArrowFlightConnection	getConnection()

Methods inherited from class org.apache.calcite.avatica.AvaticaPreparedStatement

addBatch, clearBatch, clearParameters, copyParameterValues, execute, executeBatch, executeLargeBatch, executeLargeUpdate, executeQuery, executeUpdate, getCalendar, getMetaData, getParameter, getParameterClassName, getParameterCount, getParameterMetaData, getParameterMode, getParameterType, getParameterTypeName, getParameterValueBatch, getParameterValues, getPrecision, getScale, getSite, isNullable, isSigned, setArray, setAsciiStream, setAsciiStream, setAsciiStream, setBigDecimal, setBinaryStream, setBinaryStream, setBinaryStream, setBlob, setBlob, setBlob, setBoolean, setByte, setBytes, setCharacterStream, setCharacterStream, setCharacterStream, setClob, setClob, setClob, setDate, setDate, setDouble, setFloat, setInt, setLong, setNCharacterStream, setNCharacterStream, setNClob, setNClob, setNClob, setNString, setNull, setNull, setObject, setObject, setObject, setRef, setRowId, setShort, setSQLXML, setString, setTime, setTime, setTimestamp, setTimestamp, setUnicodeStream, setURL

Methods inherited from class org.apache.calcite.avatica.AvaticaStatement

addBatch, cancel, checkOpen, clearWarnings, close_, closeOnCompletion, execute, execute, execute, execute, executeBatchInternal, executeInternal, executeInternal, executeLargeUpdate, executeQuery, executeQueryInternal, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getBoundParameterValues, getFetchDirection, getFetchSize, getGeneratedKeys, getId, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getSignature, getStatementType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, isWrapperFor, resetStatement, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout, setSignature, syncResults, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Statement

addBatch, cancel, clearBatch, clearWarnings, closeOnCompletion, execute, execute, execute, execute, executeBatch, executeLargeBatch, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, executeQuery, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getFetchDirection, getFetchSize, getGeneratedKeys, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Methods inherited from interface java.sql.PreparedStatement

setObject, setObject

Method Detail

getConnection

public ArrowFlightConnection getConnection()
                                    throws SQLException

Specified by:

getConnection in interface Statement

Specified by:

getConnection in interface ArrowFlightInfoStatement

Overrides:

getConnection in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

close

public void close()
           throws SQLException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Statement

Overrides:

close in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

executeFlightInfoQuery

public FlightInfo executeFlightInfoQuery()
                                  throws SQLException

Description copied from interface: ArrowFlightInfoStatement

Executes the query this Statement is holding.

Specified by:

executeFlightInfoQuery in interface ArrowFlightInfoStatement

Returns:

the FlightInfo for the results.

Throws:

SQLException - on error.