mysql - Mongoose 在数据库写入之前调用保存回调？

Question

我将 mongoose 与 Node 一起使用，我有一些功能允许用户上传 CSV 数据，然后将数据放入 mongo。

我正在尝试防止上传重复的用户名。为了缓解这种情况，我调用了 findOne 并在将条目保存到数据库之前查找用户名，如果找到用户名，它应该调用异步的 callback() 并进入下一次迭代。

我有一个保存回调，我希望它只在数据在数据库中时被调用，在这个回调中我调用了 callback()。

从我的控制台日志中，每个重复的 findOne 都显示为空，但数据实际上正在写入数据库(如果我尝试在 csv 中上传更多重复项，一切都会按预期工作)。

这几乎就像是在数据库写入实际发生之前调用了保存回调，所以下一次调用没有找到重复项，我对 mongo 如何写入数据库有一些根本性的误解，还是我忽略了一些明显的东西...

admin.post('/upload', function(req, res) {
if(req.files.file) {
    var file = req.files.file;

    fs.readFile(file.path, 'utf8', function(err, data) {
        if(err) return res.json({error: err});

        csv.parse(data, function(err, parsed) {
            // remove header
            if(!parsed) {
                return;
            }

            parsed.splice(0, 1);

            var headers = ['auth', 'sid', 'fl', 'dd'];

            async.each(parsed, function(row, callback) {
                var seed = {};

                for(var i = 0; i < 4; i++) {
                    if(row[i] && row[i].trim() !== '') {
                        seed[headers[i]] = row[i].trim();
                    }
                }

                if(seed.user && seed.password) {
                    User.findOne({username: seed.user}, function(err, result) {
                        if(err) {
                            console.log(err);
                            return res.json({error: err});
                        }

                        console.log(result);

                        if(!result) {
                            console.log('creating user');
                            var user = new User({
                                username: seed.user,
                                password: User.generateHash(seed.password),

                            });

                            user.save(function(err) {
                                if(err){
                                    return res.json({error: err});
                                }

                                console.log('SAVED CALLING CB');
                                callback();
                            });
                        } else {
                            callback();
                        }
                    });
                } else {
                    callback();
                }
            }, function() {
                return res.json({success: true});
            });
        });
    });
}
});

Answer 1

你可能在那里遇到了竞争条件，这似乎是因为你说你的脚本在第二次运行时工作。

因为 async.each 并行运行，如果重复的用户名在 CSV 文件中彼此相邻的行中，则可能之前进行了两次 findOne 调用第一个 save 是。

我建议您使用唯一索引在数据库上强制执行唯一性。它还会更高效(每个用户只需访问一次数据库)，并且您只需处理唯一约束错误。