1

我正在使用 NodeJS、PostgreSQL 和令人惊叹的pg-promise库。就我而言，我想执行三个主要查询：

  1. 在“tweets”表中插入一条推文。
  2. 如果推文中有主题标签，请将它们插入另一个表“主题标签”
  3. 他们在第三个表“hashtagmap”（多对多关系表）中链接推文和主题标签

以下是请求正文 (JSON) 的示例：

{
"id":"12344444",
"created_at":"1999-01-08 04:05:06 -8:00",
"userid":"@postman",
"tweet":"This is the first test from postman!",
"coordinates":"",
"favorite_count":"0",
"retweet_count":"2",
"hashtags":{
    "0":{
        "name":"test",
        "relevancetraffic":"f",
        "relevancedisaster":"f"
    },
    "1":{
        "name":"postman",
        "relevancetraffic":"f",
        "relevancedisaster":"f"
    },
    "2":{
        "name":"bestApp",
        "relevancetraffic":"f",
        "relevancedisaster":"f"
    }
}

除了主题标签之外，上述所有字段都应包含在“tweets”表中，而这些字段又应包含在“hashtags”表中。

这是我基于 NodeJS 模块内的 pg-promise 文档中的嵌套事务使用的代码。我想我需要嵌套事务，因为我需要知道这两者tweet_id并且hashtag_id为了将它们链接到 hashtagmap 表中。

// Columns
var tweetCols = ['id','created_at','userid','tweet','coordinates','favorite_count','retweet_count'];

var hashtagCols = ['name','relevancetraffic','relevancedisaster'];

//pgp Column Sets
var cs_tweets = new pgp.helpers.ColumnSet(tweetCols, {table: 'tweets'});

var cs_hashtags = new pgp.helpers.ColumnSet(hashtagCols, {table:'hashtags'});
return{
// Transactions
add: body =>
    rep.tx(t => {
        return t.one(pgp.helpers.insert(body,cs_tweets)+" ON CONFLICT(id) DO UPDATE SET coordinates = "+body.coordinates+" RETURNING id")
            .then(tweet => {
                var queries = [];
                for(var i = 0; i < body.hashtags.length; i++){
                    queries.push(
                        t.tx(t1 => {
                            return t1.one(pgp.helpers.insert(body.hashtags[i],cs_hashtags) + "ON CONFLICT(name) DO UPDATE SET fool ='f' RETURNING id")
                                .then(hash =>{
                                    t1.tx(t2 =>{
                                        return t2.none("INSERT INTO hashtagmap(tweetid,hashtagid) VALUES("+tweet.id+","+hash.id+") ON CONFLICT DO NOTHING");
                                    });
                                });
                        }));
                }
                return t.batch(queries);
            });
    })
}

问题在于这段代码我能够成功插入推文，但没有任何反应。我无法插入主题标签，也无法将主题标签链接到推文。

对不起，但我是编码新手，所以我想我不明白如何从交易中正确返回以及如何执行这个简单的任务。希望您能够帮助我。

先感谢您。

让

4

2 回答 2

2

改进 Jean Phelippe 自己的答案：

// Columns
var tweetCols = ['id', 'created_at', 'userid', 'tweet', 'coordinates', 'favorite_count', 'retweet_count'];

var hashtagCols = ['name', 'relevancetraffic', 'relevancedisaster'];

//pgp Column Sets
var cs_tweets = new pgp.helpers.ColumnSet(tweetCols, {table: 'tweets'});

var cs_hashtags = new pgp.helpers.ColumnSet(hashtagCols, {table: 'hashtags'});

return {
    /* Tweets */
    // Add a new tweet and update the corresponding hash tags
    add: body =>
        db.tx(t => {
            return t.one(pgp.helpers.insert(body, cs_tweets) + ' ON CONFLICT(id) DO UPDATE SET coordinates = ' + body.coordinates + ' RETURNING id')
                .then(tweet => {
                    var queries = Object.keys(body.hashtags).map((_, idx) => {
                        return t.one(pgp.helpers.insert(body.hashtags[i], cs_hashtags) + 'ON CONFLICT(name) DO UPDATE SET fool = $1 RETURNING id', 'f')
                            .then(hash => {
                                return t.none('INSERT INTO hashtagmap(tweetid, hashtagid) VALUES($1, $2) ON CONFLICT DO NOTHING', [+tweet.id, +hash.id]);
                            });
                    });
                    return t.batch(queries);
                });
        })
            .then(data => {
                // transaction was committed;
                // data = [null, null,...] as per t.none('INSERT INTO hashtagmap...
            })
            .catch(error => {
                // transaction rolled back
            })
},

笔记：

  • 根据我之前的笔记，您必须链接所有查询，否则您最终会得到松散的承诺
  • 远离嵌套事务，除非您完全了解它们在 PostgreSQL 中的工作原理（阅读此内容，特别是该Limitations部分）。
  • 避免手动查询格式化，这是不安全的，总是依赖库的查询格式化。
  • 除非您将交易结果传递到其他地方，否则您至少应该提供.catch处理程序。

PS 对于类似的语法+tweet.id，它与 相同parseInt(tweet.id)，只是更短，以防它们是字符串；）

于 2017-01-15T14:52:26.677 回答
0

对于那些将面临类似问题的人，我会发布答案。

首先，我的错误：

  1. 在 for 循环中：body.hashtag.length不存在，因为我正在处理一个对象（这里是非常基本的错误）。变成Object.keys(body.hashtags).length
  2. 为什么要使用这么多事务？按照vitally-t 的回答：Interdependent Transactions with pg-promise我删除了额外的交易。我还不清楚如何打开一个事务并将一个查询的结果用于同一事务中的另一个查询。

这是最终代码：

    // Columns
var tweetCols = ['id','created_at','userid','tweet','coordinates','favorite_count','retweet_count'];

var hashtagCols = ['name','relevancetraffic','relevancedisaster'];

//pgp Column Sets
var cs_tweets = new pgp.helpers.ColumnSet(tweetCols, {table: 'tweets'});

var cs_hashtags = new pgp.helpers.ColumnSet(hashtagCols, {table:'hashtags'});

return {
    /* Tweets */
    // Add a new tweet and update the corresponding hashtags
    add: body =>
        rep.tx(t => {
            return t.one(pgp.helpers.insert(body,cs_tweets)+" ON CONFLICT(id) DO UPDATE SET coordinates = "+body.coordinates+" RETURNING id")
                .then(tweet => {
                    var queries = [];
                    for(var i = 0; i < Object.keys(body.hashtags).length; i++){
                        queries.push(
                            t.one(pgp.helpers.insert(body.hashtags[i],cs_hashtags) + "ON CONFLICT(name) DO UPDATE SET fool ='f' RETURNING id")
                                .then(hash =>{
                                    t.none("INSERT INTO hashtagmap(tweetid,hashtagid) VALUES("+tweet.id+","+hash.id+") ON CONFLICT DO NOTHING");
                                })
                            );
                    }
                    return t.batch(queries);
                });
        }),
于 2017-01-15T14:27:14.487 回答