sql >> Databáze >  >> NoSQL >> MongoDB

Mongodb, souhrnný dotaz s $lookup

Pro jakýkoli konkrétní osobní dokument můžete použít populate() fungovat jako

var query = mongoose.model("person").find({ "name": "foo" }).populate("projects.tags");

A pokud chcete hledat osoby, které mají nějakou značku s například 'MongoDB' nebo 'Node JS', můžete zahrnout možnost dotazu do populate() funkce přetížení jako:

var query = mongoose.model("person").find({ "name": "foo" }).populate({
    "path": "projects.tags",
    "match": { "en": { "$in": ["MongoDB", "Node JS"] } }
});

Pokud chcete, aby všechny tagy existovaly v "project.tags" pro všechny osoby je agregační rámec tou správnou cestou. Zvažte spuštění tohoto kanálu na sbírce osob a použití $lookup operátor k provedení levého spojení kolekce značek:

mongoose.model('person').aggregate([
    { "$unwind": "$projects" },
    { "$unwind": "$projects.tags" },
    {
        "$lookup": {
            "from": "tags",
            "localField": "projects.tags",
            "foreignField": "_id",
            "as": "resultingTagsArray"
        }
    },
    { "$unwind": "$resultingTagsArray" },
    {
        "$group": {
            "_id": null,
            "allTags": { "$addToSet": "$resultingTagsArray" },
            "count": { "$sum": 1 }
        }
    }
 ]).exec(function(err, results){
    console.log(results);
 })

Pro jakoukoli konkrétní osobu pak použijte $match potrubí jako první krok k filtrování dokumentů:

mongoose.model('person').aggregate([
    { "$match": { "name": "foo" } },
    { "$unwind": "$projects" },
    { "$unwind": "$projects.tags" },
    {
        "$lookup": {
            "from": "tags",
            "localField": "projects.tags",
            "foreignField": "_id",
            "as": "resultingTagsArray"
        }
    },
    { "$unwind": "$resultingTagsArray" },
    {
        "$group": {
            "_id": null,
            "allTags": { "$addToSet": "$resultingTagsArray" },
            "count": { "$sum": 1 }
        }
    }
 ]).exec(function(err, results){
    console.log(results);
 })

Další řešení, pokud používáte MongoDB verze>=2.6 nebo <=3.0, které nepodporují $lookup operátor má naplnit výsledky z agregace jako:

mongoose.model('person').aggregate([
    { "$unwind": "$projects" },
    { "$unwind": "$projects.tags" },    
    {
        "$group": {
            "_id": null,
            "allTags": { "$addToSet": "$projects.tags" }
        }
    }
 ], function(err, result) {
    mongoose.model('person')
    .populate(result, { "path": "allTags" }, function(err, results) {
        if (err) throw err;
        console.log(JSON.stringify(results, undefined, 4 ));
    });
});


  1. Co je nového v MongoDB 4.2

  2. Mongo pole A větší než pole B

  3. Rozšíření phpredis nefunguje, nelze načíst 'redis.so'

  4. Podpora transakcí v MongoDB