如何在深度嵌套的 MongoDB 文档中保存删除内容

Question

我是 MongoDB 新手，我正在使用 MongoDB shell 来执行操作。 我正在努力从所有项目中删除名为 Process 的数组，但似乎我没有正确掌握删除概念。 我们使用的文档是深度嵌套的 - 我们不知道有多少项，也不知道嵌套的级别有多深。
到目前为止我尝试的是使用递归来迭代项目：

    function removeAllProcessFields(docItems)
    {
        if(Array.isArray(docItems))
        {
            docItems.forEach(function(item)
                {
                   print("idItem: "+item._id);
                   if(item.Process == null)
                   {
                      print("Process null");
                   }
                   else
                   {
                      $unset: { Process: ""}
                   }
                   removeAllProcessFields(item.Items);
            })
        }
    }
    
    var docs = db.getCollection('MyCollection').find({})
    docs.forEach(function(doc)
    {
        print("idDoc: "+doc._id);
        removeAllProcessFields(doc.Items);
    })

但是我在正确使用 unset 来保存操作方面遇到困难。
示例文档是：

    {
        "_id": "622226d319517e83e8ed6151",
        "Name": "test1",
        "Description": "",
        "Items": [{
            "_id": "622226d319517e83e8ed614e",
            "Name": "test-item",
            "Description": "",
            "Process": [{
                "Name": "Step1"
            }, {
                "Name": "Step2"
            }],
            "Items": [{
                    "_id": "622226d319517e83e8ed614f",
                    "Name": "test-subItem1",
                    "Description": "",
                    "Process": [{
                        "Name": "StepSub1"
                    }, {
                        "Name": "StepSub2"
                    }, {
                        "Name": "StepSub3"
                    }],
                    "Items": []
                },
                {
                    "_id": "622226d319517e83e8ed6150",
                    "Name": "test-subItem2",
                    "Description": "",
                    "Process": [{
                        "Name": "StepSub4"
                    }, {
                        "Name": "StepSub5"
                    }, {
                        "Name": "StepSub6"
                    }],
                    "Items": []
                }
    
            ]
        }]
    }

我希望实现的目标是：

    {
        "_id": "622226d319517e83e8ed6151",
        "Name": "test1",
        "Description": "",
        "Items": [{
            "_id": "622226d319517e83e8ed614e",
            "Name": "test-item",
            "Description": "",
            "Items": [{
                    "_id": "622226d319517e83e8ed614f",
                    "Name": "test-subItem1",
                    "Description": "",
                    "Items": []
                },
                {
                    "_id": "622226d319517e83e8ed6150",
                    "Name": "test-subItem2",
                    "Description": "",
                    "Items": []
                }
    
            ]
        }]
    }

Answer 1

像这样的东西可能使用 $[] 位置运算符：

db.collection.update({},
{
 $unset: {
  "Items.$[].Items.$[].Process": 1,
  "Items.$[].Process": 1
}
})

您只需要在递归中构造它...

playground< /a>

JavaScript 递归函数示例：

 mongos> db.rec.find()
{ "_id" : ObjectId("622a6c46ae295edb276df8e2"), "Items" : [ { "a" : 1 }, { "Items" : [ { "Items" : [ { "Items" : [ ], "Process" : [ 1, 2, 3 ] } ], "Process" : [ 4, 5, 6 ] } ], "Process" : [ ] } ] }

 mongos> db.rec.find().forEach(function(obj){ var id=obj._id,ar=[],z=""; function x(obj){ if(typeof obj.Items != "undefined" ){ obj.Items.forEach(function(k){ if( typeof k.Process !="undefined" ){ z=z+".Items.$[]";ar.push(z.substring(1)+".Process") }; if(typeof k.Items != "undefined"){x(k)}else{}  }) }else{}  };x(obj);ar.forEach(function(del){print( "db.collection.update({_id:ObjectId('"+id+"')},{$unset:{'"+del+"':1}})" );}) })

 db.collection.update({_id:ObjectId('622a6c46ae295edb276df8e2')},{$unset:{'Items.$[].Process':1}})
 db.collection.update({_id:ObjectId('622a6c46ae295edb276df8e2')},{$unset:{'Items.$[].Items.$[].Process':1}})
 db.collection.update({_id:ObjectId('622a6c46ae295edb276df8e2')},{$unset:{'Items.$[].Items.$[].Items.$[].Process':1}})
 mongos> 

解释：

1. 使用 forEach 循环遍历集合中的所有文档
2. 定义递归函数 x，它将循环遍历任意数量的嵌套 Items 并确定是否存在 Process 字段并推送到数组ar
3. 最后循环数组 ar 并构造更新 $unset 查询，在示例中仅出于安全原因打印，但您可以改进为每个文档生成单个查询并执行 unset 查询...

Answer 2

假设您在 v>=4.4 上，您可以使用 $merge 的“合并到自身”功能，并定义一个递归函数来扫描集合并通过外科手术删除任何级别的一个或一组字段的层次结构。当处理也是任意分层的 json-schema 数据时，也会出现同样的需求。

下面的解决方案具有额外的逻辑来“标记”进行过任何修改的文档，以便可以从传递给 $merge 的更新集中删除其他。还可以进一步细化，减少一些变量；它是从一个更通用的解决方案中编辑而来的，该解决方案必须检查键和值。

db.foo.aggregate([
    {$replaceRoot: {newRoot: {$function: {
        body: function(obj, target) {
            var didSomething = false;

            var process = function(holder, spot, value) {
                // test FIRST since [] instanceof Object is true!                           
                if(Array.isArray(value)) {
                    for(var jj = value.length - 1; jj >= 0; jj--) {
                        process(value, jj, value[jj]);
                    }
                } else if(value instanceof Object) {
                    walkObj(value);
                }
            };

            var walkObj = function(obj) {
                Object.keys(obj).forEach(function(k) {
                    if(target.indexOf(k) > -1) {
                        delete obj[k];
                        didSomething = true;
                    } else {
                        process(obj, k, obj[k]);
                    }
                });
            }

            // ENTRY POINT:      
            if(!Array.isArray(target)) {
                target = [ target ]; // if not array, make it an array
            }
            walkObj(obj);

            if(!didSomething) {
                obj['__didNothing'] = true;
            }

            return obj;
        },

        // Invoke!
        // You can delete multiple fields with an array, e.g.:
        //   ..., ['Process','Description']
        args: [ "$ROOT", 'Process' ],

        lang: "js"
        }}
    }}

    // Only let thru docs WITHOUT the marker:
    ,{$match: {'__didNothing':{$exists:false}} }

    ,{$merge: {
        into: "foo",
        on: [ "_id" ],
        whenMatched: "merge",
        whenNotMatched: "fail"
    }}

]);