-- 顯式事務(wù)示例
BEGIN TRANSACTION;
UPDATE accounts SET balance = balance - 100 WHERE user_id = 1;
UPDATE accounts SET balance = balance + 100 WHERE user_id = 2;
COMMIT; -- 或 ROLLBACK 回滾

-- 事務(wù)A
BEGIN TRANSACTION;
UPDATE accounts SET balance = balance - 100 WHERE user_id = 1;
UPDATE accounts SET balance = balance + 100 WHERE user_id = 2;

-- 事務(wù)B
BEGIN TRANSACTION;
select balance WHERE user_id = 1 from accounts;
commit;

-- 事務(wù)A
ROLLBACK ;--回滾

-- ----------------------
-- 窗口1（事務(wù)A）
-- ----------------------
-- 設(shè)置隔離級別為讀未提交
SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
START TRANSACTION;

-- 修改A賬戶余額（未提交）
UPDATE account SET balance = 800 WHERE name = 'A賬戶';
SELECT * FROM account;  -- 查看修改后結(jié)果：A賬戶800

-- ----------------------
-- 窗口2（事務(wù)B）
-- ----------------------
-- 設(shè)置隔離級別為讀未提交
SET SESSION TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;
START TRANSACTION;

-- 查詢A賬戶余額（讀到未提交的數(shù)據(jù)）
SELECT * FROM account;  -- 結(jié)果：A賬戶800（臟讀）

-- 窗口1（事務(wù)A）回滾
ROLLBACK;

-- 窗口2再次查詢
SELECT * FROM account;  -- 結(jié)果：A賬戶恢復(fù)1000（臟讀數(shù)據(jù)消失）

-- ----------------------
-- 窗口1（事務(wù)A）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED;
START TRANSACTION; --設(shè)置讀已提交的隔離級別

-- 修改A賬戶余額并提交
UPDATE account SET balance = 800 WHERE name = 'A賬戶';
COMMIT;  -- 提交事務(wù)

-- ----------------------
-- 窗口2（事務(wù)B）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED;
START TRANSACTION;

-- 第一次查詢（事務(wù)A未提交時）
SELECT * FROM account;  -- 結(jié)果：A賬戶1000

-- 此時事務(wù)A已提交...

-- 第二次查詢（事務(wù)A已提交）
SELECT * FROM account;  -- 結(jié)果：A賬戶800（不可重復(fù)讀）

ROLLBACK;

-- ----------------------
-- 窗口1（事務(wù)A）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;
START TRANSACTION;

-- 修改A賬戶余額并提交
UPDATE account SET balance = 800 WHERE name = 'A賬戶';
COMMIT;

-- ----------------------
-- 窗口2（事務(wù)B）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;
START TRANSACTION;

-- 第一次查詢
SELECT * FROM account;  -- 結(jié)果：A賬戶1000

-- 此時事務(wù)A已提交...

-- 第二次查詢（結(jié)果與第一次一致）
SELECT * FROM account;  -- 結(jié)果：A賬戶1000（可重復(fù)讀）

-- 提交事務(wù)B后，才能看到A的修改
COMMIT;
SELECT * FROM account;  -- 結(jié)果：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;  

-- 此時事務(wù)A插入新記錄并提交...

-- 第二次查詢（仍返回2條記錄）
SELECT COUNT(*) FROM account;  

-- 執(zhí)行更新操作后再次查詢（出現(xiàn)幻讀）
UPDATE account SET balance = balance+100 WHERE name = 'A賬戶';
SELECT COUNT(*) FROM account;  -- 返回3條記錄
COMMIT;

-- 事務(wù)A
-- ----------------------
-- 窗口1（事務(wù)A）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL SERIALIZABLE;
START TRANSACTION;

-- 查詢當(dāng)前數(shù)據(jù)
SELECT * FROM account;  -- 結(jié)果：A賬戶1000，B賬戶1000

-- ----------------------
-- 窗口2（事務(wù)B）
-- ----------------------
SET SESSION TRANSACTION ISOLATION LEVEL SERIALIZABLE;
START TRANSACTION;

-- 插入新數(shù)據(jù)（會被事務(wù)A阻塞，直到A提交或回滾）
INSERT INTO account (name, balance) VALUES ('C賬戶', 1000);

-- 窗口1提交事務(wù)
COMMIT;

-- 窗口2的插入操作繼續(xù)執(zhí)行（此時事務(wù)A已提交）
-- 提交后，窗口1再次查詢會看到新數(shù)據(jù)（幻讀解決）

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

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

@Transactional(
    propagation = Propagation.REQUIRED, --事務(wù)傳播行為
    isolation = Isolation.DEFAULT, --隔離級別，數(shù)據(jù)庫默認(rèn)不可重讀
    timeout = 30, --定義超時時間，超過自動給回滾
    readOnly = false, --不只讀，可修改
    rollbackFor = {SQLException.class}, --遇到異常捕獲后必須回滾
    noRollbackFor = {NullPointerException.class} --遇到NullPointerException異常時不回滾事務(wù)
)
public void updateUser(User user) {
    // 業(yè)務(wù)邏輯
}

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

@Transactional  // 失效
private void saveData() {
    // 操作數(shù)據(jù)庫
}

public class OrderService {
    public void createOrder() {
        this.saveOrder();  // 自調(diào)用，事務(wù)失效
    }
    
    @Transactional
    public void saveOrder() {
        // 保存訂單
    }
}

@Transactional
public void update() {
    try {
        jdbcTemplate.update("...");
    } catch (DataAccessException e) {
        // 捕獲后未拋出，事務(wù)不會回滾
    }
}

@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方法失效
    // 業(yè)務(wù)邏輯
}