如何解决使用 r2dbc 驱动程序的 Jooq 反应式获取
我的查询看起来像(使用 JOOQ v 3.15):
override fun getCredentialsById(id: Long): Mono<UserCredentialsModel> {
return Mono.from {
dsl.select(
USER_CREDENTIALS.ID,USER_CREDENTIALS.EMAIL,USER_CREDENTIALS.PHONE,USER_CREDENTIALS.LOGIN,USER_CREDENTIALS.PASSWORD)
.from(USER_CREDENTIALS)
.where(USER_CREDENTIALS.ID.eq(id))
.and(USER_CREDENTIALS.IS_ACTIVE.eq(true))
.fetchInto(UserCredentialsModel::class.java)
}
}
JOOQ 配置:
@Bean
fun createContext(): DSLContext {
return DSL.using(connection)
}
其中 connection
是 io.r2dbc.spi.ConnectionFactory
我得到了一个例外:
org.jooq.exception.DetachedException: Attempt to execute a blocking method (e.g. Query.execute() or ResultQuery.fetch()) when only an R2BDC ConnectionFactory was configured
我应该如何以响应式方式将查询结果提取到 Kotlin 数据类(或 Java JOOQ 的 POJO)中?
解决方法
没有测试我会说它应该
return Mono.from(
dsl.select(
USER_CREDENTIALS.ID,USER_CREDENTIALS.EMAIL,USER_CREDENTIALS.PHONE,USER_CREDENTIALS.LOGIN,USER_CREDENTIALS.PASSWORD)
.from(USER_CREDENTIALS)
.where(USER_CREDENTIALS.ID.eq(id))
.and(USER_CREDENTIALS.IS_ACTIVE.eq(true)));
,
在被动地使用 jOOQ 时,永远不要调用任何阻塞方法,例如 ResultQuery.fetchOneInto(Class)
。该方法只是 ResultQuery.fetchOne()
和 Record.into(Class)
的便捷方法。没有什么可以阻止您自己调用 Record.into(Class)
,无论是在阻塞世界还是非阻塞世界。
因此,使用您常用的反应器库方法来映射流内容:
mono.map { r -> r.into(UserCredentialsModel::class.java) }
或者,在一个完整的例子中:
return Mono.from {
dsl.select(
USER_CREDENTIALS.ID,USER_CREDENTIALS.PASSWORD)
.from(USER_CREDENTIALS)
.where(USER_CREDENTIALS.ID.eq(id))
.and(USER_CREDENTIALS.IS_ACTIVE.eq(true))
} .map { r -> r.into(UserCredentialsModel::class.java) }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。