我是mongodb和webflux的新手。我正在尝试使用“commentsids”(list idcomments)从此“post”pojo检索带有“comments”(list listcoments)的“post”:
这就是我的pojo/实体:
@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
@Document(collection = "post")
public class Post implements Serializable {
private static final long serialVersionUID = -6281811500337260230L;
@EqualsAndHashCode.Include
@Id
private String id;
private Date date;
private String title;
private String body;
private AuthorDto author;
private Comment comment;
private List<Comment> listComments = new ArrayList<>();
private List<String> idComments = new ArrayList<>();
}
这是我的服务(findpostbyidshowcomments+findcommentsbypostid):
public Mono<Post> findPostByIdShowComments(String id) {
return postRepo
.findById(id)
.switchIfEmpty(postNotFoundException())
.flatMap(postFound -> {
Flux<Comment> commentFlux = commentService
.findCommentsByPostId(postFound.getId());
Flux<Post> postFlux = commentFlux
.flatMap(comment -> {
postFound.setListComments(new ArrayList<>());
postFound.getListComments()
.add(comment);
return Mono.just(postFound);
});
return Mono.just(postFound);
});
}
public Flux<Comment> findCommentsByPostId(String id) {
return postRepo
.findById(id)
.switchIfEmpty(postNotFoundException())
.thenMany(commentRepo.findAll())
.filter(comment1 -> comment1.getIdPost()
.equals(id));
}
那是我的控制器:
@GetMapping(FIND_POST_BY_ID_SHOW_COMMENTS)
@ResponseStatus(OK)
public Mono<Post> findPostByIdShowComments(@PathVariable String id) {
return postService.findPostByIdShowComments(id);
}
因此,我无法获取我的“注解”并将它们加载到pojo中,因此,我无法在rest响应json中显示它们。作为一个“json结果”,我得到:
{
"id": "5ff0ed93b3268a39dd3bd7b9",
"date": "2011-11-11T00:00:00.000+00:00",
"title": "Lake Cliffordside",
"body": "North Sanfordborough",
"author": {
"id": "5ff0ed93b3268a39dd3bd7b6",
"name": "melissa"
},
"comment": null,
"listComments": [], //TROUBLE: As you can see, The CommentObjects are not coming
"idComments": [
"5ff0edb2b3268a39dd3bd7bc",
"5ff0edbab3268a39dd3bd7bd"
]
}
非常感谢你们的帮助。
1条答案
按热度按时间sq1bmfud1#
你没有收到评论的原因是
commentFlux
以及postFlux
变量只是声明的,但从未在执行链中使用。现在,我们将注解流和注解流作为主流的一部分注入到foundpost中。