Package org.apache.drill.jdbc.impl

Class DrillStatementImpl

java.lang.Object

org.apache.calcite.avatica.AvaticaStatement

org.apache.drill.jdbc.impl.DrillStatementImpl

All Implemented Interfaces:

AutoCloseable, Statement, Wrapper, DrillStatement

public class DrillStatementImpl
extends org.apache.calcite.avatica.AvaticaStatement
implements DrillStatement

Drill's implementation of Statement.

Field Summary

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

cancelFlag, closed, closeOnCompletion, DEFAULT_FETCH_SIZE, handle, maxRowCount, openResultSet, updateCount

Fields inherited from interface java.sql.Statement

CLOSE_ALL_RESULTS, CLOSE_CURRENT_RESULT, EXECUTE_FAILED, KEEP_CURRENT_RESULT, NO_GENERATED_KEYS, RETURN_GENERATED_KEYS, SUCCESS_NO_INFO

Method Summary

Modifier and Type	Method	Description
void	addBatch(String sql)
protected void	checkOpen()	Throws AlreadyClosedSqlException iff this Statement is closed.
void	cleanUp()
void	clearBatch()
boolean	execute(String sql, int autoGeneratedKeys)
boolean	execute(String sql, int[] columnIndexes)
boolean	execute(String sql, String[] columnNames)
int[]	executeBatch()
long	executeLargeUpdate(String sql, int autoGeneratedKeys)
long	executeLargeUpdate(String sql, int[] columnIndexes)
long	executeLargeUpdate(String sql, String[] columnNames)
int	executeUpdate(String sql, int autoGeneratedKeys)
int	executeUpdate(String sql, int[] columnIndexes)
int	executeUpdate(String sql, String[] columnNames)
DrillConnectionImpl	getConnection()
ResultSet	getGeneratedKeys()
boolean	getMoreResults()
boolean	getMoreResults(int current)
boolean	isClosed()
void	setCursorName(String name)
void	setEscapeProcessing(boolean enable)
void	setLargeMaxRows(long maxRowCount)
void	setPoolable(boolean poolable)
void	setResultSet(org.apache.calcite.avatica.AvaticaResultSet resultSet)
void	setUpdateCount(int value)

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

cancel, clearWarnings, close, close_, closeOnCompletion, execute, executeBatchInternal, executeInternal, executeInternal, executeLargeBatch, executeLargeUpdate, executeQuery, executeQueryInternal, executeUpdate, getBoundParameterValues, getFetchDirection, getFetchSize, getId, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getParameterValues, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getSignature, getStatementType, getUpdateCount, getWarnings, isCloseOnCompletion, isPoolable, isWrapperFor, resetStatement, setFetchDirection, setFetchSize, setMaxFieldSize, setMaxRows, setQueryTimeout, setSignature, syncResults, unwrap

Methods inherited from class java.lang.Object

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

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

getQueryTimeout, setQueryTimeout

Methods inherited from interface java.sql.Statement

cancel, clearWarnings, close, closeOnCompletion, enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, execute, executeLargeBatch, executeLargeUpdate, executeQuery, executeUpdate, getFetchDirection, getFetchSize, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getUpdateCount, getWarnings, isCloseOnCompletion, isPoolable, isSimpleIdentifier, setFetchDirection, setFetchSize, setMaxFieldSize, setMaxRows

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Method Details

checkOpen

protected void checkOpen()
                  throws AlreadyClosedSqlException

Throws AlreadyClosedSqlException iff this Statement is closed.

Overrides:

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

Throws:

AlreadyClosedSqlException - if Statement is closed

getConnection

public DrillConnectionImpl getConnection()
                                  throws SQLException

Specified by:

getConnection in interface Statement

Overrides:

getConnection in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

executeLargeUpdate

public long executeLargeUpdate(String sql,
 int autoGeneratedKeys)
                        throws SQLException

Specified by:

executeLargeUpdate in interface Statement

Throws:

SQLException

executeLargeUpdate

public long executeLargeUpdate(String sql,
 int[] columnIndexes)
                        throws SQLException

Specified by:

executeLargeUpdate in interface Statement

Throws:

SQLException

executeLargeUpdate

public long executeLargeUpdate(String sql,
 String[] columnNames)
                        throws SQLException

Specified by:

executeLargeUpdate in interface Statement

Throws:

SQLException

executeUpdate

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

Specified by:

executeUpdate in interface Statement

Overrides:

executeUpdate in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

executeUpdate

public int executeUpdate(String sql,
 String[] columnNames)
                  throws SQLException

Specified by:

executeUpdate in interface Statement

Overrides:

executeUpdate in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

cleanUp

public void cleanUp()

isClosed

public boolean isClosed()

Description copied from interface: DrillStatement

Drill: Does not throw SQLException.

Specified by:

isClosed in interface DrillStatement

Specified by:

isClosed in interface Statement

Overrides:

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

setEscapeProcessing

public void setEscapeProcessing(boolean enable)
                         throws SQLException

Specified by:

setEscapeProcessing in interface Statement

Overrides:

setEscapeProcessing in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

setCursorName

public void setCursorName(String name)
                   throws SQLException

Specified by:

setCursorName in interface Statement

Overrides:

setCursorName in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

getMoreResults

public boolean getMoreResults()
                       throws SQLException

Specified by:

getMoreResults in interface Statement

Overrides:

getMoreResults in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

addBatch

public void addBatch(String sql)
              throws SQLException

Specified by:

addBatch in interface Statement

Overrides:

addBatch in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

clearBatch

public void clearBatch()
                throws SQLException

Specified by:

clearBatch in interface Statement

Overrides:

clearBatch in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

executeBatch

public int[] executeBatch()
                   throws SQLException

Specified by:

executeBatch in interface Statement

Overrides:

executeBatch in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

getMoreResults

public boolean getMoreResults(int current)
                       throws SQLException

Specified by:

getMoreResults in interface Statement

Overrides:

getMoreResults in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

getGeneratedKeys

public ResultSet getGeneratedKeys()
                           throws SQLException

Specified by:

getGeneratedKeys in interface Statement

Overrides:

getGeneratedKeys in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

executeUpdate

public int executeUpdate(String sql,
 int autoGeneratedKeys)
                  throws SQLException

Specified by:

executeUpdate in interface Statement

Overrides:

executeUpdate in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

execute

public boolean execute(String sql,
 int autoGeneratedKeys)
                throws SQLException

Specified by:

execute in interface Statement

Overrides:

execute in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

execute

public boolean execute(String sql,
 int[] columnIndexes)
                throws SQLException

Specified by:

execute in interface Statement

Overrides:

execute in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

execute

public boolean execute(String sql,
 String[] columnNames)
                throws SQLException

Specified by:

execute in interface Statement

Overrides:

execute in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

setPoolable

public void setPoolable(boolean poolable)
                 throws SQLException

Specified by:

setPoolable in interface Statement

Overrides:

setPoolable in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException

setResultSet

public void setResultSet(org.apache.calcite.avatica.AvaticaResultSet resultSet)

Specified by:

setResultSet in interface DrillStatement

setUpdateCount

public void setUpdateCount(int value)

Specified by:

setUpdateCount in interface DrillStatement

setLargeMaxRows

public void setLargeMaxRows(long maxRowCount)
                     throws SQLException

Specified by:

setLargeMaxRows in interface Statement

Overrides:

setLargeMaxRows in class org.apache.calcite.avatica.AvaticaStatement

Throws:

SQLException