异构数据库的同步方法和应用系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号(10)申请公布号CN104572672A(43)申请公布日(43)申请公布日2015.04.29(21)申请号201310482186.4(22)申请日2013.10.15(71)申请人北大方正集团有限公司地址100871北京市海淀区成府路298号中关村方正大厦9层申请人方正信息产业控股有限公司北京北大方正电子有限公司(72)发明人廖凌浩蒋国新(74)专利代理机构北京同立钧成知识产权代理有限公司11205代理人张娜(51)Int.Cl.G06F17/30(2006.01)权利要求书3页说明书13页附图3页(54)发明名称异构数据库的同步方法和应用系统(57)摘要本发明提供一种异构数据库的同步方法和应用系统。部署在源数据库侧的同步处理器可以周期性地轮询同步变化表中记录的变化数据，将变化数据封装成数据流发送给部署在目标数据库侧的同步解析器。同步解析器在对该数据流进行解封装之后，可以根据预设的映射文件将源数据表中的变化数据映射为目标数据库中的目标数据表的数据结构，并根据变化数据中的变化类型值进行目标数据表的数据同步，进而可以完成异构数据库之间的数据同步。本发明，无需对现有异构数据库进行改变，只需要在同步解析器上部署不同的映射文件即可实现异构数据库之间的数据同步，实现简单，且易于扩展。CN104572672ACN104572672A权利要求书1/3页1.一种异构数据库的同步方法，其特征在于，包括：同步处理器在确定源数据库的源数据表中发生数据变化时，将所述源数据表中发生变化的数据的标识信息存储在同步变化表中，所述标识信息至少包括所述源数据表的表名、变化数据在所述源数据表中的主键值、变化类型值、变化时间；同步处理器在轮询周期到达时，根据所述同步变化表中的变化时间从所述同步变化表中获取当前时间之前的标识信息，并根据获取的标识信息中的表名、主键值和变化类型值生成变化数据；传输器采用预设的封装格式将所述变化数据封装为数据流，并发送给同步解析器；所述同步解析器接收所述同步处理器通过所述传输器发送的数据流，采用所述预设的封装格式对所述数据流解封装得到所述变化数据，根据预设的映射文件将所述变化数据映射为目标数据库中的目标数据表的数据结构，并根据所述变化数据中的变化类型值进行目标数据库中目标数据表的数据同步。2.根据权利要求1所述的方法，其特征在于，所述同步处理器在确定源数据表中发生数据变化时，将所述源数据表中发生变化的数据的标识信息存储在同步变化表中之前，还包括：数据变化触发器捕获所述源数据表中发生变化的数据，所述数据变化触发器包括插入触发器、删除触发器和更新触发器。3.根据权利要求1所述的方法，其特征在于，所述同步处理器根据获取的标识信息中的表名、主键值和变化类型值生成变化数据之前，还包括：所述同步处理器按照变化时间的先后顺序，对所述当前时间之前的具有相同的主键值的标识信息进行排序；所述同步处理器保留所述具有相同的主键值的标识信息中变化时间最晚的标识信息，并删除所述具有相同的主键值的标识信息中的其它标识信息。4.根据权利要求1所述的方法，其特征在于，若所述变化类型值为插入类型值或更新类型值，则所述同步处理器根据获取的标识信息中的表名、主键值和变化类型值生成变化数据之前，还包括：所述同步处理器根据主键值从源数据表中查找数据是否存在；若存在，则所述同步处理器读取数据完整信息，所述数据完整信息包括字段名、字段值和数据类型；相应的，所述同步处理器根据获取的标识信息中的表名、主键值和变化类型值生成变化数据，包括：所述同步处理器根据所述数据完整信息、表名、主键值和变化类型值生成变化数据；若不存在，则所述同步处理器根据获取的标识信息中的表名、主键值和变化类型值生成变化数据，包括：所述同步处理器将所述变化类型值修改为删除类型值；所述同步处理器根据表名、主键值和删除类型值生成变化数据。5.根据权利要求1所述的方法，其特征在于，所述传输器采用预设的封装格式将所述变化数据封装为数据流，包括：所述传输器采用可扩展标记语言XML将所述变化数据封装为数据流；2CN104572672A权利要求书2/3页所述同步解析器采用所述预设的封装格式对所述数据流解封装得到所述变化数据，包括：所述同步解析器采用XML对所述数据流解封装得到所述变化数据。6.根据权利要求1～5中任一项所述的方法，其特征在于，所述映射文件，包括：所述源数据表的表名与所述目标数据表的表名之间的第一映射关系、所述源数据表中的字段名和数据类型与所述目标数据表中的字段名和数据类型之间的第二映射关系；所述同步解析器根据预设的映射文件将所述变化数据映射为所述目标数据库中的目标数据表的数据结构，包括：所述同步解析器采用所述第一映射关系，将所述变化数据中