SpringデータMongoDB:ドキュメントの更新

投稿日: 2019-11-05 2019-11-05
タグ: MongoDB, Spring Data, update

Springデータ – MongoDBでは、以下のメソッドを使用してドキュメントを更新することができます。

save – オブジェクト全体を更新します. “__id”が存在する場合は、

それ以外の場合は挿入してください。

updateFirst – クエリに一致する最初のドキュメントを更新します.
updateMulti – クエリに一致するすべてのドキュメントを更新します.
アップアップ – クエリに一致するドキュメントがない場合、新しいドキュメントが

クエリオブジェクトと更新オブジェクトを組み合わせて作成されます。

findAndModify – updateMultiと同じですが、追加のオプションがあります

古い文書または新しく更新された文書を返します。

P.S全ての例は
mongo-java-driver-2.11.0.jar`と
spring-data-mongodb-1.2.0.RELEASE.jar`

でテストされています

1. saveOrUpdate – パート1の例

下記のjsonデータがMongoDBに挿入されていると仮定します。

{
    "__id" : ObjectId("id"),
    "ic" : "1001",
    "name" : "appleA",
    "age" : 20,
    "createdDate" : ISODate("2013-04-06T23:17:35.530Z")
}

ドキュメントを見つけ、 `save（）`メソッドでドキュメントを修正して更新します。

    Query query = new Query();
    query.addCriteria(Criteria.where("name").is("appleA"));

    User userTest1 = mongoOperation.findOne(query, User.class);

    System.out.println("userTest1 - " + userTest1);

   //modify and update with save()
    userTest1.setAge(99);
    mongoOperation.save(userTest1);

   //get the updated object again
    User userTest1__1 = mongoOperation.findOne(query, User.class);

    System.out.println("userTest1__1 - " + userTest1__1);

出力

userTest1 - User[id=id, ic=1001, name=appleA, age=20, createdDate=Sat Apr 06 23:17:35 MYT 2013]userTest1__1 - User[id=id, ic=1001, name=appleA, age=99, createdDate=Sat Apr 06 23:17:35 MYT 2013]....

** 注** 例2を参照してください。ほとんどの開発者が間違いを犯しています。

===  2. saveOrUpdate  - パート2の例

これは失敗した例です。本当によくある間違いです。

下記のjsonデータがMongoDBに挿入されていると仮定します。

{
“__id” : ObjectId(“id”),
“ic” : “1002”,
“name” : “appleB”,
“age” : 20,
“createdDate” : ISODate(“2013-04-06T15:22:34.530Z”)
}

`Query`では、単一の" name "フィールド値だけで返されたドキュメントを取得します。オブジェクト返されたサイズを保存することがよくありました。返された "User"オブジェクトは、age、ic、およびcreatedDateの各フィールドにnull値を持ちます。 'age'フィールドを変更してそれを更新すると、変更されたフィールド -  'age'を更新するのではなく、すべてをオーバーライドします。

Query query = new Query();
query.addCriteria(Criteria.where("name").is("appleB"));
query.fields().include("name");

User userTest2 = mongoOperation.findOne(query, User.class);
System.out.println("userTest2 - " + userTest2);

userTest2.setAge(99);

mongoOperation.save(userTest2);

//ooppss, you just override everything, it caused ic=null and
//createdDate=null

Query query1 = new Query();
query1.addCriteria(Criteria.where("name").is("appleB"));

User userTest2__1 = mongoOperation.findOne(query1, User.class);
System.out.println("userTest2__1 - " + userTest2__1);

出力

userTest2 – User[id=51603dba3004d7fffc202391, ic=null, name=appleB, age=0, createdDate=null]userTest2__1 – User[id=51603dba3004d7fffc202391, ic=null, name=appleB, age=99, createdDate=null]….

save（）の後、フィールド ‘age’は正しく更新されますが、icとcreatedDateは両方ともnullに設定され、「user」オブジェクト全体が更新されます。

単一のフィールド/キー値を更新するには、save（）を使用せず、代わりにupdateFirst（）またはupdateMulti（）を使用してください。

3. update最初の例

クエリに一致する最初のドキュメントを更新します。この場合、単一のフィールド「年齢」のみが更新されます。

{
    "__id" : ObjectId("id"),
    "ic" : "1003",
    "name" : "appleC",
    "age" : 20,
    "createdDate" : ISODate("2013-04-06T23:22:34.530Z")
}

       //returns only 'name' field
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is("appleC"));
        query.fields().include("name");

        User userTest3 = mongoOperation.findOne(query, User.class);
        System.out.println("userTest3 - " + userTest3);

        Update update = new Update();
        update.set("age", 100);

        mongoOperation.updateFirst(query, update, User.class);

       //returns everything
        Query query1 = new Query();
        query1.addCriteria(Criteria.where("name").is("appleC"));

        User userTest3__1 = mongoOperation.findOne(query1, User.class);
        System.out.println("userTest3__1 - " + userTest3__1);

出力

userTest3 - User[id=id, ic=null, name=appleC, age=0, createdDate=null]userTest3__1 - User[id=id, ic=1003, name=appleC, age=100, createdDate=Sat Apr 06 23:22:34 MYT 2013]....

===  4. updateMultiの例

クエリに一致するすべてのドキュメントを更新します。

{
”

id” : ObjectId(“id”),
“ic” : “1004”,
“name” : “appleD”,
“age” : 20,
“createdDate” : ISODate(“2013-04-06T15:22:34.530Z”)
}
{
”

id” : ObjectId(“id”),
“ic” : “1005”,
“name” : “appleE”,
“age” : 20,
“createdDate” : ISODate(“2013-04-06T15:22:34.530Z”)
}

//show the use of $or operator
 Query query = new Query();
 query.addCriteria(Criteria
         .where("name").exists(true)
         .orOperator(Criteria.where("name").is("appleD"),
                 Criteria.where("name").is("appleE")));
 Update update = new Update();

//update age to 11
 update.set("age", 11);

//remove the createdDate field
 update.unset("createdDate");

//if use updateFirst, it will update 1004 only.
//mongoOperation.updateFirst(query4, update4, User.class);

//update all matched, both 1004 and 1005
 mongoOperation.updateMulti(query, update, User.class);

System.out.println(query.toString());

List<User> usersTest4 = mongoOperation.find(query4, User.class);

for (User userTest4 : usersTest4) {
    System.out.println("userTest4 - " + userTest4);
}

出力

Query: { “name” : { “$exists” : true} ,
“$or” :[{ “name” : “appleD”} , { “name” : “appleE”}]}, Fields: null, Sort: null

userTest4 – User[id=id, ic=1004, name=appleD, age=11, createdDate=null]userTest4 – User[id=id, ic=1005, name=appleE, age=11, createdDate=null]….

5.アップサンプルの例

ドキュメントが一致する場合は更新し、そうでない場合はクエリと更新オブジェクトを組み合わせて新しいドキュメントを作成します。これは `findAndModifyElseCreate（）`のように動作します:)

{
   //no data
}

       //search a document that doesn't exist
        Query query = new Query();
        query.addCriteria(Criteria.where("name").is("appleZ"));

        Update update = new Update();
        update.set("age", 21);

        mongoOperation.upsert(query, update, User.class);

        User userTest5 = mongoOperation.findOne(query, User.class);
        System.out.println("userTest5 - " + userTest5);

出力、クエリと更新オブジェクトの両方を組み合わせて新しいドキュメントが作成されます。

userTest5 - User[id=id, ic=null, name=appleZ, age=21, createdDate=null]....

===  6. findAndModifyの例

1回の操作から新しく更新されたオブジェクトを検索して変更して取得する。

{
“__id” : ObjectId(“id”),
“ic” : “1006”,
“name” : “appleF”,
“age” : 20,
“createdDate” : ISODate(“2013-04-07T13:11:34.530Z”)
}

Query query6 = new Query();
query6.addCriteria(Criteria.where("name").is("appleF"));

Update update6 = new Update();
update6.set("age", 101);
update6.set("ic", 1111);

//FindAndModifyOptions().returnNew(true) = newly updated document
//FindAndModifyOptions().returnNew(false) = old document (not update yet)
 User userTest6 = mongoOperation.findAndModify(
         query6, update6,
         new FindAndModifyOptions().returnNew(true), User.class);
 System.out.println("userTest6 - " + userTest6);

出力

userTest6 – User[id=id, ic=1111, name=appleF, age=101, createdDate=Sun Apr 07 13:11:34 MYT 2013]….

7.完全な例

例1〜6のすべてを組み合わせる完全なアプリケーション。

package com.mkyong.core;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.data.mongodb.core.FindAndModifyOptions;
import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;

import com.mkyong.config.SpringMongoConfig;
import com.mkyong.model.User;

public class UpdateApp {

    public static void main(String[]args) {
       //For Annotation
        ApplicationContext ctx =
            new AnnotationConfigApplicationContext(SpringMongoConfig.class);
        MongoOperations mongoOperation =
            (MongoOperations) ctx.getBean("mongoTemplate");

       //insert 6 users for testing
        List<User> users = new ArrayList<User>();

        User user1 = new User("1001", "appleA", 20, new Date());
        User user2 = new User("1002", "appleB", 20, new Date());
        User user3 = new User("1003", "appleC", 20, new Date());
        User user4 = new User("1004", "appleD", 20, new Date());
        User user5 = new User("1005", "appleE", 20, new Date());
        User user6 = new User("1006", "appleF", 20, new Date());
        users.add(user1);
        users.add(user2);
        users.add(user3);
        users.add(user4);
        users.add(user5);
        users.add(user6);
        mongoOperation.insert(users, User.class);

       //Case 1 ... find and update
        System.out.println("Case 1");

        Query query1 = new Query();
        query1.addCriteria(Criteria.where("name").is("appleA"));

        User userTest1 = mongoOperation.findOne(query1, User.class);

        System.out.println("userTest1 - " + userTest1);

        userTest1.setAge(99);
        mongoOperation.save(userTest1);

        User userTest1__1 = mongoOperation.findOne(query1, User.class);

        System.out.println("userTest1__1 - " + userTest1__1);

       //Case 2 ... select single field only
        System.out.println("\nCase 2");

        Query query2 = new Query();
        query2.addCriteria(Criteria.where("name").is("appleB"));
        query2.fields().include("name");

        User userTest2 = mongoOperation.findOne(query2, User.class);
        System.out.println("userTest2 - " + userTest2);

        userTest2.setAge(99);

        mongoOperation.save(userTest2);

       //ooppss, you just override everything, it caused ic=null and
       //createdDate=null

        Query query2__1 = new Query();
        query2__1.addCriteria(Criteria.where("name").is("appleB"));

        User userTest2__1 = mongoOperation.findOne(query2__1, User.class);
        System.out.println("userTest2__1 - " + userTest2__1);

        System.out.println("\nCase 3");
        Query query3 = new Query();
        query3.addCriteria(Criteria.where("name").is("appleC"));
        query3.fields().include("name");

        User userTest3 = mongoOperation.findOne(query3, User.class);
        System.out.println("userTest3 - " + userTest3);

        Update update3 = new Update();
        update3.set("age", 100);

        mongoOperation.updateFirst(query3, update3, User.class);

        Query query3__1 = new Query();
        query3__1.addCriteria(Criteria.where("name").is("appleC"));

        User userTest3__1 = mongoOperation.findOne(query3__1, User.class);
        System.out.println("userTest3__1 - " + userTest3__1);

        System.out.println("\nCase 4");
        Query query4 = new Query();
        query4.addCriteria(Criteria
                .where("name")
                .exists(true)
                .orOperator(Criteria.where("name").is("appleD"),
                        Criteria.where("name").is("appleE")));
        Update update4 = new Update();
        update4.set("age", 11);
        update4.unset("createdDate");

       //update 1004 only.
       //mongoOperation.updateFirst(query4, update4, User.class);

       //update all matched
        mongoOperation.updateMulti(query4, update4, User.class);

        System.out.println(query4.toString());

        List<User> usersTest4 = mongoOperation.find(query4, User.class);

        for (User userTest4 : usersTest4) {
            System.out.println("userTest4 - " + userTest4);
        }

        System.out.println("\nCase 5");
        Query query5 = new Query();
        query5.addCriteria(Criteria.where("name").is("appleZ"));

        Update update5 = new Update();
        update5.set("age", 21);

        mongoOperation.upsert(query5, update5, User.class);

        User userTest5 = mongoOperation.findOne(query5, User.class);
        System.out.println("userTest5 - " + userTest5);

        System.out.println("\nCase 6");
        Query query6 = new Query();
        query6.addCriteria(Criteria.where("name").is("appleF"));

        Update update6 = new Update();
        update6.set("age", 101);
        update6.set("ic", 1111);

        User userTest6 = mongoOperation.findAndModify(query6, update6,
                new FindAndModifyOptions().returnNew(true), User.class);
        System.out.println("userTest6 - " + userTest6);

        mongoOperation.dropCollection(User.class);

    }

}

出力

Case 1
userTest1 - User[id=id, ic=1001, name=appleA, age=20, createdDate=Sun Apr 07 13:22:48 MYT 2013]userTest1__1 - User[id=id, ic=1001, name=appleA, age=99, createdDate=Sun Apr 07 13:22:48 MYT 2013]
Case 2
userTest2 - User[id=id, ic=null, name=appleB, age=0, createdDate=null]userTest2__1 - User[id=id, ic=null, name=appleB, age=99, createdDate=null]
Case 3
userTest3 - User[id=id, ic=null, name=appleC, age=0, createdDate=null]userTest3__1 - User[id=id, ic=1003, name=appleC, age=100, createdDate=Sun Apr 07 13:22:48 MYT 2013]
Case 4
Query: { "name" : { "$exists" : true} , "$or" :[{ "name" : "appleD"} , { "name" : "appleE"}]}, Fields: null, Sort: null
userTest4 - User[id=id, ic=1004, name=appleD, age=11, createdDate=null]userTest4 - User[id=id, ic=1005, name=appleE, age=11, createdDate=null]
Case 5
userTest5 - User[id=id, ic=null, name=appleZ, age=21, createdDate=null]
Case 6
userTest6 - User[id=id, ic=1006, name=appleF, age=20, createdDate=Sun Apr 07 13:22:48 MYT 2013]....

=== ソースコードをダウンロードする

ダウンロードする -  link://wp-content/uploads/2011/05/SpringMongoDB-Update-Example.zip[SpringMongoDB-Update-Example.zip]（29 KB）

=== 参考文献

.  http://static.springsource.org/spring-data/data-document/docs/current/reference/html/#mongodb-template-update[MongoDB

テンプレート更新のドキュメント]。 http://static.springsource.org/spring-data/mongodb/docs/current/reference/html/mongo.core.html#mongo-template.save-update-remove[Spring

データMongoDB  - 文書の保存、更新、削除]。リンク://mongodb/java-mongodb-update-document/[Java MongoDB update

例/]。 http://docs.mongodb.org/manual/core/update/[MongoDB更新モディファイア

オペレーション]。リンク://mongodb/spring-data-mongodb-hello-world-example/[Springデータ

MongoDB Hello Worldの例]

link://tag/mongodb/[mongodb]link://タグ/spring-data/[spring-data]link://tag/update/[update]

getdocs

13036