CN115329007B 数据库之间的数据同步方法、系统、电子设备及存储介质 （广域铭岛数字科技有限公司）

WO2015062181A1,2015.05.07息中的同步数据粒度对目标数据库对应的二进基于系统数据库对应的同步订阅信息确定原始2将任一同步订阅信息确定为目标信息，将所述目标信息对应的系将所述目标信息的同步数据粒度确定为目标粒度，根据所述目标粒库对应的二进制日志进行监听，若所述二进制日志中产生所述目标粒度对应的增量日志，根据所述目标信息的数据同步方式将所述增量数据推送至所述根据所述目标粒度对所述目标数据库对应的二进制日志进行监根据所述目标信息的数据同步方式将所述增量数据推送至所述原若所述数据同步方式包括接口请求同步，则根据预设接口信息通过所述接口地址将所述同步请求发送至所述原始数据库的若所述数据同步方式包括数据库同步，则获取所述原始数据库所述数据库类型从预设指令模板中匹配所述数据库类型对应的同将所述数据同步语句推送至所述原始数据库，使得所述原始数据库3若所述失败结果次数大于预设失败阈值，则重新根据所述目标5.根据权利要求1至4任一项所述的方法，其监控所述同步任务队列；若所述同步任务队列存在所述原始数据库对应的同步任务，则若所述同步任务队列不存在所述原始数据库对应的同步任务，获取模块，用于获取多个系统数据库，并获取至少一部分所述系据库确定为原始数据库，根据所述目标信息的订阅目标标识对各所述系统数据库进行匹提取模块，用于将所述目标信息的同步数据粒度确定为目标粒度，根据所所述提取模块通过以下方式根据所述目标粒度对所述目标数据库对应的二进制日志应的二进制日志中确定所述目标表对应的增所述同步模块通过以下方式根据所述目标信息的数据同步方式将所述增量数据推送4所述存储器用于存储计算机程序，所述处理器用于执行所述存储器存储的计算机程所述计算机程序被处理器执行时实现如权利要求1至5任一项5[0005]鉴于以上所述现有技术的缺点，本发明公开了一种数据库之间的数据同步方法、6目标信息的数据同步方式将所述增量数据推送至所述原始数据库；监控所述同步任务队息的订阅目标标识对各所述系统数据库进行匹配，得到所述原始数据库对应的目标数据7[0027]需要说明的是，以下实施例中所提供的图示仅以示意方式说明本发明的基本构89中提取数据同步方式对应的元数据；如果推送方式是http(HyperTextTransfer的系统数据库确定为原始数据库，根据目标信息的订阅目标标识对各系统数据库进行匹始数据库；数据推送服务304用于根据目标信息的数据同步方式将增量数据推送至原始数识、同步数据粒度和数据同步方式；匹配模块402用于将任一同步订阅信息确定为目标信同步数据粒度确定为目标粒度，根据目标粒度对目标数据库对应的二进制日志进行监听，[0068]图5示出了适于用来实现本申请实施例的电子设备的计算机系统的结构示意图。508加载到随机访问存储器(RandomAccessMemory，RAM)503中的程序而执行各种适当的程序和数据。CPU501、ROM502以及RAM503通过总线504彼此相连。输入/输出(Inpu或者计算机可读存储介质或者是上述两者的任意组合。计算机可读存储介质例如可以是机磁盘、硬盘、随机访问存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器质还可以是计算机可读存储介质以外的任何计算机可读介质，该计算机可读介质可以发[0076]在本实施例中，存储器可能包含随机存取存储器(RandomAccessMemory，简称[0077]上述的处理器可以是通用处理器，包括中央处理器(CentralProce简称CPU)、图形处理器(GraphicsProcessingUnit，简称GPU)，网络处理器(NetworkProcessor，简称NP)等；还可以是数字信号处理器(DigitalSignalProcessing，简称以上相关联的列出的任何以及所有可能的组合。另外，当用于本申请中时，术语“包括”对应的描述中，不同的方框所对应的