与 pg-promise 相互依赖的事务

Question

我正在尝试构建一个应用程序，涉及 posts 和 tags for posts。对于这些，我有 post、tags 和 post_tag table。 tags 有我事先定义的标签，并且在应用程序的某个地方被建议给前端的用户。 post_tag table 持有 post 和 tag ids每行成对。

我使用 express.js 和 postgreql 和 pg-promise。

据我所知，我需要一个用于创建 post 操作的事务查询。

我还需要一种机制来检测当用户创建 post 时标签是否不在 tags table 中，所以我可以即时插入它，并且每个标签我都有一个 tag_id 是 post_id 的 insertion 中必须使用的，并且tag_id 变成 post_tag table。否则，我将有一个 foreign key error，因为我需要 post_tag table 的列 post_id 和 tag_id 来引用 posts 和 tags table id 列，分别为。

这是我为此使用的 url 函数，我用过至今未成功：

privateAPIRoutes.post('/ask', function (req, res) {
    console.log('/ask req.body: ', req.body);
    // write to posts
    var post_id = ''
    var post_url = ''
    db.query(
        `
            INSERT INTO
                posts (title, text, post_url, author_id, post_type)
            VALUES
                ($(title), $(text), $(post_url), $(author_id), $(post_type))
            RETURNING id
        `,
        {
            title: req.body.title,
            text: req.body.text,
            post_url: slug(req.body.title),
            author_id: req.user.id,
            post_type: 'question'
        } // remember req.user contains decoded jwt saved by mw above.
    )
        .then(post => {
            console.log('/ask post: ', post);
            post_id = post.id
            post_url = post.post_url


            // if tag deos not exist create it here
            var tags = req.body.tags;
            console.log('2nd block tags1', tags);
            for (var i = 0; i < tags.length; i++) {
                if (tags[i].id == undefined) {
                    console.log('req.body.tags[i].id == undefined', tags[i].id);                        
                    var q1 = db.query("insert into tags (tag) values ($(tag)) returning id", {tag: tags[i].label})
                                .then(data => {
                                    console.log('2nd block tags2', tags);
                                    tags[i].id = data[0].id 


                                    // write to the post_tag
                                    db.tx(t => {
                                        var queries = [];
                                        for (var j = 0; j < tags.length; j++) {

                                            var query = t.query(
                                                `
                                                    INSERT INTO
                                                        post_tag (post_id, tag_id)
                                                    VALUES
                                                        ($(post_id), $(tag_id))
                                                `,
                                                {
                                                    post_id: post_id,
                                                    tag_id: tags[j].id
                                                }
                                            )
                                            queries.push(query);
                                        }   
                                        return t.batch(queries)
                                    })
                                        .then(data => {
                                            res.json({post_id: post_id, post_url: post_url})
                                        })
                                        .catch(error => {
                                            console.error(error);
                                        })
                                })
                                .catch(error => {
                                    console.error(error);
                                });
                }
            }
        })
        .catch(error => {
            console.error(error);
        })
});

Answer 1

您遇到的主要问题 - 您不能在任务或事务中使用根级 db 对象。在事务内部尝试创建新连接会破坏事务逻辑。在这种情况下，您需要使用 t.tx。但是，在您的情况下，我认为您根本不需要它。

更正代码：

privateAPIRoutes.post('/ask', (req, res) => {
    console.log('/ask req.body: ', req.body);
    db.tx(t => {
        return t.one(
            `
        INSERT INTO
        posts (title, text, post_url, author_id, post_type)
        VALUES
        ($(title), $(text), $(post_url), $(author_id), $(post_type))
        RETURNING *
        `,
            {
                title: req.body.title,
                text: req.body.text,
                post_url: slug(req.body.title),
                author_id: req.user.id,
                post_type: 'question'
            } // remember req.user contains decoded jwt saved by mw above.
        )
            .then(post => {
                console.log('/ask second query: post[0]: ', post);
                console.log('/ask second query: tags: ', req.body.tags);
                console.log('/ask second query: tags[0]: ', req.body.tags[0]);

                // the key piece to the answer:
                var tagIds = req.body.tags.map(tag => {
                    return tag.id || t.one("insert into tags(tag) values() returning id", tag.label, a=>a.id);
                });

                return t.batch(tagIds)
                    .then(ids => {
                        var queries = ids.map(id => {
                            return t.one(
                                `
                                INSERT INTO post_tag (post_id, tag_id)
                                VALUES ($(post_id), $(tag_id))
                                RETURNING post_id, tag_id
                                `,
                                {
                                    post_id: post.id,
                                    tag_id: id
                                }
                            )
                        });
                        return t.batch(queries);
                    });
            });
    })
        .then(data => {
            // data = result from the last query;
            console.log('/api/ask', data);
            res.json(data);

        })
        .catch(error => {
            // error
        });
});

这里的关键是简单地遍历标签 id-s，对于没有设置的标签 - 使用插入。然后通过将数组传递给 t.batch.

来解决所有问题

其他推荐：

在执行 returns 新记录列的插入时，您应该使用方法 one。
您应该只在交易中使用 try/catch 一次。这与如何使用 promises 有关，而不仅仅是这个库
您可以将查询放入外部 SQL 文件，请参阅 Query Files

要更好地理解条件插入，请参阅 SELECT->INSERT

与 pg-promise 相互依赖的事务

Interdependent Transactions with pg-promise

node.js

express

pg-promise