(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210410068.1 (22)申请日 2022.04.19 (71)申请人 泽拓科技 （深圳） 有限责任公司 地址 518110 广东省深圳市宝安区新 安街 道海滨社区N26区宝兴路21号万骏经 贸大厦509 (72)发明人 赵伟　张金冬　吴夏　王潮杰　 何革新　盛欢　刘良城　张世伟　 黄远芳　刘永松　 (74)专利代理 机构 深圳中细软知识产权代理有 限公司 4 4528 专利代理师 黄劼 (51)Int.Cl. G06F 9/46(2006.01) G06F 16/23(2019.01)G06F 16/27(2019.01) G06F 16/22(2019.01) (54)发明名称 分布式事务处 理方法、 系统及装置 (57)摘要 本发明实施例公开了一种分布式事务处理 方法、 系统及装置， 可以避免元数据过时以及元 数据过时引发的事务处理错误， 同时提升事务处 理效率， 降低计算、 传输和存储开销， 同时确保系 统具备完 备的容错和容灾能力。 该分布式事务处 理方法包括： 首先， 使用计算节点根据命令语句 启动分布式事务GT和分布式事务GT在计算节点 本地的事务 分支CT， 命令语句包括客户端发送的 数据定义语言DDL语句或数据 操纵语言DML语句， 本地事务分支CT在计算节点上完成运行； 其次， 使用计算节点对命令语句进行解析得到解析结 果， 解析结果包括命令语句的内部表 示和执行状 态； 最后， 根据解析结果， 使用计算节点在本地的 元数据表中新建或修改元数据， 新建或修改元数 据与命令语句相关， 元数据表存储在计算节点 上。 权利要求书2页 说明书12页 附图4页 CN 114816682 A 2022.07.29 CN 114816682 A 1.一种分布式事务处 理方法， 其特 征在于， 包括： 使用计算节点根据所述命令语句启动分布式事务GT和所述分布式事务GT在所述计算 节点本地的事务分支CT， 所述命令语句 包括客户端发送的数据定义语言DDL语句或数据操 纵语言DML语句， 所述本地事务分支CT在所述计算节点上完成运行； 使用所述计算节点对所述命令语句进行解析得到解析结果， 所述解析结果包括所述命 令语句的内部表示和执 行状态； 根据所述解析结果， 使用所述计算节点在本地的元数据表中新建或修改元数据， 所述 新建或修改元 数据与所述命令语句 相关， 所述元 数据表存 储在所述计算节点上。 2.根据权利要求1所述的分布式事务处理方法， 其特征在于， 若所述命令语句为DDL语 句， 所述分布式事务处 理方法还 包括： 使用所述计算节点在所述计算节点与元数据节点的连接中启动所述分布式事务GT在 所述元数据节点上的事务分支MT， 所述事务分支MT在所述元 数据节点上 执行； 若所述事务分支MT在所述元数据节点上执行成功， 使用所述元数据节点向所述计算节 点发送MT执 行成功消息； 若所述事务分支MT在所述元数据节点上执行中断， 使用所述元数据节点重新恢 复执行 所述事务分支MT直至执 行成功， 并向所述计算节点发送MT执 行失败消息 。 3.根据权利要求2所述的分布式事务处理方法， 其特征在于， 所述分布式事务处理方法 还包括： 使用所述计算节点在所述计算节点与所述元数据节点的连接 中发送DDL事务日志至所 述元数据节点， 以使得 所述元数据节点存 储所述DDL事务日志至 本地。 4.根据权利要求2或3所述的分布式事务处理方法， 其特征在于， 若存储节点支持所述 DDL语句执 行， 所述分布式事务处 理方法还 包括： 使用所述计算节点在所述计算节点与所述存储节点的连接中启动所述分布式事务GT 在所述存 储节点上的事务分支ST； 使用所述存储节点接收所述计算节点发送的所述DDL语句， 并在所述事务分支ST中执 行所述DDL语句； 若所述事务分支ST在所述存储节点上执行成功， 使用所述存储节点向所述计算节点发 送ST执行成功消息； 若所述事务分支ST在所述存储节点上执行中断， 使用所述存储节点重新恢 复执行所述 事务分支ST直至执 行成功， 并向所述计算节点发送ST执 行失败消息 。 5.根据权利要求1所述的分布式事务处理方法， 其特征在于， 若所述命令语句为DML语 句， 所述分布式事务处 理方法还 包括： 使用所述计算节点在所述计算节点与所述存储节点的连接中启动所述分布式事务GT 在所述存 储节点上的事务分支ST， 所述事务分支ST在所述存 储节点上 执行； 当所述计算节点收到所述客户端发送的提交事务命令时， 利用所述计算节点启动分布 式事务GT提交流程， 所述提交事务命令的执行过程包括所述存储节点结束所述事务分支 ST。 6.根据权利要5所述的分布式事务处理方法， 其特征在于， 所述提交事务命令包括第 一 提交命令和第二 提交命令， 所述利用所述计算节点启动分布式事务GT提交流 程， 包括：权　利　要　求　书 1/2 页 2 CN 114816682 A 2使用所述计算节点向第 一类存储节点发送所述第 一提交命令， 所述第 一类存储节点为 在所述分布式事务GT执 行过程中执 行过写操作的存 储集群对应的存 储节点； 使用所述计算节点向第 二类存储节点发送所述第 二提交命令， 所述第 二类存储节点为 在所述分布式事务GT执 行过程中执 行过只读操作的存 储集群对应的存 储节点。 7.根据权利要求6所述的分布式事务处理方法， 其特征在于， 所述分布式事务处理方法 还包括： 若所述第一提交命令全部成功返回所述计算节点， 利用所述计算节点将决定提交 的提 交决定写入 事务日志中； 若所述第一提交命令没有全部成功返回所述计算节点， 利用所述计算节点决定回滚的 提交决定写入 事务日志中； 在利用所述计算节点将所述决定提交或决定回滚的提交决定写入所述事务日志之后， 使用所述计算节点向所述第一类存 储节点发送所述第一 提交命令； 利用所述计算节点 提交所述本地事务分支CT。 8.根据权利要求7所述的分布式事务处理方法， 其特征在于， 所述利用所述计算节点将 所述决定提交或决定回滚的提交决定写入所述事务日志， 包括： 若元数据集群可以访问， 利用所述计算节点将所述决定提交或决定回滚的提交决定写 入所述元 数据集群的事务日志中； 若所述元数据集群不可以访问， 利用所述计算节点将所述决定提交或决定回滚的提交 决定写入 存储集群中任意 一个可以正常写入的存 储节点的事务日志中。 9.一种分布式事务处 理系统， 其特 征在于， 包括： 计算节点、 存 储节点和元 数据节点； 使用所述计算节点、 所述存储节点和所述元数据节点执行如上述权利要求1 ‑7中任意 一项所述的分布式事务处 理方法。 10.一种分布式事务处理装置， 其特征在于， 所述分布式事务处理装置应用于分布式事 务处理系统； 所述分布式事务处理系统提供多种事务处理服务； 所述分布式事务处理系统 包括多个事务协调器， 以及多个存储器， 所述事务协调器与所述存储器一一对应的设置， 所 述分布式事务处 理装置包括： 命令启动模块， 用于： 使用计算节点根据所述命令语句启动分布式事务GT和所述分布 式事务GT在所述计算节点本地的事务分支CT， 所述命令语句包括客户端发送的数据定义语 言DDL语句或数据操纵语言DML语句； 解析模块， 用于使用所述计算节点对所述命令语句进行解析得到解析结果， 所述解析 结果包括所述命令语句的内部表示和执行状态， 所述本地事务分支CT在所述计算节点上完 成运行； 处理模块， 用于根据所述解析结果， 使用所述计算节点在本地的元数据表中新建元数 据或修改目标元数据， 所述新建的元数据或所述 目标元数据与所述命令语句相关， 所述元 数据表存 储在所述计算节点上。权　利　要　求　书 2/2 页 3 CN 114816682 A 3