public class org.apache.drill.jdbc.impl.DrillConnectionImpl extends oadd.org.apache.calcite.avatica.AvaticaConnection implements org.apache.drill.jdbc.DrillConnection
{
private static final org.slf4j.Logger logger;
final org.apache.drill.jdbc.impl.DrillStatementRegistry openStatementsRegistry;
final org.apache.drill.jdbc.DrillConnectionConfig config;
private final oadd.org.apache.drill.exec.client.DrillClient client;
private final oadd.org.apache.drill.exec.memory.BufferAllocator allocator;
private oadd.org.apache.drill.exec.server.Drillbit bit;
private oadd.org.apache.drill.exec.server.RemoteServiceSet serviceSet;
public void <init>(org.apache.drill.jdbc.impl.DriverImpl, oadd.org.apache.calcite.avatica.AvaticaFactory, java.lang.String, java.util.Properties) throws java.sql.SQLException
{
oadd.org.apache.drill.exec.rpc.RpcException v;
oadd.org.apache.drill.exec.client.InvalidConnectionInfoException v;
org.apache.drill.jdbc.DrillConnectionConfig v, v, v, v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
boolean v, v;
java.lang.ThreadLocal v;
java.lang.Exception v, v;
oadd.org.apache.drill.exec.exception.OutOfMemoryException v;
org.apache.drill.jdbc.impl.DriverImpl v;
oadd.org.apache.drill.exec.memory.BufferAllocator v, v, v;
oadd.org.apache.drill.exec.coord.ClusterCoordinator v;
java.sql.SQLNonTransientConnectionException v, v, v, v;
java.lang.Throwable v;
oadd.org.apache.drill.common.config.DrillConfig v, v, v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v, v;
java.sql.SQLException v, v, v, v;
oadd.org.apache.drill.exec.server.Drillbit v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
oadd.org.apache.calcite.avatica.AvaticaFactory v;
org.apache.drill.jdbc.impl.DrillStatementRegistry v;
oadd.org.apache.drill.common.exceptions.UserException v;
java.util.Properties v;
oadd.org.apache.drill.exec.client.DrillClient v, v, v, v, v;
java.lang.ClassNotFoundException v;
java.lang.Object v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: org.apache.drill.jdbc.impl.DriverImpl;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaFactory;
v := @parameter: java.lang.String;
v := @parameter: java.util.Properties;
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void <init>(oadd.org.apache.calcite.avatica.UnregisteredDriver,oadd.org.apache.calcite.avatica.AvaticaFactory,java.lang.String,java.util.Properties)>(v, v, v, v);
v = new org.apache.drill.jdbc.impl.DrillStatementRegistry;
specialinvoke v.<org.apache.drill.jdbc.impl.DrillStatementRegistry: void <init>()>();
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.impl.DrillStatementRegistry openStatementsRegistry> = v;
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void setTransactionIsolation(int)>(0);
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void setAutoCommit(boolean)>(1);
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void setReadOnly(boolean)>(0);
v = new org.apache.drill.jdbc.DrillConnectionConfig;
specialinvoke v.<org.apache.drill.jdbc.DrillConnectionConfig: void <init>(java.util.Properties)>(v);
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.DrillConnectionConfig config> = v;
label:
v = null;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.DrillConnectionConfig config>;
v = virtualinvoke v.<org.apache.drill.jdbc.DrillConnectionConfig: boolean isLocal()>();
if v == 0 goto label;
label:
staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String)>("org.eclipse.jetty.server.Handler");
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLNonTransientConnectionException;
specialinvoke v.<java.sql.SQLNonTransientConnectionException: void <init>(java.lang.String)>("Running Drill in embedded mode using Drill\'s jdbc-all JDBC driver Jar file alone is not supported.");
throw v;
label:
v = staticinvoke <oadd.org.apache.drill.common.config.DrillConfig: oadd.org.apache.drill.common.config.DrillConfig create(java.util.Properties)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.memory.RootAllocatorFactory: oadd.org.apache.drill.exec.memory.BufferAllocator newRoot(oadd.org.apache.drill.common.config.DrillConfig)>(v);
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.memory.BufferAllocator allocator> = v;
v = <org.apache.drill.jdbc.impl.GlobalServiceSetReference: java.lang.ThreadLocal SETS>;
v = virtualinvoke v.<java.lang.ThreadLocal: java.lang.Object get()>();
if v != null goto label;
v = staticinvoke <oadd.org.apache.drill.exec.server.RemoteServiceSet: oadd.org.apache.drill.exec.server.RemoteServiceSet getLocalServiceSet()>();
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.RemoteServiceSet serviceSet> = v;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.RemoteServiceSet serviceSet>;
label:
v = new oadd.org.apache.drill.exec.server.Drillbit;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.RemoteServiceSet serviceSet>;
specialinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.server.RemoteServiceSet)>(v, v);
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.Drillbit bit> = v;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.Drillbit bit>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void run()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLException;
v = virtualinvoke v.<oadd.org.apache.drill.common.exceptions.UserException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failure in starting embedded Drillbit: \u0001");
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new java.sql.SQLException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Exception)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failure in starting embedded Drillbit: \u0001");
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.RemoteServiceSet serviceSet> = null;
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.Drillbit bit> = null;
label:
v = new oadd.org.apache.drill.exec.client.DrillClient;
v = virtualinvoke v.<oadd.org.apache.drill.exec.server.RemoteServiceSet: oadd.org.apache.drill.exec.coord.ClusterCoordinator getCoordinator()>();
specialinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void <init>(oadd.org.apache.drill.common.config.DrillConfig,oadd.org.apache.drill.exec.coord.ClusterCoordinator)>(v, v);
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client> = v;
goto label;
label:
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.DrillConnectionConfig config>;
v = virtualinvoke v.<org.apache.drill.jdbc.DrillConnectionConfig: boolean isDirect()>();
if v == 0 goto label;
v = staticinvoke <oadd.org.apache.drill.common.config.DrillConfig: oadd.org.apache.drill.common.config.DrillConfig forClient()>();
v = staticinvoke <oadd.org.apache.drill.exec.memory.RootAllocatorFactory: oadd.org.apache.drill.exec.memory.BufferAllocator newRoot(oadd.org.apache.drill.common.config.DrillConfig)>(v);
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.memory.BufferAllocator allocator> = v;
v = new oadd.org.apache.drill.exec.client.DrillClient;
specialinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void <init>(oadd.org.apache.drill.common.config.DrillConfig,boolean)>(v, 1);
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client> = v;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.DrillConnectionConfig config>;
v = virtualinvoke v.<org.apache.drill.jdbc.DrillConnectionConfig: java.lang.String getZookeeperConnectionString()>();
goto label;
label:
v = staticinvoke <oadd.org.apache.drill.common.config.DrillConfig: oadd.org.apache.drill.common.config.DrillConfig forClient()>();
v = staticinvoke <oadd.org.apache.drill.exec.memory.RootAllocatorFactory: oadd.org.apache.drill.exec.memory.BufferAllocator newRoot(oadd.org.apache.drill.common.config.DrillConfig)>(v);
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.memory.BufferAllocator allocator> = v;
v = new oadd.org.apache.drill.exec.client.DrillClient;
specialinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void <init>()>();
v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client> = v;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.DrillConnectionConfig config>;
v = virtualinvoke v.<org.apache.drill.jdbc.DrillConnectionConfig: java.lang.String getZookeeperConnectionString()>();
label:
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void setClientName(java.lang.String)>("Apache Drill JDBC Driver");
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: void connect(java.lang.String,java.util.Properties)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLNonTransientConnectionException;
specialinvoke v.<java.sql.SQLNonTransientConnectionException: void <init>(java.lang.String,java.lang.Throwable)>("Failure creating root allocator", v);
throw v;
label:
v := @caughtexception;
v = new java.sql.SQLNonTransientConnectionException;
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.InvalidConnectionInfoException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid parameter in connection string: \u0001");
specialinvoke v.<java.sql.SQLNonTransientConnectionException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new java.sql.SQLNonTransientConnectionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (oadd.org.apache.drill.exec.rpc.RpcException)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failure in connecting to Drill: \u0001");
specialinvoke v.<java.sql.SQLNonTransientConnectionException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = new java.sql.SQLException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Exception)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failure in creating DrillConnectionImpl: \u0001");
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void close()>();
throw v;
label:
return;
catch java.lang.ClassNotFoundException from label to label with label;
catch oadd.org.apache.drill.common.exceptions.UserException from label to label with label;
catch java.lang.Exception from label to label with label;
catch oadd.org.apache.drill.exec.exception.OutOfMemoryException from label to label with label;
catch oadd.org.apache.drill.exec.client.InvalidConnectionInfoException from label to label with label;
catch oadd.org.apache.drill.exec.rpc.RpcException from label to label with label;
catch java.sql.SQLException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected java.sql.ResultSet createResultSet(oadd.org.apache.calcite.avatica.Meta$MetaResultSet, oadd.org.apache.calcite.avatica.QueryState) throws java.sql.SQLException
{
java.sql.ResultSet v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
oadd.org.apache.calcite.avatica.QueryState v;
oadd.org.apache.calcite.avatica.Meta$MetaResultSet v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: oadd.org.apache.calcite.avatica.Meta$MetaResultSet;
v := @parameter: oadd.org.apache.calcite.avatica.QueryState;
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.ResultSet createResultSet(oadd.org.apache.calcite.avatica.Meta$MetaResultSet,oadd.org.apache.calcite.avatica.QueryState)>(v, v);
return v;
}
protected oadd.org.apache.calcite.avatica.Meta$ExecuteResult prepareAndExecuteInternal(oadd.org.apache.calcite.avatica.AvaticaStatement, java.lang.String, long) throws java.sql.SQLException, oadd.org.apache.calcite.avatica.NoSuchStatementException
{
java.lang.Throwable v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
long v;
java.lang.RuntimeException v;
java.lang.String v;
oadd.org.apache.calcite.avatica.Meta$ExecuteResult v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaStatement;
v := @parameter: java.lang.String;
v := @parameter: long;
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ExecuteResult prepareAndExecuteInternal(oadd.org.apache.calcite.avatica.AvaticaStatement,java.lang.String,long)>(v, v, v);
label:
return v;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.RuntimeException: java.lang.Throwable getCause()>();
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Throwables: void throwIfInstanceOf(java.lang.Throwable,java.lang.Class)>(v, class "Ljava/sql/SQLException;");
throw v;
catch java.lang.RuntimeException from label to label with label;
}
protected void checkOpen() throws org.apache.drill.jdbc.AlreadyClosedSqlException
{
org.apache.drill.jdbc.AlreadyClosedSqlException v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
boolean v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v = virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: boolean isClosed()>();
if v == 0 goto label;
v = new org.apache.drill.jdbc.AlreadyClosedSqlException;
specialinvoke v.<org.apache.drill.jdbc.AlreadyClosedSqlException: void <init>(java.lang.String)>("Connection is already closed.");
throw v;
label:
return;
}
public org.apache.drill.jdbc.DrillConnectionConfig getConfig()
{
org.apache.drill.jdbc.DrillConnectionConfig v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.DrillConnectionConfig config>;
return v;
}
oadd.org.apache.drill.exec.memory.BufferAllocator getAllocator()
{
oadd.org.apache.drill.exec.memory.BufferAllocator v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
return v;
}
public oadd.org.apache.drill.exec.client.DrillClient getClient()
{
oadd.org.apache.drill.exec.client.DrillClient v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
return v;
}
public void setAutoCommit(boolean) throws java.sql.SQLException
{
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
boolean v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: boolean;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
return;
}
public void commit() throws java.sql.SQLException
{
org.apache.drill.jdbc.JdbcApiSqlException v;
java.sql.SQLFeatureNotSupportedException v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
boolean v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
v = virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: boolean getAutoCommit()>();
if v == 0 goto label;
v = new org.apache.drill.jdbc.JdbcApiSqlException;
specialinvoke v.<org.apache.drill.jdbc.JdbcApiSqlException: void <init>(java.lang.String)>("Can\'t call commit() in auto-commit mode.");
throw v;
label:
v = new java.sql.SQLFeatureNotSupportedException;
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String)>("Connection.commit() is not supported.  (Drill is not transactional.)");
throw v;
}
public void rollback() throws java.sql.SQLException
{
org.apache.drill.jdbc.JdbcApiSqlException v;
java.sql.SQLFeatureNotSupportedException v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
boolean v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
v = virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: boolean getAutoCommit()>();
if v == 0 goto label;
v = new org.apache.drill.jdbc.JdbcApiSqlException;
specialinvoke v.<org.apache.drill.jdbc.JdbcApiSqlException: void <init>(java.lang.String)>("Can\'t call rollback() in auto-commit mode.");
throw v;
label:
v = new java.sql.SQLFeatureNotSupportedException;
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String)>("Connection.rollback() is not supported.  (Drill is not transactional.)");
throw v;
}
public boolean isClosed()
{
oadd.org.apache.drill.common.exceptions.DrillRuntimeException v;
java.sql.SQLException v;
oadd.org.apache.drill.exec.client.DrillClient v, v;
java.lang.Class v, v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
boolean v, v, v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean isClosed()>();
if v == 0 goto label;
label:
return 1;
label:
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
if v == null goto label;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: boolean connectionIsActive()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
goto label;
label:
v = 0;
label:
return v;
label:
v := @caughtexception;
v = new oadd.org.apache.drill.common.exceptions.DrillRuntimeException;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.Class getSuperclass()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class,java.sql.SQLException)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unexpected exception from \u.isClosed(): \u0001");
specialinvoke v.<oadd.org.apache.drill.common.exceptions.DrillRuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.sql.SQLException from label to label with label;
catch java.sql.SQLException from label to label with label;
}
public java.sql.Savepoint setSavepoint() throws java.sql.SQLException
{
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
java.sql.SQLFeatureNotSupportedException v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
v = new java.sql.SQLFeatureNotSupportedException;
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String)>("Savepoints are not supported. (Drill is not transactional.)");
throw v;
}
public java.sql.Savepoint setSavepoint(java.lang.String) throws java.sql.SQLException
{
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
java.sql.SQLFeatureNotSupportedException v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
v = new java.sql.SQLFeatureNotSupportedException;
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String)>("Savepoints are not supported. (Drill is not transactional.)");
throw v;
}
public void rollback(java.sql.Savepoint) throws java.sql.SQLException
{
java.sql.Savepoint v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
java.sql.SQLFeatureNotSupportedException v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.sql.Savepoint;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
v = new java.sql.SQLFeatureNotSupportedException;
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String)>("Savepoints are not supported. (Drill is not transactional.)");
throw v;
}
public void releaseSavepoint(java.sql.Savepoint) throws java.sql.SQLException
{
java.sql.Savepoint v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
java.sql.SQLFeatureNotSupportedException v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.sql.Savepoint;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
v = new java.sql.SQLFeatureNotSupportedException;
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String)>("Savepoints are not supported. (Drill is not transactional.)");
throw v;
}
private java.lang.String isolationValueToString(int)
{
int v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: int;
tableswitch(v)
{
case 0: goto label;
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;
default: goto label;
};
label:
return "TRANSACTION_NONE";
label:
return "TRANSACTION_READ_UNCOMMITTED";
label:
return "TRANSACTION_READ_COMMITTED";
label:
return "TRANSACTION_REPEATABLE_READ";
label:
return "TRANSACTION_SERIALIZABLE";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("<Unknown transaction isolation level value \u0001>");
return v;
}
public void setTransactionIsolation(int) throws java.sql.SQLException
{
java.sql.SQLFeatureNotSupportedException v;
org.apache.drill.jdbc.JdbcApiSqlException v;
int v, v;
java.lang.String v, v, v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: int;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
tableswitch(v)
{
case 0: goto label;
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;
default: goto label;
};
label:
v = new java.sql.SQLFeatureNotSupportedException;
v = specialinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: java.lang.String isolationValueToString(int)>(v);
v = virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: int getTransactionIsolation()>();
v = specialinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: java.lang.String isolationValueToString(int)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Can\'t change transaction isolation level to Connection.\u (from Connection.\u). (Drill is not transactional.)");
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new org.apache.drill.jdbc.JdbcApiSqlException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid transaction isolation level value \u0001");
specialinvoke v.<org.apache.drill.jdbc.JdbcApiSqlException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void setNetworkTimeout(java.util.concurrent.Executor, int) throws org.apache.drill.jdbc.JdbcApiSqlException, java.sql.SQLFeatureNotSupportedException
{
java.util.concurrent.Executor v;
java.sql.SQLFeatureNotSupportedException v;
org.apache.drill.jdbc.InvalidParameterSqlException v, v;
int v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: int;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
if null != v goto label;
v = new org.apache.drill.jdbc.InvalidParameterSqlException;
specialinvoke v.<org.apache.drill.jdbc.InvalidParameterSqlException: void <init>(java.lang.String)>("Invalid (null) \"executor\" parameter to setNetworkTimeout(...)");
throw v;
label:
if v >= 0 goto label;
v = new org.apache.drill.jdbc.InvalidParameterSqlException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Invalid (negative) \"milliseconds\" parameter to setNetworkTimeout(...) (\u)");
specialinvoke v.<org.apache.drill.jdbc.InvalidParameterSqlException: void <init>(java.lang.String)>(v);
throw v;
label:
if 0 == v goto label;
v = new java.sql.SQLFeatureNotSupportedException;
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String)>("Setting network timeout is not supported.");
throw v;
label:
return;
}
public int getNetworkTimeout() throws org.apache.drill.jdbc.AlreadyClosedSqlException
{
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
return 0;
}
public org.apache.drill.jdbc.impl.DrillStatementImpl createStatement(int, int, int) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaStatement v;
int v, v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaStatement createStatement(int,int,int)>(v, v, v);
return v;
}
public java.util.TimeZone getTimeZone()
{
org.apache.drill.jdbc.DrillConnectionConfig v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
java.util.TimeZone v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.DrillConnectionConfig config>;
v = virtualinvoke v.<org.apache.drill.jdbc.DrillConnectionConfig: java.util.TimeZone getTimeZone()>();
return v;
}
public java.sql.CallableStatement prepareCall(java.lang.String) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.sql.CallableStatement v;
java.lang.String v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.CallableStatement prepareCall(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.lang.String nativeSQL(java.lang.String) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.lang.String v, v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.lang.String nativeSQL(java.lang.String)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.CallableStatement prepareCall(java.lang.String, int, int) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
int v, v;
java.sql.CallableStatement v;
java.lang.String v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.CallableStatement prepareCall(java.lang.String,int,int)>(v, v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.util.Map getTypeMap() throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.util.Map v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Map getTypeMap()>();
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public void setTypeMap(java.util.Map) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.util.Map v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.util.Map;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void setTypeMap(java.util.Map)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.CallableStatement prepareCall(java.lang.String, int, int, int) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
int v, v, v;
java.sql.CallableStatement v;
java.lang.String v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.CallableStatement prepareCall(java.lang.String,int,int,int)>(v, v, v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String, int) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
int v;
java.lang.String v, v;
java.sql.PreparedStatement v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
v := @parameter: int;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.PreparedStatement prepareStatement(java.lang.String,int)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String, int[]) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
int[] v;
java.sql.SQLFeatureNotSupportedException v;
java.lang.String v, v;
java.sql.PreparedStatement v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
v := @parameter: int[];
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.PreparedStatement prepareStatement(java.lang.String,int[])>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String, java.lang.String[]) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.lang.String[] v;
java.lang.String v, v;
java.sql.PreparedStatement v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String[];
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.PreparedStatement prepareStatement(java.lang.String,java.lang.String[])>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.Clob createClob() throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
java.sql.Clob v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.Clob createClob()>();
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.Blob createBlob() throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.lang.String v;
java.sql.Blob v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.Blob createBlob()>();
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.NClob createNClob() throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.lang.String v;
java.sql.NClob v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.NClob createNClob()>();
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.SQLXML createSQLXML() throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.sql.SQLXML v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.SQLXML createSQLXML()>();
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public boolean isValid(int) throws java.sql.SQLException
{
java.lang.Object[] v;
java.lang.Integer v;
java.sql.SQLException v;
int v;
oadd.org.apache.drill.exec.client.DrillClient v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
boolean v, v, v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: int;
if v >= 0 goto label;
v = new java.sql.SQLException;
v = newarray (java.lang.Object)[1];
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Invalid timeout (%d<0).", v);
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: boolean isClosed()>();
if v != 0 goto label;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: boolean hasPing(long)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void setClientInfo(java.lang.String, java.lang.String) throws java.sql.SQLClientInfoException
{
java.lang.UnsupportedOperationException v;
java.sql.SQLFeatureNotSupportedException v;
java.sql.SQLClientInfoException v, v;
org.apache.drill.jdbc.AlreadyClosedSqlException v;
java.lang.String v, v, v, v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
label:
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLClientInfoException;
v = virtualinvoke v.<org.apache.drill.jdbc.AlreadyClosedSqlException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLClientInfoException: void <init>(java.lang.String,java.util.Map,java.lang.Throwable)>(v, null, v);
throw v;
label:
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void setClientInfo(java.lang.String,java.lang.String)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
v = new java.sql.SQLClientInfoException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLClientInfoException: void <init>(java.lang.String,java.util.Map,java.lang.Throwable)>(v, null, v);
throw v;
label:
return;
catch org.apache.drill.jdbc.AlreadyClosedSqlException from label to label with label;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public void setClientInfo(java.util.Properties) throws java.sql.SQLClientInfoException
{
java.lang.UnsupportedOperationException v;
java.util.Properties v;
java.sql.SQLFeatureNotSupportedException v;
java.sql.SQLClientInfoException v, v;
org.apache.drill.jdbc.AlreadyClosedSqlException v;
java.lang.String v, v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.util.Properties;
label:
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLClientInfoException;
v = virtualinvoke v.<org.apache.drill.jdbc.AlreadyClosedSqlException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLClientInfoException: void <init>(java.lang.String,java.util.Map,java.lang.Throwable)>(v, null, v);
throw v;
label:
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void setClientInfo(java.util.Properties)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
v = new java.sql.SQLClientInfoException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLClientInfoException: void <init>(java.lang.String,java.util.Map,java.lang.Throwable)>(v, null, v);
throw v;
label:
return;
catch org.apache.drill.jdbc.AlreadyClosedSqlException from label to label with label;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public java.sql.Struct createStruct(java.lang.String, java.lang.Object[]) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.lang.Object[] v;
java.sql.SQLFeatureNotSupportedException v;
java.sql.Struct v;
java.lang.String v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object[];
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.Struct createStruct(java.lang.String,java.lang.Object[])>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.UnsupportedOperationException from label to label with label;
}
public void setSchema(java.lang.String) throws java.sql.SQLException
{
java.lang.Object[] v;
oadd.org.apache.drill.exec.rpc.RpcException v;
oadd.org.apache.drill.exec.proto.UserBitShared$QueryType v;
java.sql.SQLException v;
oadd.org.apache.drill.exec.client.DrillClient v;
java.lang.String v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
v = <oadd.org.apache.drill.exec.proto.UserBitShared$QueryType: oadd.org.apache.drill.exec.proto.UserBitShared$QueryType SQL>;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("use %s", v);
virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: java.util.List runQuery(oadd.org.apache.drill.exec.proto.UserBitShared$QueryType,java.lang.String)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLException;
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String,java.lang.Throwable)>("Error when setting schema", v);
throw v;
label:
return;
catch oadd.org.apache.drill.exec.rpc.RpcException from label to label with label;
}
public java.lang.String getSchema() throws java.sql.SQLException
{
oadd.org.apache.drill.exec.rpc.DrillRpcFuture v;
oadd.org.apache.drill.exec.proto.UserProtos$RequestStatus v, v;
java.sql.SQLException v, v;
java.lang.String v, v, v, v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
boolean v, v;
oadd.org.apache.drill.exec.proto.UserProtos$ServerMeta v;
java.lang.Exception v;
oadd.org.apache.drill.exec.proto.UserBitShared$DrillPBError v;
oadd.org.apache.drill.exec.client.DrillClient v;
java.lang.Object v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillClient: oadd.org.apache.drill.exec.rpc.DrillRpcFuture getServerMeta()>();
v = interfaceinvoke v.<oadd.org.apache.drill.exec.rpc.DrillRpcFuture: java.lang.Object get()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$GetServerMetaResp: oadd.org.apache.drill.exec.proto.UserProtos$RequestStatus getStatus()>();
v = <oadd.org.apache.drill.exec.proto.UserProtos$RequestStatus: oadd.org.apache.drill.exec.proto.UserProtos$RequestStatus OK>;
if v == v goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$GetServerMetaResp: oadd.org.apache.drill.exec.proto.UserBitShared$DrillPBError getError()>();
v = new java.sql.SQLException;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserBitShared$DrillPBError: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Error when getting server meta: \u0001");
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$GetServerMetaResp: oadd.org.apache.drill.exec.proto.UserProtos$ServerMeta getServerMeta()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$ServerMeta: boolean hasCurrentSchema()>();
if v == 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.proto.UserProtos$ServerMeta: java.lang.String getCurrentSchema()>();
goto label;
label:
v = null;
label:
v = staticinvoke <oadd.org.apache.commons.lang.StringUtils: boolean isEmpty(java.lang.CharSequence)>(v);
if v == 0 goto label;
v = null;
goto label;
label:
v = v;
label:
return v;
label:
v := @caughtexception;
v = new java.sql.SQLException;
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String,java.lang.Throwable)>("Error when getting server meta", v);
throw v;
catch java.lang.InterruptedException from label to label with label;
catch java.util.concurrent.ExecutionException from label to label with label;
}
public void abort(java.util.concurrent.Executor) throws java.sql.SQLException
{
java.lang.UnsupportedOperationException v;
java.util.concurrent.Executor v;
java.sql.SQLFeatureNotSupportedException v;
java.lang.String v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v := @parameter: java.util.concurrent.Executor;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: void checkOpen()>();
label:
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void abort(java.util.concurrent.Executor)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLFeatureNotSupportedException;
v = virtualinvoke v.<java.lang.UnsupportedOperationException: java.lang.String getMessage()>();
specialinvoke v.<java.sql.SQLFeatureNotSupportedException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.UnsupportedOperationException from label to label with label;
}
oadd.org.apache.calcite.avatica.UnregisteredDriver getDriver()
{
oadd.org.apache.calcite.avatica.UnregisteredDriver v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.calcite.avatica.UnregisteredDriver driver>;
return v;
}
oadd.org.apache.calcite.avatica.AvaticaFactory getFactory()
{
oadd.org.apache.calcite.avatica.AvaticaFactory v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.calcite.avatica.AvaticaFactory factory>;
return v;
}
private static void closeOrWarn(java.lang.AutoCloseable, java.lang.String, org.slf4j.Logger)
{
java.lang.String v;
org.slf4j.Logger v;
java.lang.AutoCloseable v;
v := @parameter: java.lang.AutoCloseable;
v := @parameter: java.lang.String;
v := @parameter: org.slf4j.Logger;
if v != null goto label;
return;
label:
return;
}
public void close() throws java.sql.SQLException
{
org.slf4j.Logger v, v, v;
oadd.org.apache.drill.exec.server.RemoteServiceSet v;
oadd.org.apache.drill.exec.server.Drillbit v, v;
oadd.org.apache.drill.exec.memory.BufferAllocator v;
oadd.org.apache.drill.exec.client.DrillClient v;
org.apache.drill.jdbc.impl.DrillStatementRegistry v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void close()>();
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.apache.drill.jdbc.impl.DrillStatementRegistry openStatementsRegistry>;
virtualinvoke v.<org.apache.drill.jdbc.impl.DrillStatementRegistry: void close()>();
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.client.DrillClient client>;
v = <org.apache.drill.jdbc.impl.DrillConnectionImpl: org.slf4j.Logger logger>;
staticinvoke <org.apache.drill.jdbc.impl.DrillConnectionImpl: void closeOrWarn(java.lang.AutoCloseable,java.lang.String,org.slf4j.Logger)>(v, "Exception while closing client.", v);
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.memory.BufferAllocator allocator>;
v = <org.apache.drill.jdbc.impl.DrillConnectionImpl: org.slf4j.Logger logger>;
staticinvoke <org.apache.drill.jdbc.impl.DrillConnectionImpl: void closeOrWarn(java.lang.AutoCloseable,java.lang.String,org.slf4j.Logger)>(v, "Exception while closing allocator.", v);
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.Drillbit bit>;
if v == null goto label;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.Drillbit bit>;
virtualinvoke v.<oadd.org.apache.drill.exec.server.Drillbit: void close()>();
label:
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.RemoteServiceSet serviceSet>;
v = <org.apache.drill.jdbc.impl.DrillConnectionImpl: org.slf4j.Logger logger>;
staticinvoke <org.apache.drill.jdbc.impl.DrillConnectionImpl: void closeOrWarn(java.lang.AutoCloseable,java.lang.String,org.slf4j.Logger)>(v, "Exception while closing service set.", v);
return;
}
protected oadd.org.apache.drill.exec.server.Drillbit getDrillbit()
{
oadd.org.apache.drill.exec.server.Drillbit v;
org.apache.drill.jdbc.impl.DrillConnectionImpl v;
v := @this: org.apache.drill.jdbc.impl.DrillConnectionImpl;
v = v.<org.apache.drill.jdbc.impl.DrillConnectionImpl: oadd.org.apache.drill.exec.server.Drillbit bit>;
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/drill/jdbc/impl/DrillConnectionImpl;");
<org.apache.drill.jdbc.impl.DrillConnectionImpl: org.slf4j.Logger logger> = v;
return;
}
}