4.事务

事务

• 使用事务
  • ES6 方式
  • 动态创建类的方式
• transaction 方法
  • ES6 方式
  • 使用动态创建类的方式

模型中提供了对事务操作的支持，但前提需要数据库支持事务。

Mysql 中的 InnoDB 和 BDB 存储引擎支持事务，如果在 Mysql 下使用事务的话，需要将数据库的存储引擎设置为 InnoDB 或 BDB。

SQLite 直接支持事务。

使用事务

模型中提供了 startTrans，commit 和 rollback 3 种方法来操作事务。

• startTrans 开启事务
• commit 正常操作后，提交事务
• rollback 操作异常后进行回滚

ES6 方式

export default class extends think.controller.base {  * indexAction(){    let model = this.model("user");    try{      yield model.startTrans();      let userId = yield model.add({name: "xxx"});      let insertId = yield this.model("user_group").add({user_id: userId, group_id: 1000});      yield model.commit();    }catch(e){      yield model.rollback();    }  }}

动态创建类的方式

module.exports = think.controller({  indexAction: function(self){    var model = this.model("user");    return model.startTrans().then(function(){      return model.add({name: "xxx"});    }).then(function(userId){      return self.model("user_group").add({user_id: userId, group_id: 1000})    }).then(function(){      return self.commit();    }).catch(function(err){      return self.rollback();    });  }})

transaction 方法

使用事务时，要一直使用 startTrans，commit 和 rollback 这 3 个方法进行操作，使用起来有一些不便。为了简化这一操作，模型中提供了 transaction 方法来更加方便的处理事务。

ES6 方式

export default class extends think.controller.base {  * indexAction(self){    let model = this.model("user");    let insertId = yield model.transaction( function * (){      let userId = yield model.add({name: "xxx"});      return yield self.model("user_group").add({user_id: userId, group_id: 1000});    })  }}

注：Arrow Function 无法和 */yield 一起写，所以上面为 function *。如果想使用 Arrow Function，可以使用 async，如： async () => {}。

使用动态创建类的方式

module.exports = think.controller({  indexAction: function(self){    var model = this.model("user");    return model.transaction(function(){      return model.add({name: "xxx"}).then(function(userId){        return self.model("user_group").add({user_id: userId, group_id: 1000});      });    }).then(function(insertId){    }).catch(function(err){    })  }})

---

transaction 接收一个回调函数，这个回调函数中处理真正的逻辑，并需要返回。