public class org.apache.drill.exec.store.jdbc.JdbcBatchReader extends java.lang.Object implements org.apache.drill.exec.physical.impl.scan.framework.ManagedReader
{
private static final org.slf4j.Logger logger;
private static final org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap JDBC_TYPE_MAPPINGS;
private final javax.sql.DataSource source;
private final java.lang.String sql;
private final java.util.List columns;
private java.sql.Connection connection;
private java.sql.PreparedStatement statement;
private java.sql.ResultSet resultSet;
private java.lang.Integer updateCount;
private org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter;
private org.apache.drill.common.exceptions.CustomErrorContext errorContext;
private java.util.List columnWriters;
private java.util.List jdbcColumns;
public void <init>(javax.sql.DataSource, java.lang.String, java.util.List)
{
java.util.List v;
javax.sql.DataSource v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
v := @parameter: javax.sql.DataSource;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: javax.sql.DataSource source> = v;
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.String sql> = v;
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columns> = v;
return;
}
public boolean open(org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator)
{
java.lang.Object[] v;
java.sql.Connection v, v;
org.apache.drill.common.exceptions.CustomErrorContext v, v;
org.apache.drill.common.exceptions.UserException$Builder v, v, v, v;
org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator v;
org.apache.drill.common.exceptions.UserException v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
java.lang.Integer v;
org.apache.drill.exec.physical.resultSet.RowSetLoader v;
java.sql.SQLException v;
java.sql.ResultSet v;
int v;
javax.sql.DataSource v;
java.lang.String v, v;
boolean v;
org.slf4j.Logger v;
org.apache.drill.exec.physical.resultSet.ResultSetLoader v;
java.sql.PreparedStatement v, v, v, v;
org.apache.drill.exec.record.metadata.TupleMetadata v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
v := @parameter: org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator;
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: org.apache.drill.common.exceptions.CustomErrorContext parentErrorContext()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.common.exceptions.CustomErrorContext errorContext> = v;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: javax.sql.DataSource source>;
v = interfaceinvoke v.<javax.sql.DataSource: java.sql.Connection getConnection()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.Connection connection> = v;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.Connection connection>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.String sql>;
v = interfaceinvoke v.<java.sql.Connection: java.sql.PreparedStatement prepareStatement(java.lang.String)>(v);
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.PreparedStatement statement> = v;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.PreparedStatement statement>;
v = interfaceinvoke v.<java.sql.PreparedStatement: boolean execute()>();
if v == 0 goto label;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.PreparedStatement statement>;
v = interfaceinvoke v.<java.sql.PreparedStatement: java.sql.ResultSet getResultSet()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.ResultSet resultSet> = v;
v = specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.record.metadata.TupleMetadata buildSchema()>();
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.PreparedStatement statement>;
v = interfaceinvoke v.<java.sql.PreparedStatement: int getUpdateCount()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.Integer updateCount> = v;
v = specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.record.metadata.TupleMetadata buildUpdateQuerySchema()>();
label:
interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: void tableSchema(org.apache.drill.exec.record.metadata.TupleMetadata,boolean)>(v, 1);
v = interfaceinvoke v.<org.apache.drill.exec.physical.impl.scan.framework.SchemaNegotiator: org.apache.drill.exec.physical.resultSet.ResultSetLoader build()>();
v = interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.ResultSetLoader: org.apache.drill.exec.physical.resultSet.RowSetLoader writer()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter> = v;
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: void populateWriterArray()>();
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <org.apache.drill.common.exceptions.UserException: org.apache.drill.common.exceptions.UserException$Builder dataReadError(java.lang.Throwable)>(v);
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder message(java.lang.String,java.lang.Object[])>("The JDBC storage plugin failed while trying setup the SQL query. ", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.String sql>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(java.lang.String,java.lang.String)>("Sql", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.common.exceptions.CustomErrorContext errorContext>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(org.apache.drill.common.exceptions.CustomErrorContext)>(v);
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException build(org.slf4j.Logger)>(v);
throw v;
label:
return 1;
catch java.sql.SQLException from label to label with label;
}
public boolean next()
{
org.apache.drill.exec.physical.resultSet.RowSetLoader v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
boolean v, v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.RowSetLoader: boolean isFull()>();
if v != 0 goto label;
v = specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: boolean processRow()>();
if v != 0 goto label;
return 0;
label:
return 1;
}
private boolean processRow()
{
java.lang.Object[] v;
org.apache.drill.common.exceptions.CustomErrorContext v;
org.slf4j.Logger v;
org.apache.drill.common.exceptions.UserException$Builder v, v, v, v;
org.apache.drill.common.exceptions.UserException v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
java.sql.SQLException v;
java.sql.ResultSet v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.ResultSet resultSet>;
if v == null goto label;
v = specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: boolean processResultSetRow()>();
label:
return v;
label:
v = specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: boolean processUpdateRow()>();
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.drill.common.exceptions.UserException: org.apache.drill.common.exceptions.UserException$Builder dataReadError(java.lang.Throwable)>(v);
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder message(java.lang.String,java.lang.Object[])>("Failure while attempting to read from database.", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.String sql>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(java.lang.String,java.lang.String)>("Sql", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.common.exceptions.CustomErrorContext errorContext>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(org.apache.drill.common.exceptions.CustomErrorContext)>(v);
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException build(org.slf4j.Logger)>(v);
throw v;
catch java.sql.SQLException from label to label with label;
catch java.sql.SQLException from label to label with label;
}
private boolean processResultSetRow() throws java.sql.SQLException
{
java.util.Iterator v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
org.apache.drill.exec.physical.resultSet.RowSetLoader v, v;
java.util.List v;
java.sql.ResultSet v, v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: boolean next()>();
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.RowSetLoader: boolean start()>();
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.ResultSet resultSet>;
virtualinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcColumnWriter: void load(java.sql.ResultSet)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.RowSetLoader: void save()>();
return 1;
}
private boolean processUpdateRow()
{
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
java.lang.Integer v, v;
org.apache.drill.exec.physical.resultSet.RowSetLoader v, v, v;
java.util.List v;
org.apache.drill.exec.vector.accessor.ScalarWriter v;
int v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.Integer updateCount>;
if v != null goto label;
return 0;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.RowSetLoader: boolean start()>();
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columns>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: java.lang.String getRootSegmentPath()>();
v = interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.RowSetLoader: org.apache.drill.exec.vector.accessor.ScalarWriter scalar(java.lang.String)>(v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.Integer updateCount>;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<org.apache.drill.exec.vector.accessor.ScalarWriter: void setLong(long)>(v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
interfaceinvoke v.<org.apache.drill.exec.physical.resultSet.RowSetLoader: void save()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.Integer updateCount> = null;
return 1;
}
public void close()
{
java.lang.AutoCloseable[] v;
java.sql.Connection v;
java.sql.ResultSet v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
java.sql.PreparedStatement v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
v = newarray (java.lang.AutoCloseable)[3];
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.ResultSet resultSet>;
v[0] = v;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.PreparedStatement statement>;
v[1] = v;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.Connection connection>;
v[2] = v;
staticinvoke <org.apache.drill.common.AutoCloseables: void closeSilently(java.lang.AutoCloseable[])>(v);
return;
}
private org.apache.drill.exec.record.metadata.TupleMetadata buildSchema() throws java.sql.SQLException
{
org.apache.drill.common.exceptions.UserException v, v;
org.apache.drill.exec.record.metadata.SchemaBuilder v;
java.lang.Integer v, v;
java.sql.ResultSet v;
org.apache.drill.exec.record.metadata.TupleMetadata v;
java.util.List v, v, v, v;
java.sql.ResultSetMetaData v;
java.lang.Object[] v, v;
org.apache.drill.common.exceptions.CustomErrorContext v, v;
org.apache.drill.common.exceptions.UserException$Builder v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
java.util.ArrayList v;
int v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v;
org.apache.calcite.rel.type.RelDataTypeSystem v, v;
org.slf4j.Logger v, v, v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v;
java.lang.Object v, v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
v = new org.apache.drill.exec.record.metadata.SchemaBuilder;
specialinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: void <init>()>();
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.sql.ResultSet resultSet>;
v = interfaceinvoke v.<java.sql.ResultSet: java.sql.ResultSetMetaData getMetaData()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List jdbcColumns> = v;
v = interfaceinvoke v.<java.sql.ResultSetMetaData: int getColumnCount()>();
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columns>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v == v goto label;
v = staticinvoke <org.apache.drill.common.exceptions.UserException: org.apache.drill.common.exceptions.UserException$Builder validationError()>();
v = newarray (java.lang.Object)[2];
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columns>;
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder message(java.lang.String,java.lang.Object[])>("Expected columns count differs from the returned one.\nExpected columns: %s\nReturned columns count: %s", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.String sql>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(java.lang.String,java.lang.String)>("Sql", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.common.exceptions.CustomErrorContext errorContext>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(org.apache.drill.common.exceptions.CustomErrorContext)>(v);
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException build(org.slf4j.Logger)>(v);
throw v;
label:
v = 1;
label:
if v > v goto label;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columns>;
v = v - 1;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: java.lang.String getRootSegmentPath()>();
v = interfaceinvoke v.<java.sql.ResultSetMetaData: int getColumnType(int)>(v);
v = interfaceinvoke v.<java.sql.ResultSetMetaData: int getPrecision(int)>(v);
v = <org.apache.drill.exec.planner.types.DrillRelDataTypeSystem: org.apache.calcite.rel.type.RelDataTypeSystem DRILL_REL_DATATYPE_SYSTEM>;
v = interfaceinvoke v.<org.apache.calcite.rel.type.RelDataTypeSystem: int getMaxNumericPrecision()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = interfaceinvoke v.<java.sql.ResultSetMetaData: int getScale(int)>(v);
v = <org.apache.drill.exec.planner.types.DrillRelDataTypeSystem: org.apache.calcite.rel.type.RelDataTypeSystem DRILL_REL_DATATYPE_SYSTEM>;
v = interfaceinvoke v.<org.apache.calcite.rel.type.RelDataTypeSystem: int getMaxNumericScale()>();
v = v - 1;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap JDBC_TYPE_MAPPINGS>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger>;
v = staticinvoke <org.apache.drill.common.exceptions.UserException: org.apache.drill.common.exceptions.UserException$Builder unsupportedError()>();
v = newarray (java.lang.Object)[2];
v[0] = v;
v = staticinvoke <org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.String nameFromType(int)>(v);
v[1] = v;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder message(java.lang.String,java.lang.Object[])>("A column you queried has a data type that is not currently supported by the JDBC storage plugin. The column\'s name was %s and its JDBC data type was %s. ", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.String sql>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(java.lang.String,java.lang.String)>("Sql", v);
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(java.lang.String,java.lang.String)>("Column Name", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.common.exceptions.CustomErrorContext errorContext>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(org.apache.drill.common.exceptions.CustomErrorContext)>(v);
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException build(org.slf4j.Logger)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Ignoring column that is unsupported.", v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List jdbcColumns>;
v = new org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn;
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: void <init>(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType,int,int,int)>(v, v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType,int,int)>(v, v, v, v);
label:
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.TupleMetadata buildSchema()>();
return v;
}
private org.apache.drill.exec.record.metadata.TupleMetadata buildUpdateQuerySchema() throws java.sql.SQLException
{
java.lang.Object[] v;
org.apache.drill.common.exceptions.CustomErrorContext v;
org.apache.drill.common.exceptions.UserException$Builder v, v, v, v;
org.apache.drill.common.exceptions.UserException v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
org.apache.drill.exec.record.metadata.SchemaBuilder v, v;
java.lang.Integer v;
java.util.ArrayList v;
org.apache.drill.common.types.TypeProtos$MinorType v;
int v, v;
java.lang.String v, v;
org.apache.calcite.rel.type.RelDataTypeSystem v;
org.slf4j.Logger v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn v;
org.apache.drill.exec.record.metadata.TupleMetadata v;
java.util.List v, v, v, v;
java.lang.Object v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columns>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v == 1 goto label;
v = staticinvoke <org.apache.drill.common.exceptions.UserException: org.apache.drill.common.exceptions.UserException$Builder validationError()>();
v = newarray (java.lang.Object)[2];
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columns>;
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v[1] = v;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder message(java.lang.String,java.lang.Object[])>("Expected columns count differs from the returned one.\nExpected columns: %s\nReturned columns count: %s", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.lang.String sql>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(java.lang.String,java.lang.String)>("Sql", v);
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.common.exceptions.CustomErrorContext errorContext>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException$Builder addContext(org.apache.drill.common.exceptions.CustomErrorContext)>(v);
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.drill.common.exceptions.UserException$Builder: org.apache.drill.common.exceptions.UserException build(org.slf4j.Logger)>(v);
throw v;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columns>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: java.lang.String getRootSegmentPath()>();
v = <org.apache.drill.exec.planner.types.DrillRelDataTypeSystem: org.apache.calcite.rel.type.RelDataTypeSystem DRILL_REL_DATATYPE_SYSTEM>;
v = interfaceinvoke v.<org.apache.calcite.rel.type.RelDataTypeSystem: int getMaxNumericPrecision()>();
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType BIGINT>;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List jdbcColumns> = v;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List jdbcColumns>;
v = new org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn;
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: void <init>(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType,int,int,int)>(v, v, 0, 0, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.drill.exec.record.metadata.SchemaBuilder;
specialinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: void <init>()>();
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.SchemaBuilder addNullable(java.lang.String,org.apache.drill.common.types.TypeProtos$MinorType,int,int)>(v, v, v, 0);
v = virtualinvoke v.<org.apache.drill.exec.record.metadata.SchemaBuilder: org.apache.drill.exec.record.metadata.TupleMetadata buildSchema()>();
return v;
}
private void populateWriterArray()
{
org.apache.drill.exec.store.jdbc.writers.JdbcVarbinaryWriter v;
org.apache.drill.exec.store.jdbc.writers.JdbcDateWriter v;
org.apache.drill.exec.store.jdbc.writers.JdbcBigintWriter v;
org.apache.drill.exec.store.jdbc.writers.JdbcTimestampWriter v;
java.util.ArrayList v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.common.types.TypeProtos$MinorType v, v;
int[] v;
boolean v;
org.apache.drill.exec.store.jdbc.writers.JdbcBitWriter v;
java.util.List v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.jdbc.writers.JdbcIntWriter v;
org.apache.drill.exec.store.jdbc.writers.JdbcFloatWriter v;
org.apache.drill.exec.store.jdbc.JdbcBatchReader v;
org.apache.drill.exec.physical.resultSet.RowSetLoader v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.jdbc.writers.JdbcVarcharWriter v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.jdbc.writers.JdbcDoubleWriter v;
org.apache.drill.exec.store.jdbc.writers.JdbcTimeWriter v;
com.google.protobuf.Descriptors$EnumDescriptor v;
org.slf4j.Logger v;
java.util.Iterator v;
org.apache.drill.exec.store.jdbc.writers.JdbcVardecimalWriter v;
java.lang.Object v;
v := @this: org.apache.drill.exec.store.jdbc.JdbcBatchReader;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters> = v;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List jdbcColumns>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader$1: int[] $SwitchMap$org$apache$drill$common$types$TypeProtos$MinorType>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: org.apache.drill.common.types.TypeProtos$MinorType type>;
v = virtualinvoke v.<org.apache.drill.common.types.TypeProtos$MinorType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
case 8: goto label;
case 9: goto label;
case 10: goto label;
case 11: goto label;
default: goto label;
};
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcVarcharWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcVarcharWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcFloatWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcFloatWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcDoubleWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcDoubleWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcIntWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcIntWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcBigintWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcBigintWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcDateWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcDateWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcTimeWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcTimeWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcTimestampWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcTimestampWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcVarbinaryWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcVarbinaryWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcBitWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcBitWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int)>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: java.util.List columnWriters>;
v = new org.apache.drill.exec.store.jdbc.writers.JdbcVardecimalWriter;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.exec.physical.resultSet.RowSetLoader rowWriter>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int colPosition>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int scale>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: int precision>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.writers.JdbcVardecimalWriter: void <init>(java.lang.String,org.apache.drill.exec.physical.resultSet.RowSetLoader,int,int,int)>(v, v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger>;
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: org.apache.drill.common.types.TypeProtos$MinorType type>;
v = virtualinvoke v.<org.apache.drill.common.types.TypeProtos$MinorType: com.google.protobuf.Descriptors$EnumDescriptor getDescriptorForType()>();
v = v.<org.apache.drill.exec.store.jdbc.JdbcBatchReader$JdbcColumn: java.lang.String colName>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Unsupported data type {} found at column {}", v, v);
goto label;
label:
return;
}
private static java.lang.String nameFromType(int)
{
java.lang.Integer v;
int v, v, v, v, v;
java.lang.String v, v, v;
boolean v;
org.slf4j.Logger v;
java.lang.reflect.Field v;
java.lang.Exception v;
java.lang.reflect.Field[] v;
java.lang.Class v, v, v;
v := @parameter: int;
label:
v = class "Ljava/sql/Types;";
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Field[] getFields()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.reflect.Field: int getModifiers()>();
v = staticinvoke <java.lang.reflect.Modifier: boolean isStatic(int)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.reflect.Field: java.lang.Class getType()>();
v = <java.lang.Integer: java.lang.Class TYPE>;
if v != v goto label;
v = virtualinvoke v.<java.lang.reflect.Field: int getInt(java.lang.Object)>(null);
if v != v goto label;
v = virtualinvoke v.<java.lang.reflect.Field: java.lang.String getName()>();
label:
return v;
label:
v = v + 1;
goto label;
label:
v := @caughtexception;
v = <org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Unable to SQL type {} into String: {}", v, v);
label:
v = staticinvoke <java.lang.Integer: java.lang.String toString(int)>(v);
return v;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.IllegalAccessException from label to label with label;
catch java.lang.IllegalArgumentException from label to label with label;
catch java.lang.IllegalAccessException from label to label with label;
}
static void <clinit>()
{
java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.common.types.TypeProtos$MinorType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v, v, v, v, v;
org.slf4j.Logger v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/drill/exec/store/jdbc/JdbcBatchReader;");
<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.slf4j.Logger logger> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder builder()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(8);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(6);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT4>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -6;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType INT>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(5);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType INT>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType INT>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -5;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType BIGINT>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARCHAR>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(12);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARCHAR>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARCHAR>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2005);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARCHAR>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -15;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARCHAR>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -9;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARCHAR>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -16;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARCHAR>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -3;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARBINARY>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -4;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARBINARY>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2004);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARBINARY>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType VARDECIMAL>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(7);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType FLOAT8>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(91);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType DATE>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(92);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType TIME>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(93);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType TIMESTAMP>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(16);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType BIT>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = (int) -7;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.common.types.TypeProtos$MinorType: org.apache.drill.common.types.TypeProtos$MinorType BIT>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap build()>();
<org.apache.drill.exec.store.jdbc.JdbcBatchReader: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap JDBC_TYPE_MAPPINGS> = v;
return;
}
}