.NET中聚合Lookup时如何将字符串ID转为ObjectId？

你的问题核心是类型不匹配：Book集合的Genres字段存的是字符串ID，而Genre集合的_id是ObjectId类型，直接Lookup时两边类型不一致，导致关联失败返回空数组。以下是两种可行的解决方法：

方法1：聚合阶段转换字符串为ObjectId后再关联 #

在聚合管道中，先通过$addFields将Book的Genres字符串数组转为ObjectId数组，再执行Lookup操作，最后可按需过滤指定Title的结果。

示例代码：

using MongoDB.Driver;
using MongoDB.Bson;

var mongoClient = new MongoClient("your_connection_string");
var database = mongoClient.GetDatabase("your_db_name");
var bookCollection = database.GetCollection<Book>("Book");
var genreCollection = database.GetCollection<Genre>("Genre");

var aggregation = bookCollection.Aggregate()
    // 将字符串类型的Genres转为ObjectId数组
    .AddFields(new BsonDocument("$addFields", new BsonDocument
    {
        ["GenresObjectIds"] = new BsonDocument("$map", new BsonDocument
        {
            ["input"] = "$Genres",
            ["as"] = "genreId",
            ["in"] = new BsonDocument("$toObjectId", "$$genreId")
        })
    }))
    // 关联Genre集合，使用转换后的ObjectId数组
    .Lookup(
        foreignCollection: genreCollection,
        localField: "GenresObjectIds",
        foreignField: "_id",
        @as: "GenreDetails"
    )
    // 过滤GenreTitle为"Thriller"的结果
    .Match(new BsonDocument("GenreDetails.Title", "Thriller"))
    // 移除临时生成的转换字段
    .Project<BookWithGenres>(new BsonDocument("$unset", "GenresObjectIds"));

var result = await aggregation.ToListAsync();

// 对应实体类定义
public class Book
{
    public ObjectId Id { get; set; }
    public string Title { get; set; }
    public List<string> Genres { get; set; }
}

public class Genre
{
    public ObjectId Id { get; set; }
    public string Title { get; set; }
}

public class BookWithGenres : Book
{
    public List<Genre> GenreDetails { get; set; }
}

方法2：修改实体类，直接存储ObjectId类型的Genres #

如果是新项目或可修改现有数据结构，推荐从根源解决问题：调整Book实体类的Genres属性类型为List<ObjectId>，存入数据库时直接存储ObjectId类型，Lookup时无需转换即可匹配。

示例代码：

// 修改后的Book实体类
public class Book
{
    public ObjectId Id { get; set; }
    public string Title { get; set; }
    public List<ObjectId> Genres { get; set; } // 改为ObjectId集合类型
}

// 直接执行Lookup与过滤
var aggregation = bookCollection.Aggregate()
    .Lookup(
        foreignCollection: genreCollection,
        localField: "Genres",
        foreignField: "_id",
        @as: "GenreDetails"
    )
    .Match(new BsonDocument("GenreDetails.Title", "Fantasy"));

var result = await aggregation.ToListAsync();

注意事项 #

• 方法1适合已有数据集的场景，无需修改现有数据；方法2适合新项目，能避免后续类型匹配问题。
• $toObjectId是MongoDB 4.0及以上版本支持的操作符，请确保你的MongoDB版本符合要求。

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