如何全局配置MongoTemplate.getCollection().aggregate()结果转POJO？

问题背景 #

MongoTemplate提供了两种聚合查询API：

• 直接调用MongoTemplate.aggregate()：自带POJO映射支持，无需额外配置
• 通过MongoTemplate.getCollection().aggregate()：底层直接操作MongoDB原生的MongoCollection，默认不继承MongoTemplate的POJO编解码器配置，导致映射自定义POJO时抛出CodecConfigurationException

由于业务需求必须使用第二种API，我们可以通过全局配置MongoDB客户端的编解码器注册表，让所有通过MongoTemplate获取的MongoCollection实例默认支持POJO序列化/反序列化。

全局配置方案 #

核心思路是自定义MongoClientSettings，全局注册POJO编解码器，让Spring Boot基于这个配置创建MongoTemplate，确保底层所有MongoCollection实例都使用该编解码器。

步骤1：创建Mongo配置类 #

import com.mongodb.MongoClientSettings;
import org.bson.codecs.configuration.CodecRegistries;
import org.bson.codecs.configuration.CodecRegistry;
import org.bson.codecs.pojo.PojoCodecProvider;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.SimpleMongoClientDatabaseFactory;
import org.springframework.data.mongodb.core.convert.MongoConverter;

@Configuration
public class MongoGlobalCodecConfig {

    @Bean
    public MongoClientSettings mongoClientSettings() {
        // 构建包含默认编解码器+POJO自动映射的注册表
        CodecRegistry pojoCodecRegistry = CodecRegistries.fromRegistries(
            MongoClientSettings.getDefaultCodecRegistry(),
            CodecRegistries.fromProviders(PojoCodecProvider.builder().automatic(true).build())
        );

        return MongoClientSettings.builder()
            .codecRegistry(pojoCodecRegistry)
            .build();
    }

    @Bean
    public SimpleMongoClientDatabaseFactory mongoDatabaseFactory(MongoClientSettings mongoClientSettings) {
        // 替换为你的数据库名称，或从配置文件读取（可结合Environment）
        String dbName = "your-database-name";
        return new SimpleMongoClientDatabaseFactory(mongoClientSettings, dbName);
    }

    @Bean
    public MongoTemplate mongoTemplate(SimpleMongoClientDatabaseFactory mongoDatabaseFactory, MongoConverter mongoConverter) {
        return new MongoTemplate(mongoDatabaseFactory, mongoConverter);
    }
}

配置说明 #

• PojoCodecProvider.builder().automatic(true)：自动扫描并注册所有POJO类的编解码器，无需手动指定每个类
• 自定义的MongoClientSettings会被Spring Boot用来创建Mongo客户端，所有基于该客户端的MongoCollection实例都会默认使用这个编解码器注册表

验证配置 #

配置完成后，直接调用getCollection().aggregate()并指定POJO类型即可，无需再手动调用withCodecRegistry：

import com.mongodb.client.model.Aggregates;
import java.util.ArrayList;
import java.util.List;

// 业务代码中使用示例
List<MyPojo> results = mongoTemplate.getCollection("myCollectionName")
    .aggregate(List.of(Aggregates.match(/* 你的查询条件 */)), MyPojo.class)
    .into(new ArrayList<>());

此时不会再出现Can't find a codec for CodecCacheKey的错误。

补充说明 #

如果项目中已有自定义的MongoCustomConversions或MongoMappingContext配置，只需确保它们被Spring容器正确管理即可——Spring Data MongoDB会自动将这些自定义转换逻辑整合到全局编解码器中，无需额外调整。

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