mongodb - MongoTemplate 拉取子文档

Question

我需要在 MongoTemplate 中提取一个子文档，但不知道该怎么做。

我保存的文档是：

{
    "_id" : "FooUser",
    "_class" : "com.domain.User",
    "tests" : [ 
        {
            "variant" : {
                "_id" : "C",
                "probability" : "0.5"
            },
            "experiment" : {
                "$ref" : "experiment",
                "$id" : "MyExperiment2"
            }
        }, 
        {
            "variant" : {
                "_id" : "B",
                "probability" : "0.5"
            },
            "experiment" : {
                "$ref" : "experiment",
                "$id" : "MyExperiment1"
            }
        }
    ]
}

我只需要删除具有 MyExperiment1 的测试。执行以下命令有效：

db.user.update( {}, {$pull: { "tests":{"experiment.$id":"MyExperiment1"}}}, {multi: true} )

我应该如何使用 Spring MongoTemplate 编写这个？

我尝试了以下方法，但不起作用：

this.mongoTemplate.updateMulti(new Query(), new Update().pull("tests", "{\"experiment.$id\":\"MyExperiment1\"}"), "user");

谢谢。

Answer 1

似乎这有效：

this.mongoTemplate.updateMulti(new Query(),
        new Update().pull("tests", Query.query(Criteria.where("experiment.$id").is("MyExperiment1"))), USERS_COLLECTION_NAME);

Answer 2

另一个对我来说很好的解决方案是BasicDBObject在pull方法的value参数中使用 a 。请参阅如何使用 Spring 数据 MongoDB 为 db.test.update({name:'abc'}, {$pull: {'child': {'age':10}}}) 编写代码

Answer 3

这就是我的解决方案：

拉子字段

  public Mono<Project> DeleteCritTemplArray(String id, String country) {

    Query query = new Query();
    query.addCriteria(Criteria.where("_id")
                              .is(id));

    Update update = new Update();
    update.pull("countryList", country);

    return template
         // findAndModify:
         // Find/modify/get the "new object" from a single operation.
         .findAndModify(
              query, update,
              new FindAndModifyOptions().returnNew(true), Project.class
                       );

  }

拉子对象

 public Mono<ProjectChild> DeleteCritTemplChild(String id, String idch) {

    Query query = new Query();
    query.addCriteria(Criteria
                           .where("_id")
                           .is(id)
                           .and("tasks._id")
                           .is(idch)
                     );

    Update update = new Update();
    update.set("tasks.$", null);

    return template
         // findAndModify:
         // Find/modify/get the "new object" from a single operation.
         .findAndModify(
              query, update,
              new FindAndModifyOptions().returnNew(true), ProjectChild.class
                       );
  }