sequelize事务处理问题

问答

Iiori2882发布于 8 年前最后回复 8 年前

1056570

目前需求是同时添加2条数据库记录,这2个记录分别添加到A数据库表和B数据库表中我的A数据库表:

我的B数据库表:

我在网上查到如下的代码:

我的代码像下面这么写,为什么添加的是正确数据他直接回滚了啊?麻烦大家了~~~~~

代码开始:不知道为什么前2行不自动识别为代码

sequelize.transaction(function (t) { return BoxInfoController.addInfo(function (a,result) {

    }, {transaction:t})
        .then(function(){
            return BoxInfoController.addOa(function (a,result) {}, {transaction:t})
        });
}).then(function (results){
    /* 操作成功，事务会自动提交 */
}).catch(function(err){
    /* 操作失败，事件会自动回滚 */
});

查看回复

iori2882#108 年前

谢谢大家的回复~

zhangshiqiu#98 年前

或者是用promise写

linliny#88 年前

用async/await，大概这样写： sequelize.transaction(async t => { await BoxInfoModel.create(addBoxInfo, { transaction: t }) await BoxOaModel.create(addBoxInfo, { transaction: t }) })

可以自己加try catch

MUHM#78 年前

引用 iori2882@MUHM 十分感谢,我现在也是,一在node.js里写for循环套数据库操作我就抓狂

@iori2882 把node升级了用async/await 吧

iori2882#68 年前

引用 MUHM现在看到回调就头大，不知道是不是应该这么写然后执行

@MUHM 十分感谢,我现在也是,一在node.js里写for循环套数据库操作我就抓狂

MUHM#58 年前

现在看到回调就头大，不知道是不是应该这么写

add: function(addBoxInfo, callback) {
  return _dbManage.transaction(function (t) {
    return BoxInfoModel.create(addBoxInfo, { transaction: t })
      .then(function (boxInfo) {
        return BoxOaModel.create(addBoxInfo, { transaction: t })
          .then(function (boxOa) {
            return 'result'; //这里自己写需要的数据
          });
      });
  }).then(function (result) {
    callback(null, result);
  }).catch(function (err) {
    callback(err);
  });
}

然后执行

BoxInfoController.add(addBoxInfo,function(err,result){
	//
});

iori2882#48 年前

引用 axetroy楼上正解。两个函数你分别用了两个事物。同一逻辑下，应该用同一个事物包裹来自酷炫的 CNodeMD

@axetroy 你的意思是我把2个函数里的事物处理都去掉么?还是把2个方法合并成一个方法啊?我不是特别懂啊?麻烦帮我解惑下谢谢

iori2882#38 年前

引用 MUHM............ ............ 看写法好像BoxInfoController.addInfo()和addOa()中单独开了事务而已比较好奇你执行的时候callback是...

@MUHM 不好意思,我这其实还不能很好的理解回调函数,你的意思是我把2个函数里的事物处理都去掉么?还是把2个方法合并成一个方法啊?

axetroy#28 年前

楼上正解。

两个函数你分别用了两个事物。

同一逻辑下，应该用同一个事物包裹

来自酷炫的 CNodeMD

MUHM#18 年前

............ ............ 看写法好像BoxInfoController.addInfo()和addOa()中单独开了事务而已比较好奇你执行的时候callback是什么了....

参与回复

登录后即可参与回复。登录

sequelize事务处理问题

回复 (10)

参与回复