使用 pg-promise 查询多对多关系的最佳方法

例如，我想从数据库获取用户信息、电子邮件及其角色，并创建一个如下对象：

{
  "id": 1,
  "firstname": "John",
  "lastname": "Johnny",
  "emails": [
    {
      "type": "work",
      "email": "[email protected] /cdn-cgi/l/email-protection"
    },
    {
      "type": "personal",
      "email": "[email protected] /cdn-cgi/l/email-protection"
    }
  ],
  "roles": [
    {
      "role": "ADM",
      "title": "Admin"
    },
    {
      "role": "PUB",
      "title": "Publisher"
    }
  ]
}

我需要查询三个表：

• Users表有id, firstname,lastname.
• Emails表有type, email,user_id.
• Roles表有role, title,user_id.

基于pg-承诺 https://github.com/vitaly-t/pg-promise的维基我几乎确定它必须使用来完成Tasks https://github.com/vitaly-t/pg-promise/wiki/Learn-by-Example#tasks但不确定你会如何链接它们。

UPDATE在我的实际项目中，我必须插入一个产品并使用生成的 id 来插入属性。如果您遇到类似情况，请在此处添加我的代码：

//Insert a new product with attribites as key value pairs
post_product_with_attr: function(args) {
    return db.task(function(t) {
        return t.one(sql.post_new_product, args)
            .then(function(dt) {
                var queries = [];
                Object.keys(args).forEach(function(key) {
                    queries.push(t.one(sql.post_attr_one, { Id: dt.id, key: key, value: args[key] }));
                 });
                return queries.length ? t.batch(queries) : [dt];
            });
    });
}

您所描述的不是多对多关系，而是 2 个一对多关系。

基于pg-承诺 https://github.com/vitaly-t/pg-promise的维基我几乎确定它必须使用来完成Tasks https://github.com/vitaly-t/pg-promise/wiki/Learn-by-Example#tasks但不确定你会如何链接它们。

在您的示例中，无需链接任何内容。当一个链的结果需要用作下一个结果的标准时，一条链会承诺，因为这就是承诺的工作方式，而不仅仅是查询。

因此，您可以并行或独立执行所有 3 个查询，如下例所示：

function getUserInfo(userId) {
    return db.task(async t => {
        const user = await t.one('SELECT id, firstname, lastname FROM Users WHERE id = $1', userId);
        const emails = await t.any('SELECT type, email FROM emails WHERE user_id = $1', userId),
        const roles = await t.any('SELECT role, title FROM roles WHERE user_id = $1', userId);

        user.emails = emails;
        user.roles = roles;

        return user;
});

使用示例：

const user = await getUserInfo(123); //=> user object with all details

请注意，通过现有的 PostgreSQL JSON 函数执行此操作要高效得多，这样您就可以只执行一个查询。