使用 CouchDB 和 nano.js 进行回调和返回

Question

我正在尝试使用 nano 编写一个带有可重用数据库调用的小型库。

db.view('list', 'people', function(error, data) {
  if (error == null) {
    res.render('people/index', {
      people: data.rows
    });
  } else {
    // error
  }
});

当有多个请求时，这可能会变得非常混乱：

db.view('list', 'people', function(error, people) {
  db.view('list', 'items', function(error, items) {
    db.view('list', 'questions', function(error, questions) {
      db.view('list', 'answers', function(error, answers) {
        ...
        res.render('people/index', {
          people: people.rows,
          items: items.rows,
          questions: questions.rows
          ...

所以，我们的想法是创建一个函数：

var getPeople = function() {
  // do db calls here and return
}

res.render('people/index', {
  people: getPeople()
});

但这不起作用。

我该如何解决这个问题并将所有内容放入外部 node-js-module.js 文件中？

Answer 1

我建议使用 caolan 的 aysnc 库。非常容易使用，它可以在浏览器和沙发上使用 require （不是你将在沙发侧使用来查询）。

对于特定问题，您可以使用系列或瀑布：

• https://github.com/caolan/async#series< /a>
• https://github.com/caolan/async#waterfall

Answer 2

您是否考虑过在 CouchDB 中查看视图整理？这将帮助您减少 db.view(..) 调用次数并在 1 个视图查询中返回所需的所有数据。对于单个一对多（即“人”有许多“项目”）来说非常容易。对于多个级别来说可能需要更多的努力，但它应该以相同的方式工作。这里有一些关于 Couch 视图整理的好文章：

CouchDB Joins

CouchDB 查看排序规则

Answer 3

我知道的最好的解决方案是使用 承诺。需要一点时间来适应，但这是值得的。我正在使用 Kris Kowal 的 Q 库。他在 JSConf-2010 上很好地演练了 Q API 和设计（跳转至 15:30）。

Answer 4

您已经在这里得到了一些很好的答案。

从纳米源代码中，您有一个可能有帮助的示例：

• https:// github.com/dscape/nano/blob/master/examples/bulk_transform.js

另外，如果您不太了解 NodeJS 流控制的工作原理，我强烈推荐您查看本教程：

• http://nodetuts.com/tutorials/19-asynchronous-iteration-patterns.html #video

比使用工具更好的方法是使用该工具并了解其工作原理:) 也许您最终只会编写自己的控制流，这就是我们大多数人最终所做的事情。

希望这有帮助，为了方便起见附上代码。

  var db    = require('nano')('http://localhost:5984/emails')
    , async = require('async')
    ;

  function update_row(row,cb) {
    var doc = row.doc;
    delete doc.subject;
    db.insert(doc, doc._id, function (err, data) {
      if(err)  { console.log('err at ' + doc._id);  cb(err); }
      else     { console.log('updated ' + doc._id); cb(); }
    });
  }

  function list(offset) {
    var ended = false;
    offset = offset || 0;
    db.list({include_docs: true, limit: 10, skip: offset}, 
      function(err, data) {
        var total, offset, rows;
        if(err) { console.log('fuuuu: ' + err.message); rows = []; return; }
        total  = data.total_rows;
        offset = data.offset;
        rows   = data.rows;
        if(offset === total) { 
          ended = true;
          return; 
        }
        async.forEach(rows, update_row, function (err) {
          if(err) { console.log('something failed, check logs'); }
          if(ended) { return; }
          list(offset+10);
        });
    });
  }

  list();