使用 upsert 更新：true 是否在 express 中更新，猫鼬？

Posted 2023-03-08

【中文标题】使用 upsert 更新：true 是否在 express 中更新，猫鼬？

【英文标题】：update with upsert: true is not updating in express,mongoose?使用 upsert 更新：true 是不是在 express 中更新，猫鼬？

【发布时间】：2017-10-11 19:39:13

【问题描述】：

var logs = [
    mobilenumber: '1',
    ref: 3,
    points: 1000,
    ctype: 'mycredit',
    entry: 'sdfsdf',
    entry: 0
, 
    mobilenumber: '1',
    ref: 6,
    points: 2000,
    ctype: 'mycredit',
    entry: 'sdfsdf',
    entry: 0
, 
    mobilenumber: '2',
    ref: 7,
    points: 2600,
    ctype: 'mycredit',
    entry: 'sdfsdf',
    entry: 0
, 
    mobilenumber: '2',
    ref: 15,
    points: -1500,
    ctype: 'mycredit',
    entry: 'sdfsdf',
    entry: 0
, 
    mobilenumber: '10',
    ref: 15,
    points: 800,
    ctype: 'mycredit',
    entry: 'sdfsdf',
    entry: 0
, 
    mobilenumber: '11',
    ref: 15,
    points: 110,
    ctype: 'mycredit',
    entry: 'sdfsdf',
    entry: 0
];

var summary = [];
var positive = 0,
    negative = 0,
    total = 0,
    count = 0;
for (var i = 0; i < logs.length; i++) 
    count = 0;
    positive = 0;
    negative = 0;
    total = 0;

    for (var j = i; j < logs.length; j++) 
        if (logs[i].mobilenumber === logs[j].mobilenumber) 
            if (logs[j].points < 0) 
                negative += logs[j].points;
             else if (logs[j].points >= 0) 
                positive += logs[j].points;
            

            total += logs[j].points;
            count++;
        
    
    i += count - 1;
    var obj = 
        mobilenumber: logs[i].mobilenumber,
        positivepoint: positive,
        negativepoint: negative,
        balancepoints: total
    
    summary.push(obj);
    

如果你运行上面的代码，你会得到 Summary 对象

在下面的代码中，我尝试插入/更新代码，但插入工作正常，但没有更新

var promiseArr = [];
for(var i = 0; i<summary.length;i++) 
    promiseArr.push(saveOrUpdate(summary[i].mobilenumber, summary[i]));



function saveOrUpdate (phone, dataToUpdate) 
   return new Promise((resolve, reject) => 
    //Update document if found or insert otherwise
    // upsert:true -> If set to true, creates a new document when no document matches the query criteria

        Summary.update("mobilenumber": phone, 
            dataToUpdate,
            upsert: true, 
            function(err, raw)
                if (err)
                
                    console.log(err);
                else
                
                    console.log(raw);
                

            );
   );

我在这里尝试在摘要集合中插入或更新摘要对象。

如果手机号码已经存在，我将在 Summarycollection 中搜索手机号码，否则我将更新该文档，否则我将为该手机号码创建新文档

插入正在工作，但如果手机号码已在摘要集合中，则它不会更新

帮帮我，我三天以来一直在努力

我正在使用 mongoose 和数据库 mlab 版本 3.2.11

【问题讨论】：

What is the difference between synchronous and asynchronous programming (in node.js)的可能重复

还可以看看异步模块。 github.com/caolan/async 。会有帮助的。

JSON.stringify(obj) 不对。

不要使用JSON.stringify()。直接传递您的对象，即obj

伙计们，他使用同步 FOR 来运行异步数据库操作。这将在未来导致非常大的问题。所以 JSON.stringify 可以在这里工作，但仍然需要以异步方式重写代码，使用 Promise 或异步模块。

【参考方案1】：

 var promiseArr = [];
    for (var i = 0; i < summary.length; i++) 
        promiseArr.push(saveOrUpdate(summary[i].mobilenumber, summary[i]));
    


    function saveOrUpdate(phone, dataToUpdate) 
        return new Promise((resolve, reject) => 

            //Update document if found or insert otherwise
            // upsert:true -> If set to true, creates a new document when no document matches the query criteria
            Summary.findOne(
                "mobilenumber": phone
            , function(err, data) 
                var newSummary = dataToUpdate;
                console.log(data);
                console.log(newSummary);
                if (data) 
                    newSummary.negativepoint += data.negativepoint;
                    newSummary.positivepoint += data.positivepoint;
                    newSummary.balancepoints += data.balancepoints;
                
                Summary.update(
                        "mobilenumber": phone
                    ,
                    dataToUpdate, 
                        upsert: true
                    ,
                    function(err, raw) 
                        if (err) 
                            console.log(err);
                         else 
                            console.log(raw);
                        

                    );

            );



        );
    

【参考方案2】：

所以先看看这个。 What is the difference between synchronous and asynchronous programming (in node.js) 。永远不要在不完全了解发生了什么的情况下在同一个地方使用同步和异步操作。

让我们尝试使用异步方法重写您的代码。 首先让我们创建promise方法

function saveOrUpdate (phone, dataToUpdate) 
   return new Promise((resolve, reject) => 
    //Update document if found or insert otherwise
    // upsert:true -> If set to true, creates a new document when no document matches the query criteria
       Summary.updateOne("mobilenumber": phone, 
            $set : dataToUpdate, 
            upsert: true, 
            function(err)
                  err ? reject(err) : resolve();
            );
   );

现在只需做出一系列承诺

var promiseArr = [];
for(var i = 0; i<summary.length;i++) 
    promiseArr.push(saveOrUpdate(summary[i].mobilenumber, summary[i]));

使用 Promise.All 运行 promise 并捕获结果。

Promise.all(promiseArr)
.then((res) => console.log("All done"))
.catch(err => console.log(err));

Mongo 更新文档 https://docs.mongodb.com/manual/reference/method/db.collection.update/ Mongo updateOne docs https://docs.mongodb.com/manual/reference/method/db.collection.updateOne/

承诺https://developer.mozilla.org/en/docs/Web/javascript/Reference/Global_Objects/Promise

如果您使用猫鼬作为驱动程序。阅读文档以了解如何通过查询更新文档。 http://mongoosejs.com/docs/2.7.x/docs/updating-documents.html

Mongo DB 本机驱动程序允许您使用所有新的 mongo 功能和方法。 http://mongodb.github.io/node-mongodb-native/2.2/api/Collection.html

希望这会有所帮助。

【讨论】：

出现错误等待中... TypeError: Summary.updateOne 不是函数

好吧。您使用什么 mongodb 驱动程序来查询数据库？什么版本的mongo？

我推荐使用这个mongodb.github.io/node-mongodb-native/2.2/api/…

我正在使用 mlab mongod 版本：3.2.11 (MMAPv1)

好的..您使用什么库来查询 mongo mLab 中的文档？查找或更新？