我正在尝试使用 Node js 在 mongodb 中的两个集合之间进行查询。

我在数据库中有这两个集合:

旅行

{               
    "_id":ObjectId("55a922531e35772c1b17d4a0"),
    "name":"trip_name",
    "waypoints":[
        "4c828999d8086dcb03877752",
        "4dd2ae657d8b4c6585f1a6fd",
        "4c59c3e4f346c928a8634dca"
    ],
    "line_points":[
        [
            42.850937,
            13.569256
        ],
        [
            42.85109,
            13.569377
        ],
        [
            42.851131,
            13.569225
        ]
    ],
    "time":"00:10:23",
    "distance":6.622,
    "hashKey":"object:8207"
};

兴趣点

{  
      "_id":"4c828999d8086dcb03877752",
      "type":"Feature",
      "geometry":{  
         "type":"Point",
         "coordinates":[  
            13.575249910354614,
            42.85484995890166
         ]
      },
      "properties":{  
         "title":"Lorenz Cafè",
         "id":"4c828999d8086dcb03877752",
         "poi-type":1,
         "category":"ristorazione",
         "subCategory":"Café",
         "categoryIds":"4bf58dd8d48988d16d941735",
         "marker-color":"#FF7519",
         "marker-size":"small",
         "marker-symbol":"restaurant",
         "indirizzo":"Piazza del Popolo, 5",
         "citta":"Ascoli Piceno",
         "regione":"Marche"
      }

通过路由，我确实根据该步骤的 id 进行查询，我希望该查询可以像这样恢复 json:

我想要的结果

{"_id":"55a922531e35772c1b17d4a0","name":"trip_name","waypoints":[{"4c828999d8086dcb03877752":{"title":"Lorenz Cafè","id":"4c828999d8086dcb03877752","category":"ristorazione","position":{"lat":42.85484995890166,"lng":13.575249910354614}}},{"4dd2ae657d8b4c6585f1a6fd":{"title":"Ottica Di Ferdinando","id":"4dd2ae657d8b4c6585f1a6fd","category":"negozi","position":{"lat":42.85485741498569,"lng":13.57675423240643}}},{"4c59c3e4f346c928a8634dca":{"title":"Leopoldus Ristorante","id":"4c59c3e4f346c928a8634dca","category":"ristorazione","position":{"lat":42.85648980743132,"lng":13.575512766838072}}}],"line_points":[[42.850937,13.569256],[42.85109,13.569377],[42.851131,13.569225]],"time":"00:10:23","distance":6.622}

我实现了这条路线:

/*
TRIP BY ID
 */
var j=0;
router.get('/:id', function(req, res) {
    db = req.db;
    var idString=req.params.id;
    var objId = new ObjectID(idString);
    var collection2=db.get('poilist');
    var collection = db.get('trip');

    collection.find({"_id": objId},{},function(e,docs){
        var trip=docs[0];
        var poi=[];
        var wp=trip.waypoints;

        for(var i=0; i< wp.length; i++)
        {
            collection2.find({"properties.id": wp[i]},function(e,docs2){
                poi[j]={
                        "title" : docs2[0].properties.title,
                        "id": docs2[0].properties.id,
                        "category": docs2[0].properties.category,
                        "position": {"lat":docs2[0].geometry.coordinates[1], "lng":docs2[0].geometry.coordinates[0]}
                    };
                    var id = wp[j];
                    wp[j]= {};
                    wp[j][id]=poi[j];
                    if(j==wp.length-1){
                        console.log('emit '+j);
                        emitter.emit('attesa' + j);
                    }else{
                        j++;
                    }

            });
        }
        emitter.once('attesa'+ (trip.waypoints.length-1) ,function() {
            j=0;
            console.log('once');

            res.json(trip);
        });
    });
});

此路由有效，但如果您要同时调用多个电话，则不再有效。

我有一个想法:统计请求的数量，然后去仔细检查这个地方的id是否在这次旅行中但它似乎很昂贵。 我想知道一种更实用的方法来在 mongo 中对多个集合进行查询。 提前致谢

最佳答案

首先我推荐你使用 Mongoose 。首先你必须准备你的模型，例如:

var mongoose = require('mongoose')
  , Schema = mongoose.Schema

var personSchema = Schema({
  _id     : Number,
  name    : String,
  age     : Number,
  stories : [{ type: Schema.Types.ObjectId, ref: 'Story' }]
});

var storySchema = Schema({
  _creator : { type: Number, ref: 'Person' },
  title    : String,
  fans     : [{ type: Number, ref: 'Person' }]
});

var Story  = mongoose.model('Story', storySchema);
var Person = mongoose.model('Person', personSchema);

在此之后，当您想要“加入”时，您最常使用下一个方法:

Story.find().populate("fans");

为了摩尔http://mongoosejs.com/docs/populate.html

关于node.js - "Join"MongoDB中使用 Node js的两个集合，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/31480088/