flink sql 语法校验

说明：apache flink 源码的校验方式

        
            org.apache.flink
            flink-table-planner-blink_${scala.binary.version}
            对应flink的版本
        

    public List parseFlinkSql(String sql) throws Exception {
        List sqlList = new ArrayList<>();
        if (StringUtils.isNotBlank(sql)) {
            SqlParser parser = SqlParser.create(sql, SqlParser.configBuilder()
                    .setParserFactory(FlinkSqlParserImpl.FACTORY)
                    .setQuoting(Quoting.BACK_TICK)
                    .setUnquotedCasing(Casing.TO_LOWER)   //字段名统一转化为小写
                    .setQuotedCasing(Casing.UNCHANGED)
                    .setConformance(FlinkSqlConformance.DEFAULT)
                    .build()
            );
            List sqlNodeList = parser.parseStmtList().getList();
            if (sqlNodeList != null && !sqlNodeList.isEmpty()) {
                for (SqlNode sqlNode : sqlNodeList) {
                    sqlList.add(sqlNode.toString());
                }
            }
        }
        return sqlList;
    }