粗犷运用
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();
});
});
});
});