org.apache.drill.jdbc.impl

Class DrillMetaImpl

java.lang.Object

org.apache.calcite.avatica.MetaImpl

org.apache.drill.jdbc.impl.DrillMetaImpl

All Implemented Interfaces:

org.apache.calcite.avatica.Meta

public class DrillMetaImpl
extends org.apache.calcite.avatica.MetaImpl

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DrillMetaImpl.MetaColumn Metadata describing a column.

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.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

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

connProps

Method Summary

Modifier and Type	Method and Description
void	closeStatement(org.apache.calcite.avatica.Meta.StatementHandle h)
void	commit(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle)
protected static org.apache.calcite.avatica.ColumnMetaData	drillColumnMetaData(String name, int index, Class<?> type, boolean notNullable)
protected static org.apache.calcite.avatica.ColumnMetaData.StructType	drillFieldMetaData(Class<?> clazz)
org.apache.calcite.avatica.Meta.ExecuteResult	execute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<org.apache.calcite.avatica.remote.TypedValue> list, int i)
org.apache.calcite.avatica.Meta.ExecuteResult	execute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<org.apache.calcite.avatica.remote.TypedValue> list, long l)
org.apache.calcite.avatica.Meta.ExecuteBatchResult	executeBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<List<org.apache.calcite.avatica.remote.TypedValue>> list)
org.apache.calcite.avatica.Meta.Frame	fetch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, long l, int i)
org.apache.calcite.avatica.Meta.MetaResultSet	getCatalogs(org.apache.calcite.avatica.Meta.ConnectionHandle ch) Implements DatabaseMetaData.getCatalogs().
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) Implements DatabaseMetaData.getColumns(java.lang.String, java.lang.String, java.lang.String, java.lang.String).
org.apache.calcite.avatica.Meta.MetaResultSet	getSchemas(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern) Implements DatabaseMetaData.getSchemas().
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) Implements DatabaseMetaData.getTables(java.lang.String, java.lang.String, java.lang.String, java.lang.String[]).
org.apache.calcite.avatica.Meta.StatementHandle	prepare(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String sql, long maxRowCount)
org.apache.calcite.avatica.Meta.ExecuteResult	prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle handle, String sql, long maxRowCount, int maxRowsInFirstFrame, org.apache.calcite.avatica.Meta.PrepareCallback callback)
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)
org.apache.calcite.avatica.Meta.ExecuteBatchResult	prepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<String> list)
void	rollback(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle)
boolean	syncResults(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, org.apache.calcite.avatica.QueryState queryState, long l)

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

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

Methods inherited from class java.lang.Object

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

Method Detail

drillFieldMetaData

protected static org.apache.calcite.avatica.ColumnMetaData.StructType drillFieldMetaData(Class<?> clazz)

drillColumnMetaData

protected static org.apache.calcite.avatica.ColumnMetaData drillColumnMetaData(String name,
                                                                               int index,
                                                                               Class<?> type,
                                                                               boolean notNullable)

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)

Implements DatabaseMetaData.getTables(java.lang.String, java.lang.String, java.lang.String, java.lang.String[]).

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)

Implements DatabaseMetaData.getColumns(java.lang.String, java.lang.String, java.lang.String, java.lang.String).

Specified by:

getColumns in interface org.apache.calcite.avatica.Meta

Overrides:

getColumns 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)

Implements DatabaseMetaData.getSchemas().

Specified by:

getSchemas in interface org.apache.calcite.avatica.Meta

Overrides:

getSchemas in class org.apache.calcite.avatica.MetaImpl

getCatalogs

public org.apache.calcite.avatica.Meta.MetaResultSet getCatalogs(org.apache.calcite.avatica.Meta.ConnectionHandle ch)

Implements DatabaseMetaData.getCatalogs().

Specified by:

getCatalogs in interface org.apache.calcite.avatica.Meta

Overrides:

getCatalogs 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)

prepareAndExecute

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)

prepareAndExecute

public org.apache.calcite.avatica.Meta.ExecuteResult prepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle handle,
                                                                       String sql,
                                                                       long maxRowCount,
                                                                       int maxRowsInFirstFrame,
                                                                       org.apache.calcite.avatica.Meta.PrepareCallback callback)
                                                                throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

prepareAndExecuteBatch

public org.apache.calcite.avatica.Meta.ExecuteBatchResult prepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                                                 List<String> list)
                                                                          throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

executeBatch

public org.apache.calcite.avatica.Meta.ExecuteBatchResult executeBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                                       List<List<org.apache.calcite.avatica.remote.TypedValue>> list)
                                                                throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

fetch

public org.apache.calcite.avatica.Meta.Frame fetch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                   long l,
                                                   int i)
                                            throws org.apache.calcite.avatica.NoSuchStatementException,
                                                   org.apache.calcite.avatica.MissingResultsException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

org.apache.calcite.avatica.MissingResultsException

execute

public org.apache.calcite.avatica.Meta.ExecuteResult execute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                             List<org.apache.calcite.avatica.remote.TypedValue> list,
                                                             long l)
                                                      throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

execute

public org.apache.calcite.avatica.Meta.ExecuteResult execute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                                                             List<org.apache.calcite.avatica.remote.TypedValue> list,
                                                             int i)
                                                      throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

closeStatement

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

syncResults

public boolean syncResults(org.apache.calcite.avatica.Meta.StatementHandle statementHandle,
                           org.apache.calcite.avatica.QueryState queryState,
                           long l)
                    throws org.apache.calcite.avatica.NoSuchStatementException

Throws:

org.apache.calcite.avatica.NoSuchStatementException

commit

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

rollback

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