Spring注解驱动开发声明式事务功能

前面我们学习了Aop的注解驱动开发及相关源码的解读过程，从本节开始我们以同样的套路来学习声明式事务的注解开发及源码分析过程

声明式事务的环境搭建

• 1.在pom文件中导入相关的依赖

 <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.16</version>
    </dependency>

<dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
        <version>5.2.5.RELEASE</version>
    </dependency>

• 2. 需要配置我们的数据源信息，事务管理器等

@Configuration
@ComponentScan(value = "com.cacmp.bean.tx")
@EnableTransactionManagement
public class TxConfig {

@Bean
public DataSource dataSource(){
    ComboPooledDataSource dataSource = new ComboPooledDataSource();
    dataSource.setUser("root");
    dataSource.setPassword("admin");
    dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/tx?serverTimezone=UTC");
    return dataSource;

}

@Bean
public JdbcTemplate jdbcTemplate(){
    return new JdbcTemplate(dataSource());
}

//配置我们的事务管理器
@Bean
public PlatformTransactionManager transactionManager(){
    return new DataSourceTransactionManager(dataSource());
}

简单的来说下上述我们主要的注解

• @EnableTransactionManagement:表示开启基于注解的事务管理功能

• 3.编写一个方法来测试我们的事务

  • 3.1. Dao的编写

@Repository
public class UserDao {

@Autowired
private JdbcTemplate jdbcTemplate;
public void insert(){
    String sql ="INSERT INTO tx_user (userName,age) VALUES(?,?)";
    String userName = UUID.randomUUID().toString().substring(0,4);
    jdbcTemplate.update(sql,userName,18);
}

• 3.2. service 的编写

@Service
public class UserService {

@Resource
private UserDao userDao;
@Transactional
public void insert(){
    userDao.insert();
    System.out.println("插入成功....");
}

4. 测试代码

//声明式事务的测试
@Test
public void testTx(){
    AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext(TxConfig.class);
    UserService bean = applicationContext.getBean(UserService.class);
    bean.insert();
    applicationContext.close();
}

5 .建立对应的表在数据库中

image.png

现在我们的表中是没有数据的，我们看能否插入记录在表中

image.png

我们插入了两条记录在表中，接下来我们测试下当我们插入出现异常时看能否进行事务回滚，首先来修改下我们的代码：

@Service
public class UserService {

@Resource
private UserDao userDao;
@Transactional
public void insert(){
    userDao.insert();
    System.out.println("插入成功....");
    
    int i = 10 / 0;
}

接着测试，如下图是后台的日志打印

image.png

从截图显示插入成功，同样也报了异常，我们发现数据库中没有新的记录插入，这说明我们自己的事务起作用了，下节我们来分析其原理