(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210271997.9 (22)申请日 2022.03.18 (71)申请人 海南格子山网络科技有限公司 地址 571900 海南省澄迈县老城镇高新 技 术产业示范区海南生态软件园A17幢 二层3001 (72)发明人 李倩　 (74)专利代理 机构 成都东恒知盛知识产权代理 事务所 (特殊普通合伙) 51304 专利代理师 罗江 (51)Int.Cl. G06F 16/27(2019.01) G06F 16/23(2019.01) G06F 16/22(2019.01) (54)发明名称 数据库在线同步方法 (57)摘要 本发明涉及数据库同步技术领域， 涉及一种 数据库在线同步方法， 其包括以下步骤： 一、 建立 数据同步服务； 二、 在源数据库上创建服务配置 列表； 三、 创建了存储过程， 然后读取服务配置列 表中的列表信息， 向不同的服务发送消息； 四、 创 建同步异常信息表和数据同步反馈表； 五、 激活 在源数据库中创建的消息队列并指定存储过程； 六、 判断执行同步的操作类型， 创建的存储过程 来对数据进行处理并发送； 七、 将XML数据源中的 数据同步到数据表中； 八、 读取消息队列中的信 息并调用存储 过程将数据同步到目标数据库中； 九、 通过目标数据库中的消息队列校验数据同步 信息是否正确。 本发明在同步任务过程中能够减 少人工参与， 效率高。 权利要求书1页 说明书3页 附图1页 CN 114661819 A 2022.06.24 CN 114661819 A 1.数据库在线同步方法， 其特 征在于： 包括以下步骤： 一、 建立数据同步 服务； 二、 在源数据库上创建一个服 务配置列表， 用来保存服 务名称； 三、 创建了一个存储过程用来发送同步消息， 然后通过创建一个游标来读取服务配置 列表中的列表信息， 向不同的服 务发送消息； 四、 创建同步异常信息表和数据同步反馈表， 用来记录在数据同步过程中出现的异常 信息并记录 到异常信息表中， 并在数据异常时反馈 到UI界面； 五、 激活在源数据库中创建的消息队列并指定之前创建的存 储过程； 六、 判断执 行同步的操作类型， 创建的存 储过程来对数据进行处 理并发送； 七、 将XML数据源中的数据根据操作类型的不同 同步到数据表中； 八、 读取消息队列中的信息并调用存 储过程将数据同步到目标 数据库中； 九、 通过目标 数据库中的消息队列校验数据同步信息是否正确并反馈 到UI界面。 2.根据权利要求1所述的数据库在线 同步方法， 其特征在于： 步骤一之前， 还包括以下 步骤： a、 在页面输入数据库账号密码并给 数据库授信； b、 创建数据库密钥对传输数据进行加密； c、 创建数据同步时的消息类型以及错 误反馈消息类型和数据同步协议； d、 在目标 数据库创建消息队列。 3.根据权利要求1所述的数据库在线 同步方法， 其特征在于： 步骤一中， 如果有多个数 据表需要同步， 则需创建多个服 务。 4.根据权利要求1所述的数据库在线 同步方法， 其特征在于： 步骤二中， 同步消息内容 包括操作类型、 主键表名、 正文内容， 分别对应@DMLType,@Pri maryKeyField,@TableName,@ XMLData。 5.根据权利要求1所述的数据库在线 同步方法， 其特征在于： 步骤六中， 查询源数据库 中的Inserted和Deleted临时表来判断执 行同步的操作类型。 6.根据权利要求5所述的数据库在线同步方法， 其特征在于： 操作类型包括更新U、 新增 A和删除D。权　利　要　求　书 1/1 页 2 CN 114661819 A 2数据库在线 同步方法 技术领域 [0001]本发明涉及数据库同步 技术领域， 具体地说， 涉及一种数据库在线同步方法。 背景技术 [0002]随着项目增多相应数据量快速增大， 随着业务规模的增长， 数据同步花费的时间 会越来越长， 无法满足下游数仓生产的时间要求。 性能瓶颈： 直连数据库查询数据， 对数据 库影响非常大， 容易造成慢查询， 如果业务库没有采取主备策略， 则会影响业务线 上的正常 服务， 如果采取了主备策略， 虽然可以避免对业务系统的性能影响， 但当数据量较大时， 性 能依然会很 差。 发明内容 [0003]本发明的内容是提供一种数据库在线同步方法， 其能够克服现有技术的某种或某 些缺陷。 [0004]根据本发明的数据库在线同步方法， 其包括以下步骤： [0005]一、 建立数据同步 服务； [0006]二、 在源数据库上创建一个服 务配置列表， 用来保存服 务名称； [0007]三、 创建了一个存储过程用来发送同步消息， 然后通过创建一个游标来读取服务 配置列表中的列表信息， 向不同的服 务发送消息； [0008]四、 创建同步异常信息表和数据同步反馈表， 用来记录在数据同步过程中出现的 异常信息并记录 到异常信息表中， 并在数据异常时反馈 到UI界面； [0009]五、 激活在源数据库中创建的消息队列并指定之前创建的存 储过程； [0010]六、 判断执 行同步的操作类型， 创建的存 储过程来对数据进行处 理并发送； [0011]七、 将XML数据源中的数据根据操作类型的不同 同步到数据表中； [0012]八、 读取消息队列中的信息并调用存 储过程将数据同步到目标 数据库中； [0013]九、 通过目标 数据库中的消息队列校验数据同步信息是否正确并反馈 到UI界面。 [0014]作为优选， 步骤一之前， 还 包括以下步骤： [0015]a、 在页面输入数据库账号密码并给 数据库授信； [0016]b、 创建数据库密钥对传输数据进行加密； [0017]c、 创建数据同步时的消息类型以及错 误反馈消息类型和数据同步协议； [0018]d、 在目标 数据库创建消息队列。 [0019]作为优选， 步骤一中， 如果有 多个数据表需要同步， 则需创建多个服 务。 [0020]作为优选， 步骤二中， 同步消息内容包括操作类型、 主键表名、 正文内容， 分别对 应@DMLType,@PrimaryK eyField,@TableName,@XMLData。 [0021]作为优选， 步骤六中， 查询源数据库中的Inserted和Delet ed临时表来判断执行同 步的操作类型。 [0022]作为优选， 操作类型包括更新U、 新增A和删除D。说　明　书 1/3 页 3 CN 114661819 A 3