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