我需要在 SQL 服务器中执行一个存储过程来获取一些数据,并且由于我稍后会将数据保存到 Mongo 中并且这个是 withReactiveMongoTemplate
等等,所以我介绍了 Spring R2DBC。
implementation("org.springframework.data:spring-data-r2dbc:1.0.0.RELEASE")
implementation("io.r2dbc:r2dbc-mssql:0.8.1.RELEASE")
我看到我可以用 R2DBC 做SELECT
等等INSERT
,但有可能EXEC prod_name
吗?我试过了,它永远挂起,然后测试终止,没有成功,但也没有失败。日志的最后一行是:
io.r2dbc.mssql.QUERY - Executing query: EXEC "SCHEMA"."MY_PROCEDURE"
代码如下:
public Flux<Coupon> selectWithProcedure() {
return databaseClient
.execute("EXEC \"SCHEMA\".\"MY_PROCEDURE\" ")
.as(Coupon.class)
.fetch().all()
.doOnNext(coupon -> {
coupon.setCouponStatusRefFromId(coupon.getCouponStatusRefId());
});
}
而且似乎没有检索到任何数据。
如果我用简单的查询测试其他一些方法,就像SELECT...
它一样有效。但问题是,DBA 不允许我的应用程序读取表数据,而是为我创建了一个过程。如果无法进行此查询,我必须使用传统的 JPA 方式,而在 Mongo 端进行响应式已经失去了意义。