Я пытаюсь построить приложение включает в себясообщений а такжетеги для сообщений. Для этого у меня естьpost, tags а такжеpost_tag Таблица.tags имеет теги, которые я определил ранее, и где-то в приложении предлагается пользователю на интерфейсе.post_tag стол содержитсообщение а такжетег идентификаторы как пары в каждом ряду.

Я использую express.js и postgreql и pg-обещание.

Насколько я знаю, мне нужен транзакционный запрос (ы) для операции создания после.

Также мне нужен механизм, чтобы обнаружить, еслитег не был вtags таблица, когда пользователь создал сообщение, так что я могу вставить его на лету, и у меня естьtag_id для каждоготег что необходимо использовать вinsertion изpost_id а такжеtag_id вpost_tag Таблица. В противном случае у меня будетforeign key error так как мне нужноpost_tag столбцы таблицыpost_id а такжеtag_id ссылатьсяposts а такжеtags Таблица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);
        })
});