(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210934380.0 (22)申请日 2022.08.04 (71)申请人 平安健康保险股份有限公司 地址 200030 上海市徐汇区凯滨路16 6号B 座16楼 (72)发明人 钱鑫　 (74)专利代理 机构 深圳市世联合知识产权代理 有限公司 4 4385 专利代理师 杨晖琼 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/25(2019.01) G06F 16/27(2019.01) G06F 9/54(2006.01) G06F 9/48(2006.01) (54)发明名称 基于多写组件的数据库写入方法、 装置、 设 备及存储介质 (57)摘要 本申请实施例属于数据处理技术领域， 涉及 一种基于多写组件的数据库写入 方法， 包括将构 建的多写组件与业务系统进行连接； 通过多写组 件识别业务系统的待执行的数据库执行语句， 将 携带有目标数据库标签的数据库执行语句顺序 放入链表； 基于多写组件确定数据库执行指令触 达调用末端， 将链表封装成消息投递至消息队 列； 通过多写组件从消息队列中读取消息， 并解 析消息； 通过多写组件执行链表中的数据库执行 语句， 将源数据库中的数据写入目标数据库。 本 申请还提供一种基于多写组件的数据库写入装 置、 设备及存储介质。 此外， 本申请还涉及区块链 技术， 链表可存储于区块链中。 本申请能够实现 业务无感知的情况下完成数据库切换， 提高切换 效率。 权利要求书2页 说明书12页 附图4页 CN 115203262 A 2022.10.18 CN 115203262 A 1.一种基于多 写组件的数据库写入方法， 其特 征在于， 包括下述 步骤： 构建多写组件， 将所述多 写组件与业 务系统进行 连接； 通过所述多写组件识别所述业务系统 的待执行的数据库 执行语句， 将所述数据库 执行 语句顺序放入链 表， 其中， 所述数据库执 行语句携带有目标 数据库标签； 基于所述多写组件确定数据库执行指令触达调用末端， 将所述链表封装成消息投递至 消息队列； 通过所述多写组件从所述消息队列中读取所述消息， 并解析所述消息， 得到源数据库、 目标数据库以及对应的链 表； 通过所述多写组件执行所述链表中的数据库执行语句， 将所述源数据库中的数据写入 目标数据库。 2.根据权利要求1所述的基于多写组件的数据库写入方法， 其特征在于， 所述将所述数 据库执行语句顺序放入链 表的步骤 包括： 确定所述数据库执 行语句所属事务； 将属于同一事务的所述数据库执 行语句， 按照执 行顺序放入所属事务对应的链 表中。 3.根据权利要求1所述的基于多写组件的数据库写入方法， 其特征在于， 所述基于所述 多写组件确定数据库执行指令触达调用末端， 将所述链表封装成消息投递至消息队列的步 骤包括： 通过所述多写组件确定数据库执 行指令当前 所执行的数据库执 行语句的语句层级； 当所述语句层级为预定值时， 则确定所述数据库执 行指令触达调用末端； 按照预设消息结构将所述链 表封装成消息， 并将所述消息投递至所述消息队列。 4.根据权利要求1所述的基于多写组件的数据库写入方法， 其特征在于， 在所述解析所 述消息， 得到源数据库、 目标 数据库以及对应的链 表的步骤之后还 包括： 通过所述多写组件确定是否开启数据库语法自动转换； 若为是， 转换数据库语法， 执行所述通过所述多写组件执行所述链表中的数据库执行 语句的步骤； 若为否， 直接执 行所述通过所述多写组件执 行所述链表中的数据库执 行语句的步骤。 5.根据权利要求1所述的基于多写组件的数据库写入方法， 其特征在于， 在所述将所述 源数据库中的数据写入目标 数据库的步骤之后还 包括： 确定数据写入是否异常； 在数据写入异常时， 通过 所述多写组件识别异常类型， 并获取异常日志； 基于所述异常日志获取对应的异常执 行的数据库执 行语句， 并存 储至异常数据库中。 6.根据权利要求5所述的基于多写组件的数据库写入方法， 其特征在于， 在所述基于所 述异常日志获取对应的异常执行的数据库执行语句， 并存储至异常数据库中的步骤之后还 包括： 确定所述多 写组件识别的所述异常类型 是否为已知异常； 在所述异常类型为已知异常时， 从所述异常数据库中获取对应的所述异常执行的数据 库执行语句； 对所述异常执 行的数据库执 行语句进行自动补偿。 7.根据权利要求6所述的基于多写组件的数据库写入方法， 其特征在于， 所述对所述异权　利　要　求　书 1/2 页 2 CN 115203262 A 2常执行的数据库执 行语句进行自动补偿的步骤 包括： 通过所述多写组件按照顺序重新执 行所述异常执 行的数据库执 行语句； 每重新执 行一次， 补偿次数加一， 直至 达到预配置的补偿次数 上限。 8.一种基于多 写组件的数据库写入 装置， 其特 征在于， 包括： 构建模块， 用于构建多 写组件， 将所述多 写组件与业 务系统进行 连接； 识别模块， 用于通过所述多写组件识别所述业务系统的待执行的数据库执行语句， 将 所述数据库执 行语句顺序放入链 表， 其中， 所述数据库执 行语句携带有目标 数据库标签； 投递模块， 用于基于所述多写组件确定数据库执行指令触达调用末端， 将所述链表封 装成消息投递至消息队列； 解析模块， 用于通过所述多写组件从所述消息队列中读取所述消息， 并解析所述消息， 得到源数据库、 目标 数据库以及对应的链 表； 写入模块， 用于通过所述多写组件执行所述链表中的数据库执行语句， 将所述源数据 库中的数据写入目标 数据库。 9.一种计算机设备， 包括存储器和处理器， 所述存储器中存储有计算机可读指令， 所述 处理器执行所述计算机可读指令时实现如权利要求1至7中任一项所述的基于多写组件的 数据库写入方法的步骤。 10.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质上存储有计算机 可读指令， 所述计算机可读指 令被处理器执行时实现如权利要求 1至7中任一项 所述的基于 多写组件的数据库写入方法的步骤。权　利　要　求　书 2/2 页 3 CN 115203262 A 3