org.apache.arrow.driver.jdbc

Class ArrowFlightStatement

java.lang.Object

org.apache.calcite.avatica.AvaticaStatement

org.apache.arrow.driver.jdbc.ArrowFlightStatement

All Implemented Interfaces:

AutoCloseable, Statement, Wrapper, ArrowFlightInfoStatement

public class ArrowFlightStatement
extends org.apache.calcite.avatica.AvaticaStatement
implements ArrowFlightInfoStatement

A SQL statement for querying data from an Arrow Flight server.

Field Summary

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

Method Summary

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

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

addBatch, cancel, checkOpen, clearBatch, clearWarnings, close_, close, closeOnCompletion, execute, execute, execute, execute, executeBatch, executeBatchInternal, executeInternal, executeInternal, executeLargeBatch, executeLargeUpdate, executeQuery, executeQueryInternal, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getBoundParameterValues, getFetchDirection, getFetchSize, getGeneratedKeys, getId, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getParameterValues, 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, close, 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

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

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.