增量数据操作语句的并发应用装置和方法

摘要

本发明提供了一种增量数据操作语句的并发应用装置，包括：任务确定单元，从第一数据源中获取增量数据操作语句，将增量数据操作语句汇总成事务，根据事务中的增量数据操作语句的数量计算所需的并发任务数，为每个并发任务分配相应的增量数据操作语句；创建单元，获取本地事务的标识并创建跨连接第二数据源的本地事务，创建所需的并发任务；应用单元，将本地事务的标识和并发任务对应的增量数据操作语句集合传送至并发任务并启动并发任务，以执行相应的增量数据操作语句的并发应用，在全部并发任务成功执行结束时，提交第二数据源的本地事务。本发明还提供了一种增量数据操作语句的并发应用方法。在保证数据同步一致性的同时提高数据集成的性能。

主权项

一种增量数据操作语句的并发应用装置，用于将应用于第一数据源的增量数据操作语句同步应用于第二数据源，其特征在于，包括：任务确定单元，从所述第一数据源中获取增量数据操作语句，将所述增量数据操作语句汇总成事务，根据所述事务中的增量数据操作语句的数量计算所需的并发任务数，为每个并发任务分配相应的增量数据操作语句；创建单元，获取本地事务的标识并基于XA接口规范创建跨连接所述第二数据源的所述本地事务，创建所需的并发任务；应用单元，将所述本地事务的标识和所述并发任务对应的增量数据操作语句集合传送至所述并发任务并启动所述并发任务，以执行相应的所述增量数据操作语句的并发应用，在全部所述并发任务成功执行结束时，提交所述第二数据源的所述本地事务。