org.apache.arrow.driver.jdbc

Class ArrowFlightJdbcFactory

java.lang.Object

org.apache.arrow.driver.jdbc.ArrowFlightJdbcFactory

All Implemented Interfaces:

org.apache.calcite.avatica.AvaticaFactory

public class ArrowFlightJdbcFactory
extends Object
implements org.apache.calcite.avatica.AvaticaFactory

Factory for the Arrow Flight JDBC Driver.

Constructor Summary

Constructors

Constructor and Description
ArrowFlightJdbcFactory()

Method Summary

Modifier and Type	Method and Description
int	getJdbcMajorVersion()
int	getJdbcMinorVersion()
org.apache.calcite.avatica.AvaticaConnection	newConnection(org.apache.calcite.avatica.UnregisteredDriver driver, org.apache.calcite.avatica.AvaticaFactory factory, String url, Properties info)
org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData	newDatabaseMetaData(org.apache.calcite.avatica.AvaticaConnection connection)
ArrowFlightPreparedStatement	newPreparedStatement(org.apache.calcite.avatica.AvaticaConnection connection, org.apache.calcite.avatica.Meta.StatementHandle statementHandle, org.apache.calcite.avatica.Meta.Signature signature, int resultType, int resultSetConcurrency, int resultSetHoldability)
ArrowFlightJdbcVectorSchemaRootResultSet	newResultSet(org.apache.calcite.avatica.AvaticaStatement statement, org.apache.calcite.avatica.QueryState state, org.apache.calcite.avatica.Meta.Signature signature, TimeZone timeZone, org.apache.calcite.avatica.Meta.Frame frame)
ResultSetMetaData	newResultSetMetaData(org.apache.calcite.avatica.AvaticaStatement avaticaStatement, org.apache.calcite.avatica.Meta.Signature signature)
org.apache.calcite.avatica.AvaticaStatement	newStatement(org.apache.calcite.avatica.AvaticaConnection connection, org.apache.calcite.avatica.Meta.StatementHandle handle, int resultType, int resultSetConcurrency, int resultSetHoldability)

Methods inherited from class java.lang.Object

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

Constructor Detail

ArrowFlightJdbcFactory

public ArrowFlightJdbcFactory()

Method Detail

newConnection

public org.apache.calcite.avatica.AvaticaConnection newConnection(org.apache.calcite.avatica.UnregisteredDriver driver,
                                                                  org.apache.calcite.avatica.AvaticaFactory factory,
                                                                  String url,
                                                                  Properties info)
                                                           throws SQLException

Specified by:

newConnection in interface org.apache.calcite.avatica.AvaticaFactory

Throws:

SQLException

newStatement

public org.apache.calcite.avatica.AvaticaStatement newStatement(org.apache.calcite.avatica.AvaticaConnection connection,
                                                                org.apache.calcite.avatica.Meta.StatementHandle handle,
                                                                int resultType,
                                                                int resultSetConcurrency,
                                                                int resultSetHoldability)

Specified by:

newStatement in interface org.apache.calcite.avatica.AvaticaFactory

newPreparedStatement

public ArrowFlightPreparedStatement newPreparedStatement(org.apache.calcite.avatica.AvaticaConnection connection,
                                                         org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                         org.apache.calcite.avatica.Meta.Signature signature,
                                                         int resultType,
                                                         int resultSetConcurrency,
                                                         int resultSetHoldability)
                                                  throws SQLException

Specified by:

newPreparedStatement in interface org.apache.calcite.avatica.AvaticaFactory

Throws:

SQLException

newResultSet

public ArrowFlightJdbcVectorSchemaRootResultSet newResultSet(org.apache.calcite.avatica.AvaticaStatement statement,
                                                             org.apache.calcite.avatica.QueryState state,
                                                             org.apache.calcite.avatica.Meta.Signature signature,
                                                             TimeZone timeZone,
                                                             org.apache.calcite.avatica.Meta.Frame frame)
                                                      throws SQLException

Specified by:

newResultSet in interface org.apache.calcite.avatica.AvaticaFactory

Throws:

SQLException

newDatabaseMetaData

public org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData newDatabaseMetaData(org.apache.calcite.avatica.AvaticaConnection connection)

Specified by:

newDatabaseMetaData in interface org.apache.calcite.avatica.AvaticaFactory

newResultSetMetaData

public ResultSetMetaData newResultSetMetaData(org.apache.calcite.avatica.AvaticaStatement avaticaStatement,
                                              org.apache.calcite.avatica.Meta.Signature signature)

Specified by:

newResultSetMetaData in interface org.apache.calcite.avatica.AvaticaFactory

getJdbcMajorVersion

public int getJdbcMajorVersion()

Specified by:

getJdbcMajorVersion in interface org.apache.calcite.avatica.AvaticaFactory

getJdbcMinorVersion

public int getJdbcMinorVersion()

Specified by:

getJdbcMinorVersion in interface org.apache.calcite.avatica.AvaticaFactory