如何在C#中从MongoDB返回指定ID客户的指定字段

方案一：数据库层面动态投影（推荐，性能最优） #

如果使用Entity Framework Core（EF Core），可以通过表达式树动态构建查询，直接在数据库层面过滤ID和需要的字段，避免不必要的数据传输。

代码实现：

using System.Linq.Expressions;
using MongoDB.Bson; // 若使用MongoDB的ObjectId

public IQueryable<ExpandoObject> GetCustomers(List<string> idStrings, List<string> fields)
{
    // 将字符串ID转换为ObjectId列表
    var targetIds = idStrings.Select(s => ObjectId.Parse(s)).ToList();
    
    // 第一步：过滤ID匹配的客户
    var baseQuery = _context.Customers.Where(c => targetIds.Contains(c.id));
    
    // 第二步：动态构建字段投影表达式
    var customerParam = Expression.Parameter(typeof(Customer), "c");
    var propertyBindings = fields.Select(field =>
    {
        // 获取对应属性（忽略大小写兼容）
        var property = typeof(Customer).GetProperty(field, 
            BindingFlags.Public | BindingFlags.Instance | BindingFlags.IgnoreCase);
        if (property == null)
            throw new ArgumentException($"字段 {field} 在Customer类中不存在");
            
        var propertyExpr = Expression.Property(customerParam, property);
        // 绑定到ExpandoObject的成员
        return Expression.Bind(typeof(ExpandoObject).GetProperty(field), propertyExpr);
    });
    
    var initExpr = Expression.MemberInit(Expression.New(typeof(ExpandoObject)), propertyBindings);
    var selector = Expression.Lambda<Func<Customer, ExpandoObject>>(initExpr, customerParam);
    
    // 执行投影查询
    return baseQuery.Select(selector);
}

使用示例：

var result = GetCustomers(id1, fields1).ToList();
foreach (var customer in result)
{
    Console.WriteLine($"FirstName: {customer.FirstName}, LastName: {customer.LastName}");
}

方案二：内存中反射筛选（适合小数据量场景） #

如果已经获取了全量客户数据，或不需要数据库层面优化，可以用反射在内存中提取指定字段。

代码实现：

using MongoDB.Bson;

public List<Dictionary<string, object>> GetCustomersInMemory(List<string> idStrings, List<string> fields)
{
    var targetIds = idStrings.Select(s => ObjectId.Parse(s)).ToList();
    
    // 先查询所有匹配ID的客户（从数据库或内存数据源获取）
    var matchedCustomers = _context.Customers.Where(c => targetIds.Contains(c.id)).ToList();
    
    var result = new List<Dictionary<string, object>>();
    foreach (var customer in matchedCustomers)
    {
        var fieldDict = new Dictionary<string, object>();
        foreach (var field in fields)
        {
            var property = typeof(Customer).GetProperty(field, 
                BindingFlags.Public | BindingFlags.Instance | BindingFlags.IgnoreCase);
            if (property != null)
            {
                fieldDict[field] = property.GetValue(customer);
            }
        }
        result.Add(fieldDict);
    }
    return result;
}

关键注意事项 #

• ID类型转换：确保将传入的字符串ID正确转换为ObjectId（若使用MongoDB），避免类型不匹配错误。
• 字段大小写兼容：通过BindingFlags.IgnoreCase处理字段名大小写不一致的情况。
• 复杂字段支持：对于Emails、Phones这类集合类型，两种方案都能直接提取，无需额外处理。

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