java中实现事务的两种方式：编程式事务和声明式事务

码农世界 2024-05-13 前端 66 次浏览 0个评论

涉及到与数据库交互就必须会用到事务，如果一个方法中需要用到事务的地方没有使用事务就会造成数据不一致的风险，进而导致比较严重的bug，比如扣款时，账户的余额已经进行了扣减但是相应的订单没有生成，这种涉及账目的问题如果不使用事务进行一致性控制后果会很严重。

在项目开发中，事务又可以分为单体事务和分布式事务，对于分布式系统要实现事务会比较复杂，有时候需要引入第三方系统控制一致性；而传统的单体应用就比较容易实现事务，尤其是使用到spring框架开发项目事务使用会更容易。

使用事务进行编程可以分为声明式事务和编程式事务，声明式事务只需要在需要事务控制的方法上面添加 @Transactional 注解就可以实现事务控制；编程式事务相对代码复杂一些，需要在代码中对异常进行捕获并控制事务的提交或回滚。下面就分别介绍一下如何在项目中使用这两种事务控制：

首先需要做一些准备工作：

引入相关依赖


    org.springframework.boot
    spring-boot-starter-web


    org.springframework.boot
    spring-boot-starter-jdbc


    org.mybatis.spring.boot
    mybatis-spring-boot-starter
    2.1.2


    org.projectlombok
    lombok
    1.18.12
    provided


    mysql
    mysql-connector-java
    5.1.48

在application.yml中添加数据库相关的配置信息：

server:
  port: 8080
  shutdown: graceful
spring:
  application:
    name: test-db
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/test?allowMultiQueries=true&useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
    username: root
    password: 123456%Test
    hikari:
      auto-commit: true
      connection-timeout: 30000
      idle-timeout: 30000
      minimum-idle: 1
      maximum-pool-size: 4
      max-lifetime: 1800000
      connection-test-query: SELECT A FROM T_POOLPING

在数据库中创建表用于测试事务时使用：

-- ----------------------------
-- 学生测试表
-- ----------------------------
CREATE TABLE `student`  (
  `id` int NOT NULL AUTO_INCREMENT,
  `name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  `score` smallint NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;
-- ----------------------------
-- 用户测试表
-- ----------------------------
CREATE TABLE `user`  (
  `id` int NOT NULL AUTO_INCREMENT,
  `name` varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL,
  `age` smallint NULL DEFAULT NULL,
  `sex` tinyint NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;
-- ----------------------------
-- 连接测试表
-- ----------------------------
CREATE TABLE `T_POOLPING`  (
  `A` varchar(2) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL
) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci ROW_FORMAT = Dynamic;

创建两个实体类，分别是学生信息和用户信息：

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
 * @Author xingo
 * @Date 2024/1/30
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class Student {
    private int id;
    private String name;
    private int score;
}

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
 * @Author xingo
 * @Date 2024/1/30
 */
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class User {
    private int id;
    private String name;
    private int age;
    private int sex;
}

定义两个Mapper用于插入学生信息和用户信息：

import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
/**
 * @Author xingo
 * @Date 2024/1/30
 */
@Mapper
public interface StudentMapper {
    @Insert("insert into student(name, score) values(#{name}, #{score})")
    boolean insertStudent(Student student);
}

import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Mapper;
/**
 * @Author xingo
 * @Date 2024/1/30
 */
@Mapper
public interface UserMapper {
    @Insert("insert into user(name, age, sex) values(#{name}, #{age}, #{sex})")
    boolean insertUser(User user);
}

以上准备工作完成后演示几种事务的使用：

一、声明式事务

声明式事务使用比较简单，在需要事务控制的方法上面添加 @Transactional 注解就可以实现事务控制，在spring中事务控制是通过aop实现的，所以调用方法必须要通过代理请求才能实现事务控制，并且方法内的异常一定要抛出不能在方法内捕获，否则就不能实现事务控制。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
/**
 * @Author xingo
 * @Date 2024/1/30
 */
@RestController
public class DbController {
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private StudentMapper studentMapper;
    @Transactional(rollbackFor = Exception.class)
    @GetMapping("/db/test1")
    public String testdb1(int num) {
        Student student = Student.builder().id(1).name("张三").score(100).build();
        User user = User.builder().id(1).name("张三").age(11).sex(1).build();
        userMapper.insertUser(user);
        System.out.println(1 / num);
        studentMapper.insertStudent(student);
        return "ok";
    }
}

声明式事务使用非常方便，基本不需要额外的代码控制事务，但是它的控制粒度比较大，需要在方法上面进行控制，如果方法内部有比较耗时的操作将会导致事务不能提交，这会给数据库造成比较大的压力。要想让事务控制范围比较小的场景，就需要使用编程式事务实现：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.function.Consumer;
/**
 * @Author xingo
 * @Date 2024/1/30
 */
@RestController
public class DbController {
    @Autowired
    private TransactionTemplate transactionTemplate;
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private StudentMapper studentMapper;
    @GetMapping("/db/test2")
    public String testdb2(int num) {
        Student student = Student.builder().id(1).name("张三").score(100).build();
        User user = User.builder().id(1).name("张三").age(11).sex(1).build();
        // 有返回值的编程式事务
        transactionTemplate.execute(new TransactionCallback