1 .一种异构数据库数据同步方法,其特征在于,包括:
从源数据库传输来的增量数据文件中读取增量数据;
将所述增量数据以预设文件格式写入本地缓存文件;所述预设文件格式与对所述增量
数据的数据操作类型相关;
调用归属于目标数据库的数据装载工具从所述本地缓存文件中读取增量数据,以将读
取的增量数据批量装载至所述目标数据库;其中,所述目标数据库是数据仓库。
2.根据权利要求1所述的异构数据库数据同步方法,其特征在于,所述将所述增量数据
以预设文件格式写入本地缓存文件,包括:
获取针对所述增量数据的数据操作类型;
基于所述数据操作类型的不同,将所述增量数据以对应的不同预设文件格式写入所述
本地缓存文件。
3 .根据权利要求2所述的异构数据库数据同步方法,其特征在于,所述预设文件格式包
括第一预设文件格式、第二预设文件格式和第三预设文件格式;所述第一预设文件格式与
数据插入操作相关;所述第二预设文件格式与数据删除操作相关;所述第三预设文件格式
与数据更新操作相关;
所述基于所述数据操作类型的不同,将所述增量数据以对应的不同预设文件格式写入
所述本地缓存文件,包括:
在所述数据操作类型是数据插入操作时,将所述增量数据以所述第一预设文件格式写
入所述本地缓存文件;
在所述数据操作类型是数据删除操作时,将所述增量数据以所述第二预设文件格式写
入所述本地缓存文件;
在所述数据操作类型是数据更新操作时,将所述增量数据以所述第三预设文件格式写
入所述本地缓存文件。
4 .根据权利要求1~3任一项所述的异构数据库数据同步方法,其特征在于,所述目标
数据库提供用以批量导入格式化文本文件的数据加载工具,且所述目标数据库支持MERGE
操作;所述同步方法还包括:
所述数据装载工具将读取的增量数据写入所述目标数据库的中间临时表;
调用所述MERGE操作将所述中间临时表中的增量数据批量装载至所述目标数据库中对
应的实际数据表。
5 .根据权利要求4所述的异构数据库数据同步方法,其特征在于,所述预设文件格式还
包括第四预设文件格式,所述第四预设文件格式与所述MERGE操作相关;
所述将所述增量数据以预设文件格式写入本地缓存文件,包括:
将所述增量数据以所述第四预设文件格式写入所述本地缓存文件。
6 .根据权利要求4所述的异构数据库数据同步方法,其特征在于,所述从源数据库传输
来的增量数据文件中读取增量数据之前,还包括:
初始化读线程和写线程,建立所述写线程对应的缓存队列,将所述写线程与所述目标
数据库连接。
7 .根据权利要求6所述的异构数据库数据同步方法,其特征在于,所述从源数据库传输
来的增量数据文件中读取增量数据,包括:
权 利 要 求 书
1/2 页
2
评论