Mongoose：插入一个依赖于另一个集合的集合

Question

我需要在两个集合中插入记录。第二个集合存储第一个集合的记录 ID。这是一个 1:m (first:second) 的情况。触发器是第二个集合：

1. 如果需要存储第二个集合的记录
2. 检查第一个集合中是否已有拟合记录
3. 如果不是：则在第一个集合中保存一个
4. 存储第二个集合
5. 将第一个集合的记录id保存到第二个集合中

以下示例似乎完成了这些步骤。但我的承诺只有一半。 如何以更好的“承诺”方式做到这一点？

saveObjects(name: String, objects: Array<IObject>){

        var promise = FirstModel.findOne({Name : name}).exec();
        promise.then(function(res1){
            if (!res1){
                var la = new FirstModel();
                la.Name = name;
                la.save(function(err){
                    if (err) throw err;
                })
            }
        }).error(function(err){
            throw err;
        })

        objects.forEach(function(obj) {
            FirstModel.findOne({Name : name},'_id',function(err, res2){
                if (err) throw err;

                var vo = new SecondModel();
                vo.Name = name;
                vo.FistID = res2._id;

                vo.save(function(err){
                    if (err) throw err;
                });
            });
        });

}

Answer 1

我在这里假设您使用的是 bluebird 或其他等效的 Promise 设置。

var Promise = require('bluebird');
saveObjects(name: String, objects: Array < IObject > ) {

    // Get the first model
    return FirstModel
        .findOne({
            Name: name
        })
        .exec()
        .then(function (res1) {
            if (!res1) {
                var la = new FirstModel();
                la.Name = name;
                return la.save() // We return the save operation on the model, save() returns a promise
            }

            // We just return the model normally so it passes down the chain.
            return res1;
        })
        .then(function (res1) {
            // Here we use Promise.all() method on bluebird which accepts an Array
            // of promises, we create a promise from the objects array by using Array.map() which
            // goes through every object in the array and creates a new array. 
            return Promise
                .all(objects.map(function (obj) {
                    // We go through each object in objects and create a new 
                    // model and return the save() method of each model, this
                    // creates a array of promises which are resolved when each
                    // all model has been saved.
                    var vo = new SecondModel();
                    vo.Name = name;
                    vo.FistID = res1._id;

                    return vo.save();
                }));
        })
        .then(function (models) {
            // here we have all the models we just saved in an array called models,
            // do what you want with it.
        })
        .error(function (err) {
            throw err;
        })
}

有关更多信息，请参阅有关 Array.map() here 和 Promise.all() here 的文档