如何为MongoDB聚合管道添加投影实现Model到DTO映射

场景与问题 #

使用.NET 8 + MongoDB Driver 2.24，现有以下Model和DTO：

public class User
{
    public string FullName { get; set; }
    public string DomainEmail { get; set; }
}

public class UserDto
{
    public string Name { get; set; }
    public string Email { get; set; }
}

执行聚合查询时，需要将User的字段映射到UserDto，尝试手动创建投影但无法正常应用到Aggregate方法中，同时已配置AutoMapper映射：

CreateMap<User, UserDto>()
    .ForMember(u => u.Name, opts => opts.MapFrom(u => u.FullName))
    .ForMember(u => u.Email, opts => opts.MapFrom(u => u.DomainEmail));

原始聚合代码：

var matchStage = new BsonDocument("$match", new BsonDocument
{
    {  nameof(User.FullName), new BsonDocument("$eq", "Foo bar") }
});

var pipeline = new[] { matchStage };

var result = await _collection.Aggregate<UserDto>(pipeline).ToListAsync();

尝试的投影代码（无法正常工作）：

var projection = Builders<User>.Projection.Expression(m => new UserDto
{
    Name = m.FullName,
    Email = m.DomainEmail
});

var result = await _collection
    .Aggregate<UserDto>(pipeline)
    .Project(projection) // 此处报错
    .ToListAsync();

解决方法 #

1. 正确在聚合管道中应用投影 #

之前的问题在于Aggregate<UserDto>已经指定了输出类型，而投影需要作为管道的一部分，或者调整聚合的泛型类型后使用投影方法。

方式1：将投影转换为管道阶段加入聚合

var matchStage = new BsonDocument("$match", new BsonDocument
{
    { nameof(User.FullName), new BsonDocument("$eq", "Foo bar") }
});

// 将手动创建的投影转为BsonDocument阶段
var projectionStage = projection.ToBsonDocument();
var pipeline = new[] { matchStage, projectionStage };

// 直接聚合到UserDto
var result = await _collection.Aggregate<UserDto>(pipeline).ToListAsync();

方式2：先聚合到Model，再用泛型Project映射到DTO

var matchStage = new BsonDocument("$match", new BsonDocument
{
    { nameof(User.FullName), new BsonDocument("$eq", "Foo bar") }
});

var pipeline = new[] { matchStage };

// 先聚合查询出User对象，再通过Project表达式映射到UserDto
var result = await _collection
    .Aggregate<User>(pipeline)
    .Project(u => new UserDto
    {
        Name = u.FullName,
        Email = u.DomainEmail
    })
    .ToListAsync();

2. 利用AutoMapper在内存中映射（适合小数据量） #

如果聚合返回的数据量不大，可以先查询出User集合，再用AutoMapper批量转换为UserDto，无需在MongoDB端做投影，适合复杂映射场景：

var matchStage = new BsonDocument("$match", new BsonDocument
{
    { nameof(User.FullName), new BsonDocument("$eq", "Foo bar") }
});

var pipeline = new[] { matchStage };

// 先查询出User列表
var users = await _collection.Aggregate<User>(pipeline).ToListAsync();
// 用AutoMapper转换为UserDto
var result = _mapper.Map<List<UserDto>>(users);

3. 用AutoMapper自动生成MongoDB投影（适合大量字段） #

通过AutoMapper的MongoDB扩展包，可基于已有的映射配置自动生成MongoDB投影表达式，避免手动编写大量字段映射：

步骤1：安装扩展包

Install-Package AutoMapper.MongoDB

步骤2：配置并使用

// 初始化AutoMapper配置时添加MongoDB映射支持
var mapperConfig = new MapperConfiguration(cfg =>
{
    cfg.AddMongoDBMappingProfile();
    cfg.CreateMap<User, UserDto>()
        .ForMember(u => u.Name, opts => opts.MapFrom(u => u.FullName))
        .ForMember(u => u.Email, opts => opts.MapFrom(u => u.DomainEmail));
});
var _mapper = mapperConfig.CreateMapper();

// 生成投影表达式
var projection = mapperConfig.CreateProjection<User, UserDto>();

// 聚合查询中使用自动生成的投影
var matchStage = new BsonDocument("$match", new BsonDocument
{
    { nameof(User.FullName), new BsonDocument("$eq", "Foo bar") }
});

var pipeline = new[] { matchStage };

var result = await _collection
    .Aggregate<User>(pipeline)
    .Project(projection)
    .ToListAsync();

方法选型建议 #

• 方法1：适合需要在MongoDB端完成投影（减少网络传输数据量），且字段映射逻辑简单的场景；
• 方法2：适合数据量较小，或映射逻辑复杂（如涉及嵌套对象转换、计算逻辑）的场景；
• 方法3：适合Model和DTO字段数量多的场景，利用AutoMapper配置自动生成投影，减少重复代码。

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