首页 > 其他分享 >全局事务与本地事务的区别应用

全局事务与本地事务的区别应用

时间:2023-05-05 22:32:55浏览次数:38  
标签:事务 提交 数据库 amount 本地 mysql oracle 全局


全局事务:资源管理器管理和协调的事务,可以跨越多个数据库和进程。资源管理器一般使用 XA 二阶段提交协议与“企业信息系统”(EIS) 或数据库进行交互。 
本地事务:在单个 EIS 或数据库的本地并且限制在单个进程内的事务。本地事务不涉及多个数据来源。 

在Hibernate配置文件中有这么两种配置方式:

1.如果使用的是本地事务(jdbc事务)
<property name="hibernate.current_session_context_class">thread</property>,这个是我们常用的选项,只针对一个数据库进行操作,也就是说只针对一个事务性资源进行操作.
2. 如果使用的是全局事务(jta事务)
<property name="hibernate.current_session_context_class">jta</property>    

    以前我们学习的事务类型都属于本地事务。 JTA(全局事务)和thread(本地事务)有什么区别呢?在某些应用场合,只能使用全局事务,比如: 
有两个数据库: 
1.mysql 2.oracle  现在有个业务需求--转账 
step 1> update mysql_table set amount=amount-xx where id=aaa 发生扣钱,假设是在mysql数据库扣钱的。 
step 2> update oracle_table set amount=amount+xx where id=bbb 加钱,假设是在oracle数据库扣钱的。 
现在怎么确保两个语句在同一个事务里执行呢? 

以前在JDBC里是这样做 

connection = mysql 连接mysql 
connection.setAutoCommit(false);  不自动提交 
1> update mysql_table set amount=amount-xx where id=aaa 发生扣钱,假设是在mysql数据库扣钱的。 
2> update oracle_table set amount=amount+xx where id=bbb  发生在oracle数据库 
connection.commit();


执行这两条语句,然后通过connection对象提交事务.我们这样子做只能确保这两个语句在同一个数据库mysql里面实现在同一个事务里执行。 但是问题是我们现在是要连接到oracle数据库,是不是需要connection2啊? 

connection = mysql 连接mysql 
connection2 = oracle 连接oracle 
connection.setAutoCommit(false);  不自动提交 
1> update mysql_table set amount=amount-xx where id=aaa 发生扣钱,假设是在mysql数据库扣钱的。 
2> update oracle_table set amount=amount+xx where id=bbb  发生在oracle数据库 
connection.commit(); 
connection2.setAutoCommit(false); 
connection2.commit();


事务只能在一个connection里打开,并且确保两条语句都在该connection里执行,这样才能让两条语句在同一事务里执行,现在问题就在于connection2是连接到oracle数据库的,那么connection2再开事务有意义吗?它能确保吗?不能,所以在这种情况下就只能使用全局事务了。 
这种情况下用普通JDBC操作是满足不了这个业务需求的,这种业务需求只能使用全局事务,本地事务是无法支持我们的操作的,因为这时候,事务的生命周期不应该局限于connection对象的生命周期范围 

全局事务怎么做呢? 

JPA.getUserTransaction().begin();      首先要全局事务的API,不需要我们编写,通常容器已经提供给我们了,我们只需要begin一下 
connection = mysql 连接mysql 
connection2 = oracle 连接oracle 
connection--> update mysql_table set amount=amount-xx where id=aaa 发生扣钱,假设是在mysql数据库扣钱的。 
connection2--> update oracle_table set amount=amount+xx where id=bbb 发生在oracle数据库 
JPA.getUserTransaction().commit();



那么它是怎么知道事务该提交还是回滚呢? 
这时候它使用了二次提交协议。二次提交协议简单说就这样:如果你先执行第一条语句,执行的结果先预提交到数据库,预提交到数据库了,数据库会执行这条语句,然后返回一个执行的结果,这个结果假如我们用布尔值表示的话,成功就是true,失败就是false.然后把执行的结果放入一个(假设是List)对象里面去,接下来再执行第二条语句,执行完第二条语句之后(也是预处理,数据库不会真正实现数据的提交,只是说这条语句送到数据库里面,它模拟下执行,给你返回个执行的结果),假如这两条语句的执行结果在List里面都是true的话,那么这个事务就认为语句是成功的,这时候全局事务就会提交。二次提交协议,数据库在第一次提交这个语句时,只会做预处理,不会发生真正的数据改变,当我们在全局事务提交的时候,这时候发生了第二次提交,那么第二次提交的时候才会真正的发生数据的改动。 
   如果说在执行这两条语句中,有一个出错了,那么List集合里就有个元素为false,那么全局事务就认为你这个事务是失败的,它就会进行回滚,回滚的时候,哪怕你的第二条语句在第一次提交的时候是成功的,它在第二次提交的时候也会回滚,那么第一次的更改也会恢复到之前的状态,这就是二次提交协议。(可以查看一下数据库方面的文档来了解二次提交协议)

 


标签:事务,提交,数据库,amount,本地,mysql,oracle,全局
From: https://blog.51cto.com/iwtxokhtd/6247968

相关文章

  • 数据库事务
    数据库事务(一)概述数据库事务(DatabaseTransaction),是指作为单个逻辑工作单元执行的一系列操作。事务处理可以确保除非事务性单元内的所有操作都成功完成,否则不会永久更新面向数据的资源。通过将一组相关操作组合为一个要么全部成功要么全部失败的单元,可以简化错误恢复并使应......
  • 自定义mybatis插件之全局数据过滤
    目录一、介绍二、实现三、效果四、源码一、介绍通过开发mybatis的插件来实现对全局的sql查询语句进行拦截,并新增全局的过滤条件做到无感知的数据过滤,比如全局过滤某个租户的数据。二、实现实现思路1、通过mybatis的拦截器拦截所有查询的sql2、使用Druid里面的工具类解析sq......
  • 本地消息表模式
    分布式事务|使用dotnetcore/CAP的本地消息表模式 本地消息表模式本地消息表模式,其作为柔性事务的一种,核心是将一个分布式事务拆分为多个本地事务,事务之间通过事件消息衔接,事件消息和上个事务共用一个本地事务存储到本地消息表,再通过定时任务轮询本地消息表进行消息投递,下......
  • 本地新项目上传到git的详细步骤
    通过命令gitinit把这个目录变成git可以管理的仓库gitinit 把文件添加到暂存区中gitadd.//'.'意思是添加文件下的所有文件 把文件提到仓库gitcommit-m'类似备注,自由发挥' 关联到远程仓库gitremoteaddorigin远程仓库地址 拉取远程仓库到代码......
  • 本地jar包导入maven有两种方法
    本地jar包导入maven有两种方法第一种,安装该jar包到maven的本地仓库中,主要用到maven的命令:mvninstall:install-file-Dfile=C:\Users\Administrator\Desktop\test.jar-DgroupId=com.test-DartifactId=test-Dversion=1.0-Dpackaging=jar上面的命令解释:-Dfi......
  • 【解决】mysql本地计算机上的MySQL服务启动后停止。某些服务在未由其他服务或程序使用
    在计算机管理中启动时,发现mysql报错:mysql本地计算机上的MySQL服务启动后停止。某些服务在未由其他服务或程序使用时将自动停止。该问题的解决方式为:1找到Mysql的安装路径,看看有没有data文件夹,如果没有data文件夹,自己重新建一个;如果有的话,就把里面的内容全部清空,但保留该目录......
  • C# 获取本地共享目录和网络共享目录
    1.在工程添加对应的cs文件usingSystem;usingSystem.Collections;usingSystem.Collections.Generic;usingSystem.ComponentModel;usingSystem.IO;usingSystem.Linq;usingSystem.Net;usingSystem.Runtime.InteropServices;usingSystem.Text;usingSystem.Web;......
  • SQL Server事务执行过程中中释放锁导致的死锁问题 - 排查与分析
    0.前情提要系统的某个用来上报数据的接口存在死锁的问题。这个接口内部对多张表进行了Update操作,执行顺序为A表、B表、C表、D表、A表。死锁发生的SQL,一条是第一次更新A表的SQL,另一条是第二次更新A表的SQL。整个更新都处在一个事务内,理论上讲,只要第一个Session开始执行事务,第二个......
  • 高级Java程序员必问,Redis事务终极篇
    1.简介1.1什么是Redis事务Redis事务(Transaction)通过将多个Redis操作封装为一个原子性的操作序列,确保在事务执行过程中,不会受到其他客户端的干扰。从而在保证数据一致性的同时,协调并发,提高数据操作的效率和性能。1.2Redis事务的应用场景在分布式系统和高并发场景下,事务处理......
  • 内网穿透工具介绍-外网访问电脑本地服务器
    最近在自己家里的台式机上部署了minigpt4大模型,因此想让其他朋友来尝试以下,所有需要内网穿透工具我们在做开发时,不想购买服务器,只想搭建我们本地的服务器,我们搭建的本地服务器只能供我们自己电脑的浏览器访问,或者处于同一个wifi下的手机访问,但是我们如果想让别人访问到我们......