pool.query 不是函数 - 使用 npm mysql 包使用连接池

Question

我正在使用 npm mysql 包，使用 dbHandler.js :

 创建到我的 

mysql

数据库的连接池

var mysql = require("mysql");

var pool = mysql.createPool({
    connectionLimit : 10,
    host: "path.to.host",
    user: "username",
    password: "password",
    database: "dbname",
    debug: false
});

exports.pool = pool;

然后我在内部调用它

routesHandler.js

，来处理我的SQL请求：

var mysql = require("mysql");
var pool = require("./dbHandler");

exports.login = function(req, res) {
    var email = req.body.email;
    pool.query('SELECT * FROM users WHERE users.email = ?', [email], function(
        error,
        results,
        fields
    ) {
        if (error) {
            res.send({
                code: 400,
                failed: "Error ocurred"
            });
        } else {
            if (results.length > 0) {
                //Mail authorized
                res.send({
                    code: 200,
                    success: "Sucessfull login"
                });
            } else {
                //Mail unauthorized
                res.send({
                    code: 403,
                    failed: "Unauthorized mail"
                });
            }
        }
    });
};

我不确定这是最好的方法，但我似乎找不到合适的例子......：/
我很乐意:)接受有关处理整个过程的任何建议或链接:

• 与数据库的连接 +
• 对数据库的 SQL 请求

但是我收到了基本的错误消息，但我不知道如何摆脱它：

类型错误：pool.query 不是函数

欢迎任何指点！

Answer 1

你这样做了

exports.pool = pool;

，所以你必须像这样称呼泳池专有

var pool = require("./dbHandler");

。

如果您在

module.exports=pool

中使用

dbHandler

那么您的代码将按原样工作。

如果不直接使用我的答案：

var pool = require("./dbHandler").pool;

exports.login = function(req, res) {
    var email = req.body.email;
    pool.query('SELECT * FROM users WHERE users.email = ?', [email], function(
        error,
        results,
        fields
    ) {
        if (error) {
            res.send({
                code: 400,
                failed: "Error ocurred"
            });
        } else {
            if (results.length > 0) {
                //Mail authorized
                res.send({
                    code: 200,
                    success: "Sucessfull login"
                });
            } else {
                //Mail unauthorized
                res.send({
                    code: 403,
                    failed: "Unauthorized mail"
                });
            }
        }
    });
};

Answer 2

我遇到了类似的问题，我尝试了大多数可用的解决方案，但没有一个能正常工作，最后，我得到了问题的答案。

dbHandler.js

文件：

var Pool = require('pg').Pool;

var pool = new Pool({
    user: 'postgres',
    host: 'localhost',
    database: 'database_name',
    password: '#############',
    port: 5432,
});


module.exports = {pool};

anotherfile.js

：

let {pool: pool} = require('dbHandler');
// by this calling method I was able to use pool

Answer 3

我认为你必须在这样的函数之前使用

async/await

：

exports.login = async function(req, res) {
    var email = req.body.email;
   await pool.query('SELECT * FROM users WHERE users.email = ?', [email], function(
        error,
        results,
        fields
    ) {
        if (error) {
            res.send({
                code: 400,
                failed: "Error ocurred"
            });
        } else {
            if (results.length > 0) {
                //Mail authorized
                res.send({
                    code: 200,
                    success: "Sucessfull login"
                });
            } else {
                //Mail unauthorized
                res.send({
                    code: 403,
                    failed: "Unauthorized mail"
                });
            }
        }
    });
};

Answer 4

你基本上必须从池中创建一个客户端，调用类似这样的 const { client } = pool();等待 pool.query('SELECT * FROM users WHERE users.email = ?', [email], function( 错误， 结果， 领域 ）{ 如果（错误）{ 发送({ 代码：400， 失败：“发生错误” }); } 别的 { if (结果.长度 > 0) { //邮件授权 发送({ 代码：200， success: “登录成功” }); } 别的 { //邮件未授权 发送({ 代码：403， 失败：“未经授权的邮件” }); } } }); };