[mongodb] 다른 필드의 값을 사용하여 MongoDB 필드 업데이트

이 작업을 수행하는 가장 좋은 방법은 업데이트 문서와의 통합 파이프 라인의 사용 할 수 있습니다 버전 4.2 이상에 updateOne, updateMany또는 update수집 방법. 후자는 모든 언어 드라이버가 아니라면 대부분 더 이상 사용되지 않습니다.

MongoDB 4.2 이상

버전 4.2에는 $set에 대한 별칭 인 파이프 라인 단계 연산자 도 도입 되었습니다 $addFields. 나는 우리가 달성하려고하는 것과 매핑 될 때 $set여기에서 사용할 것 입니다.

db.collection.<update method>(
    {},
    [
        {"$set": {"name": { "$concat": ["$firstName", " ", "$lastName"]}}}
    ]
)

몽고 DB 3.4+

3.4+에서는 $addFields및 $out집계 파이프 라인 연산자를 사용할 수 있습니다 .

db.collection.aggregate(
    [
        { "$addFields": {
            "name": { "$concat": [ "$firstName", " ", "$lastName" ] }
        }},
        { "$out": "collection" }
    ]
)

이렇게하면 컬렉션 이 업데이트되지 않고 기존 컬렉션을 교체하거나 새 컬렉션을 만듭니다. 또한 “유형 캐스팅” 이 필요한 업데이트 작업에는 클라이언트 쪽 처리가 필요 하며 작업에 따라 find()메서드 대신 메서드 를 사용해야합니다 .aggreate().

MongoDB 3.2 및 3.0

이를 수행하는 방법은 $project문서를 ing하고 $concat문자열 집계 연산자를 사용 하여 연결된 문자열을 반환하는 것입니다. 거기에서 우리는, 당신은 다음 반복 커서를 하고 사용 $set하여 문서에 새로운 필드를 추가하는 업데이트 연산자를 대량 작업을 최대 효율을 위해.

집계 쿼리 :

var cursor = db.collection.aggregate([
    { "$project":  {
        "name": { "$concat": [ "$firstName", " ", "$lastName" ] }
    }}
])

MongoDB 3.2 이상

이로부터 bulkWrite메소드 를 사용해야합니다 .

var requests = [];
cursor.forEach(document => {
    requests.push( {
        'updateOne': {
            'filter': { '_id': document._id },
            'update': { '$set': { 'name': document.name } }
        }
    });
    if (requests.length === 500) {
        //Execute per 500 operations and re-init
        db.collection.bulkWrite(requests);
        requests = [];
    }
});

if(requests.length > 0) {
     db.collection.bulkWrite(requests);
}

MongoDB 2.6 및 3.0

이 버전에서는 더 이상 사용되지 않는 BulkAPI 및 관련 메소드 를 사용해야합니다 .

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

cursor.snapshot().forEach(function(document) {
    bulk.find({ '_id': document._id }).updateOne( {
        '$set': { 'name': document.name }
    });
    count++;
    if(count%500 === 0) {
        // Excecute per 500 operations and re-init
        bulk.execute();
        bulk = db.collection.initializeUnorderedBulkOp();
    }
})

// clean up queues
if(count > 0) {
    bulk.execute();
}

MongoDB 2.4

cursor["result"].forEach(function(document) {
    db.collection.update(
        { "_id": document._id },
        { "$set": { "name": document.name } }
    );
})

답변

db.person.find().snapshot().forEach(
    function (elem) {
        db.person.update(
            {
                _id: elem._id
            },
            {
                $set: {
                    name: elem.firstname + ' ' + elem.lastname
                }
            }
        );
    }
);

db.person.find().snapshot().forEach( function (hombre) {
    hombre.name = hombre.firstName + ' ' + hombre.lastName;
    db.person.save(hombre);
});

db.person.find().forEach(
    function (elem) {
        db.person.update(
            {
                _id: elem._id
            },
            {
                $set: {
                    name: elem.firstname + ' ' + elem.lastname
                }
            }
        );
    }
);

// { firstName: "Hello", lastName: "World" }
db.collection.update(
  {},
  [{ $set: { name: { $concat: [ "$firstName", " ", "$lastName" ] } } }],
  { multi: true }
)
// { "firstName" : "Hello", "lastName" : "World", "name" : "Hello World" }

MongoClient.connect("...", function(err, db){
    var c = db.collection('yourCollection');
    var s = c.find({/* your query */}).stream();
    s.on('data', function(doc){
        c.update({_id: doc._id}, {$set: {name : doc.firstName + ' ' + doc.lastName}}, function(err, result) { /* result == true? */} }
    });
    s.on('end', function(){
        // stream can end before all your updates do if you have a lot
    })
})