Package org.apache.calcite.jdbc

Class CalciteResultSet

  • All Implemented Interfaces:
    java.lang.AutoCloseable, java.sql.ResultSet, java.sql.Wrapper, org.apache.calcite.avatica.util.ArrayImpl.Factory
    public class CalciteResultSet
extends org.apache.calcite.avatica.AvaticaResultSet
    Implementation of ResultSet for the Calcite engine.

    • Field Summary

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

        accessorList, columnMetaDataList, cursor, firstFrame, localCalendar, resultSetMetaData, signature, state, statement

      • Fields inherited from interface java.sql.ResultSet

        CLOSE_CURSORS_AT_COMMIT, CONCUR_READ_ONLY, CONCUR_UPDATABLE, FETCH_FORWARD, FETCH_REVERSE, FETCH_UNKNOWN, HOLD_CURSORS_OVER_COMMIT, TYPE_FORWARD_ONLY, TYPE_SCROLL_INSENSITIVE, TYPE_SCROLL_SENSITIVE

    • Constructor Summary

      Constructors 
      Constructor Description
      CalciteResultSet​(org.apache.calcite.avatica.AvaticaStatement statement, CalcitePrepare.CalciteSignature calciteSignature, java.sql.ResultSetMetaData resultSetMetaData, java.util.TimeZone timeZone, org.apache.calcite.avatica.Meta.Frame firstFrame)
      Creates a CalciteResultSet.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.sql.ResultSet create​(org.apache.calcite.avatica.ColumnMetaData.AvaticaType elementType, java.lang.Iterable<java.lang.Object> iterable)  
      private org.apache.calcite.avatica.util.Cursor createCursor​(org.apache.calcite.avatica.ColumnMetaData.AvaticaType elementType, java.lang.Iterable iterable)  
      protected CalciteResultSet execute()  
      (package private) CalciteConnectionImpl getCalciteConnection()  
      (package private) <T> CalcitePrepare.CalciteSignature<T> getSignature()  

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

        absolute, afterLast, beforeFirst, cancel, cancelRowUpdates, checkOpen, clearWarnings, close, deleteRow, execute2, findColumn, first, getArray, getArray, getAsciiStream, getAsciiStream, getBigDecimal, getBigDecimal, getBigDecimal, getBigDecimal, getBinaryStream, getBinaryStream, getBlob, getBlob, getBoolean, getBoolean, getByte, getByte, getBytes, getBytes, getCharacterStream, getCharacterStream, getClob, getClob, getConcurrency, getCursorName, getDate, getDate, getDate, getDate, getDouble, getDouble, getFetchDirection, getFetchSize, getFloat, getFloat, getHoldability, getInt, getInt, getLocalCalendar, getLong, getLong, getMetaData, getNCharacterStream, getNCharacterStream, getNClob, getNClob, getNString, getNString, getObject, getObject, getObject, getObject, getObject, getObject, getRef, getRef, getRow, getRowId, getRowId, getShort, getShort, getSQLXML, getSQLXML, getStatement, getString, getString, getTime, getTime, getTime, getTime, getTimestamp, getTimestamp, getTimestamp, getTimestamp, getType, getUnicodeStream, getUnicodeStream, getURL, getURL, getWarnings, insertRow, isAfterLast, isBeforeFirst, isClosed, isFirst, isLast, isWrapperFor, last, moveToCurrentRow, moveToInsertRow, next, previous, refreshRow, relative, rowDeleted, rowInserted, rowUpdated, setFetchDirection, setFetchSize, unwrap, updateArray, updateArray, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateAsciiStream, updateBigDecimal, updateBigDecimal, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBinaryStream, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBlob, updateBoolean, updateBoolean, updateByte, updateByte, updateBytes, updateBytes, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateCharacterStream, updateClob, updateClob, updateClob, updateClob, updateClob, updateClob, updateDate, updateDate, updateDouble, updateDouble, updateFloat, updateFloat, updateInt, updateInt, updateLong, updateLong, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNCharacterStream, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNClob, updateNString, updateNString, updateNull, updateNull, updateObject, updateObject, updateObject, updateObject, updateRef, updateRef, updateRow, updateRowId, updateRowId, updateShort, updateShort, updateSQLXML, updateSQLXML, updateString, updateString, updateTime, updateTime, updateTimestamp, updateTimestamp, wasNull

      • Methods inherited from class org.apache.calcite.avatica.util.ArrayFactoryImpl

        createArray

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface java.sql.ResultSet

        updateObject, updateObject, updateObject, updateObject

    • Constructor Detail

      • CalciteResultSet

        CalciteResultSet​(org.apache.calcite.avatica.AvaticaStatement statement,
                 CalcitePrepare.CalciteSignature calciteSignature,
                 java.sql.ResultSetMetaData resultSetMetaData,
                 java.util.TimeZone timeZone,
                 org.apache.calcite.avatica.Meta.Frame firstFrame)
          throws java.sql.SQLException
        Creates a CalciteResultSet.
        Throws:
        java.sql.SQLException

    • Method Detail

      • execute

        protected CalciteResultSet execute()
                            throws java.sql.SQLException
        Overrides:
        execute in class org.apache.calcite.avatica.AvaticaResultSet
        Throws:
        java.sql.SQLException

      • create

        public java.sql.ResultSet create​(org.apache.calcite.avatica.ColumnMetaData.AvaticaType elementType,
                                 java.lang.Iterable<java.lang.Object> iterable)
                          throws java.sql.SQLException
        Specified by:
        create in interface org.apache.calcite.avatica.util.ArrayImpl.Factory
        Overrides:
        create in class org.apache.calcite.avatica.util.ArrayFactoryImpl
        Throws:
        java.sql.SQLException

      • createCursor

        private org.apache.calcite.avatica.util.Cursor createCursor​(org.apache.calcite.avatica.ColumnMetaData.AvaticaType elementType,
                                                            java.lang.Iterable iterable)

      • getCalciteConnection

        CalciteConnectionImpl getCalciteConnection()
                                    throws java.sql.SQLException
        Throws:
        java.sql.SQLException