weed3 5.事务和事务队列 - noear/weed3 GitHub Wiki
Weed3 一个微型ORM框架（只有0.1Mb哦）
源码：https://github.com/noear/weed3 源码：https://gitee.com/noear/weed3
之前讲过插入和更新
这次讲事务（写操作总会傍随事务嘛...）
- weed3 支持两种方式的事务
- 1.事务（主要用于单个库）
//demo1:: //事务组 // 在一个事务里，做4个插入//如果出错了，自动回滚
DbUserApi dbUserApi = XmlSqlProxy.getSingleton(DbUserApi.class);
db.tran((t) -> {
//
// 此表达式内的操作，会自动加入事务
//
//sql接口
db.sql("insert into test(txt) values(?)", "cc").insert();
db.sql("update test set txt='1' where id=1").execute();
//call接口
db.call("user_del").set("_user_id",10).execute();
//table()接口
db.table("a_config").set("cfg_id",1).insert();
//xml mapper
dbUserApi.user_add(12);
//大家使用统一的事务模式
});
- 2.事务队列（主要用于多个库的情况）
//demo2:: //事务队列
//
//假如，要跨两个数据库操作（一个事务对象没法用了）
//
DbContext db = DbConfig.pc_user;
DbContext db2 = DbConfig.pc_base;
//创建个事务队列（和传统概念的队列不一样）
DbTranQueue queue = new DbTranQueue();
//数据库1的事务
db.tran().join(queue).execute((t) => {
//
// 在这个表达示内，会自动加入事物
//
db.sql("insert into test(txt) values(?)", "cc").execute();
db.sql("insert into test(txt) values(?)", "dd").execute();
db.sql("insert into test(txt) values(?)", "ee").execute();
});
//数据库2的事务
db2.tran().join(queue).execute((t) => {
//
// 在这个表达示内，会自动加入事物
//
db2.sql("insert into test(txt) values(?)", "gg").execute();
});
//队列结组完成（即开始跑事务）
queue.complete();
- 3.事务队列的加强版，跨函数或模块跑事务
public void test_main(){
DbTranQueue queue = new DbTranQueue();
test1(queue);
test2(queue);
}
public void test1(DbTranQueue queue){
DbTran tran = DbConfig.db1.tran();//生成个事务对象
tran.join(queue).execute((t) -> {
//
// 在这个表达示内，会自动加入事物
//
t.db().sql("insert into $.test(txt) values(?)", "cc").insert();
t.db().sql("insert into $.test(txt) values(?)", "dd").execute();
t.db().sql("insert into $.test(txt) values(?)", "ee").execute();
t.result = t.db().sql("select name from $.user_info where user_id=3").getValue("");
});
}
public void test2(DbTranQueue queue){
//...test2就不写了
}