Package org.apache.calcite.jdbc

Class CalciteStatement

  • All Implemented Interfaces:
    java.lang.AutoCloseable, java.sql.Statement, java.sql.Wrapper
    Direct Known Subclasses:
    CalciteJdbc41Factory.CalciteJdbc41Statement
    public abstract class CalciteStatement
extends org.apache.calcite.avatica.AvaticaStatement
    Implementation of Statement for the Calcite engine.

    • Field Summary

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

        cancelFlag, closed, closeOnCompletion, connection, 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

    • Constructor Summary

      Constructors 
      Constructor Description
      CalciteStatement​(CalciteConnectionImpl connection, org.apache.calcite.avatica.Meta.StatementHandle h, int resultSetType, int resultSetConcurrency, int resultSetHoldability)
      Creates a CalciteStatement.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void close_()  
      CalciteConnectionImpl getConnection()  
      protected <T> CalcitePrepare.CalciteSignature<T> prepare​(Queryable<T> queryable)  
      <T> T unwrap​(java.lang.Class<T> iface)  

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

        addBatch, cancel, checkOpen, clearBatch, clearWarnings, close, closeOnCompletion, execute, execute, execute, execute, executeBatch, executeBatchInternal, executeInternal, executeInternal, executeLargeBatch, executeLargeUpdate, executeQuery, executeQueryInternal, executeUpdate, executeUpdate, executeUpdate, executeUpdate, getBoundParameterValues, getFetchDirection, getFetchSize, getGeneratedKeys, getId, getLargeMaxRows, getLargeUpdateCount, getMaxFieldSize, getMaxRows, getMoreResults, getMoreResults, getParameterValues, getQueryTimeout, getResultSet, getResultSetConcurrency, getResultSetHoldability, getResultSetType, getSignature, getStatementType, getUpdateCount, getWarnings, isClosed, isCloseOnCompletion, isPoolable, isWrapperFor, resetStatement, setCursorName, setEscapeProcessing, setFetchDirection, setFetchSize, setLargeMaxRows, setMaxFieldSize, setMaxRows, setPoolable, setQueryTimeout, setSignature, syncResults

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface java.sql.Statement

        enquoteIdentifier, enquoteLiteral, enquoteNCharLiteral, executeLargeUpdate, executeLargeUpdate, executeLargeUpdate, isSimpleIdentifier

    • Constructor Detail

      • CalciteStatement

        CalciteStatement​(CalciteConnectionImpl connection,
                 org.apache.calcite.avatica.Meta.StatementHandle h,
                 int resultSetType,
                 int resultSetConcurrency,
                 int resultSetHoldability)
        Creates a CalciteStatement.
        Parameters:
        connection - Connection
        h - Statement handle
        resultSetType - Result set type
        resultSetConcurrency - Result set concurrency
        resultSetHoldability - Result set holdability

    • Method Detail

      • unwrap

        public <T> T unwrap​(java.lang.Class<T> iface)
             throws java.sql.SQLException
        Specified by:
        unwrap in interface java.sql.Wrapper
        Overrides:
        unwrap in class org.apache.calcite.avatica.AvaticaStatement
        Throws:
        java.sql.SQLException

      • getConnection

        public CalciteConnectionImpl getConnection()
        Specified by:
        getConnection in interface java.sql.Statement
        Overrides:
        getConnection in class org.apache.calcite.avatica.AvaticaStatement

      • close_

        protected void close_()
        Overrides:
        close_ in class org.apache.calcite.avatica.AvaticaStatement