Несколько запросов mongodb с помощью узла

Question

Я не могу найти правильный ответ на мой вопрос, я просмотрел весь стек stackoverflow. Рассмотрим пример кода в C#, который я пытаюсь выполнить для порта nodejs + mongobd.

var messageList = new List<MessageHelper>(); 

foreach(MessageActivation messageToAsk in messagesToAsk) 
{ 
    var message  = from m in dbContext.Messages where m.Id == messageToAsk.MessageId select m; 
    var jokeMessage = from m in dbContext.Messages where m.Id == messageToAsk.JokeMessageId select m; 
    var user  = from u in dbContext.Users where u.Id == messageToAsk.SourceUserId select u; 

    var messageHelper = new MessageHelper(); 
     messageHelper.AskingUserId = user.ToList()[0].Id; 
     messageHelper.Message = message.ToList()[0]; 

    messageList.Add(messageHelper); 
} 

return messageList; 

Каков наилучший способ сделать это в пути узла? Просто боковой узел, dbContext будет запрашивать БД. Дело в том, чтобы собрать всю необходимую информацию, упаковать ее и только потом отправить ее.

Благодаря

EDIT:

Это то, что я попытался

// collect needed info to make next queries in db 
var messageIdList = new Array(); 
var jokeMessageIdList = new Array(); 
var sourceUserIdList = new Array(); 
for(var i=0; i < messagesToAsk.length; i++) 
{ 
    messageIdList.push(messagesToAsk[i].MessageId  ); 
    jokeMessageIdList.push(jokeMessageId[i].JokeMessageId ); 
    sourceUserIdList .push(jokeMessageId[i].SourceUserId ); 
} 

// make requests to have all the data in place 
var messages = App.DataModels.Messages.find({}); 
    messages.where('MessageId').in(messageIdList); 
    messages.exec(function (err, foundMessages) 
    { 
     var jokeMessages = App.DataModels.Messages.find({}); 
      jokeMessages.where('JokeMessageId').in(jokeMessageIdList); 
      jokeMessages.exec(function (err, foundJokeMessages) 
      { 
       var users = App.DataModels.Messages.find({}); 
        users.where('SourceUserId').in(sourceUserIdList); 
        users.exec(function (err, foundUsers) 
        { 
         var messageList = new Array(); // new List<MessageHelper>(); 

         for(var i=0; i < messagesToAsk.length; i++) 
         { 
          var message  = null; 
          var jokeMessage = null; 
          var user  = null; 

          // get the data 
          for(var j = 0; j < messages.length; j++) 
          { 
           if(messages[j].MessageId === messagesToAsk[i].MessageId) 
           { 
            message = messages[j]; 
            break; 
           } 
          } 
          for(var k = 0; k < jokeMessages.length; k++) 
          { 
           if(jokeMessages[k].JokeMessageId === messagesToAsk[k].JokeMessageId) 
           { 
            jokeMessage = jokeMessage[k]; 
            break; 
           } 
          } 
          for(var l = 0; l < users.length; l++) 
          { 
           if (users[l].SourceUserId === messagesToAsk[l].SourceUserId) 
           { 
            user = users[l]; 
            break; 
           } 
          } 

          var messageHelper = 
          { 
           "AskingUserId" : user.Id, 
           "AskingUserPic" : user.HelperPhoto, 
           "Message"  : message, 
           "JokeMessage" : message.Type === "1" ? jokeMessage.Content 
          }; 

          messageList.Add(messageHelper); 
         } 

         responseDelegate(response, messageList); 
        }); 
      }); 
    }); 

я его здесь кого-то другого, кто делает сдвиг. Идея состоит в том, что вам нужно иметь все собранные и отфильтрованные данные перед тем, как начать итерацию и собрать окончательный результат для отправки.

Answer 1

Отвечая на мой вопрос в контексте наличия аналогий запросов C#/Linq DB к NodeJS/Mongo. Какое-то отображение «мышления». Это в основном просто для понимания сдвига. Правильной реализацией будет использование шаблонов (библиотеки), таких как Promise/Deffered, как это предлагается в комментариях к вопросу от @WiredPrairie.

// collect needed info to make next queries in db 
var messageIdList = new Array(); 
var jokeMessageIdList = new Array(); 
var sourceUserIdList = new Array(); 
for(var i=0; i < messagesToAsk.length; i++) 
{ 
    messageIdList.push(messagesToAsk[i].MessageId  ); 
    jokeMessageIdList.push(jokeMessageId[i].JokeMessageId ); 
    sourceUserIdList .push(jokeMessageId[i].SourceUserId ); 
} 

// make requests to have all the data in place 
var messages = App.DataModels.Messages.find({}); 
    messages.where('MessageId').in(messageIdList); 
    messages.exec(function (err, foundMessages) 
    { 
     var jokeMessages = App.DataModels.Messages.find({}); 
      jokeMessages.where('JokeMessageId').in(jokeMessageIdList); 
      jokeMessages.exec(function (err, foundJokeMessages) 
      { 
       var users = App.DataModels.Messages.find({}); 
        users.where('SourceUserId').in(sourceUserIdList); 
        users.exec(function (err, foundUsers) 
        { 
         var messageList = new Array(); // new List<MessageHelper>(); 

         for(var i=0; i < messagesToAsk.length; i++) 
         { 
          var message  = null; 
          var jokeMessage = null; 
          var user  = null; 

          // get the data 
          for(var j = 0; j < messages.length; j++) 
          { 
           if(messages[j].MessageId === messagesToAsk[i].MessageId) 
           { 
            message = messages[j]; 
            break; 
           } 
          } 
          for(var k = 0; k < jokeMessages.length; k++) 
          { 
           if(jokeMessages[k].JokeMessageId === messagesToAsk[k].JokeMessageId) 
           { 
            jokeMessage = jokeMessage[k]; 
            break; 
           } 
          } 
          for(var l = 0; l < users.length; l++) 
          { 
           if (users[l].SourceUserId === messagesToAsk[l].SourceUserId) 
           { 
            user = users[l]; 
            break; 
           } 
          } 

          var messageHelper = 
          { 
           "AskingUserId" : user.Id, 
           "AskingUserPic" : user.HelperPhoto, 
           "Message"  : message, 
           "JokeMessage" : message.Type === "1" ? jokeMessage.Content 
          }; 

          messageList.Add(messageHelper); 
         } 

         responseDelegate(response, messageList); 
        }); 
      }); 
    });