这是我的数据库结构

 {
"_id" : ObjectId("58243c430386650d78d12d53"),
"email" : "technotest91@gmail.com",
"dentistName" : "Suzuka",
"tempDetails" : [ 
    {
        "tempName" : "Elsa",
        "city" : "bangalore",
         "tempEmail": "abc@gmail.com",
        "experience" : "5",    
        "hiredDates" : [ 
            {
                "status" : "Accepted",
                "bookingId" : "36Y0YM",
            }
        ],
    }, 
    {
        "tempName" : "Elsa",  
        "city" : "bangalore",
         "tempEmail": "abc@gmail.com",
        "experience" : "5",   
        "hiredDates" : [ 
            {

                "status" : "Hired",
                "bookingId" : "92Qhd7",
            }
        ],  
    }, 
    {
        "tempName" : "Elsa",  
        "city" : "bangalore",
        "experience" : "5",
        "tempEmail": "abc@gmail.com",
        "typeOfPractice" : "Oral Surgery",
        "hiredDates" : [ 
            {
                "status" : "Hired",
                "bookingId" : "95kTe9",
            }
        ],
    }
]
 }

我正在尝试根据 bookingId 更新 Status。我无法更新该值。我在 JAVA MONGODB 中尝试了以下代码，但它似乎没有更新。

    BasicDBObject searchQuery = new BasicDBObject();

    List<BasicDBObject> andQuery = new ArrayList<BasicDBObject>();
    andQuery.add(new BasicDBObject("email", dentalEmail));
    andQuery.add(new BasicDBObject("tempDetails.tempEmail",tempEmail));


    searchQuery.put("$and", andQuery);

    DBCursor cursor = col.find(searchQuery);
     if (cursor.count() != 0) {
    while (cursor.hasNext()) {

        BasicDBList jobStatusList = (BasicDBList) cursor.next().get("tempDetails");

            for(int k=0;k<jobStatusList.size();k++)
            {
                BasicDBObject tempJobObject = (BasicDBObject) jobStatusList.get(k);

                BasicDBList hiredDatesList = (BasicDBList) tempJobObject.get("hiredDates");


                for(int i =0; i<hiredDatesList.size();i++)
                {
                    BasicDBObject hiredDatesObject = (BasicDBObject) hiredDatesList.get(i);
                    String dbBookingId = hiredDatesObject.getString("bookingId");

                    if(dbBookingId.equalsIgnoreCase(bookingId))
                    {
                        BasicDBObject doc = new BasicDBObject("$set",
                                new BasicDBObject().append("tempDetails."+k+".hiredDates."+i+".status", status));

                        col.update(searchQuery, doc, false, false);

                        System.out.println(doc);

                    }else{
                        result = false;
                    }
                }

请帮我解决这个问题，因为我一直在努力根据 BookingId 更新记录。我通过查询获取文档并遍历对象，如果 bookingid 匹配，我将更新记录。请帮助让我知道我应该改变什么..

最佳答案

您是否正确检查了您的数据库？我能够完美无误地运行您的代码，并且它也会更新集合。

我刚刚创建了一个方法，我正在执行以下操作:

private void performOperation() {
    MongoClient mongo = new MongoClient("localhost", 27017);
    MongoClient mongoClient = new MongoClient();
    DB db = mongoClient.getDB("test");
    DBCollection table = db.getCollection("vinay");

    logger.info("connected successfully");

    BasicDBObject searchQuery = new BasicDBObject();

    List<BasicDBObject> andQuery = new ArrayList<BasicDBObject>();
    andQuery.add(new BasicDBObject("email", "technotest91@gmail.com"));
    andQuery.add(new BasicDBObject("tempDetails.tempEmail", "abc@gmail.com"));

    searchQuery.put("$and", andQuery);

    logger.info("executing :"+ searchQuery);

    DBCursor cursor = table.find(searchQuery);
    if (cursor.count() != 0) {
        while (cursor.hasNext()) {

            BasicDBList jobStatusList = (BasicDBList) cursor.next().get("tempDetails");

            for (int k = 0; k < jobStatusList.size(); k++) {
                BasicDBObject tempJobObject = (BasicDBObject) jobStatusList.get(k);

                BasicDBList hiredDatesList = (BasicDBList) tempJobObject.get("hiredDates");

                for (int i = 0; i < hiredDatesList.size(); i++) {
                    BasicDBObject hiredDatesObject = (BasicDBObject) hiredDatesList.get(i);
                    String dbBookingId = hiredDatesObject.getString("bookingId");

                    if (dbBookingId.equalsIgnoreCase("36Y0YM")) {
                        BasicDBObject doc = new BasicDBObject("$set", new BasicDBObject()
                                .append("tempDetails." + k + ".hiredDates." + i + ".status", "New Status"));

                        table.update(searchQuery, doc, false, false);

                        logger.info(doc);

                    } else {
                        logger.info("no record find");
                    }
                }
            }
        }
    }
}

执行此操作后，预订 ID 为 36Y0YM 的状态更新为“新状态”。

但我注意到了这一点。你写循环的方式......因为即使在更新记录之后它也会再次迭代并打印消息“没有找到记录”在你的情况下它会将结果设置为false，所以如果你依赖结果那么你的整个方法会错的。

我不知道您要构建什么逻辑，但重点是您的代码没有任何错误，如果您编写的循环有任何错误，它会更新 mongodb 中的记录。

关于java - 更新mongodb java中的嵌套数组值，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/40529638/