如何使用express.js正确地将mysql连接传递给路由

Question

我正在尝试找出在我的express.js路由之间传递mysql连接（使用node-
mysql）的最佳方法。我正在动态添加每个路由（在路由中为每个文件循环使用），这意味着我不能只是将连接传递给需要它的路由。我要么需要将其传递到每条路线，要么根本不需要传递。我不喜欢将其传递给不需要它的想法，因此我创建了一个dbConnection.js，可以根据需要单独导入路由。问题是我认为我做的不正确。到目前为止，我的dbConnection.js包含：

var mysql = require('mysql');
var db = null;
module.exports = function () {
    if(!db) {
            db = mysql.createConnection({
                socketPath: '/tmp/mysql.sock',
            user: '*********',
            password: '*********',
            database: '**********'
        });
    }
    return db;
};

我正在使用以下命令将其导入每个路由：

var db = require('../dbConnection.js');
var connection = new db();

但我想这样做：

var connection = require('../dbConnection.js');

但是，当我这样尝试时，我收到一条错误消息，当我尝试进行查询时，连接没有方法“ query”。

Answer 1

我发现使用node-mysql的池对象更可靠。这是我设置我的方法。我使用环境变量获取数据库信息。将其保留在回购之外。

database.js

var mysql = require('mysql');

var pool = mysql.createPool({
  host: process.env.MYSQL_HOST,
  user: process.env.MYSQL_USER,
  password: process.env.MYSQL_PASS,
  database: process.env.MYSQL_DB,
  connectionLimit: 10,
  supportBigNumbers: true
});

// Get records from a city
exports.getRecords = function(city, callback) {
  var sql = "SELECT name FROM users WHERE city=?";
  // get a connection from the pool
  pool.getConnection(function(err, connection) {
    if(err) { console.log(err); callback(true); return; }
    // make the query
    connection.query(sql, [city], function(err, results) {
      connection.release();
      if(err) { console.log(err); callback(true); return; }
      callback(false, results);
    });
  });
};

路线

var db = require('../database');

exports.GET = function(req, res) {
  db.getRecords("San Francisco", function(err, results) {
    if(err) { res.send(500,"Server Error"); return;
    // Respond with results as JSON
    res.send(results);
  });
};