node-postgres不执行client.query()？

Question

我有一个用于在Node.JS中运行PostgreSQL查询的模块database.js，如下所示：

const {Client}=require('pg');

const pgclient=new Client({
    connectionString:process.env.DATABASE_URL,
    ssl:true
});

pgclient.connect();

module.exports={

    getUser:function(phonenumber){
        queryStr='SELECT * FROM users where phonenumber=\''+phonenumber+'\';';
        console.log(queryStr);
        pgclient.query(queryStr, (err, res) => {
            console.log("rows length "+res.rows.length);
            if (err) throw err;
            if (res.rows.length==0){
                return null;
            }
            else{
                return res.rows[0];
            }           
        });
    }
}

当我调用它时，使用例如

var db=require('./database');
userObj=db.getUser('+19991112222');
if (userObj==null){
    console.log("user not found");
}
else{
    console.log(userObj["phonenumber"]);
}

然后，我得到以下控制台日志：

SELECT * FROM users where phonenumber='+19991112222';
user not found

因为rows length行没有出现在控制台日志中，所以我认为要么是pgclient.query()调用没有执行，要么是它立即以静默方式失败，并在执行(err, res) => {}函数中的任何行之前返回null。如何才能让查询真正运行？

编辑:我认为当调用getUser时，pgclient.connect()还没有建立数据库连接，所以pgclient.query()正在静默地失败。当我将所有连接代码和getUser移到包含我的测试过程的同一文件中时，它成功运行了。因此，我需要做的是弄清楚在导出的函数可用于测试过程之前，如何在模块中建立连接。

Answer 1

您不能将异步函数的结果赋给变量，就像您在下面的代码行中所做的那样：

userObj=db.getUser('+19991112222');

你必须在回调中赋值。

所以，可以这样做：

module.exports={

    // I am passing a callback function which takes error as first argument and data as second
    getUser:function(phonenumber, callback){
        queryStr='SELECT * FROM users where phonenumber=\''+phonenumber+'\';';
        console.log(queryStr);
        pgclient.query(queryStr, (err, res) => {
            console.log("rows length "+res.rows.length);
            if (err) return callback(err);
            if (res.rows.length==0){
                return callback(null, null);
            }
            else{
                return callback(null, res.rows[0]);
            }           
        });
    }
}

然后你可以像这样使用它：

var db=require('./database');
// Here I'm passing the function which is the callback and I handle the error and user in this function.
db.getUser('+19991112222', function(err, user) {
    if (err) throw err;
    if (user==null){
        console.log("user not found");
    }
    else {
        console.log(userObj["phonenumber"]);
    }
});

你也可以使用promises，它做同样的事情，但是有更多的功能。