MongoDB
 sql >> Base de données >  >> NoSQL >> MongoDB

Requêtes multiples dans la requête mongodb

Le comportement de Node.js est asynchrone, le programmeur doit coder en tenant compte de ce comportement. Utilisez des rappels ou des promesses ou une bibliothèque de contrôle de flux. Dans votre programme, vous avez placé la requête mongo dans la boucle, ce qui est une mauvaise approche de l'interrogation. Au lieu de cela, si vous interrogez plusieurs fois, utilisez l'opérateur $in. Cela optimisera les performances de votre code et résoudra également votre problème d'envoi de réponse.

var resultSet = [];
        db.get('busstopcollection').find({id_bus_stop: parseInt(req.body.busstopid)}, function(e, docs){
            if(e || docs.length === 0) {
                console.log("Sorry, wrong id.");
                return e;
            }
            var bus_ids = [];
            for(var m=0; m<docs.length; m++){
                var auxRes = {};
                auxRes.id_bus = docs[m].id_bus; 
                bus_ids.push(parseInt(docs[m].id_bus)); // collect all ids 
                auxRes.id_bus_stop = docs[m].id_bus_stop;
                auxRes.coord_x = docs[m].coord_x;
                auxRes.coord_y = docs[m].coord_y;               
                auxRes.id_bus_variation = docs[m].id_bus_variation;
                resultSet.push(auxRes);         

            }
            // Query at one time for all document 
            db.get('buscollection').find({id_bus: {$in : bus_ids}}).toArray( function(e, busDocs){
                    // Now find and merge in one go
                    busDocs.forEach(function(eachBusDoc){
                        for(var i=0,len = resultSet.length;i< len;i++){
                            if(resultSet[i].id_bus == busDocs.id_bus ){
                                resultSet[i].s_origin_description = eachBusDoc.s_origin_description;
                                resultSet[i].s_destination_description = eachBusDoc.id_destination_description;
                            }
                        }
                    });             
                       res.send(JSON.stringify(resultSet));
                });
        });