您好,登录后才能下订单哦!
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
本篇文章给大家分享的是有关weed3-5中怎么实现事务和事务队列,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。
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就不写了 }
以上就是weed3-5中怎么实现事务和事务队列,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。