我想使用 node-mssql作为 Node JS Express 4 Web 应用程序中的 MSSQL 数据库连接器。路由处理程序逻辑在单独的文件中处理。

如何创建单个/全局连接池并在处理路由逻辑的多个文件中使用它？我不想在每个路由处理函数/文件中创建一个新的连接池。

最佳答案

我问和回答这个问题已经 3 年了。从那以后，一些事情发生了变化。这是我今天建议的基于 ES6、mssql 4 和 Express 4 的新解决方案。

这里有两个关键因素。

1. Modules are cached第一次加载后。这意味着每次调用 require('./db') 都会返回完全相同的对象。 db.js 的第一个要求将运行该文件并创建 promise 并将其导出。 db.js 的第二个要求将在不运行文件的情况下返回相同的 promise 。正是这个 promise 将与池一起解决。
2. 一个promise 可以被再次验证。如果它之前解决了，它会立即再次解决它第一次解决的任何问题，即池。

在 server.js

const express = require('express')
// require route handlers.
// they will all include the same connection pool
const set1Router = require('./routes/set1')
const set2Router = require('./routes/set2')

// generic express stuff
const app = express()

// ...
app.use('/set1', set1Router)
app.use('/set2', set2Router)

// No need to connect the pool
// Just start the web server

const server = app.listen(process.env.PORT || 3000, () => {
  const host = server.address().address
  const port = server.address().port

  console.log(`Example app listening at http://${host}:${port}`)
})

在 db.js

const sql = require('mssql')
const config = {/*...*/}

const poolPromise = new sql.ConnectionPool(config)
  .connect()
  .then(pool => {
    console.log('Connected to MSSQL')
    return pool
  })
  .catch(err => console.log('Database Connection Failed! Bad Config: ', err))

module.exports = {
  sql, poolPromise
}

在 routes/set1.js 和 routes/set2.js

const express = require('express')
const router = express.Router()
const { poolPromise } = require('./db')

router.get('/', async (req, res) => {
  try {
    const pool = await poolPromise
    const result = await pool.request()
        .input('input_parameter', sql.Int, req.query.input_parameter)
        .query('select * from mytable where id = @input_parameter')      

    res.json(result.recordset)
  } catch (err) {
    res.status(500)
    res.send(err.message)
  }
})

module.exports = router

总结

由于模块缓存，您将始终获得相同的 promise ，并且该 promise 将一次又一次地与第一次解决的池一起解决。因此每个路由器文件使用相同的池。

顺便说一句:有更简单的方法可以在我不会在这个答案中介绍的快速 route 进行 try catch。在这里阅读:https://medium.com/@Abazhenov/using-async-await-in-express-with-node-8-b8af872c0016

旧的解决方案

这是我 3 年前发布的解决方案，因为我相信我有一个值得分享的答案，而且我在其他地方找不到记录在案的解决方案。在 node-mssql 的几个问题(#118、#164、#165)中也讨论了这个主题。

在 server.js

var express = require('express');
var sql     = require('mssql');
var config  = {/*...*/};
//instantiate a connection pool
var cp      = new sql.Connection(config); //cp = connection pool
//require route handlers and use the same connection pool everywhere
var set1    = require('./routes/set1')(cp);
var set2    = require('./routes/set2')(cp);

//generic express stuff
var app = express();

//...
app.get('/path1', set1.get);
app.get('/path2', set2.get);

//connect the pool and start the web server when done
cp.connect().then(function() {
  console.log('Connection pool open for duty');

  var server = app.listen(3000, function () {

    var host = server.address().address;
    var port = server.address().port;

    console.log('Example app listening at http://%s:%s', host, port);

  });
}).catch(function(err) {
  console.error('Error creating connection pool', err);
});

在 routes/set1.js

var sql     = require('mssql');

module.exports = function(cp) {
  var me = {
    get: function(req, res, next) {
      var request = new sql.Request(cp);
      request.query('select * from test', function(err, recordset) {
        if (err) {
          console.error(err);
          res.status(500).send(err.message);
          return;
        }
        res.status(200).json(recordset);
      });
    }
  };

  return me;
};

关于sql-server - 如何在 Express 4 Web 应用程序中跨多个路由使用单个 mssql 连接池？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30356148/