一种用于异构数据库之间数据复制的系统及方法

摘要

本发明公开了一种用于异构数据库之间数据复制的系统及方法，该系统包括：用于在计算机中创建并初始化数据共享内存、消息队列和信号量的初始化模块；包括数据读取器、数据适配器和数据装载器的源数据处理模块；用于根据消息队列中消息将数据共享内存中目标数据复制到至少一个目标数据库中的目标数据复制模块；用于释放复制完毕数据共享内存的清理模块。该方法包括：在计算机中创建并初始化数据共享内存、消息队列和信号量；从至少一个源数据库中读取数据，然后将该数据转成至少一个目标数据库的目标数据，再将转换后数据装载入数据共享内存；根据消息队列中消息将数据共享内存中目标数据复制到至少一个目标数据库中；释放复制完毕的数据共享内存。

主权项

一种用于异构数据库之间数据复制的系统，其特征在于，该系统包括：初始化模块，其用于在计算机中创建并初始化数据共享内存、消息队列和信号量以用于存储数据；源数据处理模块，其包括：数据读取器、数据适配器和数据装载器，所述数据读取器用于从至少一个源数据库中读取源数据，所述数据适配器用于将所述数据读取器读取的源数据转换成至少一个目标数据库的目标数据，所述数据装载器用于将转换后的所述目标数据装载入所述数据共享内存；目标数据复制模块，其用于根据所述消息队列中的消息将所述数据共享内存中的所述目标数据复制到所述至少一个目标数据库中；以及清理模块，其用于释放所存数据已被复制完毕的所述数据共享内存；其中，每一个所述数据共享内存对应于一个目标数据库中的一个目标表，所述数据共享内存的结构包括：共享内存体，其包括多个用于存储数据的共享内存段，每个所述共享内存段中的基本存储单位是数据元，所述数据元对应于所述目标数据库中的一个目标表的一条记录或该记录中部分字段的组合；以及共享内存头，其用于存放所述共享内存体的管理信息，所述管理信息包括该共享内存体中所述共享内存段的数量、该共享内存段中所述数据元的数量、所述目标数据记录的长度以及每个所述共享内存段的运行状态；所述消息队列包括：任务消息队列与空闲内存通知消息队列，所述任务消息队列用于存放任务消息，所述空闲内存通知消息队列用于存放通知出现空闲共享内存段的消息。