javascript - 在 Node 服务器上使用 mongoose 将分层 Node 从 json 文件保存到 mongodb 中

Question

我有一个包含类别列表的 JSON 文件:

"data": {
    "categories": [
        {
            "id": 1,
            "name": "Clothes",
            "children": [
                "Womens",
                "Mens",
                "Children",
                "Baby",
            ]
        },
        {
            "id": "13",
            "name": "Womens",
            "children": [
                "Womens Tops",
                "Womens Bottoms",
                "Womens Accessories",
            ]
        },
        {
            "id": "33",
            "name": "Womens Tops",
            "children": []
        },

在下面的代码中，我尝试/失败了遍历每个 Node 及其子 Node 以构建一个 path 变量，该变量也与 mongo 数据库中的数据一起存储:

for(var i in obj.data.categories) {
    var newCat = {
        name: obj.data.categories[i].name,
        children: obj.data.categories[i].children
    };
    //UPDATE OR CREATE
    Category.findOneAndUpdate({name:obj.data.categories[i].name},newCat,{upsert: true},
        function(err,cat) {
            if(err) { return handleError(res, err); }
            if(cat.children) {
                //BUILD CHILDREN PATHS
                for(var j=0;j<cat.children.length;j++) {
                    var newChildCat = { 
                        name: cat.children[j], 
                    };
                    newChildCat.path = cat.path ? cat.path+','+cat.name : cat.name;
                    Category.findOneAndUpdate({ name: newChildCat.name},newChildCat,{upsert: true},
                        function(childErr, newChildCat) {
                            if(childErr) { return handleError(res, childErr); }
                        }
                    );
                }
            }
        }
     );
}

但是，由于 javascript 异步运行，因此某些 Node 路径会在其父 Node 存储之前存储。

我在这方面仍然是个新手，正在寻找正确/最佳实践的方法来处理依赖于先前创建的对象的异步导入，如上所示。

Answer 1

使用async模块来执行此操作。您需要的函数是async.eachSeries

async.eachSeries(obj.data.categories, function(_cat, cb){
    var newCat = {...};

    Category.findOneAndUpdate({name:_cat.name},newCat,{upsert: true}, function(err,cat) {
        if(cat.children) {
          async.eachSeries(cat.children, function(_cat2, cb2){
            // the code like above with cb2()
          }, cb);
        } else {
          cb()
        }
    });

});