util_transcation.js

var $ = require('jquery-deferred');

function transaction(conn, callback) {
    var d = $.Deferred();
    d.done(function() {
        conn.query('COMMIT');
    }).fail(function() {
        conn.query('ROLLBACK');
    });
    conn.query('START TRANSACTION', function() {
        callback.apply({
            rollback: function() { d.reject.apply(d, arguments);  },
            commit  : function() { d.resolve.apply(d, arguments); }
        });
    });      
    return d.promise();
}

exports.transaction = transaction;