node.js - 使用 pg-promise 进行同步编程

Question

我是 node.js 和 pg-promise 的新手，来自 synchronis 编程背景，它需要一种新的思维。

我将从在主程序逻辑之前运行数据库初始化的场景开始。

下面这个例子: https://github.com/vitaly-t/pg-promise/wiki/Learn-by-Example#simple-select

db.any("select * from users where active=$1", [true])
  .then(function (data) {
    // success;
  })
  .catch(function (error) {
    // error;
  });

我的代码会读作:

db.query("DELETE FROM records")
  .then(function (data) {
    // success;
    console.log("This is where all my main logic goes");
  })
  .catch(function (error) {
    // error;
  });

或者它会读作:

db.query("DELETE FROM records")
  .then(function (data) {
    // success;
  })
  .catch(function (error) {
    // error;
  });
console.log("This is where all my main logic goes");

我的理解是，对于后者，消息将在记录被删除之前显示。

更新:在阅读了大量关于 promises 和回调的文章后，我了解到 pg-promise 使用链接 .then 和 .catch 来处理成功和错误场景。我现在也相信我理解 pg-promise 命令应该放在函数包装器中，例如:

function initialiseDB() {
  db.query("DELETE FROM records")
    .then(function (data) {
      // success;
    })
    .catch(function (error) {
      // error;
    });
  }

然后在我的代码中，我将使用一个异步运行该函数的简单命令来调用该函数:

initialiseDB();

然而，我仍然不确定异步编码和 promises 的概念如何适应程序的整体结构，因为程序中的几乎所有内容肯定都需要先完成初始化。因此，整个程序不需要放在函数的“.then”部分吗？也就是说，顶层的唯一代码实际上是 intialiseDB() 函数？

// Start of code here 
var pgp = require('pg-promise')();

//Configure the database connection
var config = {
  user:               'username', //env var: PGUSER 
  database:           'database', //env var: PGDATABASE 
  password:           'password', //env var: PGPASSWORD 
};

var db = pgp(config);

function initialiseDB() {
  db.query("DELETE FROM records")
    .then(function (data) {
      // This is where the main program logic goes after this line;
    })
    .catch(function (error) {
      // error;
    });
}

// Commence the program here
initialiseDB();

Answer 1

PG promise 实际上允许在较新的 nodejs 版本上使用 generators 和 async/await。 Generators 需要一个带有 promises 的适配器，该 promises 非常重要地内置于系统中，因此提供 generator 函数 将允许以同步方式实现更清晰的代码流

Taken from the repository under the tag task

没有生成器:

db.task(t => {
        // this.ctx = task config + state context;
        return t.one('SELECT * FROM users WHERE id = $1', 123)
            .then(user => {
                return t.any('SELECT * FROM events WHERE login = $1',user.name);
            });
    })
    .then(events => {
        // success;
    })
    .catch(error => {
        // error;
    });

使用生成器:

db.task(function * (t) {
        // this.ctx = task config + state context;
        let user = yield t.one('SELECT * FROM users WHERE id = $1', 123);
        return yield t.any('SELECT * FROM events WHERE login = $1', user.name);
    })
    .then(events => {
        // success;
    })
    .catch(error => {
        // error
    });

如果使用async/await，您可以简单地将function * (t)替换为async function (t)和 yield 和 await 两者的工作原理大致相同。

一些注意事项:

在更复杂的逻辑中，您应该围绕可能失败的事物使用 try catch block ，因为它们会在 generators 和 async/await 中冒泡错误

db.task(function * (t) {
    yield Promise.reject(new Error('This will cause your app to error')
}

You should also pay close attention to his pg-promise demo!它会教给您很多很棒的东西，例如扩展事件、存储库、外部 SQL 文件，以及库中的许多其他很棒的东西，例如助手!