一种分布式事务的执行方法及装置

    公开(公告)号:CN115033350A

    公开(公告)日:2022-09-09

    申请号:CN202210641911.7

    申请日:2022-06-07

    Abstract: 本说明书公开了一种分布式事务的执行方法及装置,通过先接收包含若干数据操作的事务请求,然后根据数据中心将该事务划分为若干子事务,在本地数据中心内,采用远程直接内存访问方式,执行本地子事务包含的数据操作并确定第一操作结果,以及将各远程子事务采用网络通信方式,发送至对应的其他数据中心,使得各其他数据中心采用远程直接内存访问方式执行接收到的远程子事务包含的数据操作,并接收各其他数据中心返回的第二操作结果,最后根据第一操作结果以及第二操作结果确定事务的执行结果。通过数据中心之间采用网络通信方式执行访问,每个数据中心内采用远程直接内存访问方式执行访问,提高了大范围的分布式事务的执行效率。

    一种日志提交方法、装置、存储介质及电子设备

    公开(公告)号:CN115982190A

    公开(公告)日:2023-04-18

    申请号:CN202211739339.4

    申请日:2022-12-31

    Abstract: 本说明书公开了一种日志提交方法、装置、存储介质及电子设备,本说明书实施例中第一节点确定第二节点写入的针对同一数据的各操作日志中接收到提交时刻的第一日志,并从各第一日志对应的提交时刻中确定最迟的提交时刻。从除各第一日志之外的其他操作日志中筛选出写入操作日志的时刻早于最迟的提交时刻的第二日志。等到所有第二日志接收到提交时刻后,依次提交各操作日志。第一节点和第二节点位于不同的数据中心。在此方法中,在未接收到提示信息的操作日志均接收到指示消息后,才按照提交时刻对各操作日志进行提交并依次回放,可以避免位于不同数据中心内的节点针对同一数据的日志回放顺序不一致的问题,以保证分布式数据库系统的数据一致性。

    一种跨数据中心的事务处理方法、装置以及设备

    公开(公告)号:CN115098231A

    公开(公告)日:2022-09-23

    申请号:CN202210722852.6

    申请日:2022-06-24

    Abstract: 本说明书实施例公开了跨数据中心的事务处理方法、装置以及设备。应用于由多个数据中心构成的分布式系统,方案包括:第一数据中心内的协调者节点,接收并解析客户端发送的事务请求,得到一个或者多个分别对应于一个数据中心的子事务;协调者节点,确定子事务对应的数据中心,作为第二数据中心,若第二数据中心不为第一数据中心,则在第二数据中心内确定代理协调者节点,将子事务发送给代理协调者节点;代理协调者节点,确定子事务涉及的数据分片的副本在第二数据中心内所在的数据节点,通过对数据节点进行远程直接内存访问,执行子事务,根据执行结果响应协调者节点;所述协调者节点,根据各代理协调者节点的响应,继续处理事务请求。

    一种基于分布式数据库系统的事务提交系统、方法及装置

    公开(公告)号:CN115658245B

    公开(公告)日:2023-03-10

    申请号:CN202211654866.5

    申请日:2022-12-22

    Abstract: 本说明书提供一种分布式数据库系统,包括:目标事务的事务协调者和事务参与者,每一事务参与者记录有分界位置,其中:所述事务协调者,用于向所述事务参与者发起针对所述目标事务的准备请求,以使所述事务参与者生成并持久化对应的准备日志;以及,根据所有事务参与者返回的针对所述准备日志的持久化结果,向所述事务参与者发起对应的事务执行请求;所述事务参与者,用于响应于所述准备请求生成对应的准备日志,将所述准备日志持久化,并将持久化结果返回至所述事务协调者;以及,响应于所述事务执行请求,执行对应所述事务执行请求的事务操作,并在执行完成后将所述目标事务由未决状态切换为已决状态。

    一种并行执行数据库任务的方法、装置、介质及设备

    公开(公告)号:CN115576969B

    公开(公告)日:2023-03-10

    申请号:CN202211567893.9

    申请日:2022-12-07

    Abstract: 本说明书公开了一种并行执行数据库任务的方法、装置、介质及设备,通过接收若干数据库操作任务,并调用至少一个线程,并行执行数据库操作任务。针对每个数据操作任务,记录执行该数据操作任务的线程的线程标识,以及确定线程执行该数据操作任务的时间戳,进而确定各数据库操作任务的先后顺序。当存在异常线程时,根据异常线程的线程标识以及记录的执行数据操作任务的线程的线程标识,确定异常线程执行的数据操作任务。将确定出的数据操作任务所操作的数据,作为回滚数据进行回滚,以及根据对回滚数据操作的先后顺序,将其他线程对回滚数据的操作进行回滚。该方法可实现数据库任务的并行执行,并且大大的提高了并行执行数据库任务的效率。

    一种并行执行数据库任务的方法、装置、介质及设备

    公开(公告)号:CN115576969A

    公开(公告)日:2023-01-06

    申请号:CN202211567893.9

    申请日:2022-12-07

    Abstract: 本说明书公开了一种并行执行数据库任务的方法、装置、介质及设备,通过接收若干数据库操作任务,并调用至少一个线程,并行执行数据库操作任务。针对每个数据操作任务,记录执行该数据操作任务的线程的线程标识,以及确定线程执行该数据操作任务的时间戳,进而确定各数据库操作任务的先后顺序。当存在异常线程时,根据异常线程的线程标识以及记录的执行数据操作任务的线程的线程标识,确定异常线程执行的数据操作任务。将确定出的数据操作任务所操作的数据,作为回滚数据进行回滚,以及根据对回滚数据操作的先后顺序,将其他线程对回滚数据的操作进行回滚。该方法可实现数据库任务的并行执行,并且大大的提高了并行执行数据库任务的效率。

    判断事件执行顺序的方法、装置、存储介质及电子设备

    公开(公告)号:CN115344410A

    公开(公告)日:2022-11-15

    申请号:CN202211260851.0

    申请日:2022-10-14

    Abstract: 本说明书公开了一种判断事件执行顺序的方法、装置、存储介质及电子设备,在本说明书提供的方法中,业务节点与基准节点进行消息交互,在此过程中确定业务节点与基准节点的时间偏差,根据不同业务节点执行不同事件的本地时刻及不同业务节点与基准节点的时间偏差,可以判断由不同业务节点分别执行的不同事件的执行顺序。从上述方法可以看出,当需要对分布式系统中不同节点上执行的不同事件的先后顺序进行排序时,即使不同节点之间存在时间偏差,本方法也可以对该不同事件执行的先后顺序进行排序,且通过业务节点与基准节点的消息交互就可以确定时间偏差,进而判断不同事件的执行顺序,不需要依赖专有硬件,具有普适性。

    处理事务的方法和装置
    10.
    发明授权

    公开(公告)号:CN114064810B

    公开(公告)日:2022-05-03

    申请号:CN202210049251.3

    申请日:2022-01-17

    Abstract: 本公开披露了一种处理事务的方法和装置。该方法包括:接收第一事务,第一事务为非只读事务,第一事务包括第一数据库语句和第二数据库语句,第一数据库语句和第二数据库语句分别用于对分布式数据库中的第一数据库节点和第二数据库节点进行操作;与第一数据库节点建立第一数据库连接;通过第一数据库连接向第一数据库节点发送第一数据库语句;与第二数据库节点建立第二数据库连接;通过第二数据库连接向第二数据库节点发送第二数据库语句;接收第一数据库针对第一数据库语句的反馈信息,反馈信息包括第一事务的控制信息;向第二数据库语句对应的数据库节点发送控制信息。

Patent Agency Ranking