使用C# Mongo Driver批量Upsert时_id字段插入为null的问题

我之前也踩过这个坑！核心原因其实是MongoDB驱动在批量Upsert场景下，不会像普通Insert操作那样自动为新插入的文档生成_id——普通的InsertOneAsync/InsertManyAsync会触发驱动的自动生成逻辑，但批量写操作（比如ReplaceOneModel、UpdateOneModel）的Upsert分支里，这个逻辑默认不会生效，除非你主动处理_id字段。

下面给你拆解具体的原因和解决办法：

1. 先确认实体类的_id配置（基础保障） #

虽然你说正常插入没问题，但还是快速核对下实体类的_id属性配置是否正确，确保驱动能识别它为主键：

public class YourEntity
{
    // 推荐配置：用string类型存储ObjectId，同时设置默认值自动生成
    [BsonId]
    [BsonRepresentation(BsonType.ObjectId)]
    public string Id { get; set; } = ObjectId.GenerateNewId().ToString();

    // 或者直接用ObjectId类型：
    // [BsonId]
    // public ObjectId Id { get; set; } = ObjectId.GenerateNewId();

    // 其他字段...
}

这里的关键是给_id设置默认值——当你创建实体对象时，如果没有手动赋值，默认就会生成一个合法的ObjectId。这样在批量Upsert时，即使触发插入逻辑，文档也会携带有效的_id。

2. 调整批量Upsert的代码实现 #

如果你不想修改实体类，那在构建批量操作模型时，要确保每个待处理的文档都有合法的_id：

场景一：用ReplaceOneModel做全文档替换式Upsert #

var bulkOperations = new List<WriteModel<YourEntity>>();

foreach (var item in yourDataList)
{
    // 检查并主动生成_id（如果为空）
    if (string.IsNullOrEmpty(item.Id))
    {
        item.Id = ObjectId.GenerateNewId().ToString();
    }

    // 构建过滤条件：用_id匹配
    var filter = Builders<YourEntity>.Filter.Eq(x => x.Id, item.Id);
    // 创建替换模型并开启Upsert
    var replaceModel = new ReplaceOneModel<YourEntity>(filter, item)
    {
        IsUpsert = true
    };

    bulkOperations.Add(replaceModel);
}

// 执行批量操作
await yourMongoCollection.BulkWriteAsync(bulkOperations);

场景二：用UpdateOneModel做部分字段更新式Upsert #

如果你的需求是只更新部分字段，而不是替换整个文档，那需要在UpdateDefinition里用SetOnInsert确保插入时会设置_id：

var bulkOperations = new List<WriteModel<YourEntity>>();

foreach (var item in yourDataList)
{
    // 生成或使用已有_id
    var targetId = string.IsNullOrEmpty(item.Id) ? ObjectId.GenerateNewId().ToString() : item.Id;
    var filter = Builders<YourEntity>.Filter.Eq(x => x.Id, targetId);

    // 构建更新逻辑：插入时设置_id，同时更新其他字段
    var update = Builders<YourEntity>.Update
        .SetOnInsert(x => x.Id, targetId)
        .Set(x => x.YourField1, item.YourField1)
        .Set(x => x.YourField2, item.YourField2);

    var updateModel = new UpdateOneModel<YourEntity>(filter, update)
    {
        IsUpsert = true
    };

    bulkOperations.Add(updateModel);
}

await yourMongoCollection.BulkWriteAsync(bulkOperations);

为啥普通插入没问题？ #

因为InsertOneAsync/InsertManyAsync方法内部会自动检测文档的_id是否为空，如果为空，驱动会帮你生成一个ObjectId并赋值给文档。但批量写操作的Upsert逻辑属于“更新优先”的场景，驱动默认不会主动修改你提供的文档内容，所以如果你的待插入文档没有_id，就会被插入null值。

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