如何连接来自 MongoDB 中两个集合的数据？

Question

我正在 MEAN.js 样板上开发一些应用程序，但我遇到了一个我自己无法解决的问题 :( 我有以下数据库方案：

var UserSchema = new Schema({
    profession: {
        type: Schema.ObjectId,
        ref: 'Profession'
    },
    game: {
        type: Schema.ObjectId,
        ref: 'Game'
    }
};

var ProfessionSchema = new Schema({
    assignedTaskCategories: [{
        type: Schema.ObjectId,
        ref: 'TaskCategory'
    }]
});

var TaskCategorySchema = new Schema({
    professions: [{
        type: Schema.ObjectId,
        ref: 'Profession'
    }],
    assignedToGame: {
        type: Schema.ObjectId,
        ref: 'Game'
    }
});

var TaskSchema = new Schema({
    game: {
        type: Schema.ObjectId,
        ref: 'Game'
    },
    inCategories: [{
        type: Schema.ObjectId,
        ref: 'TaskCategory'
    }]
});

现在我想获取所有任务，它们在inCategories 中有一些元素，与用户的职业任务类别数组相同。 我试过了，但它什么也没返回

Profession.find({ _id: req.user.profession }).exec(function(err, userCategories) {
        if(err) {
            return res.status(400).send({
                message: errorHandler.getErrorMessage(err)
            });
        } else {
            Task.find({ game: req.user.game, inCategories: userCategories.assignedTaskCategories}).exec(function(err, tasks) {
                if(err) {
                    return res.status(400).sed({
                        message: errorHandler.getErrorMessage(err)
                    });
                } else {
                    res.json(tasks);
                }
            });
        }
    });

谁能帮我解决这个问题？ :) 如果我的方法不好，请告诉我如何解决它的正确方法:)

编辑

我们不能使用$setEquals，因为数组不一样，考虑下面的例子：

职业程序员能够解决以下任务类别： 编程、演示、洗碗

职业秘书能够解决以下任务类别： 演示、洗碗

然后我们将创建一个任务，分配到类别：洗碗，所以职业assignedCategories数组更大，不等于任务的inCategories数组。

Answer 1

尝试使用 aggregation framework 在其中使用 $setEquals 运算符来比较数组。在以下管道中，运算符确定 Tasks 的 inCategories 数组和 assignedTaskCategories 数组是否包含相同的元素：

Profession.find({ _id: req.user.profession }).exec(function(err, userCategories) {
    if(err) {
        return res.status(400).send({
            message: errorHandler.getErrorMessage(err)
        });
    } else {
        var pipeline = [
            {
                "$match": { "game": req.user.game }
            },
            {
                "$project": { 
                    "game": 1, 
                    "inCategories": 1, 
                    "sameElements": { 
                        "$setEquals": [ "$inCategories", userCategories[0].assignedTaskCategories ] 
                    }
                }
            },
            {
                "$match": { "sameElements": true }
            }
        ];
        Task.aggregate(pipeline)
            .exec(function (err, tasks){
                if(err) {
                    return res.status(400).sed({
                        message: errorHandler.getErrorMessage(err)
                    });
                } else {
                    res.json(tasks);
                }
        });

    }
});