Package org.apache.arrow.adbc.driver.jdbc

Class JdbcConnection

java.lang.Object

org.apache.arrow.adbc.driver.jdbc.JdbcConnection

All Implemented Interfaces:

AutoCloseable, AdbcConnection, AdbcOptions

public class JdbcConnection
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()
String	getCurrentCatalog()
String	getCurrentDbSchema()
org.apache.arrow.vector.ipc.ArrowReader	getInfo(int @Nullable [] infoCodes)
IsolationLevel	getIsolationLevel()
org.apache.arrow.vector.ipc.ArrowReader	getObjects(AdbcConnection.GetObjectsDepth depth, String catalogPattern, String dbSchemaPattern, String tableNamePattern, String[] tableTypes, String columnNamePattern)
boolean	getReadOnly()
org.apache.arrow.vector.ipc.ArrowReader	getStatisticNames()
org.apache.arrow.vector.ipc.ArrowReader	getStatistics(String catalogPattern, String dbSchemaPattern, String tableNamePattern, boolean approximate)
org.apache.arrow.vector.types.pojo.Schema	getTableSchema(String catalog, String dbSchema, String tableName)
org.apache.arrow.vector.ipc.ArrowReader	getTableTypes()
void	rollback()
void	setAutoCommit(boolean enableAutoCommit)
void	setCurrentCatalog(String catalog)
void	setCurrentDbSchema(String dbSchema)
void	setIsolationLevel(IsolationLevel level)
void	setReadOnly(boolean isReadOnly)
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, getInfo, getInfo, readPartition

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

getOption, setOption

Method Detail

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

bulkIngest

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

Specified by:

bulkIngest 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

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

getStatistics

public org.apache.arrow.vector.ipc.ArrowReader getStatistics(String catalogPattern,
                                                             String dbSchemaPattern,
                                                             String tableNamePattern,
                                                             boolean approximate)
                                                      throws AdbcException

Specified by:

getStatistics in interface AdbcConnection

Throws:

AdbcException

getStatisticNames

public org.apache.arrow.vector.ipc.ArrowReader getStatisticNames()
                                                          throws AdbcException

Specified by:

getStatisticNames in interface AdbcConnection

Throws:

AdbcException

getTableSchema

public org.apache.arrow.vector.types.pojo.Schema getTableSchema(String catalog,
                                                                String dbSchema,
                                                                String tableName)
                                                         throws AdbcException

Specified by:

getTableSchema in interface AdbcConnection

Throws:

AdbcException

getTableTypes

public org.apache.arrow.vector.ipc.ArrowReader getTableTypes()
                                                      throws AdbcException

Specified by:

getTableTypes 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

getCurrentCatalog

public String getCurrentCatalog()
                         throws AdbcException

Specified by:

getCurrentCatalog in interface AdbcConnection

Throws:

AdbcException

setCurrentCatalog

public void setCurrentCatalog(String catalog)
                       throws AdbcException

Specified by:

setCurrentCatalog in interface AdbcConnection

Throws:

AdbcException

getCurrentDbSchema

public String getCurrentDbSchema()
                          throws AdbcException

Specified by:

getCurrentDbSchema in interface AdbcConnection

Throws:

AdbcException

setCurrentDbSchema

public void setCurrentDbSchema(String dbSchema)
                        throws AdbcException

Specified by:

setCurrentDbSchema in interface AdbcConnection

Throws:

AdbcException

getReadOnly

public boolean getReadOnly()
                    throws AdbcException

Specified by:

getReadOnly in interface AdbcConnection

Throws:

AdbcException

setReadOnly

public void setReadOnly(boolean isReadOnly)
                 throws AdbcException

Specified by:

setReadOnly in interface AdbcConnection

Throws:

AdbcException

getIsolationLevel

public IsolationLevel getIsolationLevel()
                                 throws AdbcException

Specified by:

getIsolationLevel in interface AdbcConnection

Throws:

AdbcException

setIsolationLevel

public void setIsolationLevel(IsolationLevel level)
                       throws AdbcException

Specified by:

setIsolationLevel 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