MongoDB线程安全UPSERT实现及Guid作为_id的问题咨询

我试了好几种方法，最终用下面的代码实现了**文档不存在则插入（UPSERT）**的逻辑：

var filter = DbClientFilterBuilder.BuildFilter(parameters?.Filter);
var db = client.GetDatabase(dbName);
var collection = db.GetCollection<T>(table);
        
var builder = Builders<T>.Update;
List<UpdateDefinition<T>> updates = new List<UpdateDefinition<T>>();
foreach (var propInfo in typeof(T).GetProperties(BindingFlags.Instance | BindingFlags.Public))
{
    if (!propInfo.Name.Equals("_id"))
    {
         updates.Add(builder.Set(propInfo.Name, propInfo.GetValue(record)));
    }
    else
    {
         updates.Add(builder.SetOnInsert(propInfo.Name, Guid.NewGuid()));
    }
} 
        
var result = await collection.FindOneAndUpdateAsync(filter, builder.Combine(updates), new FindOneAndUpdateOptions<T>
{
    IsUpsert = true,
    ReturnDocument = ReturnDocument.After
});

我的疑问： #

1. 这真的是实现UPSERT的唯一方式吗？
2. 我之前尝试直接传入完整记录，但遇到了Guid与ObjectId的兼容问题。怎么才能以线程安全的方式向集合插入文档，仅在插入时生成Guid作为_id，且读取文档时不报错？

解答 #

1. 这不是唯一的UPSERT实现方式 #

你当前的反射遍历属性的方式可行，但还有更简洁的方案：

方案一：利用ReplaceOneAsync实现UPSERT

如果过滤条件能精准匹配唯一文档，直接用ReplaceOneAsync配合IsUpsert=true更直观，性能也更好：

// 仅在插入新文档时生成Guid，更新时保留原_id
if (EqualityComparer<Guid>.Default.Equals(record._id, default))
{
    record._id = Guid.NewGuid();
}

var result = await collection.ReplaceOneAsync(
    filter,
    record,
    new ReplaceOptions { IsUpsert = true }
);

注意：此方案要求过滤条件能确保匹配唯一文档，避免误替换多条数据。

方案二：插入+捕获重复键异常（适合插入远多于更新的场景）

先尝试插入新文档，若捕获到重复键异常再执行更新：

try
{
    if (EqualityComparer<Guid>.Default.Equals(record._id, default))
    {
        record._id = Guid.NewGuid();
    }
    await collection.InsertOneAsync(record);
    // 插入成功，直接返回记录
}
catch (MongoWriteException ex) when (ex.WriteError.Category == ServerErrorCategory.DuplicateKey)
{
    // 执行更新逻辑
    var update = Builders<T>.Update
        .Set(x => x.Property1, record.Property1)
        .Set(x => x.Property2, record.Property2);
    var result = await collection.FindOneAndUpdateAsync(filter, update, new FindOneAndUpdateOptions<T>
    {
        ReturnDocument = ReturnDocument.After
    });
}

这种方式适合插入操作占比极高的场景，但要注意异常捕获的性能开销。

2. 解决Guid与ObjectId兼容问题，实现线程安全的Guid生成 #

核心配置：实体类的序列化规则

MongoDB默认用ObjectId作为_id，要兼容Guid，需在实体类中明确指定_id的类型和序列化方式：

public class YourEntity
{
    [BsonId]
    [BsonGuidRepresentation(GuidRepresentation.Standard)] // 指定标准Guid存储格式
    public Guid _id { get; set; }
    // 其他属性...
}

GuidRepresentation.Standard会让MongoDB将Guid存储为标准二进制格式，彻底解决序列化/反序列化时的类型不兼容问题。

线程安全的Guid生成

Guid.NewGuid()本身就是线程安全的——它内部调用的是Windows系统级的线程安全API，无需额外加锁或同步处理，直接使用即可。

避免插入时的_id冲突

只要在插入前判断_id是否为默认值（空Guid），仅在为空时生成新Guid，就能保证只有新文档会生成_id，更新操作会保留原文档的_id，完美适配UPSERT逻辑：

if (EqualityComparer<Guid>.Default.Equals(record._id, default))
{
    record._id = Guid.NewGuid();
}

总结 #

你当前的反射方案可行，但并非唯一选择——根据业务场景，ReplaceOneAsync或「插入+捕获异常」的方式更简洁高效。解决Guid与ObjectId的兼容问题，核心是实体类的驱动配置；Guid.NewGuid()本身线程安全，配合前置的_id判断逻辑，就能满足你的需求。

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