Spring5-事务

2023-11-26 17:10:04

事务

1、概念

是数据库操作的最基本单元，逻辑上的一组操作，要么都成功，有一个操作失败，所有的操作都失败
例如：银行转账，A转账给B的过程中出现断电了，没有事务的画，A的钱会减少，B的钱不会增多，有事务，则都不会变。

特性（ACID）

  • 原子性：要么都成功，一个失败全都失败
  • 一致性：操作之前和操作之后，总量不变
  • 隔离性：多事务操作不会互相影响
  • 持久性：事务提交后，表中数据才会真正发生变化

2、事务操作

Mysql的InnoDB引擎支持事务回滚

2.1 搭建环境

Spring5-事务
1、创建数据库表，添加记录
Spring5-事务
Spring5-事务
2、创建Service，创建Dao，完成对象创建和注入关系

  • Service中注入Dao，Dao中注入JdbcTemplate，JdbcTemPlate中注入DataSource
public interface UserDao {
}

@Repository
public class UserDaoImpl implements UserDao {
    @Autowired
    private JdbcTemplate jdbcTemplate;
}

@Service
public class UserService {

    // 注入Dao
    @Autowired
    private UserDao userDao;

}
  • dao中创建两个方法，多钱和少钱的方法；service中添加方法（转账的方法）
    UserDaoImpl中添加
@Override
    public void addMoney() {
        String sql = "update t_account set money = money + ? where username = ?";
        jdbcTemplate.update(sql,100,"Mary");
    }

    @Override
    public void reduceMoney() {
        String sql = "update t_account set money = money - ? where username = ?";
        jdbcTemplate.update(sql,100,"Lucy");
    }

UserService中添加

    // 转账的方法
    public  void  accountMoney(){
        // Lucy少100
        userDao.reduceMoney();
        // Mary多100
        userDao.addMoney();
    }

3、测试

public class Test1 {

    @Test
    public void test1(){
        ApplicationContext context = new ClassPathXmlApplicationContext("bean1.xml");
        UserService userService = context.getBean("userService", UserService.class);
        userService.accountMoney();
    }

}

转账成功
Spring5-事务
4、上面的代码正常执行没有问题，但是如果执行过程中出现异常，就有问题了。

    // 转账的方法
    public  void  accountMoney(){
        // Lucy少100
        userDao.reduceMoney();
        // 模拟异常
        int i = 10 / 0;
        // Mary多100
        userDao.addMoney();
    }

数据先手动还原成这样
Spring5-事务
测试后：Lucy钱变少了，Mary钱没增加
Spring5-事务

2.2 使用事务解决问题

1、操作过程：事务添加到Service层
Spring5-事务
2、在Spring进行事务管理操作

  • 编程式事务管理：通过写代码
  • 声明式事务管理（常用）：通过配置文件

3、声明式事务管理：底层使用AOP

  • 基于注解方式
  • 基于xml配置文件方式

4、在Spring进行声明式事务管理API

  • 提供一个接口，代表事务管理器，这个接口针对不同框架提供不同实现类Spring5-事务

2.2.1 注解式声明式事务管理

1、在Spring中配置事务管理器，开启事务注解。

@Configuration
@ComponentScan(basePackages = {"com.liukai.spring5"})
@EnableAspectJAutoProxy
@EnableTransactionManagement
public class TxConfig {

    @Bean(name = "dataSource")
    public DruidDataSource getDataSource(){
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setUrl("jdbc:mysql://localhost:3306/user_db");
        dataSource.setUsername("root");
        dataSource.setPassword("root");
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        return dataSource;
    }

    @Bean("jdbcTemplate")
    public JdbcTemplate getJdbcTemPlate(DataSource dataSource){
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        jdbcTemplate.setDataSource(dataSource);
        return jdbcTemplate;
    }

    @Bean(name = "transactionManager")
    public PlatformTransactionManager getDataSourceTransactionManager(DataSource dataSource){
        DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager();
        dataSourceTransactionManager.setDataSource(dataSource);
        return dataSourceTransactionManager;
    }
}

2、在Service类上面或者类里面方法添加一个事务注解@Transactional，类上面和方法上面都可以添加。

  • 该注解添加到类上面，表示这个类里面的所有方法都添加事务
  • 该注解添加到方法上面，只是为该方法添加事务
@Service
@Transactional
public class UserService {
    // 注入Dao
    @Autowired
    private UserDao userDao;
    // 转账的方法
    public void accountMoney() {
        // Lucy少100
        userDao.reduceMoney();
        // 模拟异常
        int i = 10 / 0;
        // Mary多100
        userDao.addMoney();
    }
}

数据库手动修改成这样
Spring5-事务
3、测试

    @Test
    public void test2(){
        ApplicationContext context = new AnnotationConfigApplicationContext(TxConfig.class);
        UserService userService = context.getBean("userService", UserService.class);
        userService.accountMoney();
    }

Spring5-事务
Spring5-事务
数据没有改变，事务回滚成功。

2.2.2 注解式声明式事务管理参数配置

1、在Service类上面添加@Transactional，这个注解里面可以配置参数
Spring5-事务

  • propagation：多事务方法直接进行调用，这个过程中事务是如何管理的，默认是REQUIRED
    Spring5-事务
    Spring5-事务
    Spring5-事务
  • ioslation：多事务操作之间不会产生影响，不考虑隔离性会产生很多问题。默认是REPEATABLE_READ
    1、脏读：多个事务之间，一个未提交事务读到另一个未提交事务的数据Spring5-事务
    2、不可重复读：一个未提交的事务读取到另一个提交事务的修改数据Spring5-事务
    3、虚（幻）读：一个未提交事务读到另一个未提交事务添加的数据
    通过设置事务的隔离级别，解决读问题
    Spring5-事务
    Spring5-事务
  • timeout：超时时间。事务需要在一定时间内提交，如果不提交进行回滚，默认值是-1，不超时，设置时间以秒为单位
  • readOnly：是否只读。默认值是false，表示可以读和写；设置成true，只能查询操作
  • rollbackFor：回滚。设置出现哪些异常进行回滚
  • noRollbackFor：不回滚。设置出现哪些异常不回滚
    Spring5-事务

2.2.2 XML声明式事务管理

1、配置事务管理器
2、配置通知
3、配置切入点和切面

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd
                           http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
                           http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">

    <!--    开启注解扫描-->
    <context:component-scan base-package="com.liukai.spring5"></context:component-scan>

    <!--    数据库连接池-->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="url" value="jdbc:mysql://localhost:3306/user_db"/>
        <property name="username" value="root"/>
        <property name="password" value="root"/>
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    </bean>

    <!--    JdbcTemplate对象-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--        注入DataSource-->
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <!--    1.配置事务管理器-->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <!--    2.配置通知-->
    <tx:advice id="txAdvice">
        <!--        配置事务参数-->
        <tx:attributes>
            <!--            指定哪种规则方法上面添加事务-->
            <tx:method name="account*" propagation="REQUIRED" timeout="5"/>
        </tx:attributes>
    </tx:advice>

    <!--    3.配置切入点和切面-->
    <aop:config>
        <!--        配置切入点-->
        <aop:pointcut id="pt" expression="execution(* com.liukai.spring5.service.UserService.*(..))"/>
        <!--        配置切面-->
        <aop:advisor advice-ref="txAdvice" pointcut-ref="pt"/>
    </aop:config>

</beans>

@Service
//@Transactional(propagation = Propagation.REQUIRED,
//        isolation = Isolation.REPEATABLE_READ,
//        timeout = 5,
//        readOnly = true)
public class UserService {

    // 注入Dao
    @Autowired
    private UserDao userDao;

    // 转账的方法
    public void accountMoney() {
        // Lucy少100
        userDao.reduceMoney();
        // 模拟异常
        int i = 10 / 0;
        // Mary多100
        userDao.addMoney();
    }

}

    @Test
    public void test3(){
        ApplicationContext context = new ClassPathXmlApplicationContext("bean2.xml");
        UserService userService = context.getBean("userService", UserService.class);
        userService.accountMoney();
    }

Spring5-事务
Spring5-事务
回滚成功

上一篇：day31_spring简介与配置


下一篇：Spring依赖注入（DI）