mongodb更新shell命令应该是什么答案

【问题标题】：what should be the mongodb update shell commandmongodb更新shell命令应该是什么
【发布时间】：2015-12-25 19:21:18
【问题描述】：

这是我收藏中的一份文件

{   
    "_id": ObjectId("55e86e98f493590878bb45d7"),
    "KIDS_M_0_2" : "",
    "KIDS_F_0_2" : "",
    "KIDS_U_0_2" : "Y",
    "KIDS_M_3_5" : "",
    "KIDS_F_3_5" : "",
    "KIDS_U_3_5" : "Y",
    "KIDS_M_6_10" : "",
    "KIDS_F_6_10" : "",
    "KIDS_U_6_10" : "",
    "KIDS_M_11_15" : "",
    "KIDS_F_11_15" : "",
    "KIDS_U_11_15" : "",
    "KIDS_M_16_17" : "",
    "KIDS_F_16_17" : "",
    "KIDS_U_16_17" : "Y"
}

我希望这样

{
    "_id":ObjectId("55e86e98f493590878bb45d7"),
    "KIDS": { "KIDS_M_0_2" : "",
    "KIDS_F_0_2" : "",
    "KIDS_U_0_2" : "Y",
    "KIDS_M_3_5" : "",
    "KIDS_F_3_5" : "",
    "KIDS_U_3_5" : "Y",
    "KIDS_M_6_10" : "",
    "KIDS_F_6_10" : "",
    "KIDS_U_6_10" : "",
    "KIDS_M_11_15" : "",
    "KIDS_F_11_15" : "",
    "KIDS_U_11_15" : "",
    "KIDS_M_16_17" : "",
    "KIDS_F_16_17" : "",
    "KIDS_U_16_17" : "Y"
}

这可以通过 shell 完成吗，我的更新命令应该是什么。 ?

【问题讨论】：

标签： javascript mongodb mongodb-query

【解决方案1】：

实际上，您需要的不仅仅是简单的命令。

您需要使用.forEach() 方法循环通过.find() 方法返回的游标，然后使用字段名称及其值创建一个新对象“kids”。接下来要做的是$unset 所有字段并使用$set 运算符创建新字段。当然，要做到这一点，您需要使用 "bulk"¹ 操作以获得最大效率。

var bulk = db.collection.initializeUnorderedBulkOp();
var count = 0; 

db.collection.find().forEach(function(doc) {
    var kids = {}; 
    for(key in doc) {
        if(key != '_id' && Object.prototype.hasOwnProperty.call(doc, key)) {
            kids[key] = doc[key];
            var unset = {};         
            unset[key] = '';         
            bulk.find( { '_id': doc._id } ).updateOne( { '$unset': unset } );
            count++;    
        }        
        bulk.find( { '_id': doc._id } ).updateOne({ '$set': { 'KIDS': kids } } ); 
        if (count % 500 === 0) {
            bulk.execute();     
            bulk = db.collection.initializeUnorderedBulkOp(); 
        }
})

if (count > 0)  
    bulk.execute()

执行此操作后，您的文档如下所示：

{
        "_id" : ObjectId("567d99bcbc08a0817a1b06dd"),
        "KIDS" : {
                "KIDS_M_0_2" : "",
                "KIDS_F_0_2" : "",
                "KIDS_U_0_2" : "Y",
                "KIDS_M_3_5" : "",
                "KIDS_F_3_5" : "",
                "KIDS_U_3_5" : "Y",
                "KIDS_M_6_10" : "",
                "KIDS_F_6_10" : "",
                "KIDS_U_6_10" : "",
                "KIDS_M_11_15" : "",
                "KIDS_F_11_15" : "",
                "KIDS_U_11_15" : "",
                "KIDS_M_16_17" : "",
                "KIDS_F_16_17" : "",
                "KIDS_U_16_17" : "Y"
        }
}

MongoDB 3.2 deprecates Bulk() 及其关联方法并提供.bulkWrite() 方法。

var operations = [];

db.collection.find().forEach(function(doc) { 
    var kids = {}; 
    for(var key in doc) { 
        if(!key.startsWith('_id') && Object.prototype.hasOwnProperty.call(doc, key)) { 
            kids[key] = doc[key];
            var unset = {};
            unset[key] = ''; 
            operations.push(
                { 'updateOne': 
                    { 
                        'filter': { '_id': doc._id } ,         
                        'update': { '$unset': unset } 
                    }             
                }         
            );    
        }     
        operations.push(         
            { 'updateOne':              
                { 
                    'filter': { '_id': doc._id } ,              
                    'update': { '$set': { 'KIDS': kids } } 
                }         
            }     
        ); 
    } 
    operations.push( { 'ordered': true } ); 
})

db.collection.bulkWrite(operations)

^{1.Bulk() API 是 2.6 版的新功能。因此，如果您使用的是旧版本，则应考虑升级}

【讨论】：