0

我是 node.js 和 postgresql 的新手。我已经与 postgres db 连接并执行一些测试代码。在我将使用准备好的语句之后。我创建一个示例登录脚本。如果用户存在，则返回用户名，否则返回消息“无效的用户名或密码”。如果用户名和密码正确，则返回用户名。但不会出现数据，然后无法返回消息。我的观点是，执行 cliend.end() 函数后控件会崩溃。

这是我的代码

UserLogin.get = function(userName, callBack) {
    pg.connect(pgConString, function(err, client, done) {
        if (err) {
            callBack("DB connection failed. " + err, null);
            return;
        }
        var selectQuery="SELECT * from  "  + TABLE + " WHERE userName=($1)";
        var query=client.query({
                text:selectQuery,
                values:[userName],
                name:"selectQuery"});

                query.on("error", function (error) {
                 callBack("DB fetch failed. Error Message: " + err, null);});

                query.on('row', function(row) {
                callBack(null, row);});

                query.on("end", function (result) {
                client.end();
                return;
                 });
            });     
}

如果 row 为空，则不返回回调。如果 row_result 不为空，它的工作正常.. 如何...???? 任何的想法...？？？

4

2 回答 2

2

最后我得到了答案。感谢您的支持

UserLogin.get = function(userName, callBack) {
    pg.connect(pgConString, function(err, client, done) {
        if (err) {
            callBack("DB connection failed. " + err, null);
            return;
        }
        var selectQuery="SELECT * from  "  + TABLE + " WHERE userName=($1)";
       var query=client.query({
            text:selectQuery,
            values:[loginId],
            name:"selectQuery"});

            query.on("error", function (error) {
             callBack("DB fetch failed. Error Message: " + err, null);return;});

            query.on('row', function(row,result) {
            result.addRow(row);
            });

            query.on('end', function (result) {
            callBack(null,result.rows);
            client.end();
            return;
             });
        });     
}

在我的旧代码中，每次查询从数据库中获取 1 行时都会调用回调。我只是改变了逻辑

于 2015-11-23T10:09:48.647 回答
0

你的代码

query.on('row', function(row) {
  callBack(null, row);
});

意味着每次查询从数据库中获取 1 行时都会调用回调。在查询结果为 0 的情况下，永远不会调用回调。

于 2015-11-23T08:07:33.687 回答