因为项目中要用到事务，而且还要保证sql语句的顺序执行，所以有了下面的代码。 也是用了好多种方法，最后决定有下面的，希望能满足你的需求。

// 加载mysql var mysql = require(’./mysqlConn’); // 加载mysql-queues 支持事务 var queues = require(‘mysql-queues’); // 加载async 支持顺序执行 var async = require(‘async’);

var db_tran = function(){ // 获取事务 queues(mysql); var trans = mysql.startTransaction();

async.series([
    function(insert_cb) { 
    	var insert_sql = "INSERT INTO `shop` (`id`, `name`, `address`, `tel`, `fax`, `mail`, `shop_kbn`, `modified_date`, `modified_id`) VALUES ('18', '1212', '1212', '12', '12', '12', '12', '2013-05-28 16:10:15', '0')";
    	// 执行第一条sql语句 如果出错 直接进入最后的 错误方法 回滚事务
    	trans.query(insert_sql, function(err, info) {
    		insert_cb(err, info);
    	})
    	
    },
    function(update_cb_1) { 
    	var update_sql_1 = "UPDATE `shop` SET `address`='管理会社  1' WHERE `id`='17'";
    	
    	// 执行第二条sql语句 如果出错 直接进入最后的 错误方法 回滚事务
    	trans.query(update_sql_1, function(err, info) {
    		update_cb_1(err, info);
    	})
    },
    function(update_cb_2) {
    	var update_sql_2 = "UPDATE `shop` SET `address`='管理会社  2' WHERE `id`='16'";
    	// 执行第三条sql语句 如果出错 直接进入最后的 错误方法 回滚事务
    	trans.query(update_sql_2, function(err, info) {
    		update_cb_2(err, info);
    	})
    	
    }
], function(err, results) {
	if (err) {
		console.log("rollback");
		// 出错的场合 回滚
		trans.rollback();
	} else {
		// 没有错误的场合 提交事务
		trans.commit();
	}
	
});
// 执行这个事务
trans.execute();

}