1、简介

最近一阵子笔者在进行完成同样功能的两套异构数据库系统的同步工作，有一些心得体会分享给大家，欢迎技术同仁拍砖。

该项目有一个运行若干年（5～10年）的旧系统，采用的是SQL Server数据库，因为旧平台功能较弱，所以所有对数据库的访问操作都通过存储过程进行操作。

新系统采用笔者公司的平台，应客户需求采用Oracle数据库，完成的功能与旧系统基本相同，但表设计与原有系统不同，有些表对应旧系统中的一张表，但字段名称等大都不一样。另外还有新系统中一张表对应旧系统中多张小表的情况，也有新系统中多个表对应旧系统中多张表的情况。新系统较少依赖数据库，数据库操作都在业务逻辑层完成。

因为旧系统在全国几十个点上运行，而新系统全部替换旧系统需要比较长的时间，该项目采用的是按地区进行逐步替换的原则，所以涉及到需要在两种不同数据库类型、不同数据库结构的异构数据库进行同步。

2、重要术语

2.1 异构数据库

异构数据库系统是相关的多个数据库系统的集合，可以实现数据的共享和透明访问，每个数据库系统在加入异构数据库系统之前本身就已经存在，拥有自己的DBMS。异构数据库的各个组成部分具有自身的自治性，实现数据共享的同时，每个数据库系统仍保有自己的应用特性、完整性控制和安全性控制。

可以是同为关系型数据库系统的Oracle、SQL Server等，也可以是不同数据模型的数据库，如关系、模式、层次、网络、面向对象，函数型数据库共同组成一个异构数据库系统。

2.2 数据捕获

数据的捕获是数据库同步的基础，变化数据的捕获主要有基于快照法、基于触发器法、基于日志法、基于API法、影子表法和控制表变化法。基于快照法效率比较低一般不能用于同步，可使用基于触发器法、基于日志法或基于API法和控制表变化法进行变化数据的捕获。

旧系统的数据库操作都是通过存储过程，所以可将存储过程作为数据捕获点。

新系统可采用笔者公司平台底层提供了同步程序，该程序能将某个Linux用户本平台进程下所有对指定表（需要同步的表）的所有INSERT、UPDATE和DELETE语句都捕获到，并同步给另一个用户下的同步数据接收进程，该进程能指定接收到同步数据时进行的操作，例如写文件、调用指定的业务进行处理等。

3、同步方案

3.1 需要同步的内容

3.1.1确认哪些SQL需要同步

在数据库表创建以后，有SELECT、INSERT、UPDATE和DELETE四种操作的语句，因为SELECT语句不会影响表数据的改变，所以只需要INSERT、UPDATE和DELETE操作进行同步。

3.1.2确认哪些表需要同步

并不是所有的表都需要进行同步的，例如如下表就不需要同步：

（1）在系统创建之初需要导入数据，后期基本不需要改动或绝少改动的表：这些表的数据基本只需要在新系统初期将数据导入即可。

（2）一方系统具有，另一方不具有的功能对应的表：例如新系统加上了一些额外的功能，而旧系统没有，这些表不需要同步。

3.1.3确认异构数据库之间的表和字段的对应

这个是异构数据库编码之前最耗费时间的工作，也是最重要的工作，因为只有严格对应，才能使两者同步后数据库在同步数据后不管用哪套系统都能完成同样的工作。

首先，要对新旧系统中的近50张表找出对应关系：某一张表在对方有一一对应的表？还是对应对方多张表？还是只是对应对方表的一部分？

接着，需要找出字段的对应关系，字段名称是否相同？字段类型是否相同？一个字段是否对应对方表的多个字段？

笔者在Excel表格中列出了所有表与对方表结构的对应关系，这个表格很重要，是后面无论采用何种同步方案都需要用到的同步的依据。

3.2 可选方案

3.2.1编写触发器进行同步

 当数据库为同步对象创建相应的触发器，当对同步对象进行INSERT、UPDATE和DELETE等DML（Data Manipulation Language）操作时，触发器被唤醒，将变换传播到目标数据库。

 采用此种方式时，需要在两边的数据库中都创建对需要同步的每个表的INSERT、UPADTE和DELETE操作的三个触发器，当源表发生INSERT、UPDATE和DELETE操作时触发器被启动。因此若两边都有50个需要同步的表，需要编写的触发器个数为：(50+50)*3 = 300（个）。

采用该种方式的缺点是：

（1）       需要为每个需要同步的表编写三个触发器，工作量巨大；

（2）       触发器具有不容易排错、可移植性差、占用资源大等缺点；

（3）       代码可复用性不好。

3.2.2按系统操作同步

 按系统操作同步就是在所有进行数据库更新操作的地方都将其转换成对方的数据库操作进行