public class org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect extends java.lang.Object implements org.apache.drill.exec.store.jdbc.JdbcDialect
{
private final org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin;
private final org.apache.calcite.sql.SqlDialect dialect;
public void <init>(org.apache.drill.exec.store.jdbc.JdbcStoragePlugin, org.apache.calcite.sql.SqlDialect)
{
org.apache.drill.exec.store.jdbc.JdbcStoragePlugin v;
org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect v;
org.apache.calcite.sql.SqlDialect v;
v := @this: org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect;
v := @parameter: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin;
v := @parameter: org.apache.calcite.sql.SqlDialect;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin> = v;
v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.calcite.sql.SqlDialect dialect> = v;
return;
}
public void registerSchemas(org.apache.drill.exec.store.SchemaConfig, org.apache.calcite.schema.SchemaPlus)
{
org.apache.drill.exec.proto.UserBitShared$UserCredentials v, v;
org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect v;
org.apache.drill.exec.store.jdbc.JdbcStoragePlugin v, v, v, v;
org.apache.drill.exec.store.jdbc.DrillJdbcConvention v;
java.lang.String v, v;
boolean v;
org.apache.calcite.schema.SchemaPlus v, v;
org.apache.calcite.sql.SqlDialect v, v;
org.apache.drill.exec.store.SchemaConfig v;
java.util.Optional v;
java.lang.Object v;
org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseCatalogSchema v;
v := @this: org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect;
v := @parameter: org.apache.drill.exec.store.SchemaConfig;
v := @parameter: org.apache.calcite.schema.SchemaPlus;
v = virtualinvoke v.<org.apache.drill.exec.store.SchemaConfig: org.apache.drill.exec.proto.UserBitShared$UserCredentials getQueryUserCredentials()>();
v = v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: java.util.Optional getDataSource(org.apache.drill.exec.proto.UserBitShared$UserCredentials)>(v);
v = virtualinvoke v.<java.util.Optional: boolean isPresent()>();
if v != 0 goto label;
return;
label:
v = v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin>;
v = v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.calcite.sql.SqlDialect dialect>;
v = virtualinvoke v.<org.apache.drill.exec.store.SchemaConfig: org.apache.drill.exec.proto.UserBitShared$UserCredentials getQueryUserCredentials()>();
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: org.apache.drill.exec.store.jdbc.DrillJdbcConvention getConvention(org.apache.calcite.sql.SqlDialect,org.apache.drill.exec.proto.UserBitShared$UserCredentials)>(v, v);
v = new org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseCatalogSchema;
v = v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: java.lang.String getName()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object get()>();
v = v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.calcite.sql.SqlDialect dialect>;
specialinvoke v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseCatalogSchema: void <init>(java.lang.String,javax.sql.DataSource,org.apache.calcite.sql.SqlDialect,org.apache.drill.exec.store.jdbc.DrillJdbcConvention)>(v, v, v, v);
v = v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.jdbc.JdbcStoragePlugin: java.lang.String getName()>();
v = interfaceinvoke v.<org.apache.calcite.schema.SchemaPlus: org.apache.calcite.schema.SchemaPlus add(java.lang.String,org.apache.calcite.schema.Schema)>(v, v);
virtualinvoke v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseCatalogSchema: void setHolder(org.apache.calcite.schema.SchemaPlus)>(v);
return;
}
public java.lang.String generateSql(org.apache.calcite.plan.RelOptCluster, org.apache.calcite.rel.RelNode)
{
org.apache.calcite.plan.RelOptCluster v;
org.apache.calcite.rel.type.RelDataTypeFactory v;
org.apache.calcite.rel.RelShuttle v;
org.apache.calcite.rel.RelNode v, v;
org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect v;
org.apache.calcite.sql.SqlDialect v, v;
org.apache.calcite.rel.rel2sql.SqlImplementor$Result v;
org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcImplementor v;
org.apache.calcite.sql.SqlNode v;
org.apache.calcite.sql.util.SqlString v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect;
v := @parameter: org.apache.calcite.plan.RelOptCluster;
v := @parameter: org.apache.calcite.rel.RelNode;
v = new org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcImplementor;
v = v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.calcite.sql.SqlDialect dialect>;
v = virtualinvoke v.<org.apache.calcite.plan.RelOptCluster: org.apache.calcite.rel.type.RelDataTypeFactory getTypeFactory()>();
specialinvoke v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcImplementor: void <init>(org.apache.calcite.sql.SqlDialect,org.apache.calcite.adapter.java.JavaTypeFactory)>(v, v);
v = <org.apache.drill.exec.store.SubsetRemover: org.apache.calcite.rel.RelShuttle INSTANCE>;
v = interfaceinvoke v.<org.apache.calcite.rel.RelNode: org.apache.calcite.rel.RelNode accept(org.apache.calcite.rel.RelShuttle)>(v);
v = virtualinvoke v.<org.apache.calcite.adapter.jdbc.JdbcImplementor: org.apache.calcite.rel.rel2sql.SqlImplementor$Result visitRoot(org.apache.calcite.rel.RelNode)>(v);
v = virtualinvoke v.<org.apache.calcite.rel.rel2sql.SqlImplementor$Result: org.apache.calcite.sql.SqlNode asStatement()>();
v = v.<org.apache.drill.exec.store.jdbc.clickhouse.ClickhouseJdbcDialect: org.apache.calcite.sql.SqlDialect dialect>;
v = virtualinvoke v.<org.apache.calcite.sql.SqlNode: org.apache.calcite.sql.util.SqlString toSqlString(org.apache.calcite.sql.SqlDialect)>(v);
v = virtualinvoke v.<org.apache.calcite.sql.util.SqlString: java.lang.String getSql()>();
return v;
}
}