domain.js

var EE = require('events').EventEmitter;
var domain = require('domain');

var mysql = require('mysql');
var pool = mysql.createPool({
	host: '127.0.0.1',
	port: 3306,
	database: 'test',
	user: 'localuser',
	password: 'localpass',
});


pool.getConnection(function(err, connection) {
	connection.end();


	AND_HERE_WE_GO(new EE, new EE);
});

function AND_HERE_WE_GO(req, res) {

	var requestDomain = domain.create();

	requestDomain.on("error", function(err) {
		console.log("DOMAIN: %s", err);
	});

	requestDomain.add(req);
	requestDomain.add(res);

	requestDomain.run(function() {

		pool.getConnection(function(err, connection) {
			// connected! (unless `err` is set)
			connection.query('SELECT 1', req.domain.intercept(function(rows) {
				throw new Error("BOOM!")
			}));
		});
	})

}