问题描述
我使用 cacite JDBC 连接 hive 并动态添加架构。想直接获取sql列元数据信息,不执行sql。 sql可以验证执行得到结果,但是无法获取sqljoin节点
Class.forName("org.apache.calcite.jdbc.Driver");
String driver = "org.apache.hive.jdbc.HiveDriver";
Class.forName(driver);
String url = "jdbc:hive2://192.168.8.225:10000/default";
Properties info = new Properties();
info.setProperty("caseSensitive","false");
info.put("lex","BIG_QUERY");
DataSource dataSource = JdbcSchema.dataSource(url,driver,null,null);
Connection conn = DriverManager.getConnection("jdbc:calcite:",info);
CalciteConnection calciteConnection = conn.unwrap(CalciteConnection.class);
calciteConnection.setSchema("fdc");
SchemaPlus rootSchema = calciteConnection.getRootSchema();
Connection dataSourceConnection = dataSource.getConnection();
DatabaseMetaData MetaData = dataSourceConnection.getMetaData();
ResultSet schemas = MetaData.getSchemas();
while(schemas.next()) {
String schemasstring = schemas.getString("TABLE_SCHEM");
//just set caseSensitive = false; unquotedCasing = Casing.UNCHANGED; quotedCasing = Casing.UNCHANGED;
HiveJdbcSchema hiveJdbcSchema = HiveJdbcSchema.create(rootSchema,schemasstring,dataSource,schemasstring);
rootSchema.add(schemasstring,hiveJdbcSchema);
}
sqlParser.Config builder = sqlParser.config().withQuotedCasing(Casing.TO_UPPER)
.withUnquotedCasing(Casing.TO_UPPER).withCaseSensitive(false)
.withQuoting(Quoting.BACK_TICK).withUnquotedCasing(Casing.UNCHANGED);
final List<RelTraitDef> traitDefs = new ArrayList<RelTraitDef>();
traitDefs.add(ConventionTraitDef.INSTANCE);
traitDefs.add(RelCollationTraitDef.INSTANCE);
final FrameworkConfig config = Frameworks.newConfigBuilder()
.defaultSchema(rootSchema.getSubSchema("default"))
.parserConfig(builder)
.operatorTable(sqlStdOperatorTable.instance())
.traitDefs(traitDefs)
.context(Contexts.EMPTY_CONTEXT)
.typeSystem(RelDataTypeSystem.DEFAULT)
.build();
Planner planner = Frameworks.getPlanner(config);
String sql = "select t1.* from fdc.t_fdc_base_visit_detail t1 join dim.t_dim3_cms_basic_doctor t2 on t1.doctor_id = t2.doctor_id limit 5";
sqlNode originsqlNode = planner.parse(sql);
Pair<sqlNode,RelDataType> sqlNodeRelDataTypePair = planner.validateAndGetType(originsqlNode);
sqlNode sqlNode = sqlNodeRelDataTypePair.getKey();
//Cannot evaluate org.apache.calcite.sql.sqlJoin.toString()
sqlSelect sqlSelect = (sqlSelect) sqlNode;
//sqlNode from = sqlSelect.getFrom();
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)