wordpress 企业内网,成都优化官网推广,建站语言,安徽建设工程信息网查询Flink SQL中使用Calcite作为sql语法解析、校验、优化工具#xff0c;本篇是实操篇#xff0c;介绍一下calcite做sql语法解析使用方式。sql经过calcite解析之后#xff0c;得到一棵抽象语法树#xff0c;也就是我们说的AST#xff0c;这棵语法树是由不同的节点组成#xf…Flink SQL中使用Calcite作为sql语法解析、校验、优化工具本篇是实操篇介绍一下calcite做sql语法解析使用方式。sql经过calcite解析之后得到一棵抽象语法树也就是我们说的AST这棵语法树是由不同的节点组成节点称之为SqlNode根据不同类型的dml、ddl得到不同的类型的SqlNode例如select语句转换为SqlSelectdelete语句转换为SqlDeletejoin语句转换为SqlJoin。使用方式SqlParser.Config config SqlParser.configBuilder() .setLex(Lex.MYSQL) //使用mysql 语法 .build();//SqlParser 语法解析器 SqlParser sqlParser SqlParser .create(select id,name,age FROM stu where age20, config);SqlNode sqlNode null;try { sqlNode sqlParser.parseStmt();} catch (SqlParseException e) { throw new RuntimeException(, e);}这里解析了一个select的语句那么得到的sqlNode就是一个SqlSelect。if(SqlKind.SELECT.equals(sqlNode.getKind())){SqlSelect sqlSelect (SqlSelect) sqlNode;SqlNode fromsqlSelect.getFrom();SqlNode wheresqlSelect.getWhere();SqlNodeList selectListsqlSelect.getSelectList();//标识符if(SqlKind.IDENTIFIER.equals(from.getKind())){System.out.println(from.toString());}if(SqlKind.LESS_THAN.equals(where.getKind())){SqlBasicCall sqlBasicCall(SqlBasicCall)where;for(SqlNode sqlNode1: sqlBasicCall.operands){if(SqlKind.LITERAL.equals(sqlNode1.getKind())){System.out.println(sqlNode1.toString());}}}selectList.getList().forEach(x-{if(SqlKind.IDENTIFIER.equals(x.getKind())){System.out.println(x.toString());}});}一个select语句包含from部分、where部分、select部分等每一部分都表示一个SqlNode。SqlKind是一个枚举类型包含了各种SqlNode类型SqlSelect、SqlIdentifier、SqlLiteral等。SqlIdentifier表示标识符例如表名称、字段名SqlLiteral表示字面常量一些具体的数字、字符。SqlBasicCall对比SqlSelect/SqlDelete而言可以理解为表示的是一些基本的、简单的调用例如聚合函数、比较函数等接下来看一下其如何解析sum操作select sum(amount) FROM orders //解析的sql//解析select部分selectList.getList().forEach(x-{ if(SqlKind.SUM.equals(x.getKind())){ SqlBasicCall sqlBasicCall(SqlBasicCall)x; System.out.println(sqlBasicCall.operands[0]); } });其内部主要就是operands也是SqlNode节点但是都是一些基本的SqlNode例如SqlIdentifier、SqlLiteral。SqlSelect/SqlDelete/SqlBasicCall 都称之为SqlCall差别是SqlSelect是复杂的SqlCall,内部可以包含其他节点而SqlBasicCall表示简单的SqlCall。另外两种SqlNode:SqlDataTypeSpec与SqlNodeListSqlDataTypeSpec代表数据类型节点例如CHAR/VARCHAR/DOUBLE SqlNodeList表示包含多个同级别的SqlNode在上面select中已经展示过看下SqlDataTypeSpec使用实例select cast(amount as CHAR) FROM orders//解析的sql//解析select部分selectList.getList().forEach(x-{ if(SqlKind.CAST.equals(x.getKind())){ SqlBasicCall sqlBasicCall(SqlBasicCall)x; System.out.println(sqlBasicCall.operands[0]); //amount SqlDataTypeSpec charType(SqlDataTypeSpec)sqlBasicCall.operands[1]; System.out.println(charType.getTypeName()); //CHAR }});另外一种节点SqlOperator可以代表函数、运算符、语法(select)结构例如sum解析为SqlAggFunction、select解析为SqlSelectOperatoras 作为SqlAsOperator。SqlOperator是被嵌入在SqlNode中作为其属性通过SqlOperator的createCall方法可以创建对应的SqlNode使用方式SqlOperator operator new SqlAsOperator();SqlParserPos sqlParserPos new SqlParserPos(1, 1);SqlIdentifier name new SqlIdentifier(orders, null, sqlParserPos);SqlIdentifier alias new SqlIdentifier(o, null, sqlParserPos);SqlNode[] sqlNodes new SqlNode[2];sqlNodes[0] name;sqlNodes[1] alias;SqlBasicCall sqlBasicCall (SqlBasicCall)operator.createCall(sqlParserPos,sqlNodes);System.out.println(sqlBasicCall); //得到的就是 Order as oSqlParsePos表示对应解析的节点在sql位置起止行与起止列。以上介绍了一下calcite解析sql的简单使用方式我们可以使用Calcite来做血缘分析、flink sql维表关联等。
