sql >> データベース >  >> NoSQL >> MongoDB

Javaを使用してMongoDBでドキュメントの一括更新を実行するにはどうすればよいですか?

    新しいbulkWrite()のマニュアルの例を使用する APIについては、次のドキュメントを含む次のテストコレクションを検討してください。

    { "_id" : 1, "char" : "Brisbane", "class" : "monk", "lvl" : 4 },
    { "_id" : 2, "char" : "Eldon", "class" : "alchemist", "lvl" : 3 },
    { "_id" : 3, "char" : "Meldane", "class" : "ranger", "lvl" : 3 }
    

    次のbulkWrite() charactersに対して複数の操作を実行します コレクション:

    Mongoシェル:

    try {
        db.characters.bulkWrite([
            { 
                insertOne:{
                    "document":{
                        "_id" : 4, "char" : "Dithras", "class" : "barbarian", "lvl" : 4
                    }
                }
            },
            { 
                insertOne:{
                    "document": {
                        "_id" : 5, "char" : "Taeln", "class" : "fighter", "lvl" : 3
                    }
                }
            },
            { 
                updateOne: {
                    "filter" : { "char" : "Eldon" },
                    "update" : { $set : { "status" : "Critical Injury" } }
                }
            },
            { 
                deleteOne: { "filter" : { "char" : "Brisbane"} }
            },
            { 
                replaceOne: {
                   "filter" : { "char" : "Meldane" },
                   "replacement" : { "char" : "Tanys", "class" : "oracle", "lvl" : 4 }
                }
            }
        ]);
    }
    catch (e) {  print(e); }
    

    出力を出力します:

    {
       "acknowledged" : true,
       "deletedCount" : 1,
       "insertedCount" : 2,
       "matchedCount" : 2,
       "upsertedCount" : 0,
       "insertedIds" : {
          "0" : 4,
          "1" : 5
       },
       "upsertedIds" : {
    
       }
    }
    

    同等のJava3.2実装は次のとおりです。

    MongoCollection<Document> collection = db.getCollection("characters");
    List<WriteModel<Document>> writes = new ArrayList<WriteModel<Document>>();
    writes.add(
        new InsertOneModel<Document>(
            new Document("_id", 4)
                .append("char", "Dithras")
                .append("class", "barbarian")
                .append("lvl", 3)
        )
    );
    writes.add(
        new InsertOneModel<Document>(
            new Document("_id", 5)
                .append("char", "Taeln")
                .append("class", "fighter")
                .append("lvl", 4)
        )
    );
    writes.add(
        new UpdateOneModel<Document>(
            new Document("char", "Eldon"), // filter
            new Document("$set", new Document("status", "Critical Injury")) // update
        )
    );
    writes.add(new DeleteOneModel<Document>(new Document("char", "Brisbane")));
    writes.add(
        new ReplaceOneModel<Document>(
            new Document("char", "Meldane"), 
            new Document("char", "Tanys")
                .append("class", "oracle")
                .append("lvl", 4)           
        )
    );
    
    BulkWriteResult bulkWriteResult = collection.bulkWrite(writes);
    

    質問には、 replaceOne()を使用してください メソッドとこれは

    として実装されます
    MongoCollection<Document> collection = db.getCollection("collection");
    List<WriteModel<Document>> writes = Arrays.<WriteModel<Document>>asList(
        new ReplaceOneModel<Document>(
            new Document("_id", 1001), // filter
            new Document("author", "newName"), // update
            new UpdateOptions().upsert(true) // options
        )   
    );
    
    BulkWriteResult bulkWriteResult = collection.bulkWrite(writes);
    



    1. 別々のnodeJSインスタンスでソケットを共有する

    2. node.jsを使用してElastiCacheクラスターに接続する方法

    3. 予期しないredisサーバー障害の診断

    4. MongoDB $ dateToParts