公开(公告)号：CN117609260A

公开(公告)日：2024-02-27

申请号：CN202311587049.7

申请日：2023-11-24

Applicant: 北京人大金仓信息技术股份有限公司

Inventor： 庞晖 ,  王凯龙

IPC: G06F16/23 ,  G06F16/27

Abstract: 本发明提供一种数据校验方法、装置、设备、介质和计算机程序产品，该方法包括：将源端数据库中的第一数据表的第一数据，与目标端数据库中的第二数据表的第二数据进行比对；在第一数据的主键值小于第二数据的主键值时，将第一数据存储至源端缓存池，并将第一数据表中排序于第一数据之后的数据，与第二数据表中的第二数据进行比对；在第一数据的主键值大于第二数据的主键值，将第二数据存储至目标端缓存池，并将第一数据与第二数据表中排序于第二数据之后的数据进行比对；在第二数据表中未含有待比对的第二数据时，在目标端缓存池中，获取每个第三数据所匹配的第四数据进行比对。本申请中，提高了数据校验的准确性。

公开(公告)号：CN117609261A

公开(公告)日：2024-02-27

申请号：CN202311587156.X

申请日：2023-11-24

Applicant: 北京人大金仓信息技术股份有限公司

Inventor： 庞晖 ,  王凯龙

IPC: G06F16/23 ,  G06F16/27

Abstract: 本发明提供一种数据校验方法、装置、设备、介质和计算机程序产品，该方法包括：获取源端数据库对应的目标文件，所述目标文件包括所述源端数据库中同步至目标端数据库的各个第一数据的第一标识；在所述目标端数据库中，获取当前同步至所述目标端数据库中的数据对应的第二标识；根据各个所述第一数据同步至所述目标端数据库的同步规则、所述第二标识以及所述目标文件中的各个第一标识，确定已同步至所述目标端数据库的第一数据，作为第二数据；确定所述第二数据在所述目标端数据库所对应的数据以作为第三数据，并比对所述第二数据与所述第三数据是否一致。本申请中，提高了数据校验效率。

公开(公告)号：CN117609378A

公开(公告)日：2024-02-27

申请号：CN202311589117.3

申请日：2023-11-24

Applicant: 北京人大金仓信息技术股份有限公司

Inventor： 庞晖 ,  王凯龙

IPC: G06F16/27 ,  G06F16/23

Abstract: 本发明提供一种数据同步方法、装置、设备、介质和计算机程序产品，该方法包括：在接收的目标端数据库反馈的第一集合的第一执行结果，指示第一集合中的事务执行错误时，将第一集合中的各个事务划分的多个第二集合，发送至目标端数据库；接收目标端数据库反馈的每个第二集合的第二执行结果，并根据各个第二执行结果获取执行错误的第二集合，作为目标集合；在目标集合中的各个事务的第一数量小于第一预设数量时，将目标集合的各个事务发送至目标端数据库；接收目标集合中的每个事务的第三执行结果，并根据各个第三执行结果，在目标集合中的各个事务中，确定出现执行错误的目标事务，且输出提示信息。本申请中，提高了出错事务的查找效率。

公开(公告)号：CN116204347A

公开(公告)日：2023-06-02

申请号：CN202310068283.2

申请日：2023-01-13

Applicant: 北京人大金仓信息技术股份有限公司

Inventor： 魏乾 ,  王凯龙 ,  庞晖

IPC: G06F11/07 ,  G06F16/27 ,  G06F16/2455

Abstract: 本发明提供了一种数据同步错误处理方法及存储介质。错误处理方法包括：获取用于数据同步的多条操作语句，并利用多条操作语句开启数据同步；在执行每条操作语句之前设置保存点；检测每条操作语句的执行结果；若操作语句出现执行失败的情况，确定执行失败的错误类型；确定错误类型是否符合预先配置的语句跳过错误；若错误类型符合语句跳过错误，则根据保存点的位置进行回滚，并执行执行失败的操作语句之后的下一条操作语句。在数据同步过程中，当操作语句出现执行失败的情况，可以只跳过执行失败的操作语句，而无需跳过整个事务，有助于避免将正常执行的操作语句一同回滚导致的丢数问题。

公开(公告)号：CN116107583A

公开(公告)日：2023-05-12

申请号：CN202310066722.6

申请日：2023-01-13

Applicant: 北京人大金仓信息技术股份有限公司

Inventor： 魏乾 ,  王凯龙 ,  庞晖

IPC: G06F8/41

Abstract: 本发明提供了一种数据同步错误处理方法、存储介质及设备，数据同步错误处理方法包括：获取用于数据同步的多个事务；将多个事务以批量同步方式进行数据同步；接收每次批量操作的返回结果；若返回结果报错，获取批量操作中的出错事务；将出错事务回滚；以预设的错误处理策略重新处理出错事务。也就是说，在数据同步正常进行的情况下，数据库系统能够保持以批量同步方式进行数据同步，保证了数据同步的同步性能。在批量同步的同步过程中出现报错时，再采用在批量同步方式下无法实现的错误处理方法对出错事务进行单独处理，有助于保证较好的错误处理效果。