async.auto({
  transaction: function(next){
    User.query(‘BEGIN‘, next);
  },
  user: [‘transaction‘, function(next) {
    User.findOne(req.param(‘id‘)).exec(next);
  }],
  // other queries in the transaction
  // ...}, function(err, results) {
  if (err) {
    User.query(‘ROLLBACK‘, next);
    return next(err);
  }
  User.query(‘COMMIT‘, next);
  // final tasks
  res.json(results.serialize);});

其中上述代码中User是model

更多async用法可以参考其官网github页

sailsjs nodejs mysql 事务操作回滚