Spring数据反应式存储库-r2dbc不工作

Question

正在执行查询，但未得到任何结果。

路由器：-api/v1/service/appt/usr/{usr_id}

private static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");

public Mono<ServerResponse> retrieveProjectsByUsr(ServerRequest request) {
        final String userIdStr = request.pathVariable(USER_ID_PARAM);
        final Optional<String> stDateStr = request.queryParam("stDate");
        final Optional<String> endDateStr = request.queryParam("endDate");

        final LocalDateTime stDate = LocalDateTime.parse(stDateStr.get(), DATE_TIME_FORMATTER);
        final LocalDateTime endDate = LocalDateTime.parse(endDateStr.get(), DATE_TIME_FORMATTER);
        long userId = Long.parseLong(userIdStr);

        return secContext.retrieveUser().flatMap(usr -> {
            Flux<Appt> appts = projectRepository.findApptsBetween(stDate, endDate, userId, usr.getOrgId());
            return ServerResponse.ok().contentType(APPLICATION_JSON).body(appts, Project.class);
        });
    }

存储库代码，

@Repository
public interface ApptRepository extends ReactiveCrudRepository<Appt, Long> {
    
    @Query("select * from appt where usr_id = :usrId and org_id = :orgId and start_time BETWEEN :stDate and :endDate")
    Flux<Appt> findApptsBetween(LocalDateTime stDate, LocalDateTime endDate, long usrId, int orgId);

}

从日志中查询，

Executing SQL statement [select * from appt where usr_id = :usrId and org_id = :orgId and start_time BETWEEN :stDate and :endDate]

项目表中的数据，

邮递员请求，

http://localhost:9090/api/v1/service/appt/usr/2?stDate=2021-01-24 03:20&endDate=2021-03-25 05:23

不确定这有什么问题。它不会返回记录。

Answer 1

以下代码有效。答案是从上面的帖子修改的。

return secContext.retrieveUser()
                .flatMap(usr -> apptRepository.findApptsBetween(userId, usr.getOrgId(), stDate, endDate).collectList()
                        .flatMap(appts -> ServerResponse.ok().contentType(APPLICATION_JSON).bodyValue(appts)));

Answer 2

这里的问题是，反应性代码需要被重新编译，才能开始执行。以下语句仅描述应发生的情况：

<代码>通量

要初始化执行，需要添加。subscribe（）操作员响应调用。但这里您不希望这样，因为这将在不同的上下文/线程中开始执行，并且您无法将值返回给外部方法。这就是为什么应该将反应性代码编写为反应性调用链的原因。（注意：控制器方法和路由器函数在代码末尾有一个隐式的.subscribe（），因此不需要添加它）

您可以将此代码重新连接到如下内容：

return secContext.retrieveUser().flatMap(usr -> 
        projectRepository.findApptsBetween(stDate, endDate, userId, usr.getOrgId())
         .collectList()
         .map(appts -> ServerResponse.ok().contentType(APPLICATION_JSON).body(appts, Project.class));