calcite跨源查询

### 使用 Apache Calcite 实现跨源查询 #### 1. 配置多个数据源 为了实现跨源查询，首先需要配置多个数据源。这可以通过定义不同的 `Schema` 来完成，每个 `Schema` 对应一个特定的数据源。 ```java // 定义 MySQL 数据源 Map<String, Object> mysqlProps = new HashMap<>(); mysqlProps.put("url", "jdbc:mysql://localhost:3306/db1"); mysqlProps.put("driver", "com.mysql.cj.jdbc.Driver"); // 定义 PostgreSQL 数据源 Map<String, Object> pgsqlProps = new HashMap<>(); pgsqlProps.put("url", "jdbc:postgresql://localhost:5432/db2"); pgsqlProps.put("driver", "org.postgresql.Driver"); // 创建 Schema 工厂实例 JdbcSchema.Factory factory = JdbcSchema.factory(); // 构建 Schemas SchemaPlus rootSchema = Frameworks.createRootSchema(true); rootSchema.add("MYSQL", factory.create(rootSchema, mysqlProps)); rootSchema.add("PGSQL", factory.create(rootSchema, pgsqlProps)); ``` #### 2. 设置 Planner 和 SqlNode 解析器 接下来设置规划器 (Planner)，并创建 SQL 查询解析器 (`SqlNode`)。 ```java FrameworkConfig config = Frameworks.newConfigBuilder() .defaultSchema(rootSchema) .build(); Planner planner = Frameworks.getPlanner(config); String sqlQuery = "SELECT * FROM MYSQL.table1 JOIN PGSQL.table2 ON table1.id = table2.ref_id"; SqlNode sqlNode; try { sqlNode = planner.parse(sqlQuery); // 将字符串形式的 SQL 转化为 SqlNode 表达式树结构[^1] } catch (SQLException e) { throw new RuntimeException(e.getMessage()); } planner.validate(sqlNode); // 校验 SQL 的合法性 RelNode relNode = planner.rel(sqlNode).rel(); // 把逻辑计划转换成物理执行计划 ``` #### 3. 执行查询 最后一步就是实际运行这个查询，并获取结果集。 ```java Enumerable<Object[]> enumerableResult = EnumerableRelImplementor singleton = new EnumerableRelImplementor().implement(relNode).enumerable; for (Object[] row : enumerableResult) { // 迭代遍历每一行记录 System.out.println(Arrays.toString(row)); // 输出每条记录的内容 } ``` 通过上述过程可以成功地利用 Apache Calcite 实施多表联接操作跨越不同类型的数据库系统之间进行复杂查询处理[^2]。