包 org.apache.arrow.adbc.driver.flightsql

类 FlightSqlClientWithCallOptions

java.lang.Object

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

所有已实现的接口

AutoCloseable

public class FlightSqlClientWithCallOptions extends Object implements AutoCloseable

FlightSqlClient 的一个包装器，它自动将 CallOptions 添加到每个 RPC 调用。

构造函数摘要

构造函数

构造函数	描述
FlightSqlClientWithCallOptions(FlightSqlClient client, CallOption... options)

方法摘要

修饰符和类型	方法	描述
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)

继承自类 java.lang.Object 的方法

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

构造器详细信息

FlightSqlClientWithCallOptions

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

方法详情

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