Uses of Class
org.apache.arrow.adbc.core.AdbcException

Packages that use AdbcException

Package	Description
org.apache.arrow.adbc.core	ADBC (Arrow Database Connectivity) is an API standard for Arrow-based database access.
org.apache.arrow.adbc.driver.flightsql
org.apache.arrow.adbc.driver.jdbc
org.apache.arrow.adbc.driver.jni
org.apache.arrow.adbc.driver.jni.impl
org.apache.arrow.adbc.driver.testsuite
org.apache.arrow.adbc.drivermanager

Uses of AdbcException in org.apache.arrow.adbc.core

Methods in org.apache.arrow.adbc.core that return AdbcException

Modifier and Type	Method	Description
static AdbcException	AdbcException.internal(String message)	Create a new exception with code AdbcStatusCode.INTERNAL.
static AdbcException	AdbcException.invalidArgument(String message)	Create a new exception with code AdbcStatusCode.INVALID_ARGUMENT.
static AdbcException	AdbcException.invalidState(String message)	Create a new exception with code AdbcStatusCode.INVALID_STATE.
static AdbcException	AdbcException.io(String message)	Create a new exception with code AdbcStatusCode.IO.
static AdbcException	AdbcException.notImplemented(String message)	Create a new exception with code AdbcStatusCode.NOT_IMPLEMENTED.
AdbcException	AdbcException.withCause(Throwable cause)	Copy this exception with a different cause (a convenience for use with the static factories).
AdbcException	AdbcException.withDetails(Collection<ErrorDetail> details)	Copy this exception with different details (a convenience for use with the static factories).

Methods in org.apache.arrow.adbc.core that throw AdbcException

Modifier and Type	Method	Description
BulkIngestBuilder	BulkIngestBuilder.appendMode()	Append to the target table; fail if not found.
default void	AdbcStatement.bind(ArrowReader reader)	Bind an ArrowReader to provide parameter values/bulk data ingestion.
default void	AdbcStatement.bind(VectorSchemaRoot root)	Bind a VectorSchemaRoot to provide parameter values/bulk data ingestion.
BulkIngestBuilder	BulkIngestBuilder.bind(ArrowReader stream)	Ingest data from the given reader.
BulkIngestBuilder	BulkIngestBuilder.bind(VectorSchemaRoot root)	Ingest data from the given root.
default AdbcStatement	AdbcConnection.bulkIngest(String targetTableName, BulkIngestMode mode)	Create a new statement to bulk ingest Arrow data into a table.
default AdbcStatement	AdbcConnection.bulkIngest(String targetTableName, BulkIngestMode mode, IngestOption... options)	Create a new statement to bulk ingest Arrow data into a table.
default void	AdbcConnection.cancel()	Cancel execution of a query.
default void	AdbcStatement.cancel()	Cancel execution of a query.
void	AdbcConnection.close()
void	AdbcDatabase.close()
void	AdbcStatement.close()
void	BulkIngestBuilder.close()	Clean up any state in this bulk ingest.
default void	AdbcConnection.commit()	Commit the pending transaction.
AdbcConnection	AdbcDatabase.connect()	Create a new connection to the database.
BulkIngestBuilder	BulkIngestBuilder.createAppendMode()	Create the target table if necessary, append if already exists.
BulkIngestBuilder	BulkIngestBuilder.createMode()	Create the target table; fail if already exists.
AdbcStatement	AdbcConnection.createStatement()	Create a new statement that can be executed.
default AdbcStatement.PartitionResult	AdbcStatement.executePartitioned()	Execute a result set-generating query and get a list of partitions of the result set.
AdbcStatement.QueryResult	AdbcStatement.executeQuery()	Execute a result set-generating query and get the result.
default Schema	AdbcStatement.executeSchema()	Get the schema of the result set without executing the query.
AdbcStatement.UpdateResult	AdbcStatement.executeUpdate()	Execute a query.
default boolean	AdbcConnection.getAutoCommit()	Get the autocommit state.
default String	AdbcConnection.getCurrentCatalog()	Get the current catalog.
default String	AdbcConnection.getCurrentDbSchema()	Get the current schema.
default ArrowReader	AdbcConnection.getInfo()	Get metadata about the driver/database.
ArrowReader	AdbcConnection.getInfo(int @Nullable [] infoCodes)	Get metadata about the driver/database.
default ArrowReader	AdbcConnection.getInfo(AdbcInfoCode[] infoCodes)	Get metadata about the driver/database.
default IsolationLevel	AdbcConnection.getIsolationLevel()	Get the isolation level used by transactions.
default double	AdbcStatement.getMaxProgress()	Get the upper bound of the progress.
default ArrowReader	AdbcConnection.getObjects(AdbcConnection.GetObjectsDepth depth, String catalogPattern, String dbSchemaPattern, String tableNamePattern, String[] tableTypes, String columnNamePattern)	Get a hierarchical view of all catalogs, database schemas, tables, and columns.
default <T> T	AdbcOptions.getOption(TypedKey<T> key)	Get a generic option.
default Schema	AdbcStatement.getParameterSchema()	Get the schema for bound parameters.
default double	AdbcStatement.getProgress()	Get the progress of executing a query.
default boolean	AdbcConnection.getReadOnly()	Get whether the connection is read-only.
default ArrowReader	AdbcConnection.getStatisticNames()	Get the names of additional statistics defined by this driver.
default ArrowReader	AdbcConnection.getStatistics(String catalogPattern, String dbSchemaPattern, String tableNamePattern, boolean approximate)	Get statistics about the data distribution of table(s).
default Schema	AdbcConnection.getTableSchema(String catalog, String dbSchema, String tableName)	Get the Arrow schema of a database table.
default ArrowReader	AdbcConnection.getTableTypes()	Get a list of table types supported by the database.
default AdbcStatement.UpdateResult	BulkIngestBuilder.ingest()	Execute the bulk ingest.
BulkIngestBuilder	BulkIngestBuilder.mode(BulkIngestMode mode)	How to handle an already-existing/non-existent target table.
AdbcDatabase	AdbcDriver.open(Map<String,Object> parameters)	Open a database via this driver.
BulkIngestBuilder	BulkIngestBuilder.option(IngestOption option)	Set an arbitrary ingest option.
<T> BulkIngestBuilder	BulkIngestBuilder.option(TypedKey<T> key, T value)	Set a statement option before ingest.
default Iterator<AdbcStatement.PartitionResult>	AdbcStatement.pollPartitioned()	Execute a result set-generating query and get a list of partitions of the result set.
void	AdbcStatement.prepare()	Turn this statement into a prepared statement.
default ArrowReader	AdbcConnection.readPartition(ByteBuffer descriptor)	Create a result set from a serialized PartitionDescriptor.
BulkIngestBuilder	BulkIngestBuilder.replaceMode()	Drop (if exists) and create the target table.
default void	AdbcConnection.rollback()	Rollback the pending transaction.
default void	AdbcConnection.setAutoCommit(boolean enableAutoCommit)	Toggle whether autocommit is enabled.
default void	AdbcConnection.setCurrentCatalog(String catalog)	Set the current catalog.
default void	AdbcConnection.setCurrentDbSchema(String dbSchema)	Set the current schema.
default void	AdbcConnection.setIsolationLevel(IsolationLevel level)	Change the isolation level used by transactions.
default <T> void	AdbcOptions.setOption(TypedKey<T> key, T value)	Set a generic option.
default void	AdbcStatement.setOption(String key, Object value)	Deprecated. Prefer AdbcOptions.setOption(TypedKey, Object).
default void	AdbcConnection.setReadOnly(boolean isReadOnly)	Toggle whether the connection is read-only.
default void	AdbcStatement.setSqlQuery(String query)	Set a SQL query to be executed on this statement.
default void	AdbcStatement.setSubstraitPlan(ByteBuffer plan)	Set a Substrait plan to be executed on this statement.
BulkIngestBuilder	BulkIngestBuilder.targetCatalog(String catalog)	Ingest into a table in the given catalog.
BulkIngestBuilder	BulkIngestBuilder.targetSchema(String schema)	Ingest into a table in the given schema.
BulkIngestBuilder	BulkIngestBuilder.targetTable(String table)	Ingest into a table with the given name (required).
default BulkIngestBuilder	BulkIngestBuilder.temporary()	Ingest into a temporary table.
BulkIngestBuilder	BulkIngestBuilder.temporary(boolean isTemporary)	Whether to ingest into a temporary table or not.
AdbcStatement	BulkIngestBuilder.toStatement()	Convert this builder to an AdbcStatement (low-level API for further control) without executing.

Uses of AdbcException in org.apache.arrow.adbc.driver.flightsql

Methods in org.apache.arrow.adbc.driver.flightsql that throw AdbcException

Modifier and Type	Method	Description
AdbcStatement	FlightSqlConnection.bulkIngest(String targetTableName, BulkIngestMode mode)
void	FlightSqlConnection.close()
void	FlightSqlDatabase.close()
void	FlightSqlStatement.close()
void	FlightSqlConnection.commit()
AdbcConnection	FlightSqlDatabase.connect()
AdbcStatement	FlightSqlConnection.createStatement()
AdbcStatement.PartitionResult	FlightSqlStatement.executePartitioned()
AdbcStatement.QueryResult	FlightSqlStatement.executeQuery()
Schema	FlightSqlStatement.executeSchema()
AdbcStatement.UpdateResult	FlightSqlStatement.executeUpdate()
boolean	FlightSqlConnection.getAutoCommit()
ArrowReader	FlightSqlConnection.getInfo(int @Nullable [] infoCodes)
ArrowReader	FlightSqlConnection.getObjects(AdbcConnection.GetObjectsDepth depth, String catalogPattern, String dbSchemaPattern, String tableNamePattern, String[] tableTypes, String columnNamePattern)
Schema	FlightSqlStatement.getParameterSchema()
AdbcDatabase	FlightSqlDriver.open(Map<String,Object> parameters)
void	FlightSqlStatement.prepare()
ArrowReader	FlightSqlConnection.readPartition(ByteBuffer descriptor)
void	FlightSqlConnection.rollback()
void	FlightSqlConnection.setAutoCommit(boolean enableAutoCommit)
void	FlightSqlStatement.setSqlQuery(String query)

Uses of AdbcException in org.apache.arrow.adbc.driver.jdbc

Methods in org.apache.arrow.adbc.driver.jdbc that throw AdbcException

Modifier and Type	Method	Description
AdbcStatement	JdbcConnection.bulkIngest(String targetTableName, BulkIngestMode mode)
void	JdbcConnection.close()
void	JdbcDataSourceDatabase.close()
void	JdbcStatement.close()
void	JdbcConnection.commit()
AdbcConnection	JdbcDataSourceDatabase.connect()
AdbcStatement	JdbcConnection.createStatement()
AdbcStatement.QueryResult	JdbcStatement.executeQuery()
Schema	JdbcStatement.executeSchema()
AdbcStatement.UpdateResult	JdbcStatement.executeUpdate()
boolean	JdbcConnection.getAutoCommit()
String	JdbcConnection.getCurrentCatalog()
String	JdbcConnection.getCurrentDbSchema()
ArrowReader	JdbcConnection.getInfo(int @Nullable [] infoCodes)
IsolationLevel	JdbcConnection.getIsolationLevel()
ArrowReader	JdbcConnection.getObjects(AdbcConnection.GetObjectsDepth depth, String catalogPattern, String dbSchemaPattern, String tableNamePattern, String[] tableTypes, String columnNamePattern)
Schema	JdbcStatement.getParameterSchema()
boolean	JdbcConnection.getReadOnly()
ArrowReader	JdbcConnection.getStatisticNames()
ArrowReader	JdbcConnection.getStatistics(String catalogPattern, String dbSchemaPattern, String tableNamePattern, boolean approximate)
Schema	JdbcConnection.getTableSchema(String catalog, String dbSchema, String tableName)
ArrowReader	JdbcConnection.getTableTypes()
AdbcDatabase	JdbcDriver.open(Map<String,Object> parameters)
void	JdbcStatement.prepare()
void	JdbcConnection.rollback()
void	JdbcConnection.setAutoCommit(boolean enableAutoCommit)
void	JdbcConnection.setCurrentCatalog(String catalog)
void	JdbcConnection.setCurrentDbSchema(String dbSchema)
void	JdbcConnection.setIsolationLevel(IsolationLevel level)
void	JdbcConnection.setReadOnly(boolean isReadOnly)
void	JdbcStatement.setSqlQuery(String query)

Uses of AdbcException in org.apache.arrow.adbc.driver.jni

Methods in org.apache.arrow.adbc.driver.jni that throw AdbcException

Modifier and Type	Method	Description
void	JniStatement.bind(ArrowReader reader)
void	JniStatement.bind(VectorSchemaRoot root)
AdbcStatement	JniConnection.bulkIngest(String targetTableName, BulkIngestMode mode)
AdbcStatement	JniConnection.bulkIngest(String targetTableName, BulkIngestMode mode, IngestOption... options)
void	JniConnection.cancel()
void	JniStatement.cancel()
void	JniConnection.close()
void	JniDatabase.close()
void	JniStatement.close()
void	JniConnection.commit()
AdbcConnection	JniDatabase.connect()
AdbcStatement	JniConnection.createStatement()
AdbcStatement.PartitionResult	JniStatement.executePartitioned()
AdbcStatement.QueryResult	JniStatement.executeQuery()
Schema	JniStatement.executeSchema()
AdbcStatement.UpdateResult	JniStatement.executeUpdate()
boolean	JniConnection.getAutoCommit()
String	JniConnection.getCurrentCatalog()
String	JniConnection.getCurrentDbSchema()
ArrowReader	JniConnection.getInfo(int @Nullable [] infoCodes)
IsolationLevel	JniConnection.getIsolationLevel()
double	JniStatement.getMaxProgress()
ArrowReader	JniConnection.getObjects(AdbcConnection.GetObjectsDepth depth, String catalogPattern, String dbSchemaPattern, String tableNamePattern, String[] tableTypes, String columnNamePattern)
<T> T	JniConnection.getOption(TypedKey<T> key)
<T> T	JniDatabase.getOption(TypedKey<T> key)
<T> T	JniStatement.getOption(TypedKey<T> key)
Schema	JniStatement.getParameterSchema()
double	JniStatement.getProgress()
boolean	JniConnection.getReadOnly()
ArrowReader	JniConnection.getStatisticNames()
ArrowReader	JniConnection.getStatistics(String catalogPattern, String dbSchemaPattern, String tableNamePattern, boolean approximate)
Schema	JniConnection.getTableSchema(String catalog, String dbSchema, String tableName)
ArrowReader	JniConnection.getTableTypes()
AdbcDatabase	JniDriver.Builder.open()	Load the driver.
AdbcDatabase	JniDriver.open(Map<String,Object> parameters)
Iterator<AdbcStatement.PartitionResult>	JniStatement.pollPartitioned()
void	JniStatement.prepare()
ArrowReader	JniConnection.readPartition(ByteBuffer descriptor)
void	JniConnection.rollback()
void	JniConnection.setAutoCommit(boolean enableAutoCommit)
void	JniConnection.setCurrentCatalog(String catalog)
void	JniConnection.setCurrentDbSchema(String dbSchema)
void	JniConnection.setIsolationLevel(IsolationLevel level)
<T> void	JniConnection.setOption(TypedKey<T> key, T value)
<T> void	JniDatabase.setOption(TypedKey<T> key, T value)
<T> void	JniStatement.setOption(TypedKey<T> key, T value)
void	JniConnection.setReadOnly(boolean isReadOnly)
void	JniStatement.setSqlQuery(String query)
void	JniStatement.setSubstraitPlan(ByteBuffer plan)

Uses of AdbcException in org.apache.arrow.adbc.driver.jni.impl

Methods in org.apache.arrow.adbc.driver.jni.impl that throw AdbcException

Modifier and Type	Method	Description
void	JniLoader.connectionCancel(NativeConnectionHandle connection)
void	JniLoader.connectionCommit(NativeConnectionHandle connection)
NativeQueryResult	JniLoader.connectionGetInfo(NativeConnectionHandle connection, int[] infoCodes)
NativeQueryResult	JniLoader.connectionGetObjects(NativeConnectionHandle connection, int depth, String catalog, String dbSchema, String tableName, String[] tableTypes, String columnName)
byte[]	JniLoader.connectionGetOptionBytes(NativeConnectionHandle handle, String key)
double	JniLoader.connectionGetOptionDouble(NativeConnectionHandle handle, String key)
long	JniLoader.connectionGetOptionLong(NativeConnectionHandle handle, String key)
String	JniLoader.connectionGetOptionString(NativeConnectionHandle handle, String key)
NativeQueryResult	JniLoader.connectionGetStatisticNames(NativeConnectionHandle connection)
NativeQueryResult	JniLoader.connectionGetStatistics(NativeConnectionHandle connection, String catalogPattern, String dbSchemaPattern, String tableNamePattern, boolean approximate)
NativeSchemaResult	JniLoader.connectionGetTableSchema(NativeConnectionHandle connection, String catalog, String dbSchema, String tableName)
NativeQueryResult	JniLoader.connectionGetTableTypes(NativeConnectionHandle connection)
NativeQueryResult	JniLoader.connectionReadPartition(NativeConnectionHandle connection, ByteBuffer partition)
void	JniLoader.connectionRollback(NativeConnectionHandle connection)
void	JniLoader.connectionSetOptionBytes(NativeConnectionHandle handle, String key, byte[] value)
void	JniLoader.connectionSetOptionDouble(NativeConnectionHandle handle, String key, double value)
void	JniLoader.connectionSetOptionLong(NativeConnectionHandle handle, String key, long value)
void	JniLoader.connectionSetOptionString(NativeConnectionHandle connection, String key, String value)
byte[]	JniLoader.databaseGetOptionBytes(NativeDatabaseHandle handle, String key)
double	JniLoader.databaseGetOptionDouble(NativeDatabaseHandle handle, String key)
long	JniLoader.databaseGetOptionLong(NativeDatabaseHandle handle, String key)
String	JniLoader.databaseGetOptionString(NativeDatabaseHandle handle, String key)
void	JniLoader.databaseSetOptionBytes(NativeDatabaseHandle handle, String key, byte[] value)
void	JniLoader.databaseSetOptionDouble(NativeDatabaseHandle handle, String key, double value)
void	JniLoader.databaseSetOptionLong(NativeDatabaseHandle handle, String key, long value)
void	JniLoader.databaseSetOptionString(NativeDatabaseHandle handle, String key, String value)
NativeConnectionHandle	JniLoader.openConnection(NativeDatabaseHandle database)
NativeDatabaseHandle	JniLoader.openDatabase(Map<String,String> parameters)
NativeStatementHandle	JniLoader.openStatement(NativeConnectionHandle connection)
void	JniLoader.statementBind(NativeStatementHandle statement, ArrowArray batch, ArrowSchema schema)
void	JniLoader.statementBindStream(NativeStatementHandle statement, ArrowArrayStream stream)
void	JniLoader.statementCancel(NativeStatementHandle statement)
NativePartitionResult	JniLoader.statementExecutePartitions(NativeStatementHandle statement)
NativeQueryResult	JniLoader.statementExecuteQuery(NativeStatementHandle statement)
NativeSchemaResult	JniLoader.statementExecuteSchema(NativeStatementHandle statement)
long	JniLoader.statementExecuteUpdate(NativeStatementHandle statement)
byte[]	JniLoader.statementGetOptionBytes(NativeStatementHandle handle, String key)
double	JniLoader.statementGetOptionDouble(NativeStatementHandle handle, String key)
long	JniLoader.statementGetOptionLong(NativeStatementHandle handle, String key)
String	JniLoader.statementGetOptionString(NativeStatementHandle handle, String key)
NativeSchemaResult	JniLoader.statementGetParameterSchema(NativeStatementHandle statement)
void	JniLoader.statementPrepare(NativeStatementHandle statement)
void	JniLoader.statementSetOptionBytes(NativeStatementHandle handle, String key, byte[] value)
void	JniLoader.statementSetOptionDouble(NativeStatementHandle handle, String key, double value)
void	JniLoader.statementSetOptionLong(NativeStatementHandle handle, String key, long value)
void	JniLoader.statementSetOptionString(NativeStatementHandle statement, String key, String value)
void	JniLoader.statementSetSqlQuery(NativeStatementHandle statement, String query)
void	JniLoader.statementSetSubstraitPlan(NativeStatementHandle statement, ByteBuffer plan)

Uses of AdbcException in org.apache.arrow.adbc.driver.testsuite

Methods in org.apache.arrow.adbc.driver.testsuite with parameters of type AdbcException

Modifier and Type	Method	Description
static ArrowAssertions.AdbcExceptionAssert	ArrowAssertions.assertAdbcException(AdbcException actual)	Assert on a AdbcException.

Methods in org.apache.arrow.adbc.driver.testsuite that throw AdbcException

Modifier and Type	Method	Description
abstract AdbcDatabase	SqlValidationQuirks.initDatabase(BufferAllocator allocator)

Uses of AdbcException in org.apache.arrow.adbc.drivermanager

Methods in org.apache.arrow.adbc.drivermanager that throw AdbcException

Modifier and Type	Method	Description
AdbcDatabase	AdbcDriverManager.connect(String driverFactoryName, BufferAllocator allocator, Map<String,Object> parameters)	Connect to a database.