如何解决SaveAll 与 Spring r2dbc ReactiveCrudRepository
SaveAll 遇到一些问题。
@Repository
public interface PrjRepository extends ReactiveCrudRepository<Prj,Integer> {
}
处理程序类
public Mono<ServerResponse> saveprjDetails(ServerRequest request) {
return context.retrieveUser().flatMap(usr -> {
return request.bodyToMono(PrjDetails.class).flatMap(prjDetails -> {
return buildPrj(prjDetails,usr).flatMap(prjRepository::saveAll)
.flatMap(res -> ServerResponse.noContent().build());
});
});
}
private Flux<ApptHealthAttrMapping> buildPrjs(final DetailsReq detailsReq,final User usr) {
List<Project> list = detailsReq.getPrjList().stream()
.map(prj -> createProject(detailsReq,usr,prj))
.collect(Collectors.toList());
return Mono.just(list).flatMapMany(Flux::fromIterable);
}
private Project createProject(PrjDetailsReq detailsReq,User usr,final Project prj) {
....
return prj;
}
错误,
返回 buildPrjs(details,usr).flatMap(prjRepository::saveAll)
Multiple markers at this line
- The type PrjRepository does not define saveAll(Project) that is applicable
here
- Cannot infer type argument(s) for <R> flatMap(Function<? super T,? extends Publisher<? extends R>>)
返回 request.bodyToMono(PrjDetails.class).flatMap(prjDetails -> {
Type mismatch: cannot convert from Mono<Object> to Mono<? extends
ServerResponse>
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。