事务支持

多条写入一致性

假设两条记录需要一起保存，第二条失败时，第一条也不能留下。下面使用一张空表，id 为主键：

CREATE TABLE user_info (
    id INTEGER PRIMARY KEY,
    name VARCHAR(100)
);

下面两次调用故意使用相同的主键：

import net.hasor.dbvisitor.jdbc.core.JdbcTemplate;

JdbcTemplate jdbc = new JdbcTemplate(dataSource);
jdbc.executeUpdate("INSERT INTO user_info (id, name) VALUES (?, ?)",
        new Object[] { 1001, "Alice" });
jdbc.executeUpdate("INSERT INTO user_info (id, name) VALUES (?, ?)",
        new Object[] { 1001, "Bob" });

未开启事务、连接使用自动提交时，Alice 先插入并提交。随后 Bob 因主键重复而报错，但 Alice 不会自动撤销。

要在失败时全部回滚，重新从空表开始，将两次调用放入事务：

import net.hasor.dbvisitor.transaction.TransactionTemplate;
import net.hasor.dbvisitor.transaction.TransactionTemplateManager;
import net.hasor.dbvisitor.transaction.support.TransactionHelper;

TransactionTemplate tx = new TransactionTemplateManager(
        TransactionHelper.txManager(dataSource));

tx.execute(status -> {
    jdbc.executeUpdate("INSERT INTO user_info (id, name) VALUES (?, ?)",
            new Object[] { 1001, "Alice" });
    jdbc.executeUpdate("INSERT INTO user_info (id, name) VALUES (?, ?)",
            new Object[] { 1001, "Bob" });
    return null;
});

Bob 插入失败后，异常传出回调，Alice 的插入也随之回滚，表中不会留下这两条记录。将第二条的 ID 改为 1002，两次插入成功后一起提交。

注意

jdbc 和事务管理器必须使用同一个 dataSource。不要在回调内捕获异常后直接正常返回；必须捕获时，调用 status.setRollback() 标记回滚。

调用方法需处理或声明 execute 抛出的 Throwable。构造器 API 和 Mapper 也可以参与事务，完整配置见事务模板。

设置隔离级别

H2 可以通过 JDBC 设置标准隔离级别。H2 还提供 SNAPSHOT，但 Isolation 枚举没有对应值，不会自动把它映射为 REPEATABLE_READ。Isolation.DEFAULT 保留当前连接设置。 见数据库隔离级别说明。

例如，在上面的事务模板中用 SERIALIZABLE 执行查询：

import net.hasor.dbvisitor.transaction.Isolation;
import net.hasor.dbvisitor.transaction.Propagation;

tx.execute(status -> {
    return jdbc.queryForList("SELECT id, name FROM user_info");
}, Propagation.REQUIRED, Isolation.SERIALIZABLE);