mysql - 如何正确使用 ExpressJs + MySQL

Question

PS:问题可能看起来很长，但下面有一些小问题。

所以我是少数不幸的人之一，他们不得不将 MySQL 与 Express 一起使用，只是因为它有意义。这将用作 API 后端。我使用其网站上的生成器( https://expressjs.com/en/starter/generator.html )生成了一个 Express 应用程序，并从 mysqljs 安装了 mysql( https://github.com/mysqljs/mysql )。

现在所有 Express 的示例都以 MongoDb 为例，它们只是使用包装器。 mysqljs 的例子也没有告诉你太多信息。这是我的项目结构，其中有一些特殊问题。

bin - auto generated files to start the app
config
models (Maybe have a base model which can talk to db wrapper and other models can extend that)
routes
.... index.js
.... users.js etc etc (each included in the app.js to have some sort of structure)
utils
.... db.js (check code below)
app.js
package.json

现在这就是我的 db.js 中的内容

var mysql = require('mysql');

var pool = mysql.createPool({
    connectionLimit : 100,
    host: 'localhost',
    user: 'root',
    password: 'notsoblank',
    database: 'somedevdb'
});

module.exports = pool;

在我的路由文件(如 users.js、index.js)中，我将其用作:

var express = require('express');
var router = express.Router();
var db = require('../utils/db');
/* GET groups listing. */
router.get('/', function(req, res, next) {
    db.getConnection(function(err, connection) {
        var sql = 'SELECT * from groups';
        connection.query(sql, function(err, rows, fields) {
            if (err) throw err;
            res.json(rows);
        });
        connection.release();
    });
});

module.exports = router;

然后在 app.js 中，上面的文件将像这样包含在内:

var express = require('express');
var path = require('path');
var logger = require('morgan');

var app = express();

var routes = require('./routes/index');
var users = require('./routes/users');
var groups = require('./routes/groups');

app.use('/apis/groups', groups);

module.exports = app;

现在，如果我正在运行此应用程序，我将拥有一个像 localhost:5000\apis\groups 这样的 API 端点，并且其他应用程序可以使用它。

这是我基于此的问题:

1. 我正在每个路由文件(index.js、users.js、groups.js)中导入 db.js。这是否意味着每次我们访问 api 时都会创建一个数据库池？

2. 我将为我的工作编写大量简单的 sql。现在我知道有很多适配器或 OEM，但我只想编写一个简单的包装器，其中包含 getOne 或添加或删除等方法。最好的方法是什么。

3. Connection.query 返回一个 promise 。如果我想做一些进一步的操作，最好的方法是什么。

除了将数据库凭据保留在 db.js 中之外，这种方法还有其他问题可能会阻止其扩展吗？

Answer 1

如果您只是想做某种有助于减少代码膨胀的数据库帮助程序模块(尽管我再次觉得这是通过 ORM 解决的问题)，那么这是非常简单的事情。只需公开您想要的任何功能并隐藏重复的内容即可。像这样的事情会起作用:

//db.js 而不仅仅是公开池

var mysql = require('mysql');

// expose the options so that the calling code can inject the password and so on, probably from config or process.env variables.
function db(options){
  // todo: sanitize options and set defaults
  var pool = mysql.createPool(options);

  return {
     query : function(sql, callback){
       db.getConnection(function(err, connection) {
        connection.query(sql, function(err, rows, fields) {
            callback(err, rows, fields);
            connection.release();
        });
       });
     }

  }

}


module.exports = db;

调用代码会执行以下操作:

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

db.query('select * from groups', console.log);

顺便说一句，您的原始代码有一些问题。

1) 您在回调中调用 connection.release() 来获取连接，而不是返回查询。对于缓慢的数据库查询，可能会导致在使用完连接之前释放连接。

2)除非您使用 Promises，否则您不应该在回调中“抛出”错误，您必须以某种方式处理它或将其传递给下一个回调(如果它们是一个)。