事务管理

2021-02-07 分类 Spring 作者 Nayuki ~5.93K 字

事务的概念

事务是数据库操作最基本单元，逻辑上的一组操作，要么都成功，如果有一个失败，则所有操作都回滚
事务四个特性ACID
- 原子性
- 一致性
- 隔离性
- 持久性

事务操作环境模拟

配置数据库连接池

<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close">
        <property name="url" value="jdbc:mysql:///user?serverTimezone=UTC" />
        <property name="username" value="root" />
        <property name="password" value="mysql" />
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />
</bean>

配置JdbcTemplate对象

1
2
3

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <property name="dataSource" ref="dataSource"></property>
</bean>

创建UserDaoImpl类

@Repository()
public class UserDaoImpl implements UserDao{
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Override
    public void reduceMoney() {
        String sql = "update user set money=money-? where name=?";
        int code=jdbcTemplate.update(sql,100,"Nayuki");
        System.out.println(code);
    }
    @Override
    public void addMoney() {
        String sql = "update user set money=money+? where name=?";
        int code=jdbcTemplate.update(sql,100,"Nayukii");
        System.out.println(code);
    }
}

创建UserService类

@Service
public class UserService {
    @Autowired
    UserDao userDao;
    public void transferMoney(){
        userDao.reduceMoney();
        userDao.addMoney();
    }
}

此过程模拟的是用户之间的转账

事务管理操作介绍

两种方式
- 声明式事务管理
  - 基于注解
  - 基于配置
- 编程式事务管理
声明式事务管理的底层是AOP原理

基于注解的声明式事务管理

创建事务管理器

1
2
3

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"></property>
</bean>

引入命名空间

<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/context
       http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd
       http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

开启事务注解

1	<tx:annotation-driven></tx:annotation-driven>

为UserService类添加事务注解

@Service
@Transactional
public class UserService {
    @Autowired
    UserDao userDao;
    //@Transactional也可以加在方法上面
    public void transferMoney(){
        userDao.reduceMoney();
        int error=1/0;
        userDao.addMoney();
    }
}

测试

@Test
public void testAdd(){
    ApplicationContext context = new ClassPathXmlApplicationContext("bean.xml");
    UserService userService =context.getBean("userService", UserService.class);
    userService.transferMoney();
}

声明式事务管理参数配置

propagation：事务传播行为
- REQUIRED
- REQUIRED_NEW
- SUPPORTS
- MANDATORY
- NOT_SUPPORTS
- NEVER
- NESTED
ioslation：事务隔离级别
- Read_Uncommitted
- Read_Committed
- Repeatable_Read
- Serializable
timeout：超时时间
- -1（默认不超时）
- 其他一秒为单位的数字
readIOnly：是否只读
rollbackFor：回滚
noRollbackFor：不回滚
示例

1	@Transactional(propagation = Propagation.REQUIRED)

基于配置的声明式事务管理

创建事务管理器

1
2
3

<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource"></property>
</bean>

配置通知

<tx:advice id="txadvice">
    <tx:attributes>
        <tx:method name="transferMoney" propagation="REQUIRED"/>
    </tx:attributes>
</tx:advice>

配置切入点和切面

<aop:config>
    <aop:pointcut id="pt" expression="execution(* service.UserService.*(..))"/>
    <aop:advisor advice-ref="txadvice" pointcut-ref="pt"/>
</aop:config>

声明式事务管理的完全注解

创建配置类

@Configuration
@ComponentScan(basePackages = "service"+"dao")
@EnableTransactionManagement
public class TxConfig {
    @Bean
    public DruidDataSource getDruidDataSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql:///user?serverTimezone=UTC");
        dataSource.setUsername("root");
        dataSource.setPassword("mysql");
        return dataSource;
    }
    @Bean
    public JdbcTemplate getJdbcTemplate(DataSource dataSource) {
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        jdbcTemplate.setDataSource(dataSource);
        return jdbcTemplate;
    }
    @Bean
    public DataSourceTransactionManager
    getDataSourceTransactionManager(DataSource dataSource) {
        DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource);
        return transactionManager;
    }
}

测试

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