Package 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 ClassesModifier and TypeClassDescriptionstatic classMetadata 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.MetaVersionColumnNested 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 TypeMethodDescriptionvoidcloseStatement(org.apache.calcite.avatica.Meta.StatementHandle h) voidcommit(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle) protected static org.apache.calcite.avatica.ColumnMetaDatadrillColumnMetaData(String name, int index, Class<?> type, boolean notNullable) protected static org.apache.calcite.avatica.ColumnMetaData.StructTypedrillFieldMetaData(Class<?> clazz) org.apache.calcite.avatica.Meta.ExecuteResultexecute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<org.apache.calcite.avatica.remote.TypedValue> list, int i) org.apache.calcite.avatica.Meta.ExecuteResultexecute(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<org.apache.calcite.avatica.remote.TypedValue> list, long l) org.apache.calcite.avatica.Meta.ExecuteBatchResultexecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<List<org.apache.calcite.avatica.remote.TypedValue>> list) org.apache.calcite.avatica.Meta.Framefetch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, long l, int i) org.apache.calcite.avatica.Meta.MetaResultSetgetCatalogs(org.apache.calcite.avatica.Meta.ConnectionHandle ch) ImplementsDatabaseMetaData.getCatalogs().org.apache.calcite.avatica.Meta.MetaResultSetgetColumns(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) org.apache.calcite.avatica.Meta.MetaResultSetgetSchemas(org.apache.calcite.avatica.Meta.ConnectionHandle ch, String catalog, org.apache.calcite.avatica.Meta.Pat schemaPattern) ImplementsDatabaseMetaData.getSchemas().org.apache.calcite.avatica.Meta.MetaResultSetgetTables(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.StatementHandleorg.apache.calcite.avatica.Meta.ExecuteResultprepareAndExecute(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.ExecuteResultprepareAndExecute(org.apache.calcite.avatica.Meta.StatementHandle h, String sql, long maxRowCount, org.apache.calcite.avatica.Meta.PrepareCallback callback) org.apache.calcite.avatica.Meta.ExecuteBatchResultprepareAndExecuteBatch(org.apache.calcite.avatica.Meta.StatementHandle statementHandle, List<String> list) voidrollback(org.apache.calcite.avatica.Meta.ConnectionHandle connectionHandle) booleansyncResults(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
-
Method Details
-
drillFieldMetaData
protected static org.apache.calcite.avatica.ColumnMetaData.StructType drillFieldMetaData(Class<?> clazz) -
drillColumnMetaData
-
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) ImplementsDatabaseMetaData.getTables(java.lang.String, java.lang.String, java.lang.String, java.lang.String[]).- Specified by:
getTablesin interfaceorg.apache.calcite.avatica.Meta- Overrides:
getTablesin classorg.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) ImplementsDatabaseMetaData.getColumns(java.lang.String, java.lang.String, java.lang.String, java.lang.String).- Specified by:
getColumnsin interfaceorg.apache.calcite.avatica.Meta- Overrides:
getColumnsin classorg.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) ImplementsDatabaseMetaData.getSchemas().- Specified by:
getSchemasin interfaceorg.apache.calcite.avatica.Meta- Overrides:
getSchemasin classorg.apache.calcite.avatica.MetaImpl
-
getCatalogs
public org.apache.calcite.avatica.Meta.MetaResultSet getCatalogs(org.apache.calcite.avatica.Meta.ConnectionHandle ch) ImplementsDatabaseMetaData.getCatalogs().- Specified by:
getCatalogsin interfaceorg.apache.calcite.avatica.Meta- Overrides:
getCatalogsin classorg.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.NoSuchStatementExceptionorg.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)
-