public class oadd.org.apache.drill.exec.client.DrillSqlLineApplication extends sqlline.Application
{
private static final org.slf4j.Logger logger;
private static final java.lang.String DRILL_SQLLINE_CONF;
private static final java.lang.String DRILL_SQLLINE_OVERRIDE_CONF;
private static final java.lang.String INFO_MESSAGE_TEMPLATE_CONF;
private static final java.lang.String QUOTES_CONF;
private static final java.lang.String DRIVERS_CONF;
private static final java.lang.String CONNECTION_URL_EXAMPLES_CONF;
private static final java.lang.String COMMANDS_TO_EXCLUDE_CONF;
private static final java.lang.String OPTS_CONF;
private static final java.lang.String PROMPT_WITH_SCHEMA;
private final oadd.com.typesafe.config.Config config;
public void <init>()
{
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
specialinvoke v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: void <init>(java.lang.String,java.lang.String)>("drill-sqlline.conf", "drill-sqlline-override.conf");
return;
}
public void <init>(java.lang.String, java.lang.String)
{
org.slf4j.Logger v;
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
oadd.com.typesafe.config.Config v, v, v;
java.lang.String v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
specialinvoke v.<sqlline.Application: void <init>()>();
v = specialinvoke v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config loadConfig(java.lang.String)>(v);
v = specialinvoke v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config overrideConfig(java.lang.String,oadd.com.typesafe.config.Config)>(v, v);
v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config> = v;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean isEmpty()>();
if v == 0 goto label;
v = <oadd.org.apache.drill.exec.client.DrillSqlLineApplication: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("Was unable to find / load [{}]. Will use default SqlLine configuration.", v);
label:
return;
}
public oadd.com.typesafe.config.Config getConfig()
{
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
oadd.com.typesafe.config.Config v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
return v;
}
public java.lang.String getInfoMessage()
{
java.lang.Object[] v;
java.util.Random v;
oadd.com.typesafe.config.Config v, v, v, v;
int v, v;
java.lang.String v, v, v, v;
boolean v, v;
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
java.util.List v;
java.lang.Object v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("drill.sqlline.info_message_template");
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("drill.sqlline.quotes");
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: java.util.List getStringList(java.lang.String)>("drill.sqlline.quotes");
v = new java.util.Random;
specialinvoke v.<java.util.Random: void <init>()>();
v = interfaceinvoke v.<java.util.List: int size()>();
v = virtualinvoke v.<java.util.Random: int nextInt(int)>(v);
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
label:
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: java.lang.String getString(java.lang.String)>("drill.sqlline.info_message_template");
v = newarray (java.lang.Object)[2];
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: java.lang.String getVersion()>();
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>(v, v);
return v;
label:
v = specialinvoke v.<sqlline.Application: java.lang.String getInfoMessage()>();
return v;
}
public java.lang.String getVersion()
{
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v = staticinvoke <oadd.org.apache.drill.common.util.DrillVersionInfo: java.lang.String getVersion()>();
return v;
}
public java.util.List allowedDrivers()
{
java.util.List v, v;
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
oadd.com.typesafe.config.Config v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("drill.sqlline.drivers");
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: java.util.List getStringList(java.lang.String)>("drill.sqlline.drivers");
return v;
label:
v = specialinvoke v.<sqlline.Application: java.util.List allowedDrivers()>();
return v;
}
public java.util.Map getOutputFormats(sqlline.SqlLine)
{
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
sqlline.SqlLine v;
java.util.Map v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v := @parameter: sqlline.SqlLine;
v = virtualinvoke v.<sqlline.SqlLine: java.util.Map getOutputFormats()>();
return v;
}
public java.util.Collection getConnectionUrlExamples()
{
java.util.List v;
java.util.Collection v;
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
oadd.com.typesafe.config.Config v, v;
boolean v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("drill.sqlline.connection_url_examples");
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: java.util.List getStringList(java.lang.String)>("drill.sqlline.connection_url_examples");
return v;
label:
v = specialinvoke v.<sqlline.Application: java.util.Collection getConnectionUrlExamples()>();
return v;
}
public java.util.Collection getCommandHandlers(sqlline.SqlLine)
{
java.lang.String[] v;
oadd.com.typesafe.config.Config v, v, v;
java.util.ArrayList v;
sqlline.SqlLine v;
java.util.stream.Collector v;
sqlline.ReflectiveCommandHandler v;
boolean v, v, v;
java.util.function.Predicate v;
java.util.Collection v, v, v;
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
java.util.List v;
java.util.stream.Stream v, v;
org.jline.reader.impl.completer.StringsCompleter v;
java.lang.Object v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v := @parameter: sqlline.SqlLine;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("drill.sqlline.connection_url_examples");
if v == 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("connect");
label:
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("drill.sqlline.commands.exclude");
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: java.util.List getStringList(java.lang.String)>("drill.sqlline.commands.exclude");
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
label:
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = virtualinvoke v.<sqlline.SqlLine: java.util.Collection getCommandHandlers()>();
return v;
label:
v = virtualinvoke v.<sqlline.SqlLine: java.util.Collection getCommandHandlers()>();
v = interfaceinvoke v.<java.util.Collection: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.client.DrillSqlLineApplication$lambda_getCommandHandlers_0__436: java.util.function.Predicate bootstrap$(java.util.List)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
if v == 0 goto label;
v = new sqlline.ReflectiveCommandHandler;
v = new org.jline.reader.impl.completer.StringsCompleter;
v = virtualinvoke v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: java.util.Collection getConnectionUrlExamples()>();
specialinvoke v.<org.jline.reader.impl.completer.StringsCompleter: void <init>(java.lang.Iterable)>(v);
v = newarray (java.lang.String)[2];
v[0] = "connect";
v[1] = "open";
specialinvoke v.<sqlline.ReflectiveCommandHandler: void <init>(sqlline.SqlLine,org.jline.reader.Completer,java.lang.String[])>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return v;
}
public sqlline.SqlLineOpts getOpts(sqlline.SqlLine)
{
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
java.util.Set v;
oadd.com.typesafe.config.Config v, v, v;
java.util.function.Consumer v;
sqlline.SqlLine v;
sqlline.SqlLineOpts v;
boolean v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v := @parameter: sqlline.SqlLine;
v = virtualinvoke v.<sqlline.SqlLine: sqlline.SqlLineOpts getOpts()>();
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("drill.sqlline.opts");
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: oadd.com.typesafe.config.Config getConfig(java.lang.String)>("drill.sqlline.opts");
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: java.util.Set entrySet()>();
v = staticinvoke <oadd.org.apache.drill.exec.client.DrillSqlLineApplication$lambda_getOpts_1__437: java.util.function.Consumer bootstrap$(sqlline.SqlLineOpts)>(v);
interfaceinvoke v.<java.util.Set: void forEach(java.util.function.Consumer)>(v);
label:
return v;
}
public sqlline.PromptHandler getPromptHandler(sqlline.SqlLine)
{
oadd.org.apache.drill.exec.client.DrillSqlLineApplication$1 v;
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
oadd.com.typesafe.config.Config v, v;
sqlline.PromptHandler v;
sqlline.SqlLine v;
boolean v, v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v := @parameter: sqlline.SqlLine;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean hasPath(java.lang.String)>("drill.sqlline.prompt.with_schema");
if v == 0 goto label;
v = v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config config>;
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: boolean getBoolean(java.lang.String)>("drill.sqlline.prompt.with_schema");
if v == 0 goto label;
v = new oadd.org.apache.drill.exec.client.DrillSqlLineApplication$1;
specialinvoke v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication$1: void <init>(oadd.org.apache.drill.exec.client.DrillSqlLineApplication,sqlline.SqlLine)>(v, v);
return v;
label:
v = specialinvoke v.<sqlline.Application: sqlline.PromptHandler getPromptHandler(sqlline.SqlLine)>(v);
return v;
}
private oadd.com.typesafe.config.Config loadConfig(java.lang.String)
{
oadd.com.typesafe.config.Config v, v, v;
int v;
java.lang.String v, v, v;
boolean v;
org.slf4j.Logger v, v, v;
java.util.Iterator v;
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
java.util.Set v;
java.lang.Exception v;
java.util.function.Consumer v;
java.lang.Object v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v := @parameter: java.lang.String;
v = staticinvoke <oadd.org.apache.drill.common.scanner.ClassPathScanner: java.util.Set forResource(java.lang.String,boolean)>(v, 0);
v = interfaceinvoke v.<java.util.Set: int size()>();
if v == 1 goto label;
v = <oadd.org.apache.drill.exec.client.DrillSqlLineApplication: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = staticinvoke <oadd.org.apache.drill.exec.client.DrillSqlLineApplication$lambda_loadConfig_2__438: java.util.function.Consumer bootstrap$(java.lang.String)>(v);
interfaceinvoke v.<java.util.Set: void forEach(java.util.function.Consumer)>(v);
label:
v = staticinvoke <oadd.com.typesafe.config.ConfigFactory: oadd.com.typesafe.config.Config empty()>();
return v;
label:
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
v = <oadd.org.apache.drill.exec.client.DrillSqlLineApplication: org.slf4j.Logger logger>;
v = virtualinvoke v.<java.net.URL: java.lang.String getPath()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Parsing [{}] for the url: [{}].", v, v);
v = staticinvoke <oadd.com.typesafe.config.ConfigFactory: oadd.com.typesafe.config.Config parseURL(java.net.URL)>(v);
label:
return v;
label:
v := @caughtexception;
v = <oadd.org.apache.drill.exec.client.DrillSqlLineApplication: org.slf4j.Logger logger>;
v = virtualinvoke v.<java.net.URL: java.lang.String getPath()>();
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Was unable to parse [{}].", v, v);
v = staticinvoke <oadd.com.typesafe.config.ConfigFactory: oadd.com.typesafe.config.Config empty()>();
return v;
catch java.lang.Exception from label to label with label;
}
private oadd.com.typesafe.config.Config overrideConfig(java.lang.String, oadd.com.typesafe.config.Config)
{
oadd.org.apache.drill.exec.client.DrillSqlLineApplication v;
oadd.com.typesafe.config.Config v, v, v, v;
java.lang.String v;
v := @this: oadd.org.apache.drill.exec.client.DrillSqlLineApplication;
v := @parameter: java.lang.String;
v := @parameter: oadd.com.typesafe.config.Config;
v = specialinvoke v.<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: oadd.com.typesafe.config.Config loadConfig(java.lang.String)>(v);
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: oadd.com.typesafe.config.Config withFallback(oadd.com.typesafe.config.ConfigMergeable)>(v);
v = interfaceinvoke v.<oadd.com.typesafe.config.Config: oadd.com.typesafe.config.Config resolve()>();
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/drill/exec/client/DrillSqlLineApplication;");
<oadd.org.apache.drill.exec.client.DrillSqlLineApplication: org.slf4j.Logger logger> = v;
return;
}
}