深入浅出Mybatis系列（五）Mybatis事务篇

article/2025/9/16 4:47:46

在学习Mysql事务开始,分为两步。一.先看下Mysql的事务级别都有什么,然后看Mysql的事务级别设置命令。及常见问题。二.JDK是如何处理数据库操作的呢? Mybatis是如何实现JDK定义的事务级别操作。

一.Mysql的事务级别及常见概念

  • MySQL事务隔离级别
事务隔离级别脏读不可重复读幻读解释
读未提交（read-uncommitted）是是是可以读到未提交的事物
不可重复读（read-committed）否是是只能读提交的事物
可重复读（repeatable-read）否否是事务提交前后都能读【MySql默认】
串行化（serializable）否否否serializable时会锁表,是最安全的,也是日常开发基本不会用

  • Mysql事务设置命令

  • 读未提交
    set session transaction isolation level read uncommitted;

  • 不可重复读(读已提交的)
    set session transaction isolation level read committed;

  • 可重复读
    set session transaction isolation level repeatable read;

  • 串行化
    set session transaction isolation level serializable;

举一个例子，我做了一个事务未提交,默认情况是看不到的，当设置了读未提交sql,就可以看到了

以上这四个事务级别最不常用的是串行化,因为他是最严格的会加行锁或者表锁。当一个事务在执行查询操作，其他的连接就不允许对表进行写操作,只允许读。显然这是不满足开发的，想想一下，支付宝当一个人A在查询账单时候，其他人B就不能消费了。因为A在对账单表进行查询，B要对账单表进行修改。

最适合的是可重复读，因为只会加行级锁。当两个事务同时进行时，其中一个事务修改数据对另一个事务不会造成影响，即使修改的事务已经提交也不会对另一个事务造成影响。
(当一个事务执行中他看到的数据是不会改变的，即在一个事务中不论查询数据多少次都不会改变，即便其他人对这个数据进行了修改，也看不到，只有在当前事务提交之后，然后在查询才能看到其他人的改变，这就解决了不可重复读和脏读的问题，但是会造成幻读)

  • √: 可能出现
  • ×: 不会出现

|脏读| 不可重复读 |幻读|
—|—|—|—
|Read uncommitted| √| √| √|
|Read committed| ×| √| √|
|Repeatable read| ×| × |√|
|Serializable| ×| ×| ×|

  • 什么是不可重复读?

就是说在一个事务中，查询了多次数据，每次看到的都不一样。因为别人对数据进行了修改。

  • 事务的并发问题

1、脏读：事务A读取了事务B更新的数据，然后B回滚操作，那么A读取到的数据是脏数据

2、不可重复读：事务 A 多次读取同一数据，事务 B 在事务A多次读取的过程中，对数据作了更新并提交，导致事务A多次读取同一数据时，结果 不一致。

3、幻读：系统管理员A将数据库中所有学生的成绩从具体分数改为ABCDE等级，但是系统管理员B就在这个时候插入了一条具体分数的记录，当系统管理员A改结束后发现还有一条记录没有改过来，就好像发生了幻觉一样，这就叫幻读。

小结：不可重复读的和幻读很容易混淆，不可重复读侧重于修改，幻读侧重于新增或删除。解决不可重复读的问题只需锁住满足条件的行(Repeatable read)，解决幻读需要锁表

  • 事务的基本要素（ACID）

1、原子性（Atomicity）：事务开始后所有操作，要么全部做完，要么全部不做，不可能停滞在中间环节。事务执行过程中出错，会回滚到事务开始前的状态，所有的操作就像没有发生一样。也就是说事务是一个不可分割的整体，就像化学中学过的原子，是物质构成的基本单位。

2、一致性（Consistency）：事务开始前和结束后，数据库的完整性约束没有被破坏 。比如A向B转账，不可能A扣了钱，B却没收到。

3、隔离性（Isolation）：同一时间，只允许一个事务请求同一数据，不同的事务之间彼此没有任何干扰。比如A正在从一张银行卡中取钱，在A取钱的过程结束前，B不能向这张卡转账。

4、持久性（Durability）：事务完成后，事务对数据库的所有更新将被保存到数据库，不能回滚。

参考地址

二.JDK是如何处理数据库操作的呢? Mybatis是如何实现JDK定义的事务级别操作。

JDK是如何处理数据库操作的呢? 其实更直接操作MySql数据库命令一样,只不过Java进行了命令的封装,是你在调用Java方法时候就自动执行了命令,下面我们看看吧.

  1. 定义底层通用接口,实现交给框架开发者来实现。

Connection。事务级JDK已经定义好了

public interface Connection  extends Wrapper, AutoCloseable {/*** 表示不支持事务的常量。*/int TRANSACTION_NONE             = 0;/*** 可读到未提交*/int TRANSACTION_READ_UNCOMMITTED = 1;/*** 只能读已提交*/int TRANSACTION_READ_COMMITTED   = 2;/*** 可重复读*/int TRANSACTION_REPEATABLE_READ  = 4;/*** 串行化操作*/int TRANSACTION_SERIALIZABLE     = 8;/*** 设置事务*/void setTransactionIsolation(int level) throws SQLException;
}

留给开发者自己实现,下图Mybatis中ConnectionImpl实现。在进行数据库操作前,会先执行设置事务。

JdbcTransaction如何设置事务呢?

在打开数据库连接时候设置事务

根据事务级别,执行不同的sql命令。

以上就是事务的底层实现,那么我们在带到项目中来看看,以一个数据库操作的例子来看看Mybatis的调用过程吧。

@Testpublic void transactionTest(){//拿到mybatis的配置文件输入流InputStream mapperInputStream = Thread.currentThread().getContextClassLoader().getResourceAsStream("mybatisConfig.xml");//SqlSessionFactoryBuilder通过XMLConfigBuilder解析器读取配置信息生成Configuration信息SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(mapperInputStream);SqlSession sqlSession = sqlSessionFactory.openSession(TransactionIsolationLevel.READ_COMMITTED);TUserMapper mapper = sqlSession.getMapper(TUserMapper.class);TUser tUser = new TUser();tUser.setId(10233);tUser.setName("事务测试");mapper.insert(tUser);
//    sqlSession.commit();sqlSession.rollback(true);}

SqlSession就是数据库的会话,要想创建数据库会话,首先要打开数据库连接。由此来判断事务级别就是在SqlSessionFactory,在获取SqlSession的时候来执行sql语句的。我们看流程图

此时事务还并没有设置，只有在
SimpleExecutor执行任意数据库操作时候才会调用

@Overridepublic int doUpdate(MappedStatement ms, Object parameter) throws SQLException {Statement stmt = null;try {Configuration configuration = ms.getConfiguration();StatementHandler handler = configuration.newStatementHandler(this, ms, parameter, RowBounds.DEFAULT, null, null);//执行事务stmt = prepareStatement(handler, ms.getStatementLog());return handler.update(stmt);} finally {closeStatement(stmt);}}private Statement prepareStatement(StatementHandler handler, Log statementLog) throws SQLException {Statement stmt;//JdbcTransaction打开连接。Connection connection = getConnection(statementLog);stmt = handler.prepare(connection, transaction.getTimeout());handler.parameterize(stmt);return stmt;}

最终调用
JdbcTransaction打开连接。

以上就是Mybatis中的事务级别控制。但是这里所说的除了在学习源码时候会看到，在日常开发中不会经常看到。大部分Java的开发都是基于Spring框架之上,Spring对事务的处理有进一步的处理。Spring提出了事务传播方式的概念，这个概念怎么理解呢?

Spring的事务传播方式

前面所说的事务,是不涉及嵌套条调用的,即是不会再事务中嵌套事务调用。但是在开发中难免会遇到这种情况。
比如，一个事务在没有执行commit之前，有调用了一个事务。
那这个时候，遇到两个都有事务的方法怎么办呢，因为Spring提出了事务传播方式这个概念。

1、PROPAGATION_REQUIRED：如果当前没有事务，就创建一个新事务，如果当前存在事务，就加入该事务，该设置是最常用的设置。

2、PROPAGATION_SUPPORTS：支持当前事务，如果当前存在事务，就加入该事务，如果当前不存在事务，就以非事务执行。‘

3、PROPAGATION_MANDATORY：支持当前事务，如果当前存在事务，就加入该事务，如果当前不存在事务，就抛出异常。

4、PROPAGATION_REQUIRES_NEW：创建新事务，无论当前存不存在事务，都创建新事务。

5、PROPAGATION_NOT_SUPPORTED：以非事务方式执行操作，如果当前存在事务，就把当前事务挂起。

6、PROPAGATION_NEVER：以非事务方式执行，如果当前存在事务，则抛出异常。

7、PROPAGATION_NESTED：如果当前存在事务，则在嵌套事务内执行。如果当前没有事务，则执行与PROPAGATION_REQUIRED类似的操作。

eg:

当前是有事务的,如果调用方法中也有一个含有事务的接口,那么就放弃里面的事务，而加入到当前的事务

   @Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, rollbackFor = Exception.class)public String doOpt() throws Exception {...}

Spring的事务传播方式的实现类

AbstractPlatformTransactionManager使用的技术手段就是代理。

其实就是set autocommit=off; 当方法执行完成无指定的异常,在进行commit;

下面我们自己来写伪代码

MyTransactional

@Documented
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
public @interface MyTransactional {//传播方式Propagation propagation() default Propagation.REQUIRED;//捕捉异常Class<? extends Throwable>[] rollbackFor() default {};
}

SqlSession保证每个线程一个连接实例


public class SqlSession {private static ThreadLocal<Connection> connections = new ThreadLocal();static {try {//注册驱动，反射方式加载Class.forName("com.mysql.jdbc.Driver");} catch (Exception e) {}}public SqlSession(boolean autocommit, int level) {try {String url = "jdbc:mysql://127.0.0.1:3306/test?useSSL=false";//设置用户名String username = "root";//设置密码String password = "";//获得连接对象Connection con = DriverManager.getConnection(url, username, password);con.setAutoCommit(autocommit);setTransactionIsolation(level, con.createStatement());connections.set(con);} catch (Exception e) {}}public void execute(String sql) {try {Console.normal("执行Sql: " + sql);
//      connections.get().createStatement().execute(sql)} catch (Exception e) {}}private static void setTransactionIsolation(int level, Statement statement) throws SQLException {String sql;switch (level) {case 0:throw SQLError.createSQLException(Messages.getString("Connection.24"), null);case 1:sql = "SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED";break;case 2:sql = "SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED";break;case 3:case 5:case 6:case 7:default:throw SQLError.createSQLException(Messages.getString("Connection.25", new Object[]{level}), "S1C00", null);case 4:sql = "SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ";break;case 8:sql = "SET SESSION TRANSACTION ISOLATION LEVEL SERIALIZABLE";}Console.customerNormal("设置事务级别Sql: ", sql);
//    statement.execute(sql);}public void commit() throws Exception {
//    Connection connection = connections.get();
//    connection.commit();Console.customerNormal("执行提交Sql:", "commit;");}public void rollback() throws Exception {
//    Connection connection = connections.get();
//    connection.rollback();Console.customerNormal("设置事务级别Sql: ", "roolback");}}

UserService

public interface UserService {void save();
}
public class UserServiceImpl implements UserService {SqlSession sqlSession = new SqlSession(false, 4);@MyTransactional(propagation = Propagation.REQUIRED, rollbackFor = ArithmeticException.class)public void save() {//执行sql1sqlSession.execute("select * from t");try {int i = 2 / 0;} catch (Exception e) {throw e;}//执行sql2sqlSession.execute("select * from t");}

测试代码

 public static void main(String[] args) {UserService userService = new UserServiceImpl();//生成JDK代理UserService userServiceProxy = (UserService) Proxy.newProxyInstance(Thread.currentThread().getContextClassLoader(), new Class[]{UserService.class}, new InvocationHandler() {@Overridepublic Object invoke(Object proxy, Method method, Object[] args) throws Throwable {Method declaredMethod = userService.getClass().getDeclaredMethod(method.getName(), method.getParameterTypes());MyTransactional declaredAnnotation = declaredMethod.getDeclaredAnnotation(MyTransactional.class);Class<? extends Throwable>[] classes = declaredAnnotation.rollbackFor();//传播方式处理逻辑//.....Object res = null;try {res = declaredMethod.invoke(userService);} catch (Exception e) {Throwable cause = e.getCause();if (cause.getClass().equals(classes[0])) {//执行回滚((UserServiceImpl) userService).sqlSession.rollback();return res;}}//执行提交((UserServiceImpl) userService).sqlSession.commit();return res;}});userServiceProxy.save();}

结果

  • 成功
[设置事务级别Sql: ]: SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ
[正常]: 执行Sql: update T_USER set name = 'china' where id = 1;
[正常]: 执行Sql: update T_USER set name = '中国' where id = 1;
[执行提交Sql:]: commit;
  • 失败
[设置事务级别Sql: ]: SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ
[正常]: 执行Sql: update T_USER set name = 'china' where id = 1;
[设置事务级别Sql: ]: roolback

以上就是Mybatis关于事务小编想说的。有问题可以提出，我们一起学习，如果有写错的地方或者想讨论的，希望能提出，再次感谢!


http://chatgpt.dhexx.cn/article/gE8vj0I0.shtml

相关文章

详解 MyBatis 事务管理，彻底颠覆你对事务的理解！

详解 MyBatis 事务管理，彻底颠覆你对事务的理解！

来源&#xff1a;https://my.oschina.net/zudajun/blog/666764 前言 说到数据库事务&#xff0c;人们脑海里自然不自然的就会浮现出事务的四大特性、四大隔离级别、七大传播特性。四大还好说&#xff0c;问题是七大传播特性是哪儿来的&#xff1f;是 Spring 在当前线程内&…
阅读更多...
MyBatis的事务

MyBatis的事务

Mybatis管理事务是分为两种方式: (1)使用JDBC的事务管理机制,就是利用java.sql.Connection对象完成对事务的提交 (2)使用MANAGED的事务管理机制&#xff0c;这种机制mybatis自身不会去实现事务管理&#xff0c;而是让程序的容器&#xff08;JBOSS,WebLogic&#xff09;来实现对…
阅读更多...
MyBatis--事务

MyBatis--事务

事务是基于关系型数据库的企业应用的重要组成部分&#xff0c;用来确保应用程序数据的完整性和一致性。 事务就是一个系列(一组、几个)操作的集合单元&#xff0c;这些操作要么全部完成&#xff0c;要么全部失败&#xff0c;如果某一个操作失败&#xff0c;就算是已经成功执行…
阅读更多...
ResNet网络结构解析

ResNet网络结构解析

ResNet是识别、检测中常用的backbone&#xff0c;看检测相关论文的时候重点都在方法创新上&#xff0c;并没有特别在意网络结构&#xff0c;但是到自己跑实验改网络的时候就涉及到结构细节问题&#xff0c;于是详细的看了下ResNet网络结构。下图是ResNet的网络结构简图&#xf…
阅读更多...
resnet网络结构图

resnet网络结构图

很重要&#xff0c;单独放
阅读更多...
ResNet网络结构，BN以及迁移学习详解

ResNet网络结构，BN以及迁移学习详解

网络中的亮点&#xff1a; 1.超深的网络结构&#xff08;超过1000层&#xff09; 2.提出residual(残差)模块 3.使用Batch Normalization加速训练&#xff08;丢弃dropout&#xff09; 左边是将卷积层和池化层进行一个简单的堆叠所搭建的网络结构 20层的训练错误率大概在1%…
阅读更多...
ResNet网络结构详解（Tensorflow2.6.0实现网络结构）

ResNet网络结构详解（Tensorflow2.6.0实现网络结构）

文章目录 1.ResNetX网络结构表&#xff08;1&#xff09;论文地址&#xff1a;&#xff08;2&#xff09;ResNet18网络结构&#xff1a;&#xff08;3&#xff09;ResNet34网络结构&#xff1a; 2.卷积神经网络的发展(1).卷积神经网络的发展&#xff1a;&#xff08;2&#xff…
阅读更多...
ResNet网络结构详解，网络搭建，迁移学习

ResNet网络结构详解，网络搭建，迁移学习

前言&#xff1a; 参考内容来自up&#xff1a;6.1 ResNet网络结构&#xff0c;BN以及迁移学习详解_哔哩哔哩_bilibili up的代码和ppt&#xff1a;https://github.com/WZMIAOMIAO/deep-learning-for-image-processing 一、简介 ResNet 网络是在 2015年 由微软实验室提出&#xf…
阅读更多...
ResNet网络结构详解与模型的搭建

ResNet网络结构详解与模型的搭建

ResNET(Deep Residual Learning for Image Recognition ) ResNet网络是在2015年由微软实验室提出&#xff0c;斩获当年ImageNet竞赛中分类任务第一名&#xff0c;目标检测第一名。获得COCO数据集中目标检测第一名&#xff0c;图像分割第一名。下图是ResNet34层模型的结构简图。…
阅读更多...
Resnet网络结构图和对应参数表的简单理解

Resnet网络结构图和对应参数表的简单理解

Resnet Resnet即就是残差网络&#xff0c;本文主要是对于resnet给出的网络结构图进行简单解释。 网络结构图 以上就是34层网络的网络结构图。 以上是18层、34层、50层、101层以及152层网络所对应的残差块。 我刚开始在网上看到这两张图片的时候&#xff0c;感觉一点都不懂&a…
阅读更多...
pytorch Resnet 网络结构

pytorch Resnet 网络结构

最近在学习廖老师的pytorch教程&#xff0c;学到Resnet 这部分着实的烧脑&#xff0c;这个模型都捣鼓了好长时间才弄懂&#xff0c;附上我学习过程中最为不解的网络的具体结构连接&#xff08;网上一直没有找到对应网络结构&#xff0c;对与一个自学的学渣般的我&#xff0c;很…
阅读更多...
ResNet网络结构解析--Pytorch

ResNet网络结构解析--Pytorch

ResNet101–DSSD/SSD &#xff08;1&#xff09;ResNet在Pytorch官方代码中有5种不同深度的结构&#xff0c;分别为18、34、50、101、152&#xff08;各网络深度指的是“需要通过训练更新参数“的层数&#xff0c;如卷积层&#xff0c;全连接层等&#xff09;&#xff0c;和论…
阅读更多...
ResNet网络结构详解及代码复现

ResNet网络结构详解及代码复现

1. ResNet论文详解 1.1. Introduction 一般网络越深&#xff0c;特征就越丰富&#xff0c;模型效果也就越好。在深度重要的驱动下&#xff0c;出现了2个问题&#xff1a; 梯度消失和梯度爆炸&#xff1a; 梯度消失&#xff1a;误差梯度<1&#xff0c;当网络层数增多时&…
阅读更多...
resnet50网络结构_pytorch实践(改造属于自己的resnet网络结构并训练二分类网络)

resnet50网络结构_pytorch实践(改造属于自己的resnet网络结构并训练二分类网络)

我的CSDN博客：https://blog.csdn.net/litt1e 我的公众号：工科宅生活 在学习pytorch过程中，突然想拥有属于自己的网络结构，于是便自己选择了一个比较简单的resnet18进行改造，并用其对蚂蚁和蜜蜂进行分类，比较一下没有经过预训练的resnet18好还是自己改造的resnet_diy好。 …
阅读更多...
【DL系列】ResNet网络结构详解、完整代码实现

【DL系列】ResNet网络结构详解、完整代码实现

Name&#xff1a; Deep Residual Learning for Image Recognition Author&#xff1a; 何恺明团队 Publiced&#xff1a; 2015.12_CVPR 文章目录 前言1. 残差网络待解决的问题2. ResNet模型亮点 ResNet模型结构1. 残差学习2. Residual模块3. ResNet模型 ResNet-layers模型完整代…
阅读更多...
pytorch实现resnet网络结构

pytorch实现resnet网络结构

ResNet结构和pytorch实现 resnet的网络结构都是经过5个不同数量的残差块最后一个全连接分类完成的。 在resnet50以后&#xff0c;由于层数的增加残差块发生了变化&#xff0c;从原来3x3卷积变为三层卷积&#xff0c;卷积核分别为1x1、3x3、1x1&#xff0c;减少了网络参数。主…
阅读更多...
ResNet网络结构搭建

ResNet网络结构搭建

ResNet 下图为包含有18层(17个卷积层和1个全连接层)、34层(33个卷积层和1个全连接层)、50层(49个卷积层和1个全连接层)、101层(100个卷积层和1个全连接层)、152层(151个卷积层和1个全连接层)的resnet结构 下图是论文中给出的两种残差结构。左边的残差结构是针对层数较少网络&a…
阅读更多...
ResNet网络结构

ResNet网络结构

注&#xff1a;深度好像就是channel w*h*c 根据b站up霹雳吧啦的讲解做的笔记 视频地址6.1 ResNet网络结构&#xff0c;BN以及迁移学习详解_哔哩哔哩_bilibiliR 6.2 使用pytorch搭建ResNet并基于迁移学习训练_哔哩哔哩_bilibili ResNet网络解决梯度消失、爆炸&#xff0c;以及…
阅读更多...
经典网络ResNet介绍

经典网络ResNet介绍

经典网络ResNet(Residual Networks)由Kaiming He等人于2015年提出&#xff0c;论文名为《Deep Residual Learning for Image Recognition》&#xff0c;论文见&#xff1a;https://arxiv.org/pdf/1512.03385.pdf ResNet要解决的是深度神经网络的”退化(degradation)”问题&…
阅读更多...
六、ResNet网络详细解析（超详细哦）

六、ResNet网络详细解析（超详细哦）

1、 RestNet网络 1.1、 RestNet网络结构 ResNet在2015年被提出&#xff0c;在ImageNet比赛classification任务上获得第一名&#xff0c;因为它“简单与实用”并存&#xff0c;之后很多方法都建立在ResNet50或者ResNet101的基础上完成的&#xff0c;检测&#xff0c;分割&…
阅读更多...
推荐文章

Copyright @ 2022~2023