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

Class FlightSqlClientWithCallOptions

java.lang.Object

org.apache.arrow.adbc.driver.flightsql.FlightSqlClientWithCallOptions

All Implemented Interfaces:

AutoCloseable

public class FlightSqlClientWithCallOptions
extends Object
implements AutoCloseable

A wrapper around FlightSqlClient which automatically adds CallOptions to each RPC call.

Constructor Summary

Constructors

Constructor	Description
FlightSqlClientWithCallOptions(FlightSqlClient client, CallOption... options)

Method Summary

Modifier and Type	Method	Description
FlightSqlClient.Savepoint	beginSavepoint(FlightSqlClient.Transaction transaction, String name, CallOption... options)
FlightSqlClient.Transaction	beginTransaction(CallOption... options)
CancelFlightInfoResult	cancelFlightInfo(CancelFlightInfoRequest request, CallOption... options)
CancelResult	cancelQuery(FlightInfo info, CallOption... options)
void	close()
void	commit(FlightSqlClient.Transaction transaction, CallOption... options)
FlightInfo	execute(String query, CallOption... options)
FlightInfo	execute(String query, FlightSqlClient.Transaction transaction, CallOption... options)
FlightInfo	executeSubstrait(FlightSqlClient.SubstraitPlan plan, CallOption... options)
FlightInfo	executeSubstrait(FlightSqlClient.SubstraitPlan plan, FlightSqlClient.Transaction transaction, CallOption... options)
long	executeSubstraitUpdate(FlightSqlClient.SubstraitPlan plan, CallOption... options)
long	executeSubstraitUpdate(FlightSqlClient.SubstraitPlan plan, FlightSqlClient.Transaction transaction, CallOption... options)
long	executeUpdate(String query, CallOption... options)
long	executeUpdate(String query, FlightSqlClient.Transaction transaction, CallOption... options)
FlightInfo	getCatalogs(CallOption... options)
SchemaResult	getCatalogsSchema(CallOption... options)
FlightInfo	getCrossReference(TableRef pkTableRef, TableRef fkTableRef, CallOption... options)
SchemaResult	getCrossReferenceSchema(CallOption... options)
SchemaResult	getExecuteSchema(String query, CallOption... options)
SchemaResult	getExecuteSchema(String query, FlightSqlClient.Transaction transaction, CallOption... options)
SchemaResult	getExecuteSubstraitSchema(FlightSqlClient.SubstraitPlan substraitPlan, CallOption... options)
SchemaResult	getExecuteSubstraitSchema(FlightSqlClient.SubstraitPlan plan, FlightSqlClient.Transaction transaction, CallOption... options)
FlightInfo	getExportedKeys(TableRef tableRef, CallOption... options)
SchemaResult	getExportedKeysSchema(CallOption... options)
FlightInfo	getImportedKeys(TableRef tableRef, CallOption... options)
SchemaResult	getImportedKeysSchema(CallOption... options)
FlightInfo	getPrimaryKeys(TableRef tableRef, CallOption... options)
SchemaResult	getPrimaryKeysSchema(CallOption... options)
SchemaResult	getSchema(FlightDescriptor descriptor, CallOption... options)
FlightInfo	getSchemas(String catalog, String dbSchemaFilterPattern, CallOption... options)
SchemaResult	getSchemasSchema(CallOption... options)
FlightInfo	getSqlInfo(int[] info, CallOption... options)
FlightInfo	getSqlInfo(Iterable<Integer> info, CallOption... options)
FlightInfo	getSqlInfo(FlightSql.SqlInfo... info)
FlightInfo	getSqlInfo(FlightSql.SqlInfo[] info, CallOption... options)
SchemaResult	getSqlInfoSchema(CallOption... options)
FlightStream	getStream(Ticket ticket, CallOption... options)
FlightInfo	getTables(String catalog, String dbSchemaFilterPattern, String tableFilterPattern, @Nullable List<String> tableTypes, boolean includeSchema, CallOption... options)
SchemaResult	getTablesSchema(boolean includeSchema, CallOption... options)
FlightInfo	getTableTypes(CallOption... options)
SchemaResult	getTableTypesSchema(CallOption... options)
FlightInfo	getXdbcTypeInfo(int dataType, CallOption... options)
FlightInfo	getXdbcTypeInfo(CallOption... options)
SchemaResult	getXdbcTypeInfoSchema(CallOption... options)
FlightSqlClient.PreparedStatement	prepare(String query, CallOption... options)
FlightSqlClient.PreparedStatement	prepare(String query, FlightSqlClient.Transaction transaction, CallOption... options)
FlightSqlClient.PreparedStatement	prepare(FlightSqlClient.SubstraitPlan plan, CallOption... options)
FlightSqlClient.PreparedStatement	prepare(FlightSqlClient.SubstraitPlan plan, FlightSqlClient.Transaction transaction, CallOption... options)
void	release(FlightSqlClient.Savepoint savepoint, CallOption... options)
FlightEndpoint	renewFlightEndpoint(RenewFlightEndpointRequest request, CallOption... options)
void	rollback(FlightSqlClient.Savepoint savepoint, CallOption... options)
void	rollback(FlightSqlClient.Transaction transaction, CallOption... options)

Methods inherited from class java.lang.Object

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

Constructor Details

FlightSqlClientWithCallOptions

public FlightSqlClientWithCallOptions(FlightSqlClient client,
 CallOption... options)

Method Details

execute

public FlightInfo execute(String query,
 CallOption... options)

execute

public FlightInfo execute(String query,
 FlightSqlClient.Transaction transaction,
 CallOption... options)

executeSubstrait

public FlightInfo executeSubstrait(FlightSqlClient.SubstraitPlan plan,
 CallOption... options)

executeSubstrait

public FlightInfo executeSubstrait(FlightSqlClient.SubstraitPlan plan,
 FlightSqlClient.Transaction transaction,
 CallOption... options)

getExecuteSchema

public SchemaResult getExecuteSchema(String query,
 FlightSqlClient.Transaction transaction,
 CallOption... options)

getExecuteSchema

public SchemaResult getExecuteSchema(String query,
 CallOption... options)

getExecuteSubstraitSchema

public SchemaResult getExecuteSubstraitSchema(FlightSqlClient.SubstraitPlan plan,
 FlightSqlClient.Transaction transaction,
 CallOption... options)

getExecuteSubstraitSchema

public SchemaResult getExecuteSubstraitSchema(FlightSqlClient.SubstraitPlan substraitPlan,
 CallOption... options)

executeUpdate

public long executeUpdate(String query,
 CallOption... options)

executeUpdate

public long executeUpdate(String query,
 FlightSqlClient.Transaction transaction,
 CallOption... options)

executeSubstraitUpdate

public long executeSubstraitUpdate(FlightSqlClient.SubstraitPlan plan,
 CallOption... options)

executeSubstraitUpdate

public long executeSubstraitUpdate(FlightSqlClient.SubstraitPlan plan,
 FlightSqlClient.Transaction transaction,
 CallOption... options)

getCatalogs

public FlightInfo getCatalogs(CallOption... options)

getCatalogsSchema

public SchemaResult getCatalogsSchema(CallOption... options)

getSchemas

public FlightInfo getSchemas(String catalog,
 String dbSchemaFilterPattern,
 CallOption... options)

getSchemasSchema

public SchemaResult getSchemasSchema(CallOption... options)

getSchema

public SchemaResult getSchema(FlightDescriptor descriptor,
 CallOption... options)

getStream

public FlightStream getStream(Ticket ticket,
 CallOption... options)

getSqlInfo

public FlightInfo getSqlInfo(FlightSql.SqlInfo... info)

getSqlInfo

public FlightInfo getSqlInfo(FlightSql.SqlInfo[] info,
 CallOption... options)

getSqlInfo

public FlightInfo getSqlInfo(int[] info,
 CallOption... options)

getSqlInfo

public FlightInfo getSqlInfo(Iterable<Integer> info,
 CallOption... options)

getSqlInfoSchema

public SchemaResult getSqlInfoSchema(CallOption... options)

getXdbcTypeInfo

public FlightInfo getXdbcTypeInfo(int dataType,
 CallOption... options)

getXdbcTypeInfo

public FlightInfo getXdbcTypeInfo(CallOption... options)

getXdbcTypeInfoSchema

public SchemaResult getXdbcTypeInfoSchema(CallOption... options)

getTables

public FlightInfo getTables(String catalog,
 String dbSchemaFilterPattern,
 String tableFilterPattern,
 @Nullable List<String> tableTypes,
 boolean includeSchema,
 CallOption... options)

getTablesSchema

public SchemaResult getTablesSchema(boolean includeSchema,
 CallOption... options)

getPrimaryKeys

public FlightInfo getPrimaryKeys(TableRef tableRef,
 CallOption... options)

getPrimaryKeysSchema

public SchemaResult getPrimaryKeysSchema(CallOption... options)

getExportedKeys

public FlightInfo getExportedKeys(TableRef tableRef,
 CallOption... options)

getExportedKeysSchema

public SchemaResult getExportedKeysSchema(CallOption... options)

getImportedKeys

public FlightInfo getImportedKeys(TableRef tableRef,
 CallOption... options)

getImportedKeysSchema

public SchemaResult getImportedKeysSchema(CallOption... options)

getCrossReference

public FlightInfo getCrossReference(TableRef pkTableRef,
 TableRef fkTableRef,
 CallOption... options)

getCrossReferenceSchema

public SchemaResult getCrossReferenceSchema(CallOption... options)

getTableTypes

public FlightInfo getTableTypes(CallOption... options)

getTableTypesSchema

public SchemaResult getTableTypesSchema(CallOption... options)

prepare

public FlightSqlClient.PreparedStatement prepare(String query,
 CallOption... options)

prepare

public FlightSqlClient.PreparedStatement prepare(String query,
 FlightSqlClient.Transaction transaction,
 CallOption... options)

prepare

public FlightSqlClient.PreparedStatement prepare(FlightSqlClient.SubstraitPlan plan,
 CallOption... options)

prepare

public FlightSqlClient.PreparedStatement prepare(FlightSqlClient.SubstraitPlan plan,
 FlightSqlClient.Transaction transaction,
 CallOption... options)

beginTransaction

public FlightSqlClient.Transaction beginTransaction(CallOption... options)

beginSavepoint

public FlightSqlClient.Savepoint beginSavepoint(FlightSqlClient.Transaction transaction,
 String name,
 CallOption... options)

commit

public void commit(FlightSqlClient.Transaction transaction,
 CallOption... options)

release

public void release(FlightSqlClient.Savepoint savepoint,
 CallOption... options)

rollback

public void rollback(FlightSqlClient.Transaction transaction,
 CallOption... options)

rollback

public void rollback(FlightSqlClient.Savepoint savepoint,
 CallOption... options)

cancelFlightInfo

public CancelFlightInfoResult cancelFlightInfo(CancelFlightInfoRequest request,
 CallOption... options)

cancelQuery

public CancelResult cancelQuery(FlightInfo info,
 CallOption... options)

renewFlightEndpoint

public FlightEndpoint renewFlightEndpoint(RenewFlightEndpointRequest request,
 CallOption... options)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception