首页 > 数据库技术 > 详细

简化SQL计算之实现跨库动态MERGE运算

时间:2015-07-04 02:11:20      阅读:289      评论:0      收藏:0      [点我收藏+]

? ? ? ? MSSQLORACLE等数据库都有MERGE语句,用于更新表很方便。但源表和目标表来自不同数据库时,就很难直接使用MERGE语句了。这时候,可以用集算器来协助处理。

???????? 参数sourcetarget代表两个结构相同但数据不同的表,分别属于两个不同的数据库,要求以主键为标准用source更新target,比如table1table2的主键都是AB,数据如下:


bubuko.com,布布扣

?

? ? ? ? ?table2更新table1之后,table1应当如下:


bubuko.com,布布扣
?

? ? ? ??集算器代码:


bubuko.com,布布扣
?

? ? ? ??A1,A2:从系统表中读出表source的主键存入变量pks,计算结果为”A,B”。各种数据库获得主键的方法不同,这里以MSSQL为例。myDB2/myDB1分别指向source/target所在数据库。

? ? ? ??A3,A4:以游标的方式读取sourcetarget,后续的归并运算要求归并项(即主键)有序,故要排序。

? ? ? ??A5:将targetsource进行左链接。@x表示操作游标,@1表示左连接。${columns}是宏,可将字符串转化为表达式。

? ? ? ??A6:从游标A5中循环取数,每次一千条。在循环体B6-B9中可以用A6来引用循环变量。下图是A6的结构:


bubuko.com,布布扣
?

? ? ? ??B6,B7:取出需要insert的记录,并更新target。选项@i表示只生成insert语句,不进行全表扫描。

? ? ? ??B8,B9:取出需要update的记录,并更新target。选项@u表示只生成update语句。函数array可以获得字段名列表。

?

???????? 循环结束后可以看到target(table1)已被更新:


bubuko.com,布布扣
?

???????? 这个方法也可以应用于那些不支持MERGE语句的数据库,如MySQL

?

?

简化SQL计算之实现跨库动态MERGE运算

原文:http://datamachine.iteye.com/blog/2223938

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!