将更新的模型保存到 mongodb

Question

我有以下代码从 db (mongo) 中获取一些数据。

function getAllUsers(){
    var UsersPromise = Q.defer();

    UserSchema.find({}, function(err, data){
        if(err){
            UsersPromise .reject(err);
        }else {
            UsersPromise .resolve(data);
        }
    });
    return UsersPromise .promise;
}

然后我修改每个模型。我根据用户的类型将某些字段添加到模型中。 （这工作正常）。

function buildUsers(users){
    // my code iterates over users and adds
    // properties as required.
    // Working fine.
    return users; // updated users.
}

现在我想将这些更新的模型保存回 mongo，这就是让我抓狂的地方。

function saveUsers(users){
    // here, the users are received correctly. But the following line to save the users fails.
    var SaveUsersPromise = Q.defer();
    UserSchema.save(users, function(err, data){
        if(err){
            SaveUsersPromise .reject(err);
        } else {
            SaveUsersPromise .resolve(data);
        }
    });
    return SaveUsersPromise .promise;
}

最后我将这些函数称为：

DB.connect()
.then(getAllUsers)
.then(buildUsers)
.then(saveUsers)
.catch(errorHandler);

在我致电UserSchema.save 之前，一切正常。可能是什么问题？

PS：我使用的是mongoose。

TIA。

Answer 1

UserSchema.save 接受单个实例，您必须遍历用户并保存每个实例。 Mongoose 尚未实现批量插入（请参阅 issue #723）。

这里是使用async.eachSeries的简单实现

function saveUsers(users){
    var async = require('async');  // <== npm install async --save
    var SaveUsersPromise = Q.defer();
    async.eachSeries(users, function(user, done){
        UserSchema.save(user, done);
        // or
        user.save(done); // if user is Mongoose-document object
    }, function(err){
        if(err){
            SaveUsersPromise.reject(err);
        } else {
            SaveUsersPromise.resolve();
        }
    });
    return SaveUsersPromise.promise;
}