node-mongoskin如何批量添加？

[skynothing]

因node-mongoskin是异步操作的，当我如下执行批量杯具就出现了：
for(var i=0;i<results.length;i++){
var result=results[i];
var name=result['name']
db.user.findOne({'name':name},function (err,user_result) {
if(user_result==null){
db.user.insert({'name':name});
}
});
｝

运行结果是：如果有10条记录就会在数据库添加了10条最后一个name相同的记录。

[ljbha007]

这个不是node-mongoskin的问题 这是javascript闭包的问题 var name 最终的值是results最后一个name所以所有的回调函数能访问到的name变量都变成了 results里边最后一个name

比如
var arr = ['a', 'b', 'c', 'd']
for (var i = 0; i< arr.length;i++){
var r = arr[i];
setTimeout(function(){console.log(r)}, 500);
}
最后结果是4个d

你把db.user.insert({'name':name});换成db.user.insert({'name':user_result['name']});就好了
虽然不是干净 但是能解决问题

[skynothing]

@ljbha007 你的意思我明白了。不过你的回答还是没解决问题。

[ljbha007]

@skynothing

for(var i=0;i<results.length;i++){
var result=results[i];
var name=result['name']
function makeCallback(val){
return function (err,user_result) {
if(user_result==null){
db.user.insert({'name':val});
}
}
}
db.user.findOne({'name':name},makeCallback(name));
｝

[skynothing]

@ljbha007 太牛了。谢谢！

[fanwei]

不用for循环，用map之类的函数来遍历，代码改动较小，你也比较好理解
results.map(function(){
var name=result['name']
db.user.findOne({'name':name},function (err,user_result) {
if(user_result==null){
db.user.insert({'name':name});
}
});
});

[fanwei]

少写了个result

results.map(function(result){
var name=result['name']
db.user.findOne({'name':name},function (err,user_result) {
if(user_result==null){
db.user.insert({'name':name});
}
});
});

[ljbha007]

@fanwei 原来是这样 学习了

[skynothing]

@fanwei 高手呀。。学习

[jinwyp]

// Bulk update
app.put('/api/products', function (req, res) {
var i, len = 0;
console.log("is Array req.body.products");
console.log(Array.isArray(req.body.products));
console.log("PUT: (products)");
console.log(req.body.products);
if (Array.isArray(req.body.products)) {
len = req.body.products.length;
}
for (i = 0; i < len; i++) {
console.log("UPDATE product by id:");
for (var id in req.body.products[i]) {
console.log(id);
}
ProductModel.update({ "_id": id }, req.body.products[i][id], function (err, numAffected) {
if (err) {
console.log("Error on update");
console.log(err);
} else {
console.log("updated num: " + numAffected);
}
});
}
return res.send(req.body.products);
});

[heroicYang]

mongoskin支持批量插入的...为嘛要each、要map？ https://github.com/kissjs/node-mongoskin#insertdocs-options-callback

[skynothing]

@heroicYang 请问有例子吗？没看懂。

[heroicYang]

@skynothing 第一个参数是你要插入的文档对象（或数组），第二个参数是一些可选项，如果想在第三参数即回调函数 callback 中取到插入的文档，可选项中请传入 { safe: true }。这样 callback 会传入两个参数：err 和 records，records即为插入之后的文档对象数组。