(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202211043727.9 (22)申请日 2022.08.30 (65)同一申请的已公布的文献号 申请公布号 CN 115129738 A (43)申请公布日 2022.09.30 (73)专利权人 太极计算机股份有限公司 地址 100020 北京市朝阳区容达路7号中国 电科太极信息产业园 (72)发明人 陈佳兴　魏凯　梁超　王丽君　 鹿洪杰　焦自玲　 (74)专利代理 机构 北京细软智谷知识产权代理 有限责任公司 1 1471 专利代理师 周亮 (51)Int.Cl. G06F 16/23(2019.01)G06F 11/14(2006.01) (56)对比文件 CN 107193827 A,2017.09.2 2 CN 112052234 A,2020.12.08 CN 112015766 A,2020.12.01 CN 113396407 A,2021.09.14 CN 101807210 A,2010.08.18 JP 2001306380 A,20 01.11.02 US 2016062852 A1,2016.0 3.03 审查员 李娜 (54)发明名称 一种数据跨库写 入方法、 装置和设备 (57)摘要 本发明涉及一种数据跨库写入 方法、 装置和 设备， 属于数据库数据写入技术领域， 创建id判 重表； 通过主业务方法启动第一数据库事务， 保 存目标写入 数据； 通过主业务方法启动第二数据 库事务， 将目标写入数据和id判重表插入第二数 据库事务； 若目标写入数据id与id判重表中的外 键id信息重复， 则第二数据库事务回滚， 第一数 据库事务回滚。 因此， 本发明在主表外构建id判 重表， 在主业务阶段对写入数据进行判重， 不同 数据库之间的数据存在重复时， 事务异常， 发生 回滚， 嵌套的上一个事务也进行回滚， 从而避免 数据重复、 写入不一致的问题； 同时， 多个事务可 同时进行， 提升 了写入效率。 权利要求书2页 说明书7页 附图2页 CN 115129738 B 2022.12.13 CN 115129738 B 1.一种数据跨库写入方法， 应用于高速数据跨库写入， 其特 征在于， 所述方法包括： 创建id判重表， 所述id判重表的外键和主键均为id； 所述id为 高速数据 id， 所述高速数 据id为出口车道+出口时间+出口顺序； 所述 id判重表设置在主表外； 通过主业务方法启动第一数据库事务， 以通过所述第一数据库事务保存目标写入数 据； 所述第一数据库事务尾部嵌套第二数据库事务； 通过所述主业务方法启动第 二数据库事务， 将所述目标写入数据和所述id判重表插入 所述第二数据库事务， 以根据所述id判重表的主键id获取目标写入数据id， 并判断所述目 标写入数据id与所述 id判重表中的外 键id信息是否 重复； 若所述目标写入数据id与所述id判重表中的外键id信息重 复， 则所述第二数据库事务 回滚， 所述第一数据库事务回滚。 2.根据权利要求1所述的方法， 其特 征在于， 在所述创建id判重表之前， 还 包括： 获取写入数据； 根据所述写入数据的passid和id， 筛选并删除所述写入数据中的重复数据， 得到目标 写入数据； 所述passi d为高速数据passi d， 所述高速数据passi d为入口地点+入口时间+入 口顺序号。 3.根据权利要求2所述的方法， 其特征在于， 所述根据所述写入数据的passid和id， 筛 选并删除所述写入数据中的重复数据， 得到目标写入数据， 包括： 根据所述写入数据的passid和id， 在全局二级索引中检索 是否存在重 复的所述写入数 据的id， 若存在重复的所述写入数据的id， 则 删除所述写入数据， 得到目标写入数据。 4.根据权利要求3所述的方法， 其特征在于， 还包括： 构建所述全局二级索引， 所述全局 二级索引的构建过程包括： 对应于主表分表建立索引分表， 以在所述主表分表中存储所述写入数据， 在对应的所 述索引分表中存 储所述写入数据的pas sid和id； 通过回表将所述索引分表中存储的写入数据的id按照预设频率定期回传至数据库， 形 成所述全局二级索引。 5.根据权利要求4所述的方法， 其特征在于， 所述主表分表的个数为至少两个； 所述索 引分表的个数与所述主表分表相对应。 6.一种数据跨库写入 装置， 其特 征在于， 应用于高速数据跨库写入， 所述装置包括： 创建模块， 用于创建id判重表， 所述id判重表的外键和主键均 为id； 所述id为 高速数据 id， 所述高速数据id为出口车道+出口时间+出口顺序； 所述 id判重表设置在主表外； 第一启动模块， 用于通过主业务方法启动第一数据库事务， 以通过所述第一数据库事 务保存目标写入数据； 所述第一数据库事务尾部嵌套第二数据库事务； 第二启动模块， 用于通过所述主业务方法启动第二数据库事务， 将所述目标写入数据 和所述id判重表插入 所述第二数据库事务， 以根据所述id判重表的主键id获取目标写入 数 据id， 并判断所述目标写入数据id与所述 id判重表中的外 键id信息是否 重复； 回滚模块， 用于若所述目标写入数据id与所述id判重表中的外键id信息重复， 则所述 第二数据库事务回滚， 所述第一数据库事务回滚。 7.根据权利要求6所述的装置， 其特征在于， 还包括： 初步判重模块， 用于获取写入数 据； 根据所述写入 数据的passid和id， 筛选并删除所述写入 数据中的重复数据， 得到目标写权　利　要　求　书 1/2 页 2 CN 115129738 B 2入数据； 所述passi d为高速数据passi d， 所述高速数据passi d为入口地点+入口时间+入口 顺序号。 8.根据权利要求7所述的装置， 其特征在于， 所述初步判重模块， 具体用于根据所述写 入数据的passid和id， 在全局二级索引中检索是否存在重复的所述写入数据的id， 若存在 重复的所述写入数据的id， 则 删除所述写入数据， 得到目标写入数据。 9.根据权利要求8所述的装置， 其特征在于， 所述初步判重模块， 还用于构建所述全局 二级索引， 所述全局二级索引的构建过程包括： 对应于主表分表建立索引分表， 以在所述主 表分表中存储所述写入数据， 在对应的所述索引分表中存储所述写入数据的passid和id； 通过回表将所述索引分表中存储的写入 数据的id按照预设频率定期回传至数据库， 形成所 述全局二级索引。 10.一种数据跨库写入设备， 其特征在于， 包括处理器和存储器， 所述处理器与存储器 相连： 其中， 所述处 理器， 用于调用并执 行所述存储器中存 储的程序； 所述存储器， 用于存储所述程序， 所述程序至少用于执行权利要求1 ‑5任一项所述的数 据跨库写入方法。权　利　要　求　书 2/2 页 3 CN 115129738 B 3