Spring WebFlux中R2DBC查询无结果时的空指针异常处理方案

我来帮你搞定这个问题——当查询不存在的数据时触发的空指针异常，本质原因是sum()这类聚合函数在没有匹配行时会返回NULL，而R2DBC的映射层在把NULL映射到Long类型时，因为你定义的返回值是Mono<Long>（非可空包装类型），再加上Reactor内部的非空检查，就直接抛出了NPE。

下面给你几种实用的解决办法：

方法1：SQL层面直接处理NULL（最推荐） #

直接在查询语句里用COALESCE函数把聚合结果的NULL转换成0，这样无论有没有匹配数据，都会返回一个有效值，从根源避免空指针：

@Nullable
@Query("select COALESCE(sum(callrxinboundcount), 0) from account_stats where botname=$1 and starttime > $2 and endtime < $3 ")
Mono<Long> findSumOfCallReceivedInboundCountByDurationForBotName(String accountId, Long startTime, Long endTime);

这种方式不需要修改业务逻辑，SQL本身就保证了返回值永远是数字，简洁又可靠。

方法2：在Reactor流中处理空值 #

如果不想改动SQL，可以在调用Repository方法后的流处理链中，用defaultIfEmpty来兜底空值：

// 业务层调用时添加处理
yourRepo.findSumOfCallReceivedInboundCountByDurationForBotName(accountId, startTime, endTime)
        .defaultIfEmpty(0L) // 当Mono无内容时返回0
        .subscribe(result -> {
            // 处理结果
        });

也可以用switchIfEmpty创建一个新的Mono返回0，但defaultIfEmpty对于这种简单场景更直接。

方法3：修改返回类型为可空包装 #

把Repository方法的返回类型改成Mono<Optional<Long>>，这样查询到的NULL会被包装成Optional.empty()，之后在业务逻辑里再转成0：

// 修改Repository方法
@Query("select sum(callrxinboundcount) from account_stats where botname=$1 and starttime > $2 and endtime < $3 ")
Mono<Optional<Long>> findSumOfCallReceivedInboundCountByDurationForBotName(String accountId, Long startTime, Long endTime);

// 调用时处理空值
yourRepo.findSumOfCallReceivedInboundCountByDurationForBotName(...)
        .map(opt -> opt.orElse(0L))
        .subscribe(...);

补充：为什么会触发这个NPE？ #

你看到的异常堆栈里的Objects.requireNonNull(Objects.java:228)，是因为R2DBC映射结果时，当返回NULL但方法定义的是Mono<Long>（非Optional），Reactor在处理这个空值时会强制执行非空检查，最终抛出空指针异常。

内容的提问来源于stack exchange，提问作者user3553913