Package org.apache.arrow.adbc.driver.flightsql

Class FlightSqlStatement

java.lang.Object

org.apache.arrow.adbc.driver.flightsql.FlightSqlStatement

All Implemented Interfaces:

AutoCloseable, AdbcOptions, AdbcStatement

public class FlightSqlStatement
extends Object
implements AdbcStatement

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.arrow.adbc.core.AdbcStatement

AdbcStatement.PartitionResult, AdbcStatement.QueryResult, AdbcStatement.UpdateResult

Method Summary

Modifier and Type	Method	Description
void	bind(org.apache.arrow.vector.VectorSchemaRoot root)
void	close()
AdbcStatement.PartitionResult	executePartitioned()
AdbcStatement.QueryResult	executeQuery()
org.apache.arrow.vector.types.pojo.Schema	executeSchema()
AdbcStatement.UpdateResult	executeUpdate()
org.apache.arrow.vector.types.pojo.Schema	getParameterSchema()
void	prepare()
void	setSqlQuery(String query)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.arrow.adbc.core.AdbcOptions

getOption, setOption

Methods inherited from interface org.apache.arrow.adbc.core.AdbcStatement

cancel, getMaxProgress, getProgress, pollPartitioned, setOption, setSubstraitPlan

Method Details

setSqlQuery

public void setSqlQuery(String query)
                 throws AdbcException

Specified by:

setSqlQuery in interface AdbcStatement

Throws:

AdbcException

bind

public void bind(org.apache.arrow.vector.VectorSchemaRoot root)

Specified by:

bind in interface AdbcStatement

executePartitioned

public AdbcStatement.PartitionResult executePartitioned()
                                                 throws AdbcException

Specified by:

executePartitioned in interface AdbcStatement

Throws:

AdbcException

executeQuery

public AdbcStatement.QueryResult executeQuery()
                                       throws AdbcException

Specified by:

executeQuery in interface AdbcStatement

Throws:

AdbcException

executeSchema

public org.apache.arrow.vector.types.pojo.Schema executeSchema()
                                                        throws AdbcException

Specified by:

executeSchema in interface AdbcStatement

Throws:

AdbcException

executeUpdate

public AdbcStatement.UpdateResult executeUpdate()
                                         throws AdbcException

Specified by:

executeUpdate in interface AdbcStatement

Throws:

AdbcException

getParameterSchema

public org.apache.arrow.vector.types.pojo.Schema getParameterSchema()
                                                             throws AdbcException

Specified by:

getParameterSchema in interface AdbcStatement

Throws:

AdbcException

prepare

public void prepare()
             throws AdbcException

Specified by:

prepare in interface AdbcStatement

Throws:

AdbcException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception