1

我有收藏items

[
    {
        itemId: 1249,
        someField: 'abc'
    },
    {
        itemId: 1479,
        anotherField: 'bcc'
    }
    ,
    // etc
]

我收到另一部分数据。有些项目可能已经存在,有些不存在,

[
    {
        itemId: 6534,
        someField: 'trw'
    },
    // already stored in collection..
    {
        itemId: 1249,
        someField: 'abc'
    }
]

我正在寻找使用upsert策略批量插入此数据的方式(意味着,如果具有此类 itemId 的项目已经存在 - 更新,否则插入)。

这是否可能只用一个查询,我需要手动完成收集并更新每个项目?

4

1 回答 1

1

我用这个,可能不是最有效的方法,但它有效

MongoClient.connect("mongodb://localhost:27017/devbed", {native_parser:true}, function(err, db) {
    db.collection(project.name).findOne({"revision":project.tmprev}, function(err,item){
                        if(item){
                          db.collection(project.name).update({JSON},{w:1},function(err, object) {
                              if (err) {console.warn(err.message);}
                              else {console.log("succesfully saved");
                              db.close();}
                          });
                        }
                        else{
                            db.collection(project.name).insert({JSON}]},{w:1},function(err, object) {
                            if (err) {console.warn(err.message);}
                            else {console.log("succesfully saved");
                            db.close();}
                            });
                        }

                    });
});

将它包装在一个函数中应该可以

于 2013-05-09T14:49:37.930 回答