Spring事务控制见解6

7.Spring事务控制

7.1.事务介绍

7.1.1.什么是事务？

当你需要一次执行多条SQL语句时，可以使用事务。通俗一点说，如果这几条SQL语句全部执行成功，则才对数据库进行一次更新，如果有一条SQL语句执行失败，则这几条SQL语句全部不进行执行，这个时候需要用到事务。

刘德华《无间道》：去不了终点，回到原点

回顾一下数据库事务的四大特性ACID：

原子性（Atomicity）要么都执行，要么都不执行一致性（Consistency）事务前后的数据都是正确的隔离性（Isolation）事物之间相互隔离，互不干扰（并发执行的事务彼此无法看到对方的中间状态）持久性（Durability）事务一旦提交不可再回滚

7.1.2.数据库本身控制事物

begin transaction；//1.本地数据库操作：张三减少金额//2.本地数据库操作：李四增加金额
rollback;
或
commit transation;

7.2.3.jdbc中使用事物

1.获取对数据库的连接

2.设置事务不自动提交（默认情况是自动提交的）

conn.setAutoCommit(false);   //其中conn是第一步获取的随数据库的连接对象。

3.把想要一次性提交的几个sql语句用事务进行提交

try{Statement stmt = null; stmt =conn.createStatement(); stmt.executeUpdate(sql1); int a=6/0;stmt.executeUpdate(Sql2); . . . conn.commit();   //使用commit提交事务 
}

4.捕获异常，进行数据的回滚（回滚一般写在catch块中）

catch（Exception e） { ... conn.rollback(); 
}

7.2.转账案例

7.2.1.拷贝上一章代码

在这里插入图片描述

7.2.2.添加转账业务

7.2.2.1.mapper
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.by.mapper.UserMapper">... ...<!--转账--><update id="updateUserOfSub">update t_user set money=money-#{money} where name=#{source}</update><update id="updateUserOfAdd">update t_user set money=money+#{money} where name=#{target}</update>
</mapper>

public interface UserMapper {... .../**扣钱*/void updateUserOfSub(@Param("source") String source, @Param("money") Float money);/*加钱*/void updateUserOfAdd(@Param("target") String target, @Param("money") Float money);
}
7.2.2.2.service
@Service
public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;/*** 转账* @param source* @param target* @param money*/@Overridepublic void updateUser(String source, String target, Float money) {userMapper.updateUserOfSub(source, money);int a = 6/0;userMapper.updateUserOfAdd(target, money);}
}
7.2.2.3.测试
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")//加载配置文件
public class ServiceTest {@Autowiredprivate UserService userService;/*** 转账业务*/@Testpublic void testUpdate(){userService.updateUser("张三丰","宋远桥",1F);}
}
  1. 此时我们观察数据表里面的变化情况：
    在这里插入图片描述
    转账是成功的，但是涉及到业务的问题，如果业务层实现类有其中一个环节出问题，都会导致灾难。
  2. 我们先把数据恢复到转账前。
    在这里插入图片描述
    现在我们故意模拟转账业务出现问题
    在这里插入图片描述
    再来测试：
    在这里插入图片描述
    业务执行出错，但是！
    在这里插入图片描述
  3. 这是因为：不满足事务的一致性（减钱的事务提交了，加钱的事务没有提交，甚至都没有执行到）。

7.2.Spring中事务控制的API介绍

  • 说明：

    • JavaEE体系进行分层开发，事务处理位于业务层，Spring提供了分层设计业务层的事务处理解决方案。

    • Spring框架为我们提供了一组事务控制的接口。具体在后面的小节介绍。这组接口是在spring-tx.RELEASE.jar中。

    • spring的事务控制都是基于AOP的，它既可以使用编程的方式实现，也可以使用配置的方式实现。我们学习的重点是使用配置的方式实现。

7.2.1.PlatformTransactionManager

  • 此接口是spring的事务管理器，它里面提供了我们常用的操作事务的方法，源代码如下：

    public interface PlatformTransactionManager { //开启事务  TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException; //提交事务void commit(TransactionStatus status) throws TransactionException; //回滚事务void rollback(TransactionStatus status) throws TransactionException;   
}

  • 真正管理事务的对象
    在这里插入图片描述

  • Spring为不同的orm框架提供了不同的PlatformTransactionManager接口实现类：

    • DataSourceTransactionManager：使用Spring JDBC或iBatis 进行持久化数据时使用
    • HibernateTransactionManager：使用Hibernate版本进行持久化数据时使用

7.2.2.TransactionDefinition

  • TransactionDefinition接口包含与事务属性相关的方法，源代码如下：

    public interface TransactionDefinition {int PROPAGATION_REQUIRED = 0;int PROPAGATION_SUPPORTS = 1;int PROPAGATION_MANDATORY = 2;int PROPAGATION_REQUIRES_NEW = 3;int PROPAGATION_NOT_SUPPORTED = 4;int PROPAGATION_NEVER = 5;int PROPAGATION_NESTED = 6;int ISOLATION_DEFAULT = -1;int ISOLATION_READ_UNCOMMITTED = 1;int ISOLATION_READ_COMMITTED = 2;int ISOLATION_REPEATABLE_READ = 4;int ISOLATION_SERIALIZABLE = 8;int TIMEOUT_DEFAULT = -1;//传播行为int getPropagationBehavior();//隔离级别int getIsolationLevel();int getTimeout();boolean isReadOnly();
}

    TransactionDefinition 接口定义的事务规则包括：事务隔离级别、事务传播行为、事务超时、事务的只读、回滚规则属性，同时，Spring 还为我们提供了一个默认的实现类：DefaultTransactionDefinition，该类适用于大多数情况。如果该类不能满足需求，可以通过实现 TransactionDefinition 接口来实现自己的事务定义。

7.2.2.1.事务隔离级别

  • 事务并发时的安全问题

    问题描述隔离级别
    脏读一个事务读取到另一个事务还未提交的数据read-commited
    不可重复读一个事务内多次读取一行数据的内容，其结果不一致repeatable-read
    幻读一个事务内多次读取一张表中的内容，其结果不一致serialized-read

  • Spring事务隔离级别（比数据库事务隔离级别多一个default）由低到高为：

    隔离级别
    ISOLATION_DEFAULT这是一个platfromtransactionmanager默认的隔离级别，使用数据库默认的事务隔离级别。
    ISOLATION_READ_UNCOMMITTED这是事务最低的隔离级别，会产生脏读，不可重复读和幻像读。
    ISOLATION_READ_COMMITTED这种事务隔离级别可以避免脏读出现，但是可能会出现不可重复读和幻像读。 Oracle数据库默认的隔离级别。
    ISOLATION_REPEATABLE_READ这种事务隔离级别可以防止脏读、不可重复读，但是可能出现幻像读。MySQL数据库默认的隔离级别。
    ISOLATION_SERIALIZABLE这是花费最高代价但是最可靠的事务隔离级别，事务被处理为顺序执行。除了防止脏读、不可重复读外，还避免了幻像读。
7.2.2.2.事务的传播行为

  • 什么是事务传播行为？

    事务传播行为（propagation behavior）指的就是当一个事务方法被另一个事务方法调用时，这个事务方法应该如何进行。
    例如：methodA事务方法调用methodB事务方法时，methodB是继续在调用者methodA的事务中运行呢，还是为自己开启一个新事务运行，这就是由methodB的事务传播行为决定的。

  • Spring定义了七种传播行为：

    事务传播行为类型说明
    PROPAGATION_REQUIRED如果当前没有事务，就新建一个事务，如果已经存在一个事务中，加入到这个事务中。这是最常见的选择。
    PROPAGATION_SUPPORTS支持当前事务，如果当前没有事务，就以非事务方式执行。
    PROPAGATION_MANDATORY使用当前的事务，如果当前没有事务，就抛出异常。
    PROPAGATION_REQUIRES_NEW新建事务，如果当前存在事务，把当前事务挂起。
    PROPAGATION_NOT_SUPPORTED以非事务方式执行操作，如果当前存在事务，就把当前事务挂起。
    PROPAGATION_NEVER以非事务方式执行，如果当前存在事务，则抛出异常。
    PROPAGATION_NESTED如果当前存在事务，则在嵌套事务内执行。如果当前没有事务，则执行与REQUIRED类似的操作。
7.2.2.3.事务超时
  • timeout事务超时时间： 当前事务所需操作的数据被其他事务占用，则等待。
    • 100：自定义等待时间100（秒）。
    • -1：由数据库指定等待时间，默认值。（建议）
7.2.2.4.读写性
  • readonly 读写性

    • true：只读，可提高查询效率，适合查询

    • false：可读可写，适合增删改

7.2.2.5.回滚规则

  • TransactionAttribute

    TransactionAttribute 的默认实现类是DefaultTransactionAttribute ，它同时继承了DefaultTransactionDefinition。在DefaultTransactionDefinition 的基础上增加了rollbackOn的实现，DefaultTransactionAttribute的实现指定了，当异常类型为unchecked exception 的情况下将回滚事务。
    在这里插入图片描述

  • rollbackOn 回滚规则，可省略或设置 rollbackOn=“Exception”

    • 如果事务中抛出 RuntimeException,则自动回滚

    • 如果事务中抛出 CheckException，不会自动回滚

7.3.3.TransactionStatus

  • PlatformTransactionManager.getTransaction(…) 方法返回一个 TransactionStatus 对象，该对象代表一个新的或已经存在的事务，源代码如下：

    public  interface TransactionStatus{boolean isNewTransaction();void setRollbackOnly();boolean isRollbackOnly();
}

7.4.改造转账案例

7.4.1.applicationContext.xml

 	<!--配置事物管理器--><bean class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><property name="dataSource" ref="dataSource"/></bean><!--配置事物属性--><bean class="org.springframework.transaction.support.DefaultTransactionDefinition"><property name="propagationBehaviorName" value="PROPAGATION_REQUIRED"/><property name="readOnly" value="false"></property></bean>

7.4.2.service

@Service
public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;@Autowiredprivate TransactionDefinition txDefinition;@Autowiredprivate PlatformTransactionManager txManager;/*** 转账* @param source* @param target* @param money*/@Overridepublic void updateUser(String source, String target, Float money) {// 获取一个事务TransactionStatus txStatus = txManager.getTransaction(txDefinition);try {userMapper.updateUserOfSub(source, money);int a = 6/0;userMapper.updateUserOfAdd(target, money);//提交事务txManager.commit(txStatus);}catch (Exception e){//回滚事务txManager.rollback(txStatus);e.printStackTrace();}}
}

7.4.3.测试

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")//加载配置文件
public class ServiceTest {@Autowiredprivate UserService userService;/*** 转账业务*/@Testpublic void testUpdate(){userService.updateUser("张三丰","宋远桥",1F);}
}
  • 事务回滚：

在这里插入图片描述

  • 满足执行：
    在这里插入图片描述
  • 我们现在虽然实现了事务控制，但是代码非常的臃肿，我们可以使用动态代理简化代码

7.3.动态代理控制事务

7.3.1.factory

我们创建一个工厂，专门用来给 Service 创建代理对象，如下：

package com.by.factory;import com.by.service.UserService;
import com.by.service.UserServiceImpl;
import org.hamcrest.Factory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;/*** bean工厂*/
@Component
public class BeanFactory {@Autowiredprivate UserService userService;@Autowiredprivate TransactionDefinition txDefinition;@Autowiredprivate PlatformTransactionManager txManager;/*** 获得UserServiceImpl对象** @return*/public UserService getUserService() {return (UserService) Proxy.newProxyInstance(userService.getClass().getClassLoader(),userService.getClass().getInterfaces(),new InvocationHandler() {public Object invoke(Object proxy, Method method, Object[] args)throws Throwable {//开启事务TransactionStatus txStatus = txManager.getTransaction(txDefinition);try {method.invoke(userService, args);//提交事务txManager.commit(txStatus);} catch (Exception e) {//回滚事务txManager.rollback(txStatus);e.printStackTrace();}return null;}});}
}

7.3.2.applicationContext.xml

<!--配置service代理对象-->
<bean id="proxyService" factory-bean="beanFactory" factory-method="getUserService"></bean>

7.2.3.service

@Service
public class UserServiceImpl implements UserService {@Autowiredprivate UserMapper userMapper;/*** 转账* @param source* @param target* @param money*/@Overridepublic void updateUser(String source, String target, Float money) {userMapper.updateUserOfSub(source, money);int a = 6/0;userMapper.updateUserOfAdd(target, money);}
}

7.2.4.测试

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")
public class ServiceTest {@Autowired@Qualifier("proxyService")//注入代理对象private UserService userService;@Testpublic void testUpdate(){userService.updateUser("张三丰","宋远桥",1F);}
}
  • 事务回滚：

在这里插入图片描述

7.4.Spring AOP控制事务

7.4.1.导入schema约束

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/contexthttp://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/txhttp://www.springframework.org/schema/tx/spring-tx.xsdhttp://www.springframework.org/schema/aophttps://www.springframework.org/schema/aop/spring-aop.xsd"><!--配置事物属性<bean class="org.springframework.transaction.support.DefaultTransactionDefinition"><property name="propagationBehaviorName" value="PROPAGATION_REQUIRED"/><property name="readOnly" value="false"></property></bean>配置service代理对象<bean id="proxyService" factory-bean="beanFactory" factory-method="getUserService"> </bean>-->
</beans>

7.4.2.配置增强

    <!-- 1、增强 --><tx:advice id="txAdvice" transaction-manager="transactionManager"><!--事务属性--><tx:attributes><!-- 指定方法名称：是业务核心方法read-only：是否是只读事务。默认false，不只读。isolation：指定事务的隔离级别。默认值是使用数据库的默认隔离级别。propagation：指定事务的传播行为。timeout：指定超时时间。默认值为：-1。永不超时。rollback-for：用于指定一个异常，当执行产生该异常时，事务回滚。产生其他异常，事务不回滚。省略时任何异常都回滚。--><tx:method name="*" read-only="false" propagation="REQUIRED"/><tx:method name="select*" read-only="true" propagation="SUPPORTS"/><tx:method name="get*" read-only="true" propagation="SUPPORTS"/></tx:attributes></tx:advice>

7.4.3.配置切点

    <aop:config><!--2、切点--><aop:pointcut expression="execution(* com.by.service.*.*(..))" id="pointcut"/></aop:config>

7.4.4.配置切面

    <aop:config><!--3、切面--><aop:advisor advice-ref="txAdvice" pointcut-ref="pointcut"></aop:advisor></aop:config>

7.4.5.factory

删除bean工程

7.4.6.测试

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")//加载配置文件
public class ServiceTest {@Autowiredprivate UserService userService;/*** 转账业务*/@Testpublic void testUpdate(){userService.updateUser("张三丰","宋远桥",1F);}
}

  • 事务回滚：

  • 在这里插入图片描述

  • 问题一：如果我们把方法名称改了，那么事务还会回滚吗？

    • 修改applicationContext.xml：

    • 修改service：

  • 问题二：如果我们把异常捕捉了，那么事务还会回滚吗？

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/334513.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

如何脱离keil在vscode上实现STM32单片机编程

如何脱离keil在vscode上实现STM32单片机编程

【VScode Embedded IDE】Keil工程导入VScode&#xff0c;与Keil协同开发MCU_vscode编辑keil工程-CSDN博客 从零开始的51单片机——VsCodeEIDE环境搭建_vscodeeidesdcc-CSDN博客 结合一下这两个大佬的博客就是可以实现STM32的编程了 主要要点&#xff1a; &#xff08;1&#…
阅读更多...
【Python机器学习】用于回归的决策树

【Python机器学习】用于回归的决策树

用于回归的决策树与用于分类的决策树类似&#xff0c;在DecisionTreeRegressor中实现。DecisionTreeRegressor不能外推&#xff0c;也不能在训练数据范围之外的数据进行预测。 利用计算机内存历史及格的数据进行实验&#xff0c;数据展示&#xff1a; import pandas as pd im…
阅读更多...
破解linux系统密码

破解linux系统密码

破解密码&#xff1a; 虚拟机重启的时候按e键 按↓键&#xff0c;找到以linux16开头的行&#xff0c;在最后加上rd.break 按ctrlx进入救援模式 重新挂载/sysroot为可读写模式&#xff0c;并切换根目录为/sysroot mount -o remount,rw /sysroot chroot /sysroot 设置密码 passwd…
阅读更多...
【方法】如何修改Word文档密码？

【方法】如何修改Word文档密码？

我们在生活和工作中经常会使用到Word&#xff0c;有时候需要保护Word文档&#xff0c;还会设置密码&#xff0c;那如果后续想要修改密码&#xff0c;要怎么操作呢&#xff1f; 下面来看看Word文档常用的3种密码是如何修改的。 一、打开密码 想要修改“打开密码”&#xff0c…
阅读更多...
《亚太教育》是什么级别的期刊？是正规期刊吗？能评职称吗？

《亚太教育》是什么级别的期刊？是正规期刊吗？能评职称吗？

《亚太教育》主要发表教育理论研究、教育教学实践、学校管理、学科教育、科研管理等学术论文以及其他与教育教学相关的学术论文和研究成果,现征集教育管理以及各学科优秀论文。欢迎.各位教师、教育工作者及高校学生踊跃投稿。 收录情况&#xff1a;知网万方维普收录 投稿方式&a…
阅读更多...
使用postman发送请求，提示Content type ‘multipart/form-data not supported

使用postman发送请求，提示Content type ‘multipart/form-data not supported

1、原因&#xff1a;后端通过RequestBody 的方式接收参数&#xff0c;不能通过form-data方式传参&#xff0c;每一个请求必须是通过实体对象进行传参&#xff0c;需要改为使用json传参
阅读更多...
Java多线程编程中的异常处理策略

Java多线程编程中的异常处理策略

第1章&#xff1a;引言 大家好&#xff0c;我是小黑&#xff0c;咱们今天聊聊异常处理。想必大家在写代码的时候都遇到过各种各样的异常吧&#xff1f;有时候&#xff0c;一个小小的异常如果处理不当&#xff0c;就可能导致整个程序崩溃。特别是在多线程环境下&#xff0c;异常…
阅读更多...
MFC Socket和合信CTMC M266ES 运动控制型PLC通信进行数据交换

MFC Socket和合信CTMC M266ES 运动控制型PLC通信进行数据交换

前言 1、前两篇文章通过对Snap7和S7-1200/S7-1500PLC的通信进行了详细的介绍。Snap7的优点开源性强、使用方便易于上手&#xff0c;跨平台和可移植性性强。但是Snap7也有个缺点就是只能访问PLC的DB、MB、I、Q区进行数据读写&#xff0c;不能对V区进行读写,有人说可以读写V区&am…
阅读更多...
Redis主从复制、哨兵及集群

Redis主从复制、哨兵及集群

目录 简介 主从复制 哨兵 集群 1.Redis 主从复制 主从复制的作用 主从工作原理 主从复制搭建 安装redis 修改redis配置文件Master节点操作 修改 Redis 配置文件slave节点操作 验证主从效果 2.Redis 哨兵模式 哨兵模式的作用 哨兵结构组成部分 故障转移机制 主…
阅读更多...
【数据库】mysql事务

【数据库】mysql事务

一、事务的基本概念 1、事务的定义 事务可由一条非常简单的SQL语句组成&#xff0c;也可以由一组复杂的SQL语句组成。。 在 MySQL 中只有使用了 Innodb 数据库引擎的数据库或表才支持事务。事务处理可以用来维护数据库的完整性&#xff0c;保证成批的 SQL 语句要么全部执行&…
阅读更多...
Java学习笔记-day05-响应式编程初探-自定义实现Reactive Streams规范

Java学习笔记-day05-响应式编程初探-自定义实现Reactive Streams规范

最近在学响应式编程&#xff0c;这里先记录下&#xff0c;响应式编程的一些基础内容 1.名词解释 Reactive Streams、Reactor、WebFlux以及响应式编程之间存在密切的关系&#xff0c;它们共同构成了在Java生态系统中处理异步和响应式编程的一系列工具和框架。 Reactive Streams…
阅读更多...
vue3 组合式 API 在 onMounted 中调用 dom 报错 Initialize failed: invalid dom.

vue3 组合式 API 在 onMounted 中调用 dom 报错 Initialize failed: invalid dom.

问题 在开发的过程中&#xff0c;项目中需要用到 echarts&#xff0c;引入后在渲染的过程中报错了&#xff1a;Initialize failed: invalid dom. 这个报错表示元素在未渲染完成的情况下就被调用了&#xff0c;作者在以前也遇到过这种情况&#xff0c;在 vue2 中正常来说将 ech…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023