分享：异步批量操作数据库的处理

Dduyinghua发布于14 年前最后回复13 年前|14 回复11901 浏览0 收藏

最近写数据库批量插入数据的时候遇到了一个异步编程之痛的问题，就是数据库操作都是异步回调的，那么就没有办法用for循环来操作了，思考了一下，看来只能利用迭代循环了，举例分享一下,希望高手提提意见，小白小心一下。

exports.saveBatch = function saveBatch(basicInfos, callback) {
    executeFunc(basicInfos, 0, [], callback);
}
function executeFunc(basicInfos, count, errs, callback) {//errs是个错误信息收集器，最后统一返回错误信息集合
    if (count == basicInfos.length) {
        callback(errs);
    } else {
        basicInfos[count].save(function (err) {
            count++;
            err && errs.push(err.message);
            executeFunc(basicInfos, count, errs, callback);
        });
    }
}

查看回复

ym1623#1·13 年前

你可以考虑用async或Jscex

a272121742#2·13 年前

使用外围标记，在for循环中使用代码段标记判断即可，形如：

    var flag = 0;
    var datas = [.........................];
    for(var i =0; i < datas.length; i++){
        save(datas[i],function(){
            if(i == ++flag){
                callback();
            }
        });
    }

duyinghua#3·13 年前

引用 a272121742使用外围标记，在for循环中使用代码段标记判断即可，形如：

这个不错

chloe#4·13 年前

引用 a272121742使用外围标记，在for循环中使用代码段标记判断即可，形如：

这个也是有问题的，如果save的 callback被立即执行，callback将不被执行

JacksonTian#5·13 年前

数据都不依赖，这样串行执行没意义啊。

JacksonTian#6·13 年前

有异步流控问题，找EventProxy

https://github.com/JacksonTian/eventproxy

a272121742#7·13 年前

引用 a272121742使用外围标记，在for循环中使用代码段标记判断即可，形如：

@chloe have a try ok？这里的比较微妙之处就是括号的用法

chloe#8·13 年前

引用 a272121742使用外围标记，在for循环中使用代码段标记判断即可，形如：

@a272121742

考虑下面这样的情况 `

function save(data,callback){

console.log(data); callback(); }

function callback(){ console.log("callback"); } var flag = 0; var datas = [1]; for(var i =0; i < datas.length; i++){ save(datas[i],function(){ if(i == ++flag){ callback(); } }); }

`这上面写法会导致callback不能被调用

hexie#9·13 年前

请关注 async.eachForSeries. 不知道有没拼写错误。

a272121742#10·13 年前

引用 a272121742使用外围标记，在for循环中使用代码段标记判断即可，形如：

@chloe 书写错误，如果flag初始值为0，使用flag++判断，如果为1，使用++flag判断

halfblood#11·13 年前

这样的批量操作肯定对性能有很大影响，弄不好网络还给堵死了。最好是运用数据库提供的批量操作，比如说pipe，或者合并sql，批量执行。

duyinghua#12·13 年前

引用 halfblood这样的批量操作肯定对性能有很大影响，弄不好网络还给堵死了。最好是运用数据库提供的批量操作，比如说pipe，或者合并sql，批量执行。

能详细介绍下如何使用pipe吗？

halfblood#13·13 年前