粗暴使用

var mysql = require('mysql');
//创建连接
var connection = mysql.createConnection(this.sails.config.connections.myApp);
connection.connect(function(err) {
  if(err){ return next(err); }
});
//外面也可以嵌套for循环
connection.beginTransaction(function(err) {
    //可以嵌套多层，看你心情
    connection.query(sql1, function(err, result) {
        if(err){
            //回滚事务
            connection.rollback(function() { if(err){ return next(err); } });
        }
        connection.query(sql2, function(err, result) {
            if(err){
                connection.rollback(function() { if(err){ return next(err); } });
            }
            //提交事务
            connection.commit(function(err) {
                if(err){
                    connection.rollback(function() { if(err){ return next(err); } });
                }
                //关闭连接
                connection.end();
            });
        });
    });
});