Package 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
-
Method Summary
Modifier and TypeMethodDescriptionint
int
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) 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) 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) 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)
-
Constructor Details
-
ArrowFlightJdbcFactory
public ArrowFlightJdbcFactory()
-
-
Method Details
-
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 interfaceorg.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 interfaceorg.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 interfaceorg.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 interfaceorg.apache.calcite.avatica.AvaticaFactory
- Throws:
SQLException
-
newDatabaseMetaData
public org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData newDatabaseMetaData(org.apache.calcite.avatica.AvaticaConnection connection) - Specified by:
newDatabaseMetaData
in interfaceorg.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 interfaceorg.apache.calcite.avatica.AvaticaFactory
-
getJdbcMajorVersion
public int getJdbcMajorVersion()- Specified by:
getJdbcMajorVersion
in interfaceorg.apache.calcite.avatica.AvaticaFactory
-
getJdbcMinorVersion
public int getJdbcMinorVersion()- Specified by:
getJdbcMinorVersion
in interfaceorg.apache.calcite.avatica.AvaticaFactory
-