Най-добрият начин да направите това е във версия 4.2+, която позволява използването на конвейер за агрегиране в актуализация документ и updateOne
, updateMany
или update
методи за събиране. Имайте предвид, че последният е отхвърлен в повечето, ако не и всички драйвери за езици.
MongoDB 4.2+
Версия 4.2 също въведе $set
оператор етап на конвейера, който е псевдоним за $addFields
. Ще използвам $set
тук, тъй като картира с това, което се опитваме да постигнем.
db.collection.<update method>(
{},
[
{"$set": {"name": { "$concat": ["$firstName", " ", "$lastName"]}}}
]
)
Обърнете внимание, че квадратните скоби във втория аргумент на метода, който дефинира конвейер за агрегиране вместо обикновен документ за актуализиране. Използването на обикновен документ не работи правилно.
MongoDB 3.4+
В 3.4+ можете да използвате $addFields
и $out
оператори на тръбопроводи за агрегация.
db.collection.aggregate(
[
{ "$addFields": {
"name": { "$concat": [ "$firstName", " ", "$lastName" ] }
}},
{ "$out": "collection" }
]
)
Имайте предвид, че това не актуализира вашата колекция, а вместо това замества съществуващата колекция или създава нова. Също така за операциите за актуализиране, които изискват „typecasting“ ще ви е необходима обработка от страна на клиента, и в зависимост от операцията може да се наложи да използвате find()
метод вместо .aggreate()
метод.
MongoDB 3.2 и 3.0
Начинът, по който правим това е чрез $project
като използваме нашите документи и използваме $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
От тази версия трябва да използвате вече оттегления Bulk
API и свързаните с него методи.
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 } }
);
})