【第16章】spring-tx基于注解的声明式事务

前言

Spring-tx是Spring框架提供的事务管理模块，它为DB事务管理提供了一种便捷的接入方式。它允许应用程序开发人员在任何环境中使用一致的编程模型，通过编程事务管理或声明式事务管理来简化事务处理的复杂性。

编程事务管理允许开发人员使用Spring框架的事务抽象，该抽象可以运行在任何底层事务基础设施上。而声明式事务管理则是一种更为简洁的方式，开发人员通常很少或不编写与事务管理相关的代码，因此不依赖于Spring Framework事务API或任何其他事务API。

Spring-tx对用户提供统一的声明式事务、编程式事务解决方案，对事务的入口、定义、传播、提交、回滚进行了封装，与业务代码隔离。它抽象出事务操作PlatformTransactionManager顶级接口，通过将连接及其他需要同步的资源交由事务同步管理器（TransactionSynchronizationManager->ThreadLocal）管理。

事务的特性包括原子性（Atomicity）、一致性（Consistency）、隔离性（Isolation）和持久性（Durability）。原子性指的是事务中的所有操作要么全部完成，要么全部不完成；一致性确保在事务开始和结束时，数据库的完整性限制没有被破坏；隔离性确保两个事务的执行互不干扰；持久性保证事务完成后对数据库的更改被持久保存。

总的来说，Spring-tx通过简化和统一事务管理的方式，使开发人员能够更专注于业务逻辑的实现，而无需过多关注底层的事务处理细节。

一、准备

1. 数据库

create table user(
	id int primary key auto_increment,
	name varchar(255),
	age int,
	address varchar(255)
)charset utf8;
INSERT INTO `test`.`user`(`id`, `name`, `age`, `address`) VALUES (1, '张三', 22, '北京');
INSERT INTO `test`.`user`(`id`, `name`, `age`, `address`) VALUES (2, '李四', 23, '邯郸');

二、后台代码

业务描述：有一个需求,用户编号销户则编号释放,将原账户编号注册为新用户(一个删,一个增)

1. 业务类

1.1 controller

package org.example.tx.annotation.controller;

import org.example.tx.annotation.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;

/**
 * Create by zjg on 2024/4/14
 */
@Controller
public class UserController {
    @Autowired
    UserService userService;
    public boolean destory(int id){
       return userService.destory(id);
    }
}

1.2 service

1.2.1 service

package org.example.tx.annotation.service;

/**
 * Create by zjg on 2024/4/14
 */
public interface UserService {
    public boolean destory(int id);
}

1.2.2 impl

package org.example.tx.annotation.service.impl;

import org.example.tx.annotation.dao.UserDao;
import org.example.tx.annotation.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/**
 * Create by zjg on 2024/4/14
 */
@Service
public class UserServiceImpl implements UserService {
    @Autowired
    UserDao userDao;
    @Transactional
    @Override
    public boolean destory(int id){
        int delete = userDao.delete(id);
//        int i=1/0;
        int add = userDao.add(id);
        if(delete==1&&add==1){
            return true;
        }
        return false;
    }
}

1.3 dao

1.3.1 dao

package org.example.tx.annotation.dao;

/**
 * Create by zjg on 2024/4/14
 */
public interface UserDao {
    public int delete(int id);
    public int add(int id);
}

1.3.2 impl

package org.example.tx.annotation.dao.impl;

import org.example.tx.annotation.dao.UserDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

/**
 * Create by zjg on 2024/4/14
 */
@Repository
public class UserDaoImpl implements UserDao {
    @Autowired
    JdbcTemplate jdbcTemplate;
    @Override
    public int delete(int id) {
        String sql="delete from user where id=?";
        return jdbcTemplate.update(sql, id);
    }

    @Override
    public int add(int id) {
        String sql="insert into user value(?,?,?,?)";
        return jdbcTemplate.update(sql, id, "张三", 30, "石家庄");
    }
}

2.配置类

2.1 jdbc.properties

jdbc_driverClassName=com.mysql.cj.jdbc.Driver
jdbc_url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true
jdbc_username=root
jdbc_password=123456a?

2.2 SpringConfig

package org.example.tx.annotation.config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

/**
 * Create by zjg on 2024/4/14
 */
@Configuration
@ComponentScan("org.example.tx.annotation")
@EnableTransactionManagement
@PropertySource("classpath:jdbc.properties")
public class SpringConfig {
    @Value("${jdbc_driverClassName}")
    private String driverClassName;

    @Value("${jdbc_url}")
    private String url;

    @Value("${jdbc_username}")
    private String username;

    @Value("${jdbc_password}")
    private String password;
    @Bean
    public DruidDataSource dataSource(){
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName(driverClassName);
        dataSource.setUrl(url);
        dataSource.setUsername(username);
        dataSource.setPassword(password);
        return dataSource;
    }
    @Bean
    public JdbcTemplate jdbcTemplate(DruidDataSource dataSource){
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        jdbcTemplate.setDataSource(dataSource);
        return jdbcTemplate;
    }
    @Bean
    public DataSourceTransactionManager transactionManager(DruidDataSource dataSource){
        DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource);
        return transactionManager;
    }
}

2.3 SpringApplication

package org.example.tx.annotation;

import org.example.tx.annotation.config.SpringConfig;
import org.example.tx.annotation.controller.UserController;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

/**
 * Create by zjg on 2024/4/14
 */
public class SpringApplication {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext acac = new AnnotationConfigApplicationContext(SpringConfig.class);
        UserController userController = acac.getBean("userController", UserController.class);
        userController.destory(1);
    }
}

三、扩展

1. 特性

2. 隔离级别

3. 传播行为

总结

回到顶部