calcite使用SqlNode

### Apache Calcite 中 SqlNode 的使用 在 Apache Calcite 中，`SqlNode` 是表示 SQL 解析树节点的核心类。当 `SqlParser` 完成对输入 SQL 字符串的解析后，会返回一个代表整个 SQL 查询结构的 `SqlNode` 对象[^1]。 #### 创建 SqlParser 实例并执行解析过程 为了获取 `SqlNode`，首先需要创建一个 `SqlParser.Config` 配置对象，并基于此配置构建 `SqlParser` 实例： ```java // 设置 SqlParser 的配置参数 SqlParser.Config config = SqlParser.config() .withLex(Lex.MYSQL); // 构建 SqlParser 实例 SqlParser parser = SqlParser.create(sqlString, config); ``` 接着调用 `parser.parseQuery()` 方法传入待解析的 SQL 语句字符串即可得到对应的 `SqlNode` 结果： ```java try { // 执行 SQL 解析操作 SqlNode sqlNode = parser.parseQuery(); } catch (SQLException e) { System.out.println("SQL 解析失败：" + e.getMessage()); } ``` #### 访问和遍历 SqlNode 树形结构 一旦获得了 `SqlNode`，就可以利用其提供的 API 来访问子节点或者属性值。对于复杂的查询表达式来说，通常采用递归方式遍历整棵树状图，从而提取所需的信息或修改某些部分的内容[^2]。 例如，如果想要查找所有的表名，则可以通过判断当前节点类型是否为 `SqlIdentifier` 并且该标识符位于 FROM 子句中来定位目标表格名称；如果是希望替换某个函数调用的形式，那么就需要深入到更深层次去匹配具体的语法单元。 #### 应用于实际场景下的例子 假设现在有一个需求是要统计某张订单表里每种商品的数量总和，原始 SQL 如下所示： ```sql SELECT product_id, SUM(quantity) AS total_quantity FROM orders GROUP BY product_id; ``` 此时可以先按照上述方法获得相应的 `SqlNode` 表达式之后再做进一步处理，比如动态调整聚合字段或是增加过滤条件等逻辑上的变更。 ```java if (sqlNode instanceof SqlSelect) { final SqlSelect selectStmt = (SqlSelect) sqlNode; // 获取 SELECT 列表项 List<SqlNode> selectListItems = selectStmt.getSelectList().getOperandList(); // 修改原有列定义... // 或者添加新的 WHERE 过滤条件 SqlBasicCall newWhereCondition = ... ; // 自定义条件 ((SqlSelect) sqlNode).setWhere(newWhereCondition); } ``` 通过这种方式可以在不改变原生数据库驱动程序的前提下灵活地操纵 SQL 文本，极大地提高了开发效率以及维护成本。