com.cestc.dassets.service;importcom.alibaba.druid.sql.SQLUtils;importcom.alibaba.druid.sql.ast.SQLStatement;importcom.alibaba.druid.sql.visitor.SchemaStatVisitor;importcom.alibaba.druid.stat.TableStat;importcom.alibaba.druid.util.JdbcConstants;importlombok.extern.slf4j.Slf4j;importjava.util.Collection;importjava.util.List;importjava.util.Map;importjava.util.Objects;
@Slf4jpublic classTest {public static void main(String args[]) throwsException {
String sql= "insert overwrite table kf_zt.account2 SELECT swjg_dm,swjgmc FROM (SELECT swjg_dm AS swjg_dm, swjgmc AS swjgmc FROM (SELECT swjg_dm,swjgmc FROM ( SELECT swjg_dm,swjgmc FROM yuangongs) table_350 UNION SELECT swjg_dm,swjgmc FROM (SELECT swjg_dm2,swjgmc2 FROM yuangong ) table_295) union_013) udf_882";
List sqlStatements =SQLUtils.parseStatements(sql.toLowerCase(), JdbcConstants.HIVE);for(SQLStatement sqlStatement : sqlStatements) {
SchemaStatVisitor schemaStatVisitor=SQLUtils.createSchemaStatVisitor(JdbcConstants.HIVE);
sqlStatement.accept(schemaStatVisitor);
Map tables =schemaStatVisitor.getTables();
Collection columns =schemaStatVisitor.getColumns();if(Objects.nonNull(tables)) {
tables.forEach(((name, tableStat)->{if (tableStat.getCreateCount() > 0 || tableStat.getInsertCount() > 0) {
log.info("to: table[{}]", name.getName().toLowerCase());
columns.stream().filter(column-> Objects.equals(column.getTable().toLowerCase(), name.getName().toLowerCase())).forEach(column ->{
log.info("to: table[{}] column[{}]", column.getTable().toLowerCase(), column.getName().toLowerCase());
});
}else if (tableStat.getSelectCount() > 0) {
log.info("from: table[{}]", name.getName().toLowerCase());
columns.stream().filter(column-> Objects.equals(column.getTable().toLowerCase(), name.getName().toLowerCase())).forEach(column ->{
log.info("from: table[{}] column[{}]", column.getTable().toLowerCase(), column.getName().toLowerCase());
});
}
}));
}
}
}
}
使用Druid解析SQL实现血缘关系计算
标签：log slf4j exception druid exce over div 计算 creat
本条技术文章来源于互联网，如果无意侵犯您的权益请点击此处反馈版权投诉
本文系统来源：https://www.cnblogs.com/changxy-codest/p/13535143.html