• 1NutTxDao的由来
• 2用法
• 3多线程环境
• 4交叉事务
• 5调试开关

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);