MongoDB嵌套查询只返回最近发生的结果

MongoDB Nested Query Returns Only Last Occuring Result

本文关键字：结果 最近 返回 嵌套 查询 MongoDB      更新时间：2023-09-26

好的，这段代码包含一个嵌套查询在for循环中

var query = records.find({$or:[{starter:data},{receiver:data}]},{});//check the records table for all persons the logged in user has spoken to
    query.sort('-createDate').exec(function (err, docs){
        if(err) throw err;
        for(var i=docs.length-1; i>= 0; i--)
        {
           var starter  = docs[i].starter;
            var receiver = docs[i].receiver;
            var lasttxt = docs[i].lastMessage; 
            if (starter == socket.usernames){
              var target = receiver;
            }else
            {
              var target = starter;
            }
          usersrec.find({username:target},{}).lean().exec(function (errx, docx){
                if(errx) throw errx;
                docx[0].message = lasttxt;
                socket.emit('usernames', docx);
          });
        }
    })

它意味着获取当前登录用户与之交谈的每个人的最后一条消息，并将其存储在lasttxt变量中。问题是它只获取数据库中最后一个用户的最后一条消息然后，它将最后一条消息分配给每个人，作为他们自己的最后一条消息。

这不会影响数据库的记录。只是客户端我错过了什么?

为了导航js异步，我用socket做了一些来回发射。IO和它工作

服务器端

var query = records.find({$or:[{starter:data},{receiver:data}]},{});//check the records table for all persons the logged in user has spoken to
query.sort('-createDate').exec(function (err, docs){
    if(err) throw err;
    for(var i=docs.length-1; i>= 0; i--)
    {
       var starter  = docs[i].starter;
        var receiver = docs[i].receiver;
        var lasttxt = docs[i].lastMessage; 
        if (starter == socket.usernames){
          var target = receiver;
        }else
        {
          var target = starter;
        }
      var userlast = target+" "+lasttxt;
                socket.emit('lastly', userlast);//Emit the username and last message for the client to emit back here
    }
})

在客户端，拾取发出的数据

 socket.on('lastly', function(data){//Recieve the data and send right back
                  socket.emit('lastly2', data);
              });

回到你的服务器端，接收发送回来的数据

socket.on('lastly2', function(data){//receive the username and last message to work with
var check = data;
var space = check.indexOf(' ');
var name = check.substr(0, space);
var msg = check.substr(space+1);
usersrec.find({username:name},{}).lean().exec(function (errx, docx){
            if(errx) throw errx;
            docx[0].message = msg;
            socket.emit('usernames', docx);
      });

是的，它可能是不正统的，但至少它完成了工作。

相关文章：