(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211086924.9 (22)申请日 2022.09.07 (71)申请人 中邮科通信技 术股份有限公司 地址 350007 福建省福州市仓山区仓山科 技园6区1号 (72)发明人 李松清　邵冲　 (74)专利代理 机构 福州元创专利商标代理有限 公司 35100 专利代理师 陈明鑫　蔡学俊 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/242(2019.01) (54)发明名称 一种写入多数据源的实现方法与系统 (57)摘要 本发明涉及一种写入多数据源的实现方法 与系统。 根据业务场景， 以yml格式定义语句所在 的数据源列表， 然后使用语句获取器得到相应的 存储过程， 新增、 更新、 删除语句以及数据源信 息， 整合成主题消息发送给中间件。 在语句准备 场景中， 多线程管理器会根据所配置的主题， 开 启多个线程池。 在语句执行场景中， 执行线程会 对语句进行转换， 并在指定数据源 执行转换后的 语句。 在语句收集场景中， 语句获取器或者语句 执行器在工作的过程中出现错误语句会被语句 收集器写入错误日志数据库。 在日志执行场景 中， 日志执行器会定期从错误日志数据库获取需 要处理的语句， 重新执行。 本发明能够以相对通 用的方式实现写入多个数据源功能， 并且保障一 定的实时性和写 入性能。 权利要求书2页 说明书6页 附图3页 CN 115408472 A 2022.11.29 CN 115408472 A 1.一种写入多数据源的实现方法， 其特 征在于， 包括： 根据业务场景， 以yml格 式定义语句所在的数据源列表， 然后使用语句获取器得到相应 的存储过程， 新增、 更新、 删除语句以及数据源信息， 整合成主题消息发送给中间件； 在语句准备场景中， 多线程管理器会根据 所配置的主题， 开启多个线程池； 每个线程池 会根据所配置的线程数， 启动多个线程， 从中间件中采集语句信息； 在语句执行场景中， 执行线程会对语句进行转换， 并在指定数据源执行转换后的语句， 实现写入多数据源功能； 在语句收集场景中， 语句获取器或者语句执行场景中采用的语句执行器在工作的过程 中如果出现错误， 所处理的语句会被语句收集器写入错误日志数据库， 以供后续分析、 处 理； 在日志执行场景中， 日志执行器会定期从错误日志数据库获取需要处理的语句， 重新 执行。 2.根据权利要求1所述的一种 写入多数据源的实现方法， 其特征在于， 语句获取器的语 句拦截功能采用  Druid 的过滤器实现。 3.根据权利要求1所述的一种 写入多数据源的实现方法， 其特征在于， 语句获取器与语 句执行器之间通过中间件进行异步 通信。 4.根据权利要求3所述的一种 写入多数据源的实现方法， 其特征在于， 中间件为消息框 架或数据库。 5.根据权利要求1所述的一种 写入多数据源的实现方法， 其特征在于， 所述根据业务场 景， 以yml格式定义语句所在的数据源列表， 然后使用语句获取器得到相应的存储过程， 新 增、 更新、 删除语句以及数据源信息， 整合成主题消息发送给中间件的具体实现步骤如下： 步骤S51、 判断是否开启多 写功能； 步骤S52、 如果 开启多写， 就利用Druid  的过滤器拦截语句或存 储过程； 步骤S53、 解析步骤S52获得以上语句或存 储过程中的入参； 步骤S54、 基于步骤S53， 判断是否是存储过程、 新增、 更新或删除语句； 若是， 将语句信 息和相关入参发送给中间件； 若否， 返回步骤S5 3； 步骤S55、 如果发送成功， 就继续 监听拦截； 如果发送失败， 就写入异常日志。 6.根据权利要求5所述的一种 写入多数据源的实现方法， 其特征在于， 异常日志为文件 或数据库。 7.根据权利要求1所述的一种 写入多数据源的实现方法， 其特征在于， 语句执行场景具 体包括如下步骤： 步骤S71、 开启并保持 “获取”线程， 持续 不断地从中间件中获取语句 相关信息； 步骤S72、 依据主题， 初始化相应的主题线程池， 并依据所配置的线程池内容， 初始化每 一个线程池； 步骤S73、 开启多个 语句执行线程； 每 个语句执行线程具体包括以下步骤： 步骤S731、 判断是否只需要单写； 如果只需要单写， 则线程执 行完毕； 步骤S732、 判断是否需要关键字转换； 如果需要转换， 则依据配置的转换规则 对语句进 行转换； 步骤S733、 切换到语句需要的数据源；权　利　要　求　书 1/2 页 2 CN 115408472 A 2步骤S734、 判断是否是存 储过程； 如果是， 就执 行存储过程； 如果 不是， 就执 行语句； 步骤S735、 如果执 行存储过程或执 行语句失败， 就写入异常日志。 8.一种计算机存储介质， 其特征在于， 包括计算机指令， 当所述计算机指令在电子设备 上运行时， 使得 所述电子设备 执行如权利要求1 ‑7任一项所述的写入多数据源的实现方法。 9.一种写入多个数据源的实现系统， 其特征在于， 包括存储器、 处理器， 所述存储器上 存储有实现权利要求1 ‑7任一项所述的一种写入多数据源的实现方法的计算机指令， 所述 处理器在运行时执 行存储器上存 储的计算机指令 。权　利　要　求　书 2/2 页 3 CN 115408472 A 3