如何使用rethinkdb在koa中执行初始设置

Question

我使用rethinkdbdash the，并试图找出如何在应用程序第一次启动时执行数据库的设置。我试图完成类似于Segphalt的猫的instagram教程，但使用koa。

var conn;
r.connect(config.database).then(function(c) {
  conn = c;
  return r.dbCreate(config.database.db).run(conn);
})
.then(function() {
  return r.tableCreate("instacat").run(conn);
})
.then(function() {
  return q.all([
    r.table("instacat").indexCreate("time").run(conn),
    r.table("instacat").indexCreate("place", {geo: true}).run(conn)
  ]);
})
.error(function(err) {
  if (err.msg.indexOf("already exists") == -1)
    console.log(err);
})
.finally(function() {
  r.table("instacat").changes().run(conn)
  .then(function(cursor) {
    cursor.each(function(err, item) {
      if (item && item.new_val)
        io.sockets.emit("cat", item.new_val);
    });
  })
  .error(function(err) {
    console.log("Error:", err);
  });

我尝试过放弃，而不是将承诺链接起来，但这会引发错误，原因是语法无效。

 try {
   yield r.dbCreate(config.database.db).run();
   yield r.tableCreate('user').run();
 }
 catch (err) {
   if (err.message.indexOf("already exists") == -1)
      console.log(err.message);
 }

app.listen(port);

执行这种设置的最佳方法是什么，包括执行在koa中运行.changes()的查询，这样它只能在服务器启动时执行，而不是在每个请求周期中执行。还是有更好的方法在考拉完成这一任务？

Answer 1

您只能在生成器函数(签名中带有星号的函数)中使用yield关键字。通常，如果您想使用yield等待承诺的完成，您将使用基于生成器的协同线包装整个操作集。

有两个库可用于此：

• Co：https://www.npmjs.com/package/co
• 蓝鸟：https://www.npmjs.com/package/bluebird

Co是Koa在其所有中间件处理程序中使用的内容，但我个人更喜欢Bluebird，因为在我的经验中，它似乎有更好的错误处理。

您可以将设置代码包装在Bluebird协同线中，然后将其称为就位：

bluebird.coroutine(function *() {
  try {
    yield r.dbCreate(config.database.db).run();
    yield r.tableCreate('user').run();
  }
  catch (err) {
    if (err.message.indexOf("already exists") == -1)
      console.log(err.message);
  }
})();