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

Class FlightSqlConnection

java.lang.Object

org.apache.arrow.adbc.driver.flightsql.FlightSqlConnection

All Implemented Interfaces:

AutoCloseable, AdbcConnection, AdbcOptions

public class FlightSqlConnection
extends Object
implements AdbcConnection

Nested Class Summary

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

AdbcConnection.GetObjectsDepth

Method Summary

Modifier and Type	Method	Description
AdbcStatement	bulkIngest(String targetTableName, BulkIngestMode mode)
void	close()
void	commit()
AdbcStatement	createStatement()
boolean	getAutoCommit()
org.apache.arrow.vector.ipc.ArrowReader	getInfo(int @Nullable [] infoCodes)
org.apache.arrow.vector.ipc.ArrowReader	getObjects(AdbcConnection.GetObjectsDepth depth, String catalogPattern, String dbSchemaPattern, String tableNamePattern, String[] tableTypes, String columnNamePattern)
org.apache.arrow.vector.ipc.ArrowReader	readPartition(ByteBuffer descriptor)
void	rollback()
void	setAutoCommit(boolean enableAutoCommit)
String	toString()

Methods inherited from class java.lang.Object

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

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

cancel, getCurrentCatalog, getCurrentDbSchema, getInfo, getInfo, getIsolationLevel, getReadOnly, getStatisticNames, getStatistics, getTableSchema, getTableTypes, setCurrentCatalog, setCurrentDbSchema, setIsolationLevel, setReadOnly

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

getOption, setOption

Method Details

commit

public void commit()
            throws AdbcException

Specified by:

commit in interface AdbcConnection

Throws:

AdbcException

createStatement

public AdbcStatement createStatement()
                              throws AdbcException

Specified by:

createStatement in interface AdbcConnection

Throws:

AdbcException

readPartition

public org.apache.arrow.vector.ipc.ArrowReader readPartition(ByteBuffer descriptor)
                                                      throws AdbcException

Specified by:

readPartition in interface AdbcConnection

Throws:

AdbcException

bulkIngest

public AdbcStatement bulkIngest(String targetTableName,
 BulkIngestMode mode)
                         throws AdbcException

Specified by:

bulkIngest in interface AdbcConnection

Throws:

AdbcException

getObjects

public org.apache.arrow.vector.ipc.ArrowReader getObjects(AdbcConnection.GetObjectsDepth depth,
 String catalogPattern,
 String dbSchemaPattern,
 String tableNamePattern,
 String[] tableTypes,
 String columnNamePattern)
                                                   throws AdbcException

Specified by:

getObjects in interface AdbcConnection

Throws:

AdbcException

getInfo

public org.apache.arrow.vector.ipc.ArrowReader getInfo(int @Nullable [] infoCodes)
                                                throws AdbcException

Specified by:

getInfo in interface AdbcConnection

Throws:

AdbcException

rollback

public void rollback()
              throws AdbcException

Specified by:

rollback in interface AdbcConnection

Throws:

AdbcException

getAutoCommit

public boolean getAutoCommit()
                      throws AdbcException

Specified by:

getAutoCommit in interface AdbcConnection

Throws:

AdbcException

setAutoCommit

public void setAutoCommit(boolean enableAutoCommit)
                   throws AdbcException

Specified by:

setAutoCommit in interface AdbcConnection

Throws:

AdbcException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object