Làm thế nào để thay thế chuỗi trong tất cả các tài liệu trong Mongo

Question

Tôi cần phải thay thế một chuỗi trong các tài liệu nhất định. Tôi đã googled mã này, nhưng nó không may thay đổi bất cứ điều gì. Tôi không chắc chắn về cú pháp trên dòng dưới đây:

pulpdb = db.getSisterDB("pulp_database"); 
var cursor = pulpdb.repos.find(); 
while (cursor.hasNext()) { 
    var x = cursor.next(); 
    x['source']['url'].replace('aaa', 'bbb'); // is this correct? 
    db.foo.update({_id : x._id}, x); 
} 

Tôi muốn thêm một số bản in gỡ lỗi để xem giá trị là gì, nhưng tôi không có kinh nghiệm với MongoDB Shell. Tôi chỉ cần phải thay thế này:

{ "source": { "url": "http://aaa/xxx/yyy" } } 

với

{ "source": { "url": "http://bbb/xxx/yyy" } } 

Answer 1

Nó không sửa thường: nếu bạn có chuỗi http://aaa/xxx/aaa (yyy tương đương với aaa), bạn sẽ kết thúc với http://bbb/xxx/bbb. Nhưng nếu bạn đồng ý với điều này, mã sẽ hoạt động.

Để thêm thông tin gỡ lỗi sử dụng print chức năng:

var cursor = db.test.find(); 
while (cursor.hasNext()) { 
    var x = cursor.next(); 
    print("Before: "+x['source']['url']); 
    x['source']['url'] = x['source']['url'].replace('aaa', 'bbb'); 
    print("After: "+x['source']['url']); 
    db.test.update({_id : x._id}, x); 
} 

(Và bằng cách này, nếu bạn muốn in ra đối tượng, đó cũng là printjson chức năng)

Answer 2

MongoDB có thể làm tìm kiếm chuỗi/thay thế qua mapreduce. Có, bạn cần phải có một cấu trúc dữ liệu rất đặc biệt cho nó - bạn không thể có bất cứ điều gì trong các phím trên cùng nhưng bạn cần phải lưu trữ tất cả mọi thứ dưới một subdocument dưới value. Như thế này:

{ 
    "_id" : ObjectId("549dafb0a0d0ca4ed723e37f"), 
    "value" : { 
      "title" : "Top 'access denied' errors", 
      "parent" : "system.admin_reports", 
      "p" : "\u0001\u001a%" 
    } 
} 

Một khi bạn đã này gọn gàng thiết lập bạn có thể làm:

$map = new \MongoCode("function() { 
    this.value['p'] = this.value['p'].replace('$from', '$to'); 
    emit(this._id, this.value); 
}"); 
$collection = $this->mongoCollection(); 
// This won't be called. 
$reduce = new \MongoCode("function() { }"); 
$collection_name = $collection->getName(); 
$collection->db->command([ 
    'mapreduce' => $collection_name, 
    'map' => $map, 
    'reduce' => $reduce, 
    'out' => ['merge' => $collection_name], 
    'query' => $query, 
    'sort' => ['_id' => 1], 
]); 

Answer 3

Cách tốt nhất để làm điều này nếu bạn đang ở trên MongoDB 2.6 hoặc phiên bản mới hơn được Looping trên đối tượng con trỏ bằng cách sử dụng .forEach phương pháp và cập nhật từng tài liệu usin "bulk" hoạt động để đạt hiệu quả tối đa.

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

db.collection.find().forEach(function(doc) { 
    print("Before: "+doc.source.url); 
    bulk.find({ '_id': doc._id }).update({ 
     '$set': { 'source.url': doc.source.url.replace('aaa', 'bbb') } 
    }) 
    count++; 
    if(count % 200 === 0) { 
     bulk.execute(); 
     bulk = db.collection.initializeOrderedBulkOp(); 
    } 

// Clean up queues 
if (count > 0) 
    bulk.execute(); 

---

Từ MongoDB 3.2 các Bulk() API và nó liên quan đến methods đang bị phản đối, bạn sẽ cần phải sử dụng các phương pháp db.collection.bulkWrite().

Bạn sẽ cần lặp qua con trỏ, tạo truy vấn động và $push mỗi hoạt động vào một mảng.

var operations = []; 
db.collection.find().forEach(function(doc) { 
    print("Before: "+doc.source.url); 
    var operation = { 
     updateOne: { 
      filter: { '_id': doc._id }, 
      update: { 
       '$set': { 'source.url': doc.source.url.replace('aaa', 'bbb') } 
      } 
     } 
    }; 
    operations.push(operation); 
}) 
operations.push({ 
    ordered: true, 
    writeConcern: { w: "majority", wtimeout: 5000 } 
}) 

db.collection.bulkWrite(operations);