NutTxDao的由来

先看看Trans的优缺点

自动事务管理, 一个内部类完全隔离事务实现, 能有效确保事务的完整性,而且很直观.
不支持嵌套事务
手动控制事务比较麻烦

Trans.exec( () -> {
    dao.update(user);
    dao.update(role);
});

NutTxDao试图解决:

嵌套事务及手动控制事务,以增强事务的可控性
借助JDK7+的try-with-resource语法,协助用户确保事务的完整性

    try (NutTxDao tx = new NutTxDao(dao);) {
        tx.beginRC();
        tx.update(user);
        tx.update(role);
        tx.commit();
    } catch (Throwable e) {
        tx.rollback();
        log.debug("tx fail", e);
    } finally {
        tx.close();
    }

用法

NutTxDao 是NutDao的子类,通过复制NutDao的内部状态,并设置DaoRunner实例, 改变原有的事务控制逻辑

一般写法

    // 通过NutDao实例构建一下NutTxDao
    NutTxDao tx = new NutTxDao(dao);
    try {
        // 开启事务, tx.beginRC()开启事务级别为Connection.READ_COMMITTED. 是 tx.begin(Connection.READ_COMMITTED); 的缩写.
        tx.beginRC(); 
        
        tx.update(user);
        tx.update(role);
        
        // 提交事务
        tx.commit();
    } catch (Throwable e) {
        // 回滚事务
        tx.rollback();
        log.debug("tx fail", e);
    } finally {
        // 关闭事务
        tx.close();
    }

结合JDK7+语法

    // 通过NutDao实例构建一下NutTxDao
    try (NutTxDao tx = new NutTxDao(dao);) {
        // 开启事务, tx.beginRC()开启事务级别为Connection.READ_COMMITTED. 是 tx.begin(Connection.READ_COMMITTED); 的缩写.
        tx.beginRC(); 
        
        tx.update(user);
        tx.update(role);
        
        // 提交事务
        tx.commit();
    } catch (Throwable e) {
        // 回滚事务
        tx.rollback();
        log.debug("tx fail", e);
    }

多线程环境

NutTxDao的beginX/commit/rollback/close*不是*线程安全的.

NutTxDao应该以局部变量的形式出现在代码中,而不应该是实例属性或静态属性.

创建NutTxDao自身的成本很低,相对于数据库事务来说微乎其微.

交叉事务

NutTxDao的事务仅依赖于实例本身,与Trans无关,也与其他NutTxDao实例无关.

所以, 你可以同时开始多个事务, 然后按需要调用commit或rollback

NutTxDao tx1 = new NutTxDao(dao);
NutTxDao tx2 = new NutTxDao(dao);
NutTxDao tx3 = new NutTxDao(dao);
try {
    tx1.beiginRC();
    tx2.beiginRC();
    
    // 中间嵌套一个独立的事务3
    tx3.beiginRC();
    tx3.commit();
    
    tx1.commit();
    tx2.commit();
} catch (Throwable e) {
    tx1.rollback();
    tx2.rollback();
    tx3.rollback();
}

调试开关

若对一个NutTxDao的事务行为有疑惑,可以开启其debug开关

NutTxDao tx1 = new NutTxDao(dao).setDebug(true);

本页面的文字允许在知识共享署名-相同方式共享 3.0协议和GNU自由文档许可证下修改和再使用。