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
Modifier and TypeClassDescriptionstatic class
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 TypeMethodDescriptionvoid
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) ImplementsDatabaseMetaData.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) 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()
.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.StatementHandle
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
-
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:
getTables
in interfaceorg.apache.calcite.avatica.Meta
- Overrides:
getTables
in 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:
getColumns
in interfaceorg.apache.calcite.avatica.Meta
- Overrides:
getColumns
in 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:
getSchemas
in interfaceorg.apache.calcite.avatica.Meta
- Overrides:
getSchemas
in 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:
getCatalogs
in interfaceorg.apache.calcite.avatica.Meta
- Overrides:
getCatalogs
in 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.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)
-