Spring Boot Mongo查询映射出错时如何返回部分结果？

针对单条记录映射失败导致整个查询抛出异常的问题，有两种实用方案可以实现仅返回成功映射的结果：

方案一：手动遍历文档逐个映射（推荐，灵活可控） #

先以Document类型取出所有查询结果，再逐个尝试映射到目标实体类，捕获单条记录的映射异常并跳过失败项：

// 查询所有原始MongoDB文档
List<Document> rawDocuments = mongoTemplate.find(query, Document.class);
List<ProfileMongo> validProfiles = new ArrayList<>();

for (Document doc : rawDocuments) {
    try {
        // 调用转换器手动映射单条文档
        ProfileMongo profile = mongoTemplate.getConverter().read(ProfileMongo.class, doc);
        validProfiles.add(profile);
    } catch (MappingException e) {
        // 记录失败日志，便于后续排查问题
        log.warn("映射文档失败，ID: {}，错误信息: {}", doc.get("_id"), e.getMessage());
        // 直接跳过当前失败记录
    }
}

这种方式无需修改实体类或转换器配置，完全控制每条记录的映射流程，适合快速解决问题。

方案二：自定义转换器处理转换异常 #

针对报错中ArrayList转SegmentTargetingGroupIncludeExcludeMongo的转换逻辑，编写自定义转换器捕获异常，返回默认值或null，后续过滤无效结果：

1. 实现自定义Converter #

public class SegmentTargetingConverter implements Converter<ArrayList, ProfileMongo.SegmentTargetingGroupIncludeExcludeMongo> {

    @Override
    public ProfileMongo.SegmentTargetingGroupIncludeExcludeMongo convert(ArrayList source) {
        try {
            // 编写正常转换逻辑，根据source结构构造目标对象
            ProfileMongo.SegmentTargetingGroupIncludeExcludeMongo target = new ProfileMongo.SegmentTargetingGroupIncludeExcludeMongo();
            // 示例：将source中的数据赋值到target字段
            // target.setXXX(source.get(0));
            return target;
        } catch (Exception e) {
            // 转换失败时返回null，后续过滤含null字段的实体
            return null;
        }
    }
}

2. 注册自定义转换器到Spring Data MongoDB #

@Configuration
public class MongoConfig {

    @Bean
    public MongoCustomConversions mongoCustomConversions() {
        return new MongoCustomConversions(List.of(new SegmentTargetingConverter()));
    }
}

3. 查询后过滤无效结果 #

List<ProfileMongo> profileMongoList = mongoTemplate.find(query, ProfileMongo.class);
// 过滤掉SegmentTargetingGroupIncludeExclude字段为null的无效记录
List<ProfileMongo> validProfiles = profileMongoList.stream()
        .filter(profile -> profile.getSegmentTargetingGroupIncludeExclude() != null)
        .collect(Collectors.toList());

该方案适合需要统一处理该类型转换异常的场景，但需额外编写转换器代码。

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