如何用 JDBC 进行跨库查询
例题描述和简单分析
Oracle数据库中，有 STATEINFO 表，部分数据如下所示：
STATEID |
POPULATION |
AREA |
1 |
4779736 |
52419 |
2 |
710231 |
663267 |
3 |
6392017 |
113998 |
4 |
2915918 |
52897 |
5 |
37253956 |
163700 |
… |
… |
… |
MySQL数据库中，有 STATENAME 表，部分数据如下所示：
STATEID |
NAME |
ABBR |
1 |
Alabama |
AL |
2 |
Alaska |
AK |
3 |
Arizona |
AZ |
4 |
Arkansas |
AR |
5 |
California |
CA |
… |
… |
… |
逻辑上，两表按 STATEID 关联，需要用 JDBC 进行跨库查询，部分结果如下：
STATEID |
POPULATION |
AREA |
NAME |
ABBR |
1 |
4779736 |
52419 |
Alabama |
AL |
2 |
710231 |
663267 |
Alaska |
AK |
3 |
6392017 |
113998 |
Arizona |
AZ |
4 |
2915918 |
52897 |
Arkansas |
AR |
5 |
37253956 |
163700 |
California |
CA |
… |
… |
… |
… |
… |
解法及简要说明
在集算器中编写脚本 p1.dfx，如下所示：
方法一：SPL
A |
|
1 |
=connect("oracle") |
2 |
=A1.query@x("SELECT * FROM STATEINFO") |
3 |
=connect("mysql") |
4 |
=A3.query@x("SELECT * FROM STATENAME") |
5 |
=join(A2:SI,STATEID;A4:SN,STATEID) |
6 |
=A5.new(SI.STATEID,SI.POPULATION,SI.AREA,SN.NAME,SN.ABBR) |
简要说明：
A1 连接数据源名为 oracle 的数据库
A2 执行 SQL，结果返回序表，执行完后关闭数据库连接
A3 连接数据源名为 mysql 的数据库
A4 执行 SQL，结果返回序表，执行完后关闭数据库连接
A5 序表 A2、A4 按关联字段 STATEID 进行关联
A6 生成需要的结果序表
方法二：简单SQL
A |
|
1 |
=connect("mysql").cursor@x("SELECT * FROM STATENAME") |
2 |
=connect("oracle").cursor@x("SELECT * FROM STATEINFO") |
3 |
$select n.STATEID as STATEID,n.POPULATION as POPULATION,n.AREA as AREA,m.NAME as NAME,m.ABBR as ABBR from {A1} m join {A2} n on m.STATEID=n.STATEID |
简要说明：
A1 连接数据源名为 mysql 的数据库，返回根据 sql 创建的数据库游标，关闭游标时自动关闭数据库连接
A2 连接数据源名为 oracle 的数据库，返回根据 sql 创建的数据库游标，关闭游标时自动关闭数据库连接
A3 用简单 SQL 关联两表
JAVA 集成这段代码的方法可参考：《Java 如何调用 SPL 脚本》。
英文版