保存更新的模型到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接受单个实例，您必须遍历用户并保存每个实例。猫鼬没有实施批量插入（参见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; 
}