MongoTemplate 操作 Mongo的字段中List元素

YangTG5号

已于 2023-05-09 16:44:33 修改

阅读量655

点赞数

分类专栏： mongo 文章标签： mongodb

于 2023-01-16 16:59:02 首次发布

本文链接：https://blog.csdn.net/java821643/article/details/128706422

版权

mongo 专栏收录该内容

1 篇文章

订阅专栏

文章展示了在MongoDB中对文档的subscribers字段进行操作的方法，包括添加新数据、删除数据和编辑数据。使用Java的MongoTemplate进行查询和更新，基于_id和subscribers.userId进行精准定位。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

mongo中原始数据

{
	"_id": {
		"$numberLong": "7085200805669904384"
	},
	"message": "Thank you for your support",
	"announcement": "weekend",
	"created_user_id": {
		"$numberLong": "8637022162191"
	},
	"update_time": {
		"$date": "2022-12-15T06:24:00.193Z"
	},
	"status": "1",
	"subscribers": [
		{
			"boolean": false,
			"userId": {
				"$numberLong": "8637022162191"
			}
		}
	]
}

给subscribers 字段新增一条数据

    public static void main(String[] args) {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is(7085200805669904384L));
        Update update = new Update();
       
        Map<String, Object> sub = new HashMap<>();
        sub.put("userId", 8637022162191L);
        sub.put("boolean", false);
        update.push("subscribers", sub);
        mongoTemplate.updateFirst(query, update, "store_time_away");
    }

给subscribers 字段删除一条数据

    public static void main(String[] args) {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is(7085200805669904384L));
        Update update = new Update();
     
        Map<String, Object> sub = new HashMap<>();
        sub.put("userId", 8637022162191L);
        update.pull("subscribers", sub);
        mongoTemplate.updateFirst(query, update, "store_time_away");
    }

给subscribers 编辑一条数据

    public static void main(String[] args) {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is(7085200805669904384L))
                .addCriteria(Criteria.where("subscribers.userId").is(8637022162191L));
        Update update = new Update();
       //不预先查询文档我们就不知道要修改数组的元素的下标。这时定位操作符“$”
        update.set("subscribers.$.boolean",false);
        mongoTemplate.updateFirst(query, update, "store_time_away");
    }

查询

   public static void main(String[] args) {
        Query query = new Query();
        query.addCriteria(Criteria.where("_id").is(7085200805669904384L))
                .addCriteria(Criteria.where("subscribers.userId").is(8637022162191L));

        StoreTimeAwayV1 storeTimeAways = mongoTemplate.findOne(query,  StoreTimeAwayV1.class);
    }