Package org.apache.drill.jdbc.impl

Class DrillConnectionImpl

java.lang.Object

org.apache.calcite.avatica.AvaticaConnection

org.apache.drill.jdbc.impl.DrillConnectionImpl

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper, DrillConnection

public class DrillConnectionImpl
extends org.apache.calcite.avatica.AvaticaConnection
implements DrillConnection

Drill's implementation of Connection.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.calcite.avatica.AvaticaConnection

org.apache.calcite.avatica.AvaticaConnection.CallableWithoutException<T extends Object>, org.apache.calcite.avatica.AvaticaConnection.Trojan

Field Summary

Fields inherited from class org.apache.calcite.avatica.AvaticaConnection

driver, factory, handle, HELPER, id, info, maxRetriesPerExecute, meta, metaData, NUM_EXECUTE_RETRIES_DEFAULT, NUM_EXECUTE_RETRIES_KEY, PLAN_COLUMN_NAME, properties, ROWCOUNT_COLUMN_NAME, statementCount, statementMap, transparentReconnectEnabled

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

Constructors

Constructor	Description
DrillConnectionImpl(DriverImpl driver, org.apache.calcite.avatica.AvaticaFactory factory, String url, Properties info)

Method Summary

Modifier and Type	Method	Description
void	abort(Executor executor)
protected void	checkOpen()	Throws AlreadyClosedSqlException iff this Connection is closed.
void	close()
void	commit()	Drill: Not supported.
Blob	createBlob()
Clob	createClob()
NClob	createNClob()
protected ResultSet	createResultSet(org.apache.calcite.avatica.Meta.MetaResultSet metaResultSet, org.apache.calcite.avatica.QueryState state)
SQLXML	createSQLXML()
DrillStatementImpl	createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)
Struct	createStruct(String typeName, Object[] attributes)
DrillClient	getClient()
DrillConnectionConfig	getConfig()	Returns a view onto this connection's configuration properties.
protected Drillbit	getDrillbit()
int	getNetworkTimeout()	Drill: Returns zero.
String	getSchema()
TimeZone	getTimeZone()
Map<String,Class<?>>	getTypeMap()
boolean	isClosed()
boolean	isValid(int timeout)
String	nativeSQL(String sql)
protected org.apache.calcite.avatica.Meta.ExecuteResult	prepareAndExecuteInternal(org.apache.calcite.avatica.AvaticaStatement statement, String sql, long maxRowCount)
CallableStatement	prepareCall(String sql)
CallableStatement	prepareCall(String sql, int resultSetType, int resultSetConcurrency)
CallableStatement	prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
PreparedStatement	prepareStatement(String sql, int autoGeneratedKeys)
PreparedStatement	prepareStatement(String sql, int[] columnIndexes)
PreparedStatement	prepareStatement(String sql, String[] columnNames)
void	releaseSavepoint(Savepoint savepoint)	Drill: Not supported.
void	rollback()	Drill: Not supported.
void	rollback(Savepoint savepoint)	Drill: Not supported.
void	setAutoCommit(boolean autoCommit)
void	setClientInfo(String name, String value)
void	setClientInfo(Properties properties)
void	setNetworkTimeout(Executor executor, int milliseconds)	Drill: Not supported (for non-zero timeout value).
Savepoint	setSavepoint()	Drill: Not supported.
Savepoint	setSavepoint(String name)	Drill: Not supported.
void	setSchema(String schema)
void	setTransactionIsolation(int level)
void	setTypeMap(Map<String,Class<?>> map)

Methods inherited from class org.apache.calcite.avatica.AvaticaConnection

clearWarnings, config, createArrayOf, createStatement, createStatement, createTrojan, executeBatchUpdateInternal, executeQueryInternal, getAutoCommit, getCancelFlag, getCatalog, getClientInfo, getClientInfo, getHoldability, getKerberosConnection, getMetaData, getService, getTransactionIsolation, getWarnings, invokeWithRetries, isReadOnly, isWrapperFor, lookupStatement, openConnection, prepareAndUpdateBatch, prepareStatement, prepareStatement, prepareStatement, setCatalog, setHoldability, setKerberosConnection, setReadOnly, setService, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Connection

clearWarnings, createArrayOf, createStatement, createStatement, getCatalog, getClientInfo, getClientInfo, getHoldability, getMetaData, getWarnings, isReadOnly, prepareStatement, prepareStatement, prepareStatement, setCatalog, setHoldability, setReadOnly

Methods inherited from interface org.apache.drill.jdbc.DrillConnection

getAutoCommit, getTransactionIsolation, isWrapperFor, unwrap

Constructor Details

DrillConnectionImpl

public DrillConnectionImpl(DriverImpl driver,
 org.apache.calcite.avatica.AvaticaFactory factory,
 String url,
 Properties info)
                    throws SQLException

Throws:

SQLException

Method Details

createResultSet

protected ResultSet createResultSet(org.apache.calcite.avatica.Meta.MetaResultSet metaResultSet,
 org.apache.calcite.avatica.QueryState state)
                             throws SQLException

Overrides:

createResultSet in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

prepareAndExecuteInternal

protected org.apache.calcite.avatica.Meta.ExecuteResult prepareAndExecuteInternal(org.apache.calcite.avatica.AvaticaStatement statement,
 String sql,
 long maxRowCount)
                                                                           throws SQLException,
org.apache.calcite.avatica.NoSuchStatementException

Overrides:

prepareAndExecuteInternal in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

org.apache.calcite.avatica.NoSuchStatementException

checkOpen

protected void checkOpen()
                  throws AlreadyClosedSqlException

Throws AlreadyClosedSqlException iff this Connection is closed.

Overrides:

checkOpen in class org.apache.calcite.avatica.AvaticaConnection

Throws:

AlreadyClosedSqlException - if Connection is closed

getConfig

public DrillConnectionConfig getConfig()

Description copied from interface: DrillConnection

Returns a view onto this connection's configuration properties. Code within Optiq should use this view rather than calling Properties.getProperty(String).

Specified by:

getConfig in interface DrillConnection

getClient

public DrillClient getClient()

Specified by:

getClient in interface DrillConnection

setAutoCommit

public void setAutoCommit(boolean autoCommit)
                   throws SQLException

Description copied from interface: DrillConnection

Drill: Accepts only true.

Specified by:

setAutoCommit in interface Connection

Specified by:

setAutoCommit in interface DrillConnection

Overrides:

setAutoCommit in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

commit

public void commit()
            throws SQLException

Description copied from interface: DrillConnection

Drill: Not supported. Always throws SQLFeatureNotSupportedException (or AlreadyClosedSqlException).

Specified by:

commit in interface Connection

Specified by:

commit in interface DrillConnection

Overrides:

commit in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

rollback

public void rollback()
              throws SQLException

Description copied from interface: DrillConnection

Drill: Not supported. Always throws SQLFeatureNotSupportedException (or AlreadyClosedSqlException).

Specified by:

rollback in interface Connection

Specified by:

rollback in interface DrillConnection

Overrides:

rollback in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

isClosed

public boolean isClosed()

Description copied from interface: DrillConnection

Drill: Does not throw SQLException.

Specified by:

isClosed in interface Connection

Specified by:

isClosed in interface DrillConnection

Overrides:

isClosed in class org.apache.calcite.avatica.AvaticaConnection

setSavepoint

public Savepoint setSavepoint()
                       throws SQLException

Description copied from interface: DrillConnection

Drill: Not supported. Always throws SQLFeatureNotSupportedException (or AlreadyClosedSqlException).

Specified by:

setSavepoint in interface Connection

Specified by:

setSavepoint in interface DrillConnection

Overrides:

setSavepoint in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

setSavepoint

public Savepoint setSavepoint(String name)
                       throws SQLException

Description copied from interface: DrillConnection

Drill: Not supported. Always throws SQLFeatureNotSupportedException (or AlreadyClosedSqlException).

Specified by:

setSavepoint in interface Connection

Specified by:

setSavepoint in interface DrillConnection

Overrides:

setSavepoint in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

rollback

public void rollback(Savepoint savepoint)
              throws SQLException

Description copied from interface: DrillConnection

Drill: Not supported. Always throws SQLFeatureNotSupportedException (or AlreadyClosedSqlException).

Specified by:

rollback in interface Connection

Specified by:

rollback in interface DrillConnection

Overrides:

rollback in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

releaseSavepoint

public void releaseSavepoint(Savepoint savepoint)
                      throws SQLException

Description copied from interface: DrillConnection

Drill: Not supported. Always throws SQLFeatureNotSupportedException (or AlreadyClosedSqlException).

Specified by:

releaseSavepoint in interface Connection

Specified by:

releaseSavepoint in interface DrillConnection

Overrides:

releaseSavepoint in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

setTransactionIsolation

public void setTransactionIsolation(int level)
                             throws SQLException

Description copied from interface: DrillConnection

Drill: Accepts only Connection.TRANSACTION_NONE.

Specified by:

setTransactionIsolation in interface Connection

Specified by:

setTransactionIsolation in interface DrillConnection

Overrides:

setTransactionIsolation in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

setNetworkTimeout

public void setNetworkTimeout(Executor executor,
 int milliseconds)
                       throws JdbcApiSqlException,
SQLFeatureNotSupportedException

Description copied from interface: DrillConnection

Drill: Not supported (for non-zero timeout value).

Normally, just throws SQLFeatureNotSupportedException unless request is trivially for no timeout (zero milliseconds value).

Specified by:

setNetworkTimeout in interface Connection

Specified by:

setNetworkTimeout in interface DrillConnection

Overrides:

setNetworkTimeout in class org.apache.calcite.avatica.AvaticaConnection

Throws:

AlreadyClosedSqlException - if connection is closed

JdbcApiSqlException - if an invalid parameter value is detected (and not above case)

SQLFeatureNotSupportedException - if timeout is non-zero (and not above case)

getNetworkTimeout

public int getNetworkTimeout()
                      throws AlreadyClosedSqlException

Description copied from interface: DrillConnection

Drill: Returns zero.

Specified by:

getNetworkTimeout in interface Connection

Specified by:

getNetworkTimeout in interface DrillConnection

Overrides:

getNetworkTimeout in class org.apache.calcite.avatica.AvaticaConnection

Throws:

AlreadyClosedSqlException - if connection is closed

createStatement

public DrillStatementImpl createStatement(int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                                   throws SQLException

Specified by:

createStatement in interface Connection

Overrides:

createStatement in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

getTimeZone

public TimeZone getTimeZone()

Overrides:

getTimeZone in class org.apache.calcite.avatica.AvaticaConnection

prepareCall

public CallableStatement prepareCall(String sql)
                              throws SQLException

Specified by:

prepareCall in interface Connection

Overrides:

prepareCall in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

nativeSQL

public String nativeSQL(String sql)
                 throws SQLException

Specified by:

nativeSQL in interface Connection

Overrides:

nativeSQL in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

prepareCall

public CallableStatement prepareCall(String sql,
 int resultSetType,
 int resultSetConcurrency)
                              throws SQLException

Specified by:

prepareCall in interface Connection

Overrides:

prepareCall in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

getTypeMap

public Map<String,Class<?>> getTypeMap()
                                throws SQLException

Specified by:

getTypeMap in interface Connection

Overrides:

getTypeMap in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

setTypeMap

public void setTypeMap(Map<String,Class<?>> map)
                throws SQLException

Specified by:

setTypeMap in interface Connection

Overrides:

setTypeMap in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

prepareCall

public CallableStatement prepareCall(String sql,
 int resultSetType,
 int resultSetConcurrency,
 int resultSetHoldability)
                              throws SQLException

Specified by:

prepareCall in interface Connection

Overrides:

prepareCall in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
 int autoGeneratedKeys)
                                   throws SQLException

Specified by:

prepareStatement in interface Connection

Overrides:

prepareStatement in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
 int[] columnIndexes)
                                   throws SQLException

Specified by:

prepareStatement in interface Connection

Overrides:

prepareStatement in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

prepareStatement

public PreparedStatement prepareStatement(String sql,
 String[] columnNames)
                                   throws SQLException

Specified by:

prepareStatement in interface Connection

Overrides:

prepareStatement in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

createClob

public Clob createClob()
                throws SQLException

Specified by:

createClob in interface Connection

Overrides:

createClob in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

createBlob

public Blob createBlob()
                throws SQLException

Specified by:

createBlob in interface Connection

Overrides:

createBlob in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

createNClob

public NClob createNClob()
                  throws SQLException

Specified by:

createNClob in interface Connection

Overrides:

createNClob in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

createSQLXML

public SQLXML createSQLXML()
                    throws SQLException

Specified by:

createSQLXML in interface Connection

Overrides:

createSQLXML in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

isValid

public boolean isValid(int timeout)
                throws SQLException

Specified by:

isValid in interface Connection

Overrides:

isValid in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

setClientInfo

public void setClientInfo(String name,
 String value)
                   throws SQLClientInfoException

Specified by:

setClientInfo in interface Connection

Overrides:

setClientInfo in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLClientInfoException

setClientInfo

public void setClientInfo(Properties properties)
                   throws SQLClientInfoException

Specified by:

setClientInfo in interface Connection

Overrides:

setClientInfo in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLClientInfoException

createStruct

public Struct createStruct(String typeName,
 Object[] attributes)
                    throws SQLException

Specified by:

createStruct in interface Connection

Overrides:

createStruct in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

setSchema

public void setSchema(String schema)
               throws SQLException

Specified by:

setSchema in interface Connection

Specified by:

setSchema in interface DrillConnection

Overrides:

setSchema in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

getSchema

public String getSchema()
                 throws SQLException

Specified by:

getSchema in interface Connection

Specified by:

getSchema in interface DrillConnection

Overrides:

getSchema in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

abort

public void abort(Executor executor)
           throws SQLException

Specified by:

abort in interface Connection

Overrides:

abort in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

close

public void close()
           throws SQLException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Connection

Overrides:

close in class org.apache.calcite.avatica.AvaticaConnection

Throws:

SQLException

getDrillbit

protected Drillbit getDrillbit()