This is a Fork of the project https://github.com/pwalczyszyn/express-myconnection

The only difference from the original one is that this module return promises instead of callbacks and additionally this module allows to set 2 different mysql connections for the same express API. This fork was required to support simultaneous connections to 2 different mysql databases (main instance and a read-replica instance), Secondary connection is optional.

Usage

// app.js
...
var mysql = require('mysql'), // node-mysql module
myConnection = require('express-myconnection'), // express-myconnection module

dbOptions = {
  host: 'localhost',
  user: 'dbuser',
  password: 'password',
  port: 3306,
  database: 'mydb'
};
dbOptionsSecondary = {
  host: 'localhost2',
  user: 'dbuser2',
  password: 'password2',
  port: 3306,
  database: 'mydb'
};
  
app.use(myConnection(mysql, 'single', dbOptions, dbOptionsSecondary));
...

express-myconnection extends request object with getConectionAsync and getConectionSecondaryAsync promise functions, this way connection instance can be accessed anywhere in routers during request/response life cycle:

// myroute.js
...
module.exports = function(req, res, next) {
    ...
    req.getConnectionAsync(function(err, connection) {
      if (err) return next(err);
      
      connection.query('SELECT 1 AS RESULT', [], function(err, results) {
        if (err) return next(err);
        
        results[0].RESULT;
        // -> 1
        
        res.send(200);
      });
      
    });
    ...
}
...

// myroute2.js
...
module.exports = function(req, res, next) {
    ...
    req.getConnectionSecondaryAsync(function(err, connection) {
      if (err) return next(err);
      
      connection.query('SELECT 1 AS RESULT', [], function(err, results) {
        if (err) return next(err);
        
        results[0].RESULT;
        // -> 1
        
        res.send(200);
      });
      
    });
    ...
}
...

release connection use req.releaseConnection to manual release a connection // myroute.js ... module.exports = function(req, res, next) { ... req.getConnectionAsync(function(err, connection) { if (err) return next(err); connection.query('SELECT 1 AS RESULT', [], function(err, results) { connection = null; req.releaseConnection(); //manual to release a connection if (err) return next(err); results[0].RESULT; // -> 1 requestUrl(url, function(err, data) { if (err) return next(err); req.getConnection(function(err, connection) { //get a connection again connection.query('SELECT 2 AS RESULT', [], function(err, results) { res.send(200); }); }); }) });

  });
  ...
}
...