从MongoDB中的手动参考中查找所有嵌入的文档

Question

我在一个项目中使用MongoDB和Spring Boot。我用手动参考来指出一个集合，我的结构如下：

卷轴收集

{
_id : "reel_id_1",
name: "reel 1",
category :[
{
_id : "category_id_1",
name: "category 1", 
videos: ["video_id_1","video_id_2"]
}
]
}

视频采集

{
_id: "video_id_1",  // first document
name: "mongo"
}
{
_id: "video_id_2",  // seconddocument
name: "java"
}

Java类是

@Document
@Data
public class Reel {
@Id
private ObjectId _id;
private String name;
List<Category> category;
}
@Data
public class Category {
@Id    
private ObjectId _id=new ObjectId();
private String name;
Video videos;
}
@Document
@Data
public class Video {
@Id
private ObjectId _id = new ObjectId();
private String name;

}

我试图通过mongoTemplate 加入这两个文档

public List<Reel> findById(ObjectId _id) {
LookupOperation lookupOperation = LookupOperation.newLookup()
.from("video")
.localField("category.videos")
.foreignField("_id")
.as("category.videos");

UnwindOperation unwindOperation = Aggregation.unwind("category");
Aggregation agg = newAggregation(unwindOperation,match(Criteria.where("_id").is(_id)),lookupOperation);

Aggregation aggregation = newAggregation(lookupOperation);
List<Reel> results = mongoTemplate.aggregate(aggregation, "reel", Reel.class).getMappedResults();
return results;
}

但它抛出了一个错误。

Failed to instantiate java.util.List using constructor NO_CONSTRUCTOR with arguments

但由于我使用"；展开"；，我创建了一个新的实体UnwindReel，并添加了Category category而不是List<Category> category。并使用

List<UnwindReel> results = mongoTemplate.aggregate(aggregation, "reel", UnwindReel.class).getMappedResults();

它只组合第一个视频(video_id_1(对象。如何获取视频数组中的所有对象？有什么方法可以提取吗？

Answer 1

存储在数据库中的JSON结构错误。您的Reel类需要Category的列表，但在数据库中，您已将其存储为嵌套对象。

您需要在$lookup之后添加此阶段

{
"$addFields": {
"category": {
"$map": {
"input": "$category.videos",
"in": {
"videos": "$$this"
}
}
}
}
}

Java代码

public List<Reel> findById(String _id) {
Aggregation aggregation = Aggregation.newAggregation(
Aggregation.match(Criteria.where("_id").is(_id)),
Aggregation.lookup(mongoTemplate.getCollectionName(Video.class), "category.videos", "_id", "category.videos"),
new AggregationOperation() {
@Override
public Document toDocument(AggregationOperationContext context) {
return new Document("$addFields",
new Document("category", new Document("$map", new Document("input", "$category.videos")
.append("in", new Document("videos", "$$this")))));
}
})
.withOptions(AggregationOptions.builder().allowDiskUse(Boolean.TRUE).build());
LOG.debug(
aggregation.toString().replaceAll("__collection__", mongoTemplate.getCollectionName(Reel.class)));
return mongoTemplate.aggregate(aggregation, mongoTemplate.getCollectionName(Reel.class), Reel.class)
.getMappedResults();
}

建议

1. 不要硬编码集合名称，使用更好的mongoTemplate.getCollectionName方法
2. 在执行之前始终记录聚合管道，这有助于调试
3. 如果您的收藏将来会增长，请使用{allowDiskUse: true}MongoDb聚合选项