zoukankan      html  css  js  c++  java
  • Egg.js中使用sequelize事务

    对数据库的操作很多时候需要同时进行几个操作,比如需要同时改动几张表的数据,或者对同一张表中不同行(row)或列(column)做不同操作,比较典型的例子就是用户转账问题(A账户向B账号汇钱):
    1 从A账号中把余额读出来。
    2 对A账号做减法操作。
    3 把结果写回A账号中。
    4 从B账号中把余额读出来。
    5 对B账号做加法操作。
    6 把结果写回B账号中。
    为了数据的一致性,这6件事,要么操作全部成功,要么全部失败回滚。这就是事务的一个特性:原子性。关于事务的四大特性(ACID)这里不做深究。
    项目使用的是 Egg+egg-sequelize 模式,查阅了一下 sequelize 的官方文档,使用方法如下:

    // 受管理的事务(auto-callback)
    return sequelize.transaction(function (t) {
      // 要确保所有的查询链都有return返回
      return User.create({
        firstName: 'Abraham',
        lastName: 'Lincoln'
      }, {transaction: t}).then(function (user) {
        return user.setShooter({
          firstName: 'John',
          lastName: 'Boothe'
        }, {transaction: t});
      });
    }).then(function (result) {
      // Transaction 会自动提交
      // result 是事务回调中使用promise链中执行结果
    }).catch(function (err) {
      // Transaction 会自动回滚
      // err 是事务回调中使用promise链中的异常结果
    });
    
    // 不受管理的事务(then-callback)
    return sequelize.transaction().then(function (t) {
      return User.create({
        firstName: 'Homer',
        lastName: 'Simpson'
      }, {transaction: t}).then(function (user) {
        return user.addSibling({
          firstName: 'Lisa',
          lastName: 'Simpson'
        }, {transaction: t});
      }).then(function () {
        return t.commit();
      }).catch(function (err) {
        return t.rollback();
      });
    });
    

    使用 ES6 的语法如下:

    let transaction;
    try {
      transaction = await this.ctx.model.transaction();
      await this.service.xxx.xxx(parms, transaction);
      await this.service.xxx.xxx(parms1, parms2, transaction);
      await transaction.commit();
    
      return true
    } catch (e) {
      await transaction.rollback();
    
      return false
    }
    
     
    //
    async () => { let t; try { t = await sequelize.transaction({ autocommit: true}); let _user = await User.create({}, {t}); let _userInfo = await UserInfo.create({}, {t}); t.afterCommit((t) => { _user.setUserInfo(_userInfo); // other logic }); } catch (err) { throw err; } }
  • 相关阅读:
    Scars To Your Beautiful
    【BZOJ1833】【ZJOI2010】数字计数(数位DP)
    滑块拼图
    神经元(prufer序列+dp)
    sequence(dp+hash+二分搜索+前缀和优化)
    循环移位(后缀自动机)
    MST(最小生成树+倍增)
    nyoj 845【水】
    分割问题【知识点】
    扩展欧几里得【知识点】
  • 原文地址:https://www.cnblogs.com/zzsdream/p/11270259.html
Copyright © 2011-2022 走看看