Package org.apache.druid.sql.avatica

Class DruidMeta

java.lang.Object
org.apache.calcite.avatica.MetaImpl
org.apache.druid.sql.avatica.DruidMeta
All Implemented Interfaces:
org.apache.calcite.avatica.Meta
public class DruidMeta extends org.apache.calcite.avatica.MetaImpl

  • Nested Class Summary

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

    org.apache.calcite.avatica.MetaImpl.ColumnNoNulls, org.apache.calcite.avatica.MetaImpl.ColumnNullable, org.apache.calcite.avatica.MetaImpl.ColumnNullableUnknown, org.apache.calcite.avatica.MetaImpl.MetaAttribute, org.apache.calcite.avatica.MetaImpl.MetaBestRowIdentifier, org.apache.calcite.avatica.MetaImpl.MetaCatalog, org.apache.calcite.avatica.MetaImpl.MetaClientInfoProperty, org.apache.calcite.avatica.MetaImpl.MetaColumn, org.apache.calcite.avatica.MetaImpl.MetaColumnPrivilege, org.apache.calcite.avatica.MetaImpl.MetaCrossReference, org.apache.calcite.avatica.MetaImpl.MetaExportedKey, org.apache.calcite.avatica.MetaImpl.MetaFunction, org.apache.calcite.avatica.MetaImpl.MetaFunctionColumn, org.apache.calcite.avatica.MetaImpl.MetaImportedKey, org.apache.calcite.avatica.MetaImpl.MetaIndexInfo, org.apache.calcite.avatica.MetaImpl.MetaPrimaryKey, org.apache.calcite.avatica.MetaImpl.MetaProcedure, org.apache.calcite.avatica.MetaImpl.MetaProcedureColumn, org.apache.calcite.avatica.MetaImpl.MetaPseudoColumn, org.apache.calcite.avatica.MetaImpl.MetaSchema, org.apache.calcite.avatica.MetaImpl.MetaSuperTable, org.apache.calcite.avatica.MetaImpl.MetaSuperType, org.apache.calcite.avatica.MetaImpl.MetaTable, org.apache.calcite.avatica.MetaImpl.MetaTablePrivilege, org.apache.calcite.avatica.MetaImpl.MetaTableType, org.apache.calcite.avatica.MetaImpl.MetaTypeInfo, org.apache.calcite.avatica.MetaImpl.MetaUdt, org.apache.calcite.avatica.MetaImpl.MetaVersionColumn, org.apache.calcite.avatica.MetaImpl.Named

    Nested classes/interfaces inherited from interface org.apache.calcite.avatica.Meta

    org.apache.calcite.avatica.Meta.ConnectionHandle, org.apache.calcite.avatica.Meta.ConnectionProperties, org.apache.calcite.avatica.Meta.CursorFactory, org.apache.calcite.avatica.Meta.DatabaseProperty, org.apache.calcite.avatica.Meta.ExecuteBatchResult, org.apache.calcite.avatica.Meta.ExecuteResult, org.apache.calcite.avatica.Meta.Factory, org.apache.calcite.avatica.Meta.Frame, org.apache.calcite.avatica.Meta.MetaResultSet, org.apache.calcite.avatica.Meta.Pat, org.apache.calcite.avatica.Meta.PrepareCallback, org.apache.calcite.avatica.Meta.Signature, org.apache.calcite.avatica.Meta.StatementHandle, org.apache.calcite.avatica.Meta.StatementType, org.apache.calcite.avatica.Meta.Style

  • Field Summary

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

    connection, connProps

  • Constructor Summary

    Constructors
    Constructor
    Description
    DruidMeta(SqlStatementFactory sqlStatementFactory, QueryConfigProvider queryConfigProvider, org.apache.druid.sql.avatica.AvaticaServerConfig config, org.apache.druid.sql.avatica.ErrorHandler errorHandler, ScheduledExecutorService exec, List<Authenticator> authenticators, DruidJdbcResultSet.ResultFetcherFactory fetcherFactory)
     
    DruidMeta(SqlStatementFactory sqlStatementFactory, QueryConfigProvider queryConfigProvider, org.apache.druid.sql.avatica.AvaticaServerConfig config, org.apache.druid.sql.avatica.ErrorHandler errorHandler, AuthenticatorMapper authMapper)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    closeAllConnections()
     
    void
    closeConnection(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
     
    void
    closeStatement(org.apache.calcite.avatica.Meta.StatementHandle h)
     
    void
    commit(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
     
    org.apache.calcite.avatica.Meta.ConnectionProperties
    connectionSync(org.apache.calcite.avatica.Meta.ConnectionHandle ch, org.apache.calcite.avatica.Meta.ConnectionProperties connProps)
     
    Iterable<Object>
    createIterable(org.apache.calcite.avatica.Meta.StatementHandle statement, org.apache.calcite.avatica.QueryState state, org.apache.calcite.avatica.Meta.Signature signature, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, org.apache.calcite.avatica.Meta.Frame firstFrame)
     
    org.apache.calcite.avatica.Meta.StatementHandle
    createStatement(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
    Creates a new implementation of the one-pass JDBC Statement class.
    protected org.apache.calcite.avatica.Meta.ExecuteResult
    doFetch(AbstractDruidJdbcStatement druidStatement, int maxRows)
     
    org.apache.calcite.avatica.Meta.ExecuteResult
    execute(org.apache.calcite.avatica.Meta.StatementHandle statement, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, int maxRowsInFirstFrame)
     
    org.apache.calcite.avatica.Meta.ExecuteResult
    execute(org.apache.calcite.avatica.Meta.StatementHandle statement, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, long maxRowCount)
    Deprecated.
    org.apache.calcite.avatica.Meta.ExecuteBatchResult
    executeBatch(org.apache.calcite.avatica.Meta.StatementHandle statement, List<List<org.apache.calcite.avatica.remote.TypedValue>> parameterValues)
     
    org.apache.calcite.avatica.Meta.Frame
    fetch(org.apache.calcite.avatica.Meta.StatementHandle statement, long offset, int fetchMaxRowCount)
     
    org.apache.calcite.avatica.Meta.MetaResultSet
    getCatalogs(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
     
    org.apache.calcite.avatica.Meta.MetaResultSet
    getColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern, org.apache.calcite.avatica.Meta.Pat columnNamePattern)
     
    Map<org.apache.calcite.avatica.Meta.DatabaseProperty,Object>
    getDatabaseProperties(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
     
    org.apache.calcite.avatica.Meta.MetaResultSet
    getSchemas(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern)
     
    org.apache.calcite.avatica.Meta.MetaResultSet
    getTables(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern, List<String> typeList)
     
    org.apache.calcite.avatica.Meta.MetaResultSet
    getTableTypes(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
     
    static <T extends Throwable>
    T
    logFailure(T error)
    Logs any throwable at the error level with the throwables message.
    static <T extends Throwable>
    T
    logFailure(T error, String message, Object... format)
    Logs any throwable and string format message with args at the error level.
    void
    openConnection(org.apache.calcite.avatica.Meta.ConnectionHandle ch, Map<String,String> info)
     
    org.apache.calcite.avatica.Meta.StatementHandle
    prepare(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String sql, long maxRowCount)
    Creates a new implementation of the JDBC PreparedStatement class which allows preparing once, executing many times.
    org.apache.calcite.avatica.Meta.ExecuteResult
    prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle statement, String sql, long maxRowCount, int maxRowsInFirstFrame, org.apache.calcite.avatica.Meta.PrepareCallback callback)
    Prepares and executes a JDBC Statement.
    org.apache.calcite.avatica.Meta.ExecuteResult
    prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle h, String sql, long maxRowCount, org.apache.calcite.avatica.Meta.PrepareCallback callback)
    Deprecated.
    org.apache.calcite.avatica.Meta.ExecuteBatchResult
    prepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle statement, List<String> sqlCommands)
     
    void
    rollback(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
     
    void
    stop()
     
    boolean
    syncResults(org.apache.calcite.avatica.Meta.StatementHandle sh, org.apache.calcite.avatica.QueryState state, long offset)
     

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

    checkParameterValueHasNull, collect, collect, columnMetaData, columnMetaData, columnMetaData, columnMetaData, columnMetaData, columnMetaData, createCursor, createEmptyResultSet, createResultSet, fetch, fieldMetaData, getAttributes, getBestRowIdentifier, getClientInfoProperties, getColumnNullability, getColumnPrivileges, getCrossReference, getExportedKeys, getFunctionColumns, getFunctions, getImportedKeys, getIndexInfo, getPrimaryKeys, getProcedureColumns, getProcedures, getPseudoColumns, getSuperTables, getSuperTypes, getTablePrivileges, getTypeInfo, getUDTs, getVersionColumns

    Methods inherited from class java.lang.Object

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

  • Constructor Details

  • Method Details

    • logFailure

      public static <T extends Throwable> T logFailure(T error, String message, Object... format)
      Logs any throwable and string format message with args at the error level.
      Type Parameters:
      T - any type that extends throwable
      Parameters:
      error - the Throwable to be logged
      message - the message to be logged. Can be in string format structure
      format - the format arguments for the format message string
      Returns:
      the original Throwable

    • logFailure

      public static <T extends Throwable> T logFailure(T error)
      Logs any throwable at the error level with the throwables message.
      Type Parameters:
      T - any type that extends throwable
      Parameters:
      error - the throwable to be logged
      Returns:
      the original Throwable

    • stop

      public void stop() throws InterruptedException
      Throws:
      InterruptedException

    • openConnection

      public void openConnection(org.apache.calcite.avatica.Meta.ConnectionHandle ch, Map<String,String> info)
      Specified by:
      openConnection in interface org.apache.calcite.avatica.Meta
      Overrides:
      openConnection in class org.apache.calcite.avatica.MetaImpl

    • closeConnection

      public void closeConnection(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
      Specified by:
      closeConnection in interface org.apache.calcite.avatica.Meta
      Overrides:
      closeConnection in class org.apache.calcite.avatica.MetaImpl

    • connectionSync

      public org.apache.calcite.avatica.Meta.ConnectionProperties connectionSync(org.apache.calcite.avatica.Meta.ConnectionHandle ch, org.apache.calcite.avatica.Meta.ConnectionProperties connProps)
      Specified by:
      connectionSync in interface org.apache.calcite.avatica.Meta
      Overrides:
      connectionSync in class org.apache.calcite.avatica.MetaImpl

    • createStatement

      public org.apache.calcite.avatica.Meta.StatementHandle createStatement(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
      Creates a new implementation of the one-pass JDBC Statement class. Corresponds to the JDBC Connection.createStatement() method.
      Specified by:
      createStatement in interface org.apache.calcite.avatica.Meta
      Overrides:
      createStatement in class org.apache.calcite.avatica.MetaImpl

    • prepare

      public org.apache.calcite.avatica.Meta.StatementHandle prepare(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String sql, long maxRowCount)
      Creates a new implementation of the JDBC PreparedStatement class which allows preparing once, executing many times. Corresponds to the JDBC Connection.prepareStatement() call.

    • prepareAndExecute

      @Deprecated public org.apache.calcite.avatica.Meta.ExecuteResult prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle h, String sql, long maxRowCount, org.apache.calcite.avatica.Meta.PrepareCallback callback)
      Deprecated.

    • prepareAndExecute

      public org.apache.calcite.avatica.Meta.ExecuteResult prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle statement, String sql, long maxRowCount, int maxRowsInFirstFrame, org.apache.calcite.avatica.Meta.PrepareCallback callback)
      Prepares and executes a JDBC Statement.

    • doFetch

      protected org.apache.calcite.avatica.Meta.ExecuteResult doFetch(AbstractDruidJdbcStatement druidStatement, int maxRows)

    • prepareAndExecuteBatch

      public org.apache.calcite.avatica.Meta.ExecuteBatchResult prepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle statement, List<String> sqlCommands)

    • executeBatch

      public org.apache.calcite.avatica.Meta.ExecuteBatchResult executeBatch(org.apache.calcite.avatica.Meta.StatementHandle statement, List<List<org.apache.calcite.avatica.remote.TypedValue>> parameterValues)

    • fetch

      public org.apache.calcite.avatica.Meta.Frame fetch(org.apache.calcite.avatica.Meta.StatementHandle statement, long offset, int fetchMaxRowCount) throws org.apache.calcite.avatica.NoSuchStatementException, org.apache.calcite.avatica.MissingResultsException
      Throws:
      org.apache.calcite.avatica.NoSuchStatementException
      org.apache.calcite.avatica.MissingResultsException

    • execute

      @Deprecated public org.apache.calcite.avatica.Meta.ExecuteResult execute(org.apache.calcite.avatica.Meta.StatementHandle statement, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, long maxRowCount)
      Deprecated.

    • execute

      public org.apache.calcite.avatica.Meta.ExecuteResult execute(org.apache.calcite.avatica.Meta.StatementHandle statement, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, int maxRowsInFirstFrame)

    • createIterable

      public Iterable<Object> createIterable(org.apache.calcite.avatica.Meta.StatementHandle statement, org.apache.calcite.avatica.QueryState state, org.apache.calcite.avatica.Meta.Signature signature, List<org.apache.calcite.avatica.remote.TypedValue> parameterValues, org.apache.calcite.avatica.Meta.Frame firstFrame)
      Specified by:
      createIterable in interface org.apache.calcite.avatica.Meta
      Overrides:
      createIterable in class org.apache.calcite.avatica.MetaImpl

    • closeStatement

      public void closeStatement(org.apache.calcite.avatica.Meta.StatementHandle h)

    • syncResults

      public boolean syncResults(org.apache.calcite.avatica.Meta.StatementHandle sh, org.apache.calcite.avatica.QueryState state, long offset)

    • commit

      public void commit(org.apache.calcite.avatica.Meta.ConnectionHandle ch)

    • rollback

      public void rollback(org.apache.calcite.avatica.Meta.ConnectionHandle ch)

    • getDatabaseProperties

      public Map<org.apache.calcite.avatica.Meta.DatabaseProperty,Object> getDatabaseProperties(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
      Specified by:
      getDatabaseProperties in interface org.apache.calcite.avatica.Meta
      Overrides:
      getDatabaseProperties in class org.apache.calcite.avatica.MetaImpl

    • getCatalogs

      public org.apache.calcite.avatica.Meta.MetaResultSet getCatalogs(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
      Specified by:
      getCatalogs in interface org.apache.calcite.avatica.Meta
      Overrides:
      getCatalogs in class org.apache.calcite.avatica.MetaImpl

    • getSchemas

      public org.apache.calcite.avatica.Meta.MetaResultSet getSchemas(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern)
      Specified by:
      getSchemas in interface org.apache.calcite.avatica.Meta
      Overrides:
      getSchemas in class org.apache.calcite.avatica.MetaImpl

    • getTables

      public org.apache.calcite.avatica.Meta.MetaResultSet getTables(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern, List<String> typeList)
      Specified by:
      getTables in interface org.apache.calcite.avatica.Meta
      Overrides:
      getTables in class org.apache.calcite.avatica.MetaImpl

    • getColumns

      public org.apache.calcite.avatica.Meta.MetaResultSet getColumns(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern, org.apache.calcite.avatica.Meta.Pat tableNamePattern, org.apache.calcite.avatica.Meta.Pat columnNamePattern)
      Specified by:
      getColumns in interface org.apache.calcite.avatica.Meta
      Overrides:
      getColumns in class org.apache.calcite.avatica.MetaImpl

    • getTableTypes

      public org.apache.calcite.avatica.Meta.MetaResultSet getTableTypes(org.apache.calcite.avatica.Meta.ConnectionHandle ch)
      Specified by:
      getTableTypes in interface org.apache.calcite.avatica.Meta
      Overrides:
      getTableTypes in class org.apache.calcite.avatica.MetaImpl

    • closeAllConnections

      public void closeAllConnections()