鼎泰网
（十六）Spring对事务的支持
创始人
2024-04-13 20:46:14
0次

文章目录

  • 环境
  • 事务概述
  • 引入事务场景
    • 第一步：准备环境
    • 第二步：编写持久层
    • 第三步：编写业务层
    • 第四步：编写Spring配置文件
    • 第五步：编写表示层（测试程序）
    • 模拟异常
  • Spring对事务的支持
    • Spring事务管理API
    • 声明式事务之注解实现方式
    • 事务属性
      • 事务属性包括哪些
        • 事务传播行为
          • 演示程序
        • 事务隔离级别
          • 演示程序
        • 事务超时
          • 演示程序
        • 只读事务
          • 演示程序
        • 设置哪些异常回滚事务
          • 演示程序
        • 设置哪些异常不回滚事务
          • 演示程序
    • 事务的全注解式开发
    • 声明式事务之XML实现方式
      • 第一步：基础配置
      • 第二步：配置通知
      • 第三步：配置切面
      • 测试

上一篇：（十五）Spring之面向切面编程AOP

下一篇：（十七）Spring6整合JUnit

环境

spring6里程碑版本的仓库
依赖：spring context依赖、junit依赖、log4j2依赖、mysql驱动依赖、德鲁伊连接池依赖、@Resource注解依赖、spring jdbc依赖
log4j2.xml文件放到类路径下。
数据库：账户表t_act
请添加图片描述
初始数据：
请添加图片描述
实体类：Account

/*** 简单的账户类*/
public class Account {private Long id;private String actno;private Double balance;public Account() {}public Account(Long id, String actno, Double balance) {this.id = id;this.actno = actno;this.balance = balance;}@Overridepublic String toString() {return "Account{" +"id=" + id +", actno='" + actno + '\'' +", balance=" + balance +'}';}public Long getId() {return id;}public void setId(Long id) {this.id = id;}public String getActno() {return actno;}public void setActno(String actno) {this.actno = actno;}public Double getBalance() {return balance;}public void setBalance(Double balance) {this.balance = balance;}
}

事务概述

什么是事务：

  • 在一个业务流程当中，通常需要多条DML（insert delete
    update）语句共同联合才能完成，这多条DML语句必须同时成功，或者同时失败，这样才能保证数据的安全。
  • 多条DML要么同时成功，要么同时失败，这叫做事务。
  • 事务：Transaction（tx）

事务的四个处理过程：

  • 第一步：开启事务 (start transaction)
  • 第二步：执行核心业务代码
  • 第三步：提交事务（如果核心业务处理过程中没有出现异常）(commit transaction)
  • 第四步：回滚事务（如果核心业务处理过程中出现异常）(rollback transaction)

事务的四个特性：

  • A 原子性：事务是最小的工作单元，不可再分。
  • C 一致性：事务要求要么同时成功，要么同时失败。事务前和事务后的总量不变。
  • I 隔离性：事务和事务之间因为有隔离性，才可以保证互不干扰。
  • D 持久性：持久性是事务结束的标志。

引入事务场景

以银行账户转账为例。两个账户act-001和act-002。act-001账户向act-002账户转账，必须同时成功，或者同时失败。（一个减成功，一个加成功， 这两条update语句必须同时成功，或同时失败。）

连接数据库的技术采用Spring框架的JdbcTemplate。

采用三层架构搭建：

第一步：准备环境

相关依赖、数据库表（t_act）及数据、实体类（Account）

第二步：编写持久层

创建dao包，在dao包下创建接口：AccountDao

/*** 专门负责账户信息的CRUD操作，不和业务挂钩*/
public interface AccountDao {/*** 根据账号查询账户信息* @param actno* @return*/Account selectByActno(String actno);/*** 更新账户信息* @param act* @return*/int update(Account act);
}

在dao层下，创建impl包，新建AccountDao的实现类：AccountDaoImpl

@Repository("accountDao")
public class AccountDaoImpl implements AccountDao {@Resource(name = "jdbcTemplate")private JdbcTemplate jdbcTemplate;@Overridepublic Account selectByActno(String actno) {String sql = "select * from t_act where actno = ?";Account account = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(Account.class), actno);return account;}@Overridepublic int update(Account act) {String sql = "update t_act set balance = ? where actno = ?";int update = jdbcTemplate.update(sql, act.getBalance(), act.getActno());return update;}
}

第三步：编写业务层

创建service包，在service包创建接口：AccountService

public interface AccountService {/*** 转账业务* @param fromAct 转出账户* @param toAct 转出账户* @param money 转账金额*/void transfer(String fromAct,String toAct,double money);
}

在service层下创建impl包，编写AccountService的实现类：AccountServiceImpl

@Service("accountService")
public class AccountServiceImpl implements AccountService {@Resource(name = "accountDao")private AccountDao accountDao;@Overridepublic void transfer(String fromActno, String toActno, double money) {//查询转出账户余额是否充足Account fromAccount = accountDao.selectByActno(fromAct);if (fromAccount.getBalance() < money) {//余额不足抛异常throw new RuntimeException("余额不足");}//修改内存中两个对象的余额Account toAccount = accountDao.selectByActno(toAct);fromAccount.setBalance(fromAccount.getBalance() - money);toAccount.setBalance(toAccount.getBalance() + money);//数据库更新int count = accountDao.update(fromAccount);//模拟异常/*String s = null;s.toString();*/count += accountDao.update(toAccount);if (count != 2) {throw new RuntimeException("转账失败");}
}

第四步：编写Spring配置文件

创建spring.xml：
添加组件扫描、配置jdbcTemplate、配置德鲁伊连接池

第五步：编写表示层（测试程序）

@Testpublic void testSpringTx(){ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");AccountService accountService = applicationContext.getBean("accountService", AccountService.class);try {accountService.transfer("act001","act002",1000);System.out.println("转账成功。。。");}catch (Exception e){e.printStackTrace();}}

运行程序：
请添加图片描述
数据库数据改变：
请添加图片描述

模拟异常

把在业务代码里的模拟异常松开：

@Service("accountService")
public class AccountServiceImpl implements AccountService {@Resource(name = "accountDao")private AccountDao accountDao;@Overridepublic void transfer(String fromActno, String toActno, double money) {//查询转出账户余额是否充足Account fromAccount = accountDao.selectByActno(fromAct);if (fromAccount.getBalance() < money) {//余额不足抛异常throw new RuntimeException("余额不足");}//修改内存中两个对象的余额Account toAccount = accountDao.selectByActno(toAct);fromAccount.setBalance(fromAccount.getBalance() - money);toAccount.setBalance(toAccount.getBalance() + money);//数据库更新int count = accountDao.update(fromAccount);//模拟异常String s = null;s.toString();count += accountDao.update(toAccount);if (count != 2) {throw new RuntimeException("转账失败");}
}

再次运行：
请添加图片描述
数据库表中数据：
请添加图片描述
数据异常，丢失1千

Spring对事务的支持

Spring实现事务的两种方式

  • 编程式事务（基本不会用）
    通过编写代码的方式来实现事务的管理。
  • 声明式事务
    • 基于注解方式（常用）
    • 基于XML配置方式（不常用）

Spring事务管理API

Spring对事务的管理底层实现方式是基于AOP实现的。采用AOP的方式进行了封装。所以Spring专门针对事务开发了一套API，API的核心接口如下：
在这里插入图片描述
PlatformTransactionManager接口：spring事务管理器的核心接口。在Spring6中它有两个实现：

  • DataSourceTransactionManager：支持JdbcTemplate、MyBatis、Hibernate等事务管理。
  • JtaTransactionManager：支持分布式事务管理。

如果要在Spring6中使用JdbcTemplate，就要使用DataSourceTransactionManager来管理事务。（Spring内置写好了，可以直接用。）

声明式事务之注解实现方式

第一步：在spring配置文件中配置事务管理器。

第二步：在spring配置文件中引入tx命名空间。

第三步：在spring配置文件中配置“事务注解驱动器”，开始注解的方式控制事务。

第四步：在service类上或方法上添加@Transactional注解
@Transactional

  • 写在方法上，只针对于该方法应用事务。
  • 写在类上，代表这个类上所有方法应用事务。
	@Override@Transactionalpublic void transfer(String fromAct, String toAct, double money) {//查询转出账户余额是否充足Account fromAccount = accountDao.selectByActno(fromAct);if (fromAccount.getBalance() < money) {//余额不足抛异常throw new RuntimeException("余额不足");}//修改内存中两个对象的余额Account toAccount = accountDao.selectByActno(toAct);fromAccount.setBalance(fromAccount.getBalance() - money);toAccount.setBalance(toAccount.getBalance() + money);//数据库更新int count = accountDao.update(fromAccount);//模拟异常String s = null;s.toString();count += accountDao.update(toAccount);if (count != 2) {throw new RuntimeException("转账失败");}}

执行测试程序：
请添加图片描述
虽然出现异常了，再次查看数据库表中数据：
请添加图片描述
发现数据没有变化，事务起作用了。

事务属性

事务属性包括哪些

我们可以查看一下@Transactional注解源码：

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface Transactional {@AliasFor("transactionManager")String value() default "";@AliasFor("value")String transactionManager() default "";String[] label() default {};Propagation propagation() default Propagation.REQUIRED;Isolation isolation() default Isolation.DEFAULT;int timeout() default -1;String timeoutString() default "";boolean readOnly() default false;Class[] rollbackFor() default {};String[] rollbackForClassName() default {};Class[] noRollbackFor() default {};String[] noRollbackForClassName() default {};
}

有很多的属性，我们只关注重点属性：
事务中的重点属性：

  • 事务传播行为 propagation()
  • 事务隔离级别 isolation()
  • 事务超时 timeout()
  • 只读事务 readOnly()
  • 设置出现哪些异常回滚事务 rollbackFor()
  • 设置出现哪些异常不回滚事务 noRollbackFor()

事务传播行为

什么是事务的传播行为？
例如在service类中有a()方法和b()方法，a()方法上有事务，b()方法上也有事务，当a()方法执行过程中调用了b()方法，事务是如何传递的？合并到一个事务里？还是开启一个新的事务？这就是事务传播行为。

事务传播行为在spring框架中被定义为枚举类型：

public enum Propagation {REQUIRED(0),SUPPORTS(1),MANDATORY(2),REQUIRES_NEW(3),NOT_SUPPORTED(4),NEVER(5),NESTED(6);private final int value;private Propagation(int value) {this.value = value;}public int value() {return this.value;}
}

一共有七种传播行为：

  • REQUIRED：支持当前事务，如果不存在就新建一个(默认)
    没有就新建，有就加入

  • SUPPORTS：支持当前事务，如果当前没有事务，就以非事务方式执行
    有就加入，没有就不管了

  • MANDATORY：必须运行在一个事务中，如果当前没有事务正在发生，将抛出一个异常
    有就加入，没有就抛异常

  • REQUIRES_NEW：开启一个新的事务，如果一个事务已经存在，则将这个存在的事务挂起
    不管有没有，直接开启一个新事务，开启的新事务和之前的事务不存在嵌套关系，之前事务被挂起

  • NOT_SUPPORTED：以非事务方式运行，如果有事务存在，挂起当前事务
    不支持事务，存在就挂起

  • NEVER：以非事务方式运行，如果有事务存在，抛出异常
    不支持事务，存在就抛异常

  • NESTED：如果当前正有一个事务在进行中，则该方法应当运行在一个嵌套式事务中。被嵌套的事务可以独立于外层事务进行提交或回滚。如果外层事务不存在，行为就像REQUIRED一样。
    有事务的话，就在这个事务里再嵌套一个完全独立的事务，嵌套的事务可以独立的提交和回滚。没有事务就和REQUIRED一样。

演示程序

需要在数据库中新增两个账户，在一个保存方法里调用另一个保存方法。
首先在持久层接口添加方法，并在实现类实现：
AccountDao接口新增方法：

    /*** 新增账户信息* @param act* @return*/int insert(Account act);

AccountDaoImpl实现：

    @Overridepublic int insert(Account act) {String sql = "insert into t_act values(null,?,?)";int count = jdbcTemplate.update(sql, act.getActno(), act.getBalance());return count;}

在业务层接口添加方法，及实现类实现：
AccountService接口：

    /*** 保存账户信息* @param act*/void save(Account act);

新增第二个实现类：AccountServiceImpl2

@Service("accountService2")
public class AccountServiceImpl2 implements AccountService {@Resource(name = "accountDao")private AccountDao accountDao;@Overridepublic void transfer(String fromAct, String toAct, double money) {}@Override@Transactional(propagation = Propagation.REQUIRED)public void save(Account act) {accountDao.insert(act);//模拟异常/*String s = null;s.toString();*/}
}

AccountServiceImpl实现方法：调用AccountServiceImpl2的save方法

    @Resource(name = "accountService2")private AccountService accountService;@Override@Transactional(propagation = Propagation.REQUIRED)public void save(Account act) {//先保存act账户accountDao.insert(act);//再保存act2账户Account act2 = new Account();act2.setActno("act-004");act2.setBalance(1000.0);try {accountService.save(act2);//调用AccountServiceImpl2的save方法}catch (Exception e){}}

测试程序：

    @Testpublic void testPropagation(){ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");AccountService accountService = applicationContext.getBean("accountService", AccountService.class);Account account = new Account();account.setActno("act-003");account.setBalance(10000.0);accountService.save(account);}

请添加图片描述
可以看见在两个SQL语句之间，Participating in existing transaction，翻译为：参与现有交易，实际上就是加入事务了，查看数据库数据：
请添加图片描述
正常插入。
如果把AccountServiceImpl2模拟注释松开:

@Override@Transactional(propagation = Propagation.REQUIRED)public void save(Account act) {accountDao.insert(act);//模拟异常String s = null;s.toString();}

发生异常了，回滚事务
请添加图片描述
数据库数据不改变：
请添加图片描述
如果把AccountServiceImpl2的事务传播类型换成REQUIRES_NEW

    @Override//@Transactional(propagation = Propagation.REQUIRED)@Transactional(propagation = Propagation.REQUIRES_NEW)public void save(Account act) {accountDao.insert(act);//模拟异常String s = null;s.toString();}

再次运行：
请添加图片描述
可以看见在两个SQL语句之间，Suspending current transaction, creating new transaction with name，翻译为：正在挂起当前事务，正在创建名为的新事务
并且事务2发生异常回滚了，然后
Resuming suspended transaction after completion of inner transaction
Initiating transaction commit
翻译为：

内部事务完成，恢复暂停的事务
启动事务提交

也就是说事务1不会受到事务2的影响，并且如果事务2发生异常，进行捕获，也捕获不到，发生异常后会自动回滚，事务1恢复，并且进行往下执行。

查看数据库：只新增了事务1的账户
请添加图片描述
余下的事务传播行为就不演示了。

事务隔离级别

数据库中读取数据存在的三大问题：（三大读问题）

  • 脏读：读取到没有提交到数据库的数据，叫做脏读。
  • 不可重复读：在同一个事务当中，第一次和第二次读取的数据不一样。
  • 幻读：读到的数据是假的。

事务隔离级别包括四个级别：

  • 读未提交：READ_UNCOMMITTED
    这种隔离级别，存在脏读问题，所谓的脏读(dirty read)表示能够读取到其它事务未提交的数据。
  • 读提交：READ_COMMITTED
    解决了脏读问题，其它事务提交之后才能读到，但存在不可重复读问题。
  • 可重复读：REPEATABLE_READ
    解决了不可重复读，可以达到可重复读效果，只要当前事务不结束，读取到的数据一直都是一样的。但存在幻读问题。
  • 序列化：SERIALIZABLE
    解决了幻读问题，事务排队执行。不支持并发。

表格归纳：

隔离级别脏读不可重复读
读未提交有有
读提交无有
可重复读无无
序列化无无

隔离级别在spring中也是以枚举类型存在：

public enum Isolation {DEFAULT(-1),READ_UNCOMMITTED(1),READ_COMMITTED(2),REPEATABLE_READ(4),SERIALIZABLE(8);private final int value;private Isolation(int value) {this.value = value;}public int value() {return this.value;}
}
  • DEFAULT：
    这是一个PlatfromTransactionManager默认的隔离级别，使用数据库默认的事务隔离级别。另外四个与JDBC的隔离级别相对应
  • READ_UNCOMMITTED： 读未提交
  • READ_COMMITTED：读提交
  • REPEATABLE_READ： 可重复读
  • SERIALIZABLE：序列化
演示程序

一个service负责插入，一个service负责查询。负责插入的service要模拟延迟。
创建AccountServiceImpl3类，不实现接口了，负责查询：

/*** 演示隔离级别* 3号负责查询，4号负责插入*/
@Service("accountService3")
public class AccountServiceImpl3 {@Resource(name = "accountDao")private AccountDao accountDao;/*** 根据账户查询* @param actno*/@Transactional(isolation = Isolation.READ_UNCOMMITTED)public void getByActno(String actno){Account account = accountDao.selectByActno(actno);System.out.println("账户信息：" + account);}
}

创建AccountServiceImpl4类，不实现接口了，负责插入：

@Service("accountService4")
public class AccountServiceImpl4 {@Resource(name = "accountDao")private AccountDao accountDao;@Transactionalpublic void save(Account act){        accountDao.insert(act);//让程序睡眠一会try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}       }
}

测试程序：

    @Testpublic void testIsolation1() {ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");AccountServiceImpl4 accountService4 = applicationContext.getBean("accountService4", AccountServiceImpl4.class);Account account = new Account();account.setActno("act-003");account.setBalance(50000.0);accountService4.save(account);}@Testpublic void testIsolation2(){ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");AccountServiceImpl3 accountService3 = applicationContext.getBean("accountService3", AccountServiceImpl3.class);accountService3.getByActno("act-003");}

执行前需要把数据库数据删除到初始数据。
请添加图片描述

先执行testIsolation1，在执行testIsolation2
testIsolation1：
请添加图片描述
testIsolation2：读到了未提交的数据
请添加图片描述
等testIsolation1执行完后查看数据库数据：
请添加图片描述
余下的隔离级别就不演示了。

事务超时

事务超时：使用timeout=整数设置，表示超过多少秒如果该事务中所有的DML语句还没有执行完毕的话，最终结果会选择回滚。默认值是-1，表示没有时间限制。

  • 最后一条DML语句执行之后的时间就不会被记录到超时时间里。
  • 反之在最后一条DML语句执行之前的时间就会被记录到超时时间里。
演示程序

在AccountServiceImpl4里设置事务超时
在最后一条DML语句执行之后让程序睡眠情况：

	//@Transactional@Transactional(timeout = 10)//设置超时事务10秒public void save(Account act) throws IOException {accountDao.insert(act);//让程序睡眠一会try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}}

运行测试程序testIsolation1：
请添加图片描述
事务提交了，睡眠程序没有计入超时时间，查看数据库数据：成功插入数据
请添加图片描述
如果想让整个方法的所有代码都计入超时时间的话，可以在方法最后一行添加一行无关紧要的DML语句。
在最后一条DML语句执行之前让程序睡眠情况：

//@Transactional@Transactional(timeout = 10)public void save(Account act){try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}accountDao.insert(act);//让程序睡眠一会/*try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}*/}

再次运行测试程序testIsolation1：
请添加图片描述
睡眠时间计入超时时间，事务超时，进行了回滚，数据库数据：原封不动
请添加图片描述

只读事务

使用readOnly = ture|false 配置，默认未false
将当前事务设置为只读事务，在该事务执行过程中只允许select语句执行，delete insert update均不可执行。

该特性的作用是：启动spring的优化策略。提高select语句执行效率。

如果该事务中确实没有增删改操作，建议设置为只读事务。

演示程序

在AccountServiceImpl4里设置为只读事务

	//@Transactional//@Transactional(timeout = 10)    @Transactional(readOnly = true)public void save(Account act) throws IOException {/*try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}*/accountDao.insert(act);//让程序睡眠一会/*try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}*/}

运行测试程序testIsolation1：
出现异常，说Connection是只读的，也就是事务是只读的，不允许导致数据修改
请添加图片描述
数据库数据不变：
请添加图片描述

设置哪些异常回滚事务

使用rollbackFor = {异常1.class,异常2.class,...}进行设置，表示只有发生异常或该异常的子类异常才回滚。默认为空，表示所有异常都回滚。

演示程序

在AccountServiceImpl4里设置：

	//@Transactional//@Transactional(timeout = 10)//@Transactional(readOnly = true)@Transactional(rollbackFor = RuntimeException.class)//只要发生RuntimeException或者这个子类的异常，都回滚public void save(Account act) throws IOException {/*try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}*/accountDao.insert(act);//模拟异常//throw new IOException();//IO异常是编译时异常throw new RuntimeException();//让程序睡眠一会/*try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}*/}

运行测试程序testIsolation1：
请添加图片描述
数据库数据不变：
请添加图片描述
把异常改为其他异常，把另一个异常注释松开，注释RuntimeException异常，再次运行程序：
请添加图片描述
出现异常，但是事务提交了，数据库数据改变：
请添加图片描述

设置哪些异常不回滚事务

使用norollbackFor = {异常1.class,异常2.class,...}进行设置，表示发生该异常或该异常的子类异常不回滚，其他异常则回滚，默认为空，表示所有异常都回滚。

演示程序

还是修改AccountServiceImpl4：

	//@Transactional//@Transactional(timeout = 10)//@Transactional(readOnly = true)//@Transactional(rollbackFor = RuntimeException.class)//只要发生RuntimeException或者这个子类的异常，都回滚@Transactional(noRollbackFor = NullPointerException.class)public void save(Account act) throws IOException {/*try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}*/accountDao.insert(act);//模拟异常//throw new IOException();//IO异常是编译时异常//throw new RuntimeException();throw new NullPointerException();//让程序睡眠一会/*try {Thread.sleep(1000 * 20);} catch (InterruptedException e) {e.printStackTrace();}*/}

运行测试程序testIsolation1：
请添加图片描述
发生了空指针异常，但是事务提交了，数据库数据改变：
请添加图片描述
把异常改为其他异常，把另一个RuntimeException异常注释松开，注释NullPointerException异常，再次运行程序：
请添加图片描述
发生异常，但是回滚了，数据库数据不变：
请添加图片描述

事务的全注解式开发

编写一个类来代替配置文件，怎么编写jdbcTemplate、德鲁伊数据源、事务管理器这些Bean呢？

可以在配置文件编写方法使用@Bean注解修饰，Bean的id就使用name属性设置。

Spring框架看到这个@Bean注解的时候，会调用这个注解标注的方法，返回该方法的对象，该对象会自动纳入IoC容器管理。

这个返回值就是Spring容器的Bean对象了，并且这个Bean对象的名字就是name。

这些Bean的属性是怎么注入呢？
简单类型的属性可以使用注解的value进行配置
如果注入非简单类型的话，它是一个Bean，有两种注入方式

  • 1.想要注入哪个Bean，可以调用@Bean标注的那个方法
  • 2.通过参数传递，在方法@Bean标注的方法里设置一个参数，这个参数是你要注入的类型，Spring框架会自动寻找这个类型的Bean，传给这个方法使用。

一般非简单类型使用第二种设置

@Configuration// 代替Spring配置文件
@ComponentScan("com.bank")// 代替组件扫描
@EnableTransactionManagement //开启事务注解
public class SpringConfig {@Bean(name = "jdbcTemplate")public JdbcTemplate getJdbcTemplate(DataSource dataSource){JdbcTemplate jdbcTemplate = new JdbcTemplate();//两种注入方式//jdbcTemplate.setDataSource(getDruidDataSource());jdbcTemplate.setDataSource(dataSource);return jdbcTemplate;}@Bean(name = "dataSource")public DruidDataSource getDruidDataSource(){DruidDataSource dataSource = new DruidDataSource();dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");dataSource.setUrl("jdbc:mysql://localhost:3306/mvc");dataSource.setUsername("root");dataSource.setPassword("root");return dataSource;}@Bean(name = "txManager")public DataSourceTransactionManager getDataSourceTransactionManager(DataSource dataSource){DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();transactionManager.setDataSource(dataSource);return transactionManager;}
}

测试还是使用账户转账，把异常去掉：

    @Testpublic void testNoXML(){ApplicationContext applicationContext = new AnnotationConfigApplicationContext(SpringConfig.class);AccountService accountService = applicationContext.getBean("accountService", AccountService.class);try {accountService.transfer("act001","act002",1000);System.out.println("转账成功。。。");}catch (Exception e){e.printStackTrace();}}

请添加图片描述
请添加图片描述

声明式事务之XML实现方式

测试的话还是使用账户转账。
配置步骤：

  • 第一步：基础配置
  • 第二步：配置通知
  • 第三步：配置切面

记得添加aspectj的依赖：


org.springframeworkspring-aspects6.0.0-M2

第一步：基础配置

**添加aop的命名空间。**为后面配置通知和切面做准备。
并且配置组件扫描、配置jdbcTemplate、配置德鲁伊连接池、配置事务管理器

第二步：配置通知

配置通知：使用tx:advice标签

  • id属性：唯一标识
  • transaction-manager：配置关联事务管理器

在tx:advice标签里面配置通知的相关属性，使用嵌套标签配置
之前说的所有的事务属性都可以在标签以属性的方式配置
如果方法比较多可以采用通配符的方式进行模糊匹配配置
例如 就是save开始发方法都需要进行事务管理

第三步：配置切面

配置切点：使用标签配置

  • id属性：唯一标识
  • expression：切点表达式

配置切面：等于通知加切点，使用标签配置

  • advice-ref属性：通知的id
  • pointcut-ref属性：切点的id

测试

将AccountServiceImpl类上的@Transactional注解注释或删除。并且模拟异常
测试程序：

    @Testpublic void testXML(){ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring.xml");AccountService accountService = applicationContext.getBean("accountService", AccountService.class);try {accountService.transfer("act001","act002",1000);System.out.println("转账成功。。。");}catch (Exception e){e.printStackTrace();}}

请添加图片描述
数据库数据：
请添加图片描述
通过测试可以看到配置XML已经起作用了。

词库加载错误:未能找到文件“E:\highferrum_mysql\Configuration\Dict_Stopwords.txt”。

上一篇：李宏毅：Life Long Learning

下一篇：leetcode：6248. 统计中位数为 K 的子数组【问题转化 + 排序二分】

相关内容

热门资讯

节前给父母买礼物？警惕保健品骗... 年底将至，不少朋友开始计划给父母选购礼物。给父母的礼物一般以实用为主，因而不少朋友会从“健康”方面考...
跨周期调节发力 一大批重磅政策... 央视网消息：为落实中央经济工作会议部署的重点任务，12月31日上午，国家发展改革委举行新闻发布会，发...
中国证监会修改《证券期货行政执... 新华社北京12月31日电（记者刘慧、刘羽佳）中国证监会对《证券期货行政执法当事人承诺制度实施规定》进...
一揽子解决4000余起涉央视著... 寒风凛冽，北京迎来深冬。最高人民法院的那棵皂角树也褪去了旧衣，门口的接待室里来了几位“熟悉”的客人，...
南山区商事（金融）纠纷调处中心... 12月31日，深圳市南山区商事（金融）纠纷调处中心召开座谈会。南山区司法局、南山区人民法院，以及入驻...
深圳写手智能科技申请法律服务平... 国家知识产权局信息显示，深圳写手智能科技有限公司申请一项名为“法律服务平台的数据信息集成方法及系统”...
江苏博云塑业申请无氟阻燃工程塑... 国家知识产权局信息显示，江苏博云塑业股份有限公司申请一项名为“无氟阻燃工程塑料合金及其制备方法”的专...
国常会：审议通过《供水条例(草... 钛媒体App 12月31日消息，李强主持召开国务院常务会议，审议通过《供水条例(草案)》和《中华人民...
教育部出台制度规范职业教育教师... 新华社北京12月31日电（记者魏冠宇）记者从教育部获悉，教育部教师队伍建设专家指导委员会职业学校教师...
证监会：支持相关市场机构、人员... 证监会有关部门负责人答记者问。问：12月30日，五矿证券公告就广道数字虚假陈述设立先行赔付专项基金，...