Weed3 一个超轻量级ORM框架(只有90kb不到哦)
源码:https://github.com/noear/weed3
之前讲了插入和更新
这次讲事务(写操作总会傍随事务嘛...)
- weed3 支持两种方式的事务
- 1.事务(主要用于单个库)
//demo1:: //事务组 // 在一个事务里,做4个插入//如果出错了,自动回滚
db.tran((t) => {
//以下操作在同一个事务里执行
t.db().sql("insert into test(txt) values(?)", "cc").tran(t).insert();
t.db().sql("insert into test(txt) values(?)", "dd").tran(t).insert();
t.db().sql("insert into test(txt) values(?)", "ee").tran(t).insert();
t.db().sql("update test set txt='1' where id=1").tran(t).insert();
});
- 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").tran(t).execute();
db.sql("insert into test(txt) values(?)", "dd").tran(t).execute();
db.sql("insert into test(txt) values(?)", "ee").tran(t).execute();
});
//数据库2的事务
db2.tran().join(queue).execute((t) => {
db2.sql("insert into test(txt) values(?)", "gg").tran(t).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").tran(t).insert();
t.db().sql("insert into $.test(txt) values(?)", "dd").tran(t).execute();
t.db().sql("insert into $.test(txt) values(?)", "ee").tran(t).execute();
t.result = t.db().sql("select name from $.user_info where user_id=3").tran(t).getValue("");
});
}
public void test2(DbTranQueue queue){
//...test2就不写了
}
网友评论