Mongoのすべての文書でstringを置き換える方法

Question

特定の文書の文字列を置き換える必要があります。私はこのコードをgoogled、しかしそれは残念ながら何も変更されません。私はライン怒鳴る上の構文について確認していない：

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); 
} 

私は値が何であるかを確認するために、いくつかのデバッグプリントを追加したいと思いますが、私はMongoDBのシェルとは経験がありません。それは一般的に修正されません

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

Answer 1

で

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

：あなたは文字列http://aaa/xxx/aaaを（yyyがaaaに等しい）がある場合は、http://bbb/xxx/bbbになってしまいます私はこれを交換する必要があります。 これで問題なければ、コードは機能します。

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); 
} 

（あなたがオブジェクトを印刷したい場合は、途中で、printjson機能もある）

Answer 2

のMongoDBは、文字列検索を行うことができます。print機能を使用するデバッグ情報を追加するには

/mapreduce経由で置き換えます。はい、あなたはそれのための非常に特殊なデータ構造を持っている必要があります - あなたはトップキーに何もすることはできませんが、valueの下にすべてのサブ文書の下に格納する必要があります。このように：あなたはこのきちんと設定したら

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

あなたが行うことができます：あなたはMongoDBの2.6またはそれ以降である場合は、これを行うには

$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

最善の方法を使用してカーソルオブジェクトをループさ.forEachメソッドを使用して、効率を最大化するために各ドキュメントを"bulk"操作で更新してください。 MongoDB 3.2から

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(); 

---

Bulk() APIとmethodsはあなたがdb.collection.bulkWrite()メソッドを使用する必要があります廃止され、その関連。

カーソルをループし、クエリを動的に構築し、アレイごとに$pushの操作を行う必要があります。

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);