Node.js表达并承诺不做我期望的事情?mysql

代码问题 好的，这里有很多问题，所以首先要先做。

    connection.query('...', function (err, rows) {
        connection.release();
        if (!err) {
            return rows;
        } else {
            return false;
        }
    });

这将无法正常工作，因为您正在将数据返回给调用方，这是使用err和调用回调rows并且不关心回调的返回值的数据库查询。

您需要做的是在有行或无行时调用其他函数或方法。

您正在致电：

var rows = loginM.findUser(req.body, res); 并且您希望在那里获得行，但不会。您将获得的是undefined，甚至比启动数据库查询还要快。它是这样的：

me.findUser = function(params, res) { // (1) you save the username in a variable var username = params.username;

// (2) you pass a function to getConnection method
pool.getConnection(function (err, connection) {
    console.log("Connection ");

    if (err) {
        console.log("ERROR 1 ");
        res.send({"code": 100, "status": "Error in connection database"});
        return;
    }

    connection.query('select Id, Name, Password from Users ' +
        'where Users.Name = ?', [username], function (err, rows) {
        connection.release();
        if (!err) {
            return rows;
        } else {
            return false;
        }
    });

    //connection.on('error', function (err) {
    //    res.send({"code": 100, "status": "Error in connection database"});
    //    return;
    //});
});

// (3) you end a function and implicitly return undefined

} pool.getConnection在传递函数之后，甚至在建立与数据库的连接之前，该方法都会立即返回。然后，过了一段时间，传递给该方法的函数可能会被调用，但是要返回undefined到需要以下值的代码很久之后：

var rows = loginM.findUser(req.body, res); 与从回调中返回值不同，您需要从它们中调用其他一些函数或方法（例如您需要调用的某些回调或用于解决Promise的方法）。

返回值是一个同步概念，不适用于异步代码。

应如何使用诺言 现在，如果您的函数返回了promise：

me.findUser = function(params, res) { var username = params.username;

return new Promise(function (res, rej) {

  pool.getConnection(function (err, connection) {
    console.log("Connection ");

    if (err) {
      rej('db error');
    } else {
      connection.query('...', [username], function (err, rows) {
        connection.release();
        if (!err) {
            res(rows);
        } else {
            rej('other error');
        }
    });
  });
});

} 那么您将可以在代码的其他部分以如下方式使用它：

app.post('/login/', function(req, res, next) {

var promise = new Promise(function (resolve, reject) {

    // rows is a promise now:
    var rows = loginM.findUser(req.body, res);

    rows.then(function (rowsValue) {
        console.log("Success");
        resolve(rowsValue);
    }).catch(function (err) {
        console.log("Failed");
        reject(err);
    });
});
// ...

说明 总而言之，如果您正在运行异步操作（例如数据库查询），则无法立即获得如下所示的值：

var value = query(); 因为服务器需要先阻塞等待数据库才能执行分配-这就是在每种语言中都发生同步阻塞I / O的情况（这就是为什么您需要使用这些语言的线程以便可以做其他事情）在该线程被阻止时完成）。

在Node中，您可以使用传递给异步函数的回调函数来在有数据时进行调用：

query(function (error, data) { if (error) { // we have error } else { // we have data } }); otherCode(); 或者您可以得到一个承诺：

var promise = query(); promise.then(function (data) { // we have data }).catch(function (error) { // we have error }); otherCode(); 但是在这两种情况下，otherCode()将在注册您的回调或promise处理程序后立即运行，而不需要查询包含任何数据，这无需执行阻止操作。

摘要 整个想法是，在像Node.JS这样的异步，无阻塞，单线程环境中，您一次不会做一件事情，但是您可以等待很多事情。但是，您不只是等待某事而在等待时什么也不做，您安排其他事情，等待更多事情，最终在准备就绪时会给您回电。来源：stack overflow