从查询的匿名函数中写入更高范围的数组

Question

我需要从一个函数返回一个值，该函数从查询中获取其信息。我在将信息从查询的匿名函数传递到容器函数时遇到了一些问题。

我尝试在更高范围（容器函数）中创建一个数组，并让查询函数根据结果写入数组，但这似乎不起作用。我还尝试将数组传递给查询的匿名函数。这似乎也不起作用。

---

这是我的函数（在 Node 中执行）：

function retrieveSales(connection,timeFrame) {

    var sales = new Array();

    connection.query('select * from sales_entries where date BETWEEN ? AND ?',
    timeFrame,

    function (err, rows, fields, sales) {

        if (err) return callback(new Error('Failed to connect'), null);

        connection.end();

        for (x = 0; x < rows.length; x++) {
            sales.push(rows[x]);
        }

    });

    console.log('Sales Returned: ' + JSON.stringify(sales, null, 4));

    return sales;

}

导致'cannot call method 'push' of undefined。

我应该如何正确地写入sales 数组，以便可以使用retrieveSales() 返回它？

Answer 1

您正在处理 JavaScript 的漂亮 asynchronous-ness-icity。您正试图从异步方法中返回。尝试复习异步编程的工作原理，它会让你的生活变得更加轻松；这不是很难，只是不同。看看这个代码示例，希望它能让你振作起来。

// use this as your callback to handle the results from connection.query()
function sales_cb(rows) {
  var sales = [];
  for (x = 0; x < rows.length; x++) {
    sales.push(rows[x]);
  }
  console.log('Sales Returned: ' + JSON.stringify(sales, null, 4));
}

function retrieveSales(connection, timeFrame) {
  // connection.query() is asynchronous - interact with it accordingly
  connection.query('select * from sales_entries where date BETWEEN ? AND ?', timeFrame,
    function (err, rows, fields, sales) {
      if (err) {
        callback(new Error('Failed to connect'), null);
      } else {
        // invoke sales_cb(sales) once the for loop is done
        sales_cb(rows);
      }
    });
}

如果这有帮助，请告诉我:)

Answer 2

使用：

https://github.com/kriskowal/q

以下是如何使用承诺：

var q = require('q');


function retrieveSales(connection,timeFrame) {

  var sales = new Array();
  var deferred = q.defer();

  connection.query('select * from sales_entries where date BETWEEN ? AND ?',
     timeFrame,

     function (err, rows, fields) {

     if (err) return callback(new Error('Failed to connect'), null);

     connection.end();

      for (x = 0; x < rows.length; x++) {
          sales.push(rows[x]);
      }

      deferred.resolve(sales);
  });

  deferred.then(function(salesback) {
    console.log('Sales Returned: ' + JSON.stringify(salesback, null, 4));
  }

  // added bonus -- the calling function can also use the promise
  return deferred;

}

更多信息：http://howtonode.org/promises