MongoDB Fluent C#中复合外键Lookup报错的解决方法咨询

问题原因 #

你遇到的ExpressionNotSupportedException是因为MongoDB的LINQ3实现无法将匿名类型的构造表达式（new { x.AccountId, x.InstitutionGroupId }）转换为MongoDB能识别的聚合字段映射，匿名类型的表达式翻译在当前版本的MongoDB驱动中未被支持。

解决方案 #

方法1：使用强类型复合键类 #

定义一个与复合键结构匹配的强类型类，替换匿名类型，MongoDB驱动可以正确识别这种强类型的属性映射：

1. 首先定义复合键类：

public class AccountCompositeKey
{
    public long AccountId { get; set; }
    public int InstitutionGroupId { get; set; }
}

2. 修改Lookup代码，使用这个强类型类：

public async Task<List<AccountwithLinkedEntities>> Lookup(int institutionGroupId, long accountId)
{
    var filter = Builders<Account>.Filter.Eq(a => a.InstitutionGroupId, institutionGroupId)
                & Builders<Account>.Filter.Eq(a => a.AccountId, accountId);
                
    var test = await _mongoDbContext.Accounts.Aggregate().Match(filter)
              .Lookup<Account, LinkedEntities, AccountwithLinkedEntities>(_mongoDbContext.LinkedEntities,
                  x => new AccountCompositeKey { AccountId = x.AccountId, InstitutionGroupId = x.InstitutionGroupId },
                  y => new AccountCompositeKey { AccountId = y.AccountId, InstitutionGroupId = y.InstitutionGroupId },
                  x => x.InnerLinkedEntities)
              .ToListAsync();
              
    return test;
}

方法2：手动构建Lookup的BsonDocument阶段 #

如果不想新增强类型类，可以直接用原生的聚合语法构建Lookup阶段，绕开LINQ表达式的限制：

public async Task<List<AccountwithLinkedEntities>> Lookup(int institutionGroupId, long accountId)
{
    var filter = Builders<Account>.Filter.Eq(a => a.InstitutionGroupId, institutionGroupId)
                & Builders<Account>.Filter.Eq(a => a.AccountId, accountId);
                
    // 手动构建Lookup阶段的BsonDocument
    var lookupStage = new BsonDocument("$lookup", new BsonDocument
    {
        { "from", _mongoDbContext.LinkedEntities.CollectionNamespace.CollectionName },
        { "let", new BsonDocument
            {
                { "accountId", "$AccountId" },
                { "institutionGroupId", "$InstitutionGroupId" }
            }
        },
        { "pipeline", new BsonArray
            {
                new BsonDocument("$match", new BsonDocument("$expr", new BsonDocument("$and", new BsonArray
                {
                    new BsonDocument("$eq", new BsonArray { "$AccountId", "$$accountId" }),
                    new BsonDocument("$eq", new BsonArray { "$InstitutionGroupId", "$$institutionGroupId" })
                })))
            }
        },
        { "as", "InnerLinkedEntities" }
    });
    
    var test = await _mongoDbContext.Accounts.Aggregate()
        .Match(filter)
        .AppendStage<AccountwithLinkedEntities>(lookupStage)
        .ToListAsync();
        
    return test;
}

这种方法直接使用MongoDB的$lookup原生语法，通过let传递主集合的字段，再在pipeline里用$expr匹配复合键，完全绕开LINQ表达式翻译的问题。

验证说明 #

两种方法都能实现基于AccountId和InstitutionGroupId的复合键关联查询，你可以根据项目的代码风格选择合适的方案。强类型方案更符合C#的面向对象风格，而原生语法方案则更灵活，适合复杂的聚合场景。

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