Найти все встроенные документы из справочника в 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). Как я могу получить все объекты в массиве videos ? Есть ли способ получить? и может кто-нибудь, пожалуйста, дайте мне знать, что я здесь пропустил? Заранее спасибо.

Answer 1

Ваш JSON хранится в базе данных, имеет неправильную структуру. Ваш класс Reel ожидает список Category, но в базе данных вы сохранили его как вложенный объект.

Этот этап необходимо добавить сразу после $lookup

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

Java code

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.