java – 用spring数据更新对象mongodb和kotlin不能正常工作
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了java – 用spring数据更新对象mongodb和kotlin不能正常工作,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1217字,纯文字阅读大概需要2分钟。
内容图文
![java – 用spring数据更新对象mongodb和kotlin不能正常工作](/upload/InfoBanner/zyjiaocheng/906/e3ce381f59de45dc94ca4ac5a60786c6.jpg)
我有以下请求处理程序
fun x(req: ServerRequest) = req.toMono()
.flatMap {
...
val oldest = myRepository.findOldest(...) // this is the object I want to modify
...
val v= anotherMongoReactiveRepository.save(Y(...)) // this saves successfully
myRepository.save(oldest.copy(
remaining = (oldest.remaining - 1)
)) // this is not saved
ok().body(...)
}
和以下mongodb反应库
@Repository
interface MyRepository : ReactiveMongoRepository<X, String>, ... {
}
问题是执行save()方法后,对象中没有更改.我设法用save().block()修复了这个问题但是我不知道为什么第一个保存在另一个存储库上工作而这个没有.为什么需要这个块()?
解决方法:
在有人订阅被动发布者之前,没有任何事情发生.这就是你使用block()时它开始工作的原因.如果你需要调用DB并在另一个DB请求中使用结果,而不是使用mono / Flux运算符(如map(),flatMap(),…)来构建所需操作的管道,然后返回结果Mono / Flux作为控制器的响应. Spring将订阅Mono / Flux并返回请求.你不需要阻止它.并且不建议这样做(使用block()方法).
简单示例如何在Java中使用MongoDB反应式存储库:
@GetMapping("/users")
public Mono<User> getPopulation() {
return userRepository.findOldest()
.flatMap(user -> { // process the response from DB
user.setTheOldest(true);
return userRepository.save(user);
})
.map(user -> {...}); // another processing
}
内容总结
以上是互联网集市为您收集整理的java – 用spring数据更新对象mongodb和kotlin不能正常工作全部内容,希望文章能够帮你解决java – 用spring数据更新对象mongodb和kotlin不能正常工作所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。