CN115422286B 一种分布式数据库的数据同步方法及设备 （武汉达梦数据库股份有限公司）

发区高新大道999号未来科技大厦C3US2019179930A1,2019.本发明涉及一种分布式数据库的数据同步所述源端数据同步系统从源端数据库读取、解端数据同步系统在接收到所述源端数据同步系2数据同步系统包括元数据管理节点运行模式以及数在元数据管理节点运行模式下，所述源端数据同步系统初始化所述目标端数据同步系统在接收到所述源端数据同步系统发送过来的消息包后进行所述目标端同步系统的DDL协同入库策略包括：目标端数据同步系统在目标端数据库若n1不大于0，则进行DDL操作类型的判断并根据操作类型的不同使0，则进行DDL操作类型的判断并根据操作类型的不同使用不同过程对DDL_SYNC表上X锁具5.根据权利要求4所述的分布式数据库的数据同步方法，其特征在于，所述获取DDL_3元数据管理节点对应的源端数据同步系统初始化一个日志读取线程、日志解析线程、元数据管理节点对应的日志读取线程用于读取数据库日志，将元数据管理节点对应的日志解析线程用于从待解析队列中获取日志并解析成待处理元数据管理节点对应的日志缓存线程用于从待缓存队列数据节点对应的源端数据同步系统初始化一个日志读取线程、数据节点对应的日志读取线程用于从对应数据节点读取日志，并将读取么通过DDL日志请求模块从元数据管理节点对应的源端数据同步系统中获取DDL相关日志，数据节点对应的日志发送线程用于将待发送队列中的消息发送到目标端数据同步系包括至少一个处理器和存储器，所述至少一个处理器和存储器之间通过数据总线连4源端数据同步系统包括元数据管理节点运行模式5[0012]所述目标端数据同步系统在接收到所述源端数据同步系统发送过来的消息包后[0014]目标端数据同步系统在目标端数据库上初始化一个DDL协同入库辅助表DDL_入到日志待缓存队列；6日志请求模块从元数据管理节点对应的源端数据同步系统中获取DDL相关日志，并将其加每个节点的表数据操作的时序性和一致性。在目标端DDL入库时，使用锁表机制保证每个7提供的各个实施例或单个实施例中的技术特征可以相互任意结合，以形成可行的技术方[0056]存在唯一的一个元数据管理主节点，所有元数据(DDL)操作都详细记录在本节点[0059]DDL事务会在每个数据节点中记录一个DDL标识日志，该日志包含信息：事务ID、[0063]如图1所示，本发明实施例提供一种分布式数据库的数据同步方法，具体步骤如[0067]步骤400：所述目标端数据同步系统在接收到所述源端数据同步系统发送过来的8[0073]步骤203：元数据管理节点对应的日志解析线程用于从待解析队列中获取日志并[0074]步骤204：元数据管理节点对应的日志缓存线程用于从待缓存队列中获取日志信根据事务ID从元数据管理节点获取相关的DD[0078]步骤303：数据节点对应的日志解析线程用于解析待解析队列中的日志，若遇到[0079]步骤304：数据节点对应的日志发送线程用于将待发送队列中的消息发送到目标9判断并根据操作类型的不同使用不同过程对DDL[0091]步骤433：若是ALTER或TRUNCATE操作，则从DDL_SYNC表查询获得STATE值为i＝i+1，等待1秒后重新进入n1获取步骤，这里重新进入n1获取步骤是为了获取最新的数据库的DML和DDL操作日志分布在不同的节点，本优选实施例采用多节点并发同步的架构，每个节点涉及到的DDL操作从元数据管理节点获取，这样就能保证每个节点的表数据操作志读取线程负责从对应数据节点读取日志，并将读取的日志加入到日志待解析队列中；从元数据管理节点EP0对应的源端同步系统HS0中获取DDL相关日志，并将其加入到日志待源端同步系统HS1……HSn相对应的设置有目标端同步系统(也即目标端数据同步系统)[0119]101：目标端数据同步系统在目标数据库上初始化一个DDL协同入库辅助表DDL_[0136]综上所述，本实施例基于分布式数据库的DML和DDL操作[0138]在上述实施例1提供的分布式数据库的数据同步方法的基础上，本发明还提供了[0140]存储器22作为一种非易失性计算机可读存储介质，可用于存储非易失性软件程式数据库的数据同步设备的各种功能应用以及数据处理，即实现实施例1的分布式数据库[0143]本领域普通技术人员可以理解实施例的各种方法中的全部或部分步骤是可以通