spring中@Transactional注解和事务的实战

-- 显式事务示例
BEGIN TRANSACTION;
UPDATE accounts SET balance = balance - 100 WHERE user_id = 1;
UPDATE accounts SET balance = balance + 100 WHERE user_id = 2;
COMMIT; -- 或 ROLLBACK 回滚

-- 事务A
BEGIN TRANSACTION;
UPDATE accounts SET balance = balance - 100 WHERE user_id = 1;
UPDATE accounts SET balance = balance + 100 WHERE user_id = 2;

-- 事务B
BEGIN TRANSACTION;
select balance WHERE user_id = 1 from accounts;
commit;

-- 事务A
ROLLBACK ;--回滚

-- ----------------------
-- 窗口1（事务A）
-- ----------------------
-- 设置隔离级别为读未提交
SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
START TRANSACTION;

-- 修改A账户余额（未提交）
UPDATE account SET balance = 800 WHERE name = 'A账户';
SELECT * FROM account;  -- 查看修改后结果：A账户800

-- ----------------------
-- 窗口2（事务B）
-- ----------------------
-- 设置隔离级别为读未提交
SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
START TRANSACTION;

-- 查询A账户余额（读到未提交的数据）
SELECT * FROM account;  -- 结果：A账户800（脏读）

-- 窗口1（事务A）回滚
ROLLBACK;

-- 窗口2再次查询
SELECT * FROM account;  -- 结果：A账户恢复1000（脏读数据消失）

-- ----------------------
-- 窗口1（事务A）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED;
START TRANSACTION; --设置读已提交的隔离级别

-- 修改A账户余额并提交
UPDATE account SET balance = 800 WHERE name = 'A账户';
COMMIT;  -- 提交事务

-- ----------------------
-- 窗口2（事务B）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED;
START TRANSACTION;

-- 第一次查询（事务A未提交时）
SELECT * FROM account;  -- 结果：A账户1000

-- 此时事务A已提交...

-- 第二次查询（事务A已提交）
SELECT * FROM account;  -- 结果：A账户800（不可重复读）

ROLLBACK;

-- ----------------------
-- 窗口1（事务A）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;
START TRANSACTION;

-- 修改A账户余额并提交
UPDATE account SET balance = 800 WHERE name = 'A账户';
COMMIT;

-- ----------------------
-- 窗口2（事务B）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;
START TRANSACTION;

-- 第一次查询
SELECT * FROM account;  -- 结果：A账户1000

-- 此时事务A已提交...

-- 第二次查询（结果与第一次一致）
SELECT * FROM account;  -- 结果：A账户1000（可重复读）

-- 提交事务B后，才能看到A的修改
COMMIT;
SELECT * FROM account;  -- 结果：A账户800

SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;
START TRANSACTION;

-- 插入新记录
INSERT INTO account(name, balance) VALUES ('C账户', 500);
COMMIT;

SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;
START TRANSACTION;

-- 第一次查询（返回2条记录）
SELECT COUNT(*) FROM account;  

-- 此时事务A插入新记录并提交...

-- 第二次查询（仍返回2条记录）
SELECT COUNT(*) FROM account;  

-- 执行更新操作后再次查询（出现幻读）
UPDATE account SET balance = balance+100 WHERE name = 'A账户';
SELECT COUNT(*) FROM account;  -- 返回3条记录
COMMIT;

-- 事务A
-- ----------------------
-- 窗口1（事务A）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL SERIALIZABLE;
START TRANSACTION;

-- 查询当前数据
SELECT * FROM account;  -- 结果：A账户1000，B账户1000

-- ----------------------
-- 窗口2（事务B）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL SERIALIZABLE;
START TRANSACTION;

-- 插入新数据（会被事务A阻塞，直到A提交或回滚）
INSERT INTO account (name, balance) VALUES ('C账户', 1000);

-- 窗口1提交事务
COMMIT;

-- 窗口2的插入操作继续执行（此时事务A已提交）
-- 提交后，窗口1再次查询会看到新数据（幻读解决）

@Service
public class UserService {
    @Autowired
    private UserRepository userRepository;
    
    @Transactional
    public void createUser(User user) {
        userRepository.save(user);
    }
}

#使用注解时候默认配置如下
@Transactional(
    propagation = Propagation.REQUIRED,
    isolation = Isolation.DEFAULT,
    timeout = -1,
    readOnly = false,
    rollbackFor = {RuntimeException.class, Error.class}
)

@Transactional(
    propagation = Propagation.REQUIRED, --事务传播行为
    isolation = Isolation.DEFAULT, --隔离级别，数据库默认不可重读
    timeout = 30, --定义超时时间，超过自动给回滚
    readOnly = false, --不只读，可修改
    rollbackFor = {SQLException.class}, --遇到异常捕获后必须回滚
    noRollbackFor = {NullPointerException.class} --遇到NullPointerException异常时不回滚事务
)
public void updateUser(User user) {
    // 业务逻辑
}

@Transactional(readOnly = true)
public User getUser(Long id) {
    return userRepository.findById(id);
}

@Transactional  // 失效
private void saveData() {
    // 操作数据库
}

public class OrderService {
    public void createOrder() {
        this.saveOrder();  // 自调用，事务失效
    }
    
    @Transactional
    public void saveOrder() {
        // 保存订单
    }
}

@Transactional
public void update() {
    try {
        jdbcTemplate.update("...");
    } catch (DataAccessException e) {
        // 捕获后未抛出，事务不会回滚
    }
}

@Transactional(rollbackFor = IOException.class)

catch (IOException e) {
   throw new RuntimeException("Wrapped exception", e);
}

CREATE TABLE test (
    id INT PRIMARY KEY
) ENGINE=InnoDB;  // 必须为InnoDB

@SpringBootApplication
// 若手动配置需添加@EnableTransactionManagement
public class App {
    public static void main(String[] args) {
        SpringApplication.run(App.class, args);
    }
}

@Transactional
public final void process() {  // final方法失效
    // 业务逻辑
}