public abstract class oadd.org.apache.calcite.avatica.AvaticaConnection extends java.lang.Object implements java.sql.Connection
{
public static final java.lang.String ROWCOUNT_COLUMN_NAME;
public static final java.lang.String NUM_EXECUTE_RETRIES_KEY;
public static final java.lang.String NUM_EXECUTE_RETRIES_DEFAULT;
public static final java.lang.String PLAN_COLUMN_NAME;
public static final oadd.org.apache.calcite.avatica.Helper HELPER;
protected int statementCount;
private boolean closed;
private int holdability;
private int networkTimeout;
private oadd.org.apache.calcite.avatica.remote.KerberosConnection kerberosConnection;
private oadd.org.apache.calcite.avatica.remote.Service service;
public final java.lang.String id;
public final oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle;
protected final oadd.org.apache.calcite.avatica.UnregisteredDriver driver;
protected final oadd.org.apache.calcite.avatica.AvaticaFactory factory;
final java.lang.String url;
protected final java.util.Properties info;
protected final oadd.org.apache.calcite.avatica.Meta meta;
protected final oadd.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData metaData;
public final java.util.Map properties;
public final java.util.Map statementMap;
final java.util.Map flagMap;
protected final long maxRetriesPerExecute;
protected final boolean transparentReconnectEnabled;
static final boolean $assertionsDisabled;
protected void <init>(oadd.org.apache.calcite.avatica.UnregisteredDriver, oadd.org.apache.calcite.avatica.AvaticaFactory, java.lang.String, java.util.Properties)
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.HashMap v;
long v;
oadd.org.apache.calcite.avatica.UnregisteredDriver v;
java.sql.SQLException v;
int v;
java.lang.String v, v, v;
oadd.org.apache.calcite.avatica.AvaticaFactory v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
boolean v;
oadd.org.apache.calcite.avatica.Meta v;
java.util.Properties v;
java.util.concurrent.ConcurrentHashMap v, v;
java.lang.RuntimeException v;
java.util.UUID v;
oadd.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData v, v;
oadd.org.apache.calcite.avatica.ConnectionConfig v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.UnregisteredDriver;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaFactory;
v := @parameter: java.lang.String;
v := @parameter: java.util.Properties;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Map properties> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Map statementMap> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Map flagMap> = v;
v = staticinvoke <java.util.UUID: java.util.UUID randomUUID()>();
v = virtualinvoke v.<java.util.UUID: java.lang.String toString()>();
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.lang.String id> = v;
v = new oadd.org.apache.calcite.avatica.Meta$ConnectionHandle;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.lang.String id>;
specialinvoke v.<oadd.org.apache.calcite.avatica.Meta$ConnectionHandle: void <init>(java.lang.String)>(v);
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle> = v;
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.UnregisteredDriver driver> = v;
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaFactory factory> = v;
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.lang.String url> = v;
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Properties info> = v;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.UnregisteredDriver: oadd.org.apache.calcite.avatica.Meta createMeta(oadd.org.apache.calcite.avatica.AvaticaConnection)>(v);
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta> = v;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.AvaticaFactory: oadd.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData newDatabaseMetaData(oadd.org.apache.calcite.avatica.AvaticaConnection)>(v);
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData metaData> = v;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData metaData>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData: int getResultSetHoldability()>();
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int holdability> = v;
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: long getNumStatementRetries(java.util.Properties)>(v);
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: long maxRetriesPerExecute> = v;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.ConnectionConfig config()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.ConnectionConfig: boolean transparentReconnectionEnabled()>();
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean transparentReconnectEnabled> = v;
return;
catch java.sql.SQLException from label to label with label;
}
long getNumStatementRetries(java.util.Properties)
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.Properties v;
java.lang.Object v;
long v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.util.Properties;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = virtualinvoke v.<java.util.Properties: java.lang.String getProperty(java.lang.String,java.lang.String)>("avatica.statement.retries", "5");
v = staticinvoke <java.lang.Long: long parseLong(java.lang.String)>(v);
return v;
}
public oadd.org.apache.calcite.avatica.ConnectionConfig config()
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.Properties v;
oadd.org.apache.calcite.avatica.ConnectionConfigImpl v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = new oadd.org.apache.calcite.avatica.ConnectionConfigImpl;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Properties info>;
specialinvoke v.<oadd.org.apache.calcite.avatica.ConnectionConfigImpl: void <init>(java.util.Properties)>(v);
return v;
}
public void openConnection()
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.Properties v;
java.util.Map v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Properties info>;
v = staticinvoke <oadd.org.apache.calcite.avatica.remote.Service$OpenConnectionRequest: java.util.Map serializeProperties(java.util.Properties)>(v);
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: void openConnection(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle,java.util.Map)>(v, v);
return;
}
protected void checkOpen() throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean isClosed()>();
if v == 0 goto label;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException closed()>();
throw v;
label:
return;
}
public oadd.org.apache.calcite.avatica.AvaticaStatement createStatement() throws java.sql.SQLException
{
int v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int holdability>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaStatement createStatement(int,int,int)>(1003, 1007, v);
return v;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
int v;
java.lang.String v;
java.sql.PreparedStatement v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int holdability>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.PreparedStatement prepareStatement(java.lang.String,int,int,int)>(v, 1003, 1007, v);
return v;
}
public java.sql.CallableStatement prepareCall(java.lang.String) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.lang.String nativeSQL(java.lang.String) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public void setAutoCommit(boolean) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: boolean;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
v = new oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl;
specialinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties setAutoCommit(boolean)>(v);
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties connectionSync(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle,oadd.org.apache.calcite.avatica.Meta$ConnectionProperties)>(v, v);
return;
}
public boolean getAutoCommit() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
java.lang.Boolean v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties sync()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta$ConnectionProperties: java.lang.Boolean isAutoCommit()>();
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean unbox(java.lang.Boolean,boolean)>(v, 1);
return v;
}
public void commit() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: void commit(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle)>(v);
return;
}
public void rollback() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: void rollback(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle)>(v);
return;
}
public void close() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Handler v;
java.lang.RuntimeException v;
oadd.org.apache.calcite.avatica.UnregisteredDriver v;
oadd.org.apache.calcite.avatica.remote.KerberosConnection v, v;
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.Helper v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean closed>;
if v != 0 goto label;
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean closed> = 1;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: void closeConnection(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle)>(v);
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.UnregisteredDriver driver>;
v = v.<oadd.org.apache.calcite.avatica.UnregisteredDriver: oadd.org.apache.calcite.avatica.Handler handler>;
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Handler: void onConnectionClose(oadd.org.apache.calcite.avatica.AvaticaConnection)>(v);
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.remote.KerberosConnection kerberosConnection>;
if null == v goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.remote.KerberosConnection kerberosConnection>;
virtualinvoke v.<oadd.org.apache.calcite.avatica.remote.KerberosConnection: void stopRenewalThread()>();
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String,java.lang.Exception)>("While closing connection", v);
throw v;
label:
return;
catch java.lang.RuntimeException from label to label with label;
}
public boolean isClosed() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean closed>;
return v;
}
public java.sql.DatabaseMetaData getMetaData() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaSpecificDatabaseMetaData metaData>;
return v;
}
public void setReadOnly(boolean) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: boolean;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
v = new oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl;
specialinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties setReadOnly(boolean)>(v);
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties connectionSync(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle,oadd.org.apache.calcite.avatica.Meta$ConnectionProperties)>(v, v);
return;
}
public boolean isReadOnly() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
java.lang.Boolean v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties sync()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta$ConnectionProperties: java.lang.Boolean isReadOnly()>();
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean unbox(java.lang.Boolean,boolean)>(v, 1);
return v;
}
public void setCatalog(java.lang.String) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl v;
java.lang.String v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
v = new oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl;
specialinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties setCatalog(java.lang.String)>(v);
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties connectionSync(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle,oadd.org.apache.calcite.avatica.Meta$ConnectionProperties)>(v, v);
return;
}
public java.lang.String getCatalog() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.lang.String v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties sync()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta$ConnectionProperties: java.lang.String getCatalog()>();
return v;
}
public void setTransactionIsolation(int) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl v;
int v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: int;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
v = new oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl;
specialinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties setTransactionIsolation(int)>(v);
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties connectionSync(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle,oadd.org.apache.calcite.avatica.Meta$ConnectionProperties)>(v, v);
return;
}
public int getTransactionIsolation() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
int v;
java.lang.Integer v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties sync()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta$ConnectionProperties: java.lang.Integer getTransactionIsolation()>();
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int unbox(java.lang.Integer,int)>(v, 0);
return v;
}
public java.sql.SQLWarning getWarnings() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
return null;
}
public void clearWarnings() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
return;
}
public java.sql.Statement createStatement(int, int) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
int v, v, v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int holdability>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaStatement createStatement(int,int,int)>(v, v, v);
return v;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String, int, int) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
int v, v, v;
java.lang.String v;
java.sql.PreparedStatement v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int holdability>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.PreparedStatement prepareStatement(java.lang.String,int,int,int)>(v, v, v, v);
return v;
}
public java.sql.CallableStatement prepareCall(java.lang.String, int, int) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
int v, v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.util.Map getTypeMap() throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public void setTypeMap(java.util.Map) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.util.Map v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.util.Map;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public void setHoldability(int) throws java.sql.SQLException
{
int v;
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: int;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
if v == 2 goto label;
if v == 1 goto label;
v = new java.sql.SQLException;
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String)>("invalid value");
throw v;
label:
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int holdability> = v;
return;
}
public int getHoldability() throws java.sql.SQLException
{
int v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int holdability>;
return v;
}
public java.sql.Savepoint setSavepoint() throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.sql.Savepoint setSavepoint(java.lang.String) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public void rollback(java.sql.Savepoint) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.sql.Savepoint v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.sql.Savepoint;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public void releaseSavepoint(java.sql.Savepoint) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.sql.Savepoint v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.sql.Savepoint;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public oadd.org.apache.calcite.avatica.AvaticaStatement createStatement(int, int, int) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
int v, v, v;
oadd.org.apache.calcite.avatica.AvaticaFactory v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaFactory factory>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.AvaticaFactory: oadd.org.apache.calcite.avatica.AvaticaStatement newStatement(oadd.org.apache.calcite.avatica.AvaticaConnection,oadd.org.apache.calcite.avatica.Meta$StatementHandle,int,int,int)>(v, null, v, v, v);
return v;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String, int, int, int) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.lang.RuntimeException v;
oadd.org.apache.calcite.avatica.AvaticaPreparedStatement v;
oadd.org.apache.calcite.avatica.Meta$Signature v;
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.Meta$StatementHandle v;
oadd.org.apache.calcite.avatica.Helper v;
int v, v, v;
java.lang.String v, v;
oadd.org.apache.calcite.avatica.AvaticaFactory v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$StatementHandle prepare(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle,java.lang.String,long)>(v, v, -1L);
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaFactory factory>;
v = v.<oadd.org.apache.calcite.avatica.Meta$StatementHandle: oadd.org.apache.calcite.avatica.Meta$Signature signature>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.AvaticaFactory: oadd.org.apache.calcite.avatica.AvaticaPreparedStatement newPreparedStatement(oadd.org.apache.calcite.avatica.AvaticaConnection,oadd.org.apache.calcite.avatica.Meta$StatementHandle,oadd.org.apache.calcite.avatica.Meta$Signature,int,int,int)>(v, v, v, v, v, v);
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
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[])>("while preparing SQL: \u0001");
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String,java.lang.Exception)>(v, v);
throw v;
catch java.lang.RuntimeException from label to label with label;
}
public java.sql.CallableStatement prepareCall(java.lang.String, int, int, int) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
int v, v, v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String, int) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
int v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: int;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String, int[]) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
int[] v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: int[];
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.sql.PreparedStatement prepareStatement(java.lang.String, java.lang.String[]) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.String[] v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String[];
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.sql.Clob createClob() throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.sql.Blob createBlob() throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.sql.NClob createNClob() throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public java.sql.SQLXML createSQLXML() throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public boolean isValid(int) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
int v;
boolean v, v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: int;
if v >= 0 goto label;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String)>("timeout is less than 0");
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean isClosed()>();
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.sql.SQLClientInfoException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.String v, v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLClientInfoException clientInfo()>();
throw v;
}
public void setClientInfo(java.util.Properties) throws java.sql.SQLClientInfoException
{
java.sql.SQLClientInfoException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.Properties v;
oadd.org.apache.calcite.avatica.Helper v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.util.Properties;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLClientInfoException clientInfo()>();
throw v;
}
public java.lang.String getClientInfo(java.lang.String) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.Properties v;
java.lang.String v, v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Properties getClientInfo()>();
v = virtualinvoke v.<java.util.Properties: java.lang.String getProperty(java.lang.String)>(v);
return v;
}
public java.util.Properties getClientInfo() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.Properties v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = new java.util.Properties;
specialinvoke v.<java.util.Properties: void <init>()>();
return v;
}
public java.sql.Array createArrayOf(java.lang.String, java.lang.Object[]) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.lang.Object[] v;
oadd.org.apache.calcite.avatica.util.ArrayFactoryImpl v;
java.sql.Array v;
oadd.org.apache.calcite.avatica.ColumnMetaData$ScalarType v;
java.sql.SQLException v, v, v;
int[] v;
oadd.org.apache.calcite.avatica.Helper v, v;
int v, v, v;
java.lang.String v, v;
oadd.org.apache.calcite.avatica.SqlType v;
oadd.org.apache.calcite.avatica.ColumnMetaData$Rep v;
java.util.TimeZone v;
java.lang.IllegalArgumentException v;
java.util.List v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object[];
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = staticinvoke <oadd.org.apache.calcite.avatica.AvaticaUtils: java.util.List primitiveList(java.lang.Object)>(v);
label:
v = staticinvoke <oadd.org.apache.calcite.avatica.SqlType: oadd.org.apache.calcite.avatica.SqlType valueOf(java.lang.String)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.sql.SQLException;
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[])>("Could not find JDBC type for \'\u0001\'");
specialinvoke v.<java.sql.SQLException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <oadd.org.apache.calcite.avatica.AvaticaConnection$2: int[] $SwitchMap$org$apache$calcite$avatica$SqlType>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.SqlType: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String)>("Cannot create an ARRAY of ARRAY\'s");
throw v;
label:
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String)>("Cannot create an ARRAY of STRUCT\'s");
throw v;
label:
v = v.<oadd.org.apache.calcite.avatica.SqlType: int id>;
v = staticinvoke <oadd.org.apache.calcite.avatica.ColumnMetaData$Rep: oadd.org.apache.calcite.avatica.ColumnMetaData$Rep nonPrimitiveRepOf(oadd.org.apache.calcite.avatica.SqlType)>(v);
v = staticinvoke <oadd.org.apache.calcite.avatica.ColumnMetaData: oadd.org.apache.calcite.avatica.ColumnMetaData$ScalarType scalar(int,java.lang.String,oadd.org.apache.calcite.avatica.ColumnMetaData$Rep)>(v, v, v);
v = new oadd.org.apache.calcite.avatica.util.ArrayFactoryImpl;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.TimeZone getTimeZone()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.util.ArrayFactoryImpl: void <init>(java.util.TimeZone)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.util.ArrayFactoryImpl: java.sql.Array createArray(oadd.org.apache.calcite.avatica.ColumnMetaData$AvaticaType,java.lang.Iterable)>(v, v);
return v;
catch java.lang.IllegalArgumentException from label to label with label;
}
public java.sql.Struct createStruct(java.lang.String, java.lang.Object[]) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.lang.Object[] v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object[];
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public void setSchema(java.lang.String) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl v;
java.lang.String v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.String;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
v = new oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl;
specialinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties setSchema(java.lang.String)>(v);
interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties connectionSync(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle,oadd.org.apache.calcite.avatica.Meta$ConnectionProperties)>(v, v);
return;
}
public java.lang.String getSchema() throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.lang.String v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties sync()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta$ConnectionProperties: java.lang.String getSchema()>();
return v;
}
public void abort(java.util.concurrent.Executor) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.concurrent.Executor v;
oadd.org.apache.calcite.avatica.Helper v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.util.concurrent.Executor;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException unsupported()>();
throw v;
}
public void setNetworkTimeout(java.util.concurrent.Executor, int) throws java.sql.SQLException
{
int v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.concurrent.Executor v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.util.concurrent.Executor;
v := @parameter: int;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int networkTimeout> = v;
return;
}
public int getNetworkTimeout() throws java.sql.SQLException
{
int v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void checkOpen()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int networkTimeout>;
return v;
}
public java.lang.Object unwrap(java.lang.Class) throws java.sql.SQLException
{
java.sql.SQLException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.Class;
v = virtualinvoke v.<java.lang.Class: boolean isInstance(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Class: java.lang.Object cast(java.lang.Object)>(v);
return v;
label:
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Class)>(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[])>("does not implement \'\u0001\'");
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String)>(v);
throw v;
}
public boolean isWrapperFor(java.lang.Class) throws java.sql.SQLException
{
java.lang.Class v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.Class;
v = virtualinvoke v.<java.lang.Class: boolean isInstance(java.lang.Object)>(v);
return v;
}
public java.util.TimeZone getTimeZone()
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.TimeZone v;
oadd.org.apache.calcite.avatica.ConnectionConfig v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.ConnectionConfig config()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.ConnectionConfig: java.lang.String timeZone()>();
if v != null goto label;
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getDefault()>();
goto label;
label:
v = staticinvoke <java.util.TimeZone: java.util.TimeZone getTimeZone(java.lang.String)>(v);
label:
return v;
}
protected java.sql.ResultSet executeQueryInternal(oadd.org.apache.calcite.avatica.AvaticaStatement, oadd.org.apache.calcite.avatica.Meta$Signature, oadd.org.apache.calcite.avatica.Meta$Frame, oadd.org.apache.calcite.avatica.QueryState, boolean) throws java.sql.SQLException
{
byte v;
oadd.org.apache.calcite.avatica.Helper v, v;
boolean v, v;
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaResultSet v, v, v, v, v, v;
java.util.TimeZone v;
java.lang.Exception v, v;
java.util.List v, v, v;
java.lang.Throwable v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
long v, v;
oadd.org.apache.calcite.avatica.Meta$ExecuteResult v;
oadd.org.apache.calcite.avatica.Meta$Signature v, v;
java.sql.SQLException v, v;
oadd.org.apache.calcite.avatica.Meta$StatementHandle v, v;
int v, v;
java.lang.String v, v, v, v;
oadd.org.apache.calcite.avatica.AvaticaFactory v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
java.lang.Object v, v;
oadd.org.apache.calcite.avatica.Meta$Frame v, v;
oadd.org.apache.calcite.avatica.QueryState v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaStatement;
v := @parameter: oadd.org.apache.calcite.avatica.Meta$Signature;
v := @parameter: oadd.org.apache.calcite.avatica.Meta$Frame;
v := @parameter: oadd.org.apache.calcite.avatica.QueryState;
v := @parameter: boolean;
v = v;
v = v;
entermonitor v;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet>;
if v == null goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet>;
v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet> = null;
label:
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaStatement: boolean isWrapperFor(java.lang.Class)>(class "Loadd/org/apache/calcite/avatica/AvaticaPreparedStatement;");
if v == 0 goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaPreparedStatement: oadd.org.apache.calcite.avatica.Meta$StatementHandle handle>;
if v == 0 goto label;
v = new oadd.org.apache.calcite.avatica.Meta$StatementHandle;
v = v.<oadd.org.apache.calcite.avatica.Meta$StatementHandle: java.lang.String connectionId>;
v = v.<oadd.org.apache.calcite.avatica.Meta$StatementHandle: int id>;
specialinvoke v.<oadd.org.apache.calcite.avatica.Meta$StatementHandle: void <init>(java.lang.String,int,oadd.org.apache.calcite.avatica.Meta$Signature)>(v, v, null);
v = v;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaPreparedStatement: java.util.List getParameterValues()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaStatement: int getFetchSize()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ExecuteResult execute(oadd.org.apache.calcite.avatica.Meta$StatementHandle,java.util.List,int)>(v, v, v);
v = v.<oadd.org.apache.calcite.avatica.Meta$ExecuteResult: java.util.List resultSets>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<oadd.org.apache.calcite.avatica.Meta$MetaResultSet: oadd.org.apache.calcite.avatica.Meta$Frame firstFrame>;
v = v.<oadd.org.apache.calcite.avatica.Meta$MetaResultSet: long updateCount>;
v.<oadd.org.apache.calcite.avatica.AvaticaStatement: long updateCount> = v;
v = v.<oadd.org.apache.calcite.avatica.Meta$ExecuteResult: java.util.List resultSets>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = v.<oadd.org.apache.calcite.avatica.Meta$MetaResultSet: oadd.org.apache.calcite.avatica.Meta$Signature signature>;
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String,java.lang.Exception)>(v, v);
throw v;
label:
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.TimeZone getTimeZone()>();
if v != null goto label;
if v != null goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: long updateCount>;
v = v cmp -1L;
if v == 0 goto label;
v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet> = null;
goto label;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaFactory factory>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.AvaticaFactory: oadd.org.apache.calcite.avatica.AvaticaResultSet newResultSet(oadd.org.apache.calcite.avatica.AvaticaStatement,oadd.org.apache.calcite.avatica.QueryState,oadd.org.apache.calcite.avatica.Meta$Signature,java.util.TimeZone,oadd.org.apache.calcite.avatica.Meta$Frame)>(v, v, v, v, v);
v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet> = v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet>;
if v == null goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet>;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaResultSet: oadd.org.apache.calcite.avatica.AvaticaResultSet execute()>();
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void isUpdateCapable(oadd.org.apache.calcite.avatica.AvaticaStatement)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<java.lang.Exception: 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[])>("exception while executing query: \u0001");
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String,java.lang.Exception)>(v, v);
throw v;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet>;
return v;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
}
protected long[] executeBatchUpdateInternal(oadd.org.apache.calcite.avatica.AvaticaPreparedStatement) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.AvaticaPreparedStatement v;
java.lang.Exception v;
java.sql.SQLException v;
java.util.List v;
oadd.org.apache.calcite.avatica.Meta$StatementHandle v;
long[] v;
oadd.org.apache.calcite.avatica.Meta$ExecuteBatchResult v;
oadd.org.apache.calcite.avatica.Helper v;
java.lang.String v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaPreparedStatement;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaPreparedStatement: oadd.org.apache.calcite.avatica.Meta$StatementHandle handle>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaPreparedStatement: java.util.List getParameterValueBatch()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ExecuteBatchResult executeBatch(oadd.org.apache.calcite.avatica.Meta$StatementHandle,java.util.List)>(v, v);
v = v.<oadd.org.apache.calcite.avatica.Meta$ExecuteBatchResult: long[] updateCounts>;
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String,java.lang.Exception)>(v, v);
throw v;
catch java.lang.Exception from label to label with label;
}
private void isUpdateCapable(oadd.org.apache.calcite.avatica.AvaticaStatement) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$StatementType v, v;
long v;
oadd.org.apache.calcite.avatica.Meta$Signature v;
java.sql.SQLException v;
byte v;
oadd.org.apache.calcite.avatica.Helper v;
int v, v;
boolean v, v, v;
oadd.org.apache.calcite.avatica.AvaticaResultSet v, v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
java.lang.Object v, v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaStatement;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.Meta$Signature getSignature()>();
if v == null goto label;
v = v.<oadd.org.apache.calcite.avatica.Meta$Signature: oadd.org.apache.calcite.avatica.Meta$StatementType statementType>;
if v != null goto label;
label:
return;
label:
v = v.<oadd.org.apache.calcite.avatica.Meta$Signature: oadd.org.apache.calcite.avatica.Meta$StatementType statementType>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Meta$StatementType: boolean canUpdate()>();
if v == 0 goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: long updateCount>;
v = v cmp -1L;
if v != 0 goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet>;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaResultSet: boolean next()>();
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaResultSet: java.lang.Object getObject(java.lang.String)>("ROWCOUNT");
v = v instanceof java.lang.Number;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Number: int intValue()>();
v.<oadd.org.apache.calcite.avatica.AvaticaStatement: long updateCount> = v;
goto label;
label:
v = v instanceof java.util.List;
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(0);
v = virtualinvoke v.<java.lang.Number: int intValue()>();
v.<oadd.org.apache.calcite.avatica.AvaticaStatement: long updateCount> = v;
goto label;
label:
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Helper: java.sql.SQLException createException(java.lang.String)>("Not a valid return result.");
throw v;
label:
v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.AvaticaResultSet openResultSet> = null;
label:
return;
}
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
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
long v;
oadd.org.apache.calcite.avatica.Meta$ExecuteResult v;
oadd.org.apache.calcite.avatica.Meta$StatementHandle v;
int v;
java.lang.String v;
oadd.org.apache.calcite.avatica.AvaticaConnection$1 v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaStatement;
v := @parameter: java.lang.String;
v := @parameter: long;
v = new oadd.org.apache.calcite.avatica.AvaticaConnection$1;
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection$1: void <init>(oadd.org.apache.calcite.avatica.AvaticaConnection,oadd.org.apache.calcite.avatica.AvaticaStatement,java.lang.String)>(v, v, v);
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.Meta$StatementHandle handle>;
v = staticinvoke <oadd.org.apache.calcite.avatica.AvaticaUtils: int toSaturatedInt(long)>(v);
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ExecuteResult prepareAndExecute(oadd.org.apache.calcite.avatica.Meta$StatementHandle,java.lang.String,long,int,oadd.org.apache.calcite.avatica.Meta$PrepareCallback)>(v, v, v, v, v);
return v;
}
protected oadd.org.apache.calcite.avatica.Meta$ExecuteBatchResult prepareAndUpdateBatch(oadd.org.apache.calcite.avatica.AvaticaStatement, java.util.List) throws oadd.org.apache.calcite.avatica.NoSuchStatementException, java.sql.SQLException
{
oadd.org.apache.calcite.avatica.Meta v;
java.util.List v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$StatementHandle v;
oadd.org.apache.calcite.avatica.Meta$ExecuteBatchResult v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaStatement;
v := @parameter: java.util.List;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaStatement: oadd.org.apache.calcite.avatica.Meta$StatementHandle handle>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ExecuteBatchResult prepareAndExecuteBatch(oadd.org.apache.calcite.avatica.Meta$StatementHandle,java.util.List)>(v, v);
return v;
}
protected java.sql.ResultSet createResultSet(oadd.org.apache.calcite.avatica.Meta$MetaResultSet, oadd.org.apache.calcite.avatica.QueryState) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
oadd.org.apache.calcite.avatica.Meta$Signature v, v;
oadd.org.apache.calcite.avatica.Meta$StatementHandle v;
java.sql.ResultSet v;
int v;
java.sql.Statement v;
java.lang.String v;
oadd.org.apache.calcite.avatica.Meta$Frame v;
oadd.org.apache.calcite.avatica.QueryState v;
boolean v;
oadd.org.apache.calcite.avatica.Meta$MetaResultSet v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.Meta$MetaResultSet;
v := @parameter: oadd.org.apache.calcite.avatica.QueryState;
v = new oadd.org.apache.calcite.avatica.Meta$StatementHandle;
v = v.<oadd.org.apache.calcite.avatica.Meta$MetaResultSet: java.lang.String connectionId>;
v = v.<oadd.org.apache.calcite.avatica.Meta$MetaResultSet: int statementId>;
specialinvoke v.<oadd.org.apache.calcite.avatica.Meta$StatementHandle: void <init>(java.lang.String,int,oadd.org.apache.calcite.avatica.Meta$Signature)>(v, v, null);
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaStatement lookupStatement(oadd.org.apache.calcite.avatica.Meta$StatementHandle)>(v);
v = v.<oadd.org.apache.calcite.avatica.Meta$MetaResultSet: oadd.org.apache.calcite.avatica.Meta$Signature signature>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.Meta$Signature: oadd.org.apache.calcite.avatica.Meta$Signature sanitize()>();
v = v.<oadd.org.apache.calcite.avatica.Meta$MetaResultSet: oadd.org.apache.calcite.avatica.Meta$Frame firstFrame>;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.sql.ResultSet executeQueryInternal(oadd.org.apache.calcite.avatica.AvaticaStatement,oadd.org.apache.calcite.avatica.Meta$Signature,oadd.org.apache.calcite.avatica.Meta$Frame,oadd.org.apache.calcite.avatica.QueryState,boolean)>(v, v, v, v, 0);
v = v.<oadd.org.apache.calcite.avatica.Meta$MetaResultSet: boolean ownStatement>;
if v == 0 goto label;
v = interfaceinvoke v.<java.sql.ResultSet: java.sql.Statement getStatement()>();
interfaceinvoke v.<java.sql.Statement: void closeOnCompletion()>();
label:
return v;
}
protected oadd.org.apache.calcite.avatica.AvaticaStatement lookupStatement(oadd.org.apache.calcite.avatica.Meta$StatementHandle) throws java.sql.SQLException
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.AvaticaStatement v;
java.lang.Integer v;
oadd.org.apache.calcite.avatica.Meta$StatementHandle v;
java.util.Map v;
int v, v;
java.lang.Object v, v;
oadd.org.apache.calcite.avatica.AvaticaFactory v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.Meta$StatementHandle;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Map statementMap>;
v = v.<oadd.org.apache.calcite.avatica.Meta$StatementHandle: int id>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
return v;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.AvaticaFactory factory>;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: int holdability>;
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.AvaticaFactory: oadd.org.apache.calcite.avatica.AvaticaStatement newStatement(oadd.org.apache.calcite.avatica.AvaticaConnection,oadd.org.apache.calcite.avatica.Meta$StatementHandle,int,int,int)>(v, v, 1003, 1007, v);
return v;
}
protected static oadd.org.apache.calcite.avatica.AvaticaConnection$Trojan createTrojan()
{
oadd.org.apache.calcite.avatica.AvaticaConnection$Trojan v;
v = new oadd.org.apache.calcite.avatica.AvaticaConnection$Trojan;
specialinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection$Trojan: void <init>()>();
return v;
}
private boolean unbox(java.lang.Boolean, boolean)
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.lang.Boolean v;
boolean v, v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.Boolean;
v := @parameter: boolean;
if v != null goto label;
v = v;
goto label;
label:
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
label:
return v;
}
private int unbox(java.lang.Integer, int)
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
int v, v;
java.lang.Integer v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: java.lang.Integer;
v := @parameter: int;
if v != null goto label;
v = v;
goto label;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
label:
return v;
}
private oadd.org.apache.calcite.avatica.Meta$ConnectionProperties sync()
{
oadd.org.apache.calcite.avatica.Meta v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.Meta$ConnectionProperties v;
oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl v;
oadd.org.apache.calcite.avatica.Meta$ConnectionHandle v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta meta>;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Meta$ConnectionHandle handle>;
v = new oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl;
specialinvoke v.<oadd.org.apache.calcite.avatica.ConnectionPropertiesImpl: void <init>()>();
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.Meta: oadd.org.apache.calcite.avatica.Meta$ConnectionProperties connectionSync(oadd.org.apache.calcite.avatica.Meta$ConnectionHandle,oadd.org.apache.calcite.avatica.Meta$ConnectionProperties)>(v, v);
return v;
}
public java.util.concurrent.atomic.AtomicBoolean getCancelFlag(oadd.org.apache.calcite.avatica.Meta$StatementHandle) throws oadd.org.apache.calcite.avatica.NoSuchStatementException
{
java.lang.Throwable v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.Integer v, v;
oadd.org.apache.calcite.avatica.Meta$StatementHandle v;
java.util.Map v, v, v;
int v, v;
java.lang.Object v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.Meta$StatementHandle;
staticinvoke <oadd.org.apache.calcite.avatica.AvaticaUtils: boolean upgrade(java.lang.String)>("after dropping JDK 1.7, use Map.computeIfAbsent");
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Map flagMap>;
entermonitor v;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Map flagMap>;
v = v.<oadd.org.apache.calcite.avatica.Meta$StatementHandle: int id>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>()>();
v = v;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: java.util.Map flagMap>;
v = v.<oadd.org.apache.calcite.avatica.Meta$StatementHandle: int id>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
catch java.lang.Throwable from label to label with label;
}
public java.lang.Object invokeWithRetries(oadd.org.apache.calcite.avatica.AvaticaConnection$CallableWithoutException)
{
java.lang.IllegalStateException v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
long v;
oadd.org.apache.calcite.avatica.AvaticaClientRuntimeException v, v;
byte v;
int v, v;
oadd.org.apache.calcite.avatica.AvaticaConnection$CallableWithoutException v;
java.lang.Object v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.AvaticaConnection$CallableWithoutException;
v = null;
v = 0;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: long maxRetriesPerExecute>;
v = v cmp v;
if v >= 0 goto label;
label:
v = interfaceinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection$CallableWithoutException: java.lang.Object call()>();
label:
return v;
label:
v := @caughtexception;
v = v;
v = virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaClientRuntimeException: int getErrorCode()>();
if 1 != v goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean transparentReconnectEnabled>;
if v == 0 goto label;
virtualinvoke v.<oadd.org.apache.calcite.avatica.AvaticaConnection: void openConnection()>();
goto label;
label:
throw v;
label:
v = v + 1;
goto label;
label:
if null == v goto label;
throw v;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>()>();
throw v;
catch oadd.org.apache.calcite.avatica.AvaticaClientRuntimeException from label to label with label;
}
public void setKerberosConnection(oadd.org.apache.calcite.avatica.remote.KerberosConnection)
{
java.lang.Object v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.remote.KerberosConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.remote.KerberosConnection;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.remote.KerberosConnection kerberosConnection> = v;
return;
}
public oadd.org.apache.calcite.avatica.remote.KerberosConnection getKerberosConnection()
{
oadd.org.apache.calcite.avatica.AvaticaConnection v;
oadd.org.apache.calcite.avatica.remote.KerberosConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.remote.KerberosConnection kerberosConnection>;
return v;
}
public oadd.org.apache.calcite.avatica.remote.Service getService()
{
oadd.org.apache.calcite.avatica.remote.Service v, v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
java.lang.AssertionError v;
boolean v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v = <oadd.org.apache.calcite.avatica.AvaticaConnection: boolean $assertionsDisabled>;
if v != 0 goto label;
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.remote.Service service>;
if null != v goto label;
v = new java.lang.AssertionError;
specialinvoke v.<java.lang.AssertionError: void <init>()>();
throw v;
label:
v = v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.remote.Service service>;
return v;
}
public void setService(oadd.org.apache.calcite.avatica.remote.Service)
{
oadd.org.apache.calcite.avatica.remote.Service v;
java.lang.Object v;
oadd.org.apache.calcite.avatica.AvaticaConnection v;
v := @this: oadd.org.apache.calcite.avatica.AvaticaConnection;
v := @parameter: oadd.org.apache.calcite.avatica.remote.Service;
v = staticinvoke <java.util.Objects: java.lang.Object requireNonNull(java.lang.Object)>(v);
v.<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.remote.Service service> = v;
return;
}
static void <clinit>()
{
oadd.org.apache.calcite.avatica.Helper v;
java.lang.Class v;
boolean v, v;
v = class "Loadd/org/apache/calcite/avatica/AvaticaConnection;";
v = virtualinvoke v.<java.lang.Class: boolean desiredAssertionStatus()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
<oadd.org.apache.calcite.avatica.AvaticaConnection: boolean $assertionsDisabled> = v;
v = <oadd.org.apache.calcite.avatica.Helper: oadd.org.apache.calcite.avatica.Helper INSTANCE>;
<oadd.org.apache.calcite.avatica.AvaticaConnection: oadd.org.apache.calcite.avatica.Helper HELPER> = v;
return;
}
}