MongoDB BulkWrite能否返回成功替换的ID？C#批量替换文档疑问

好问题！MongoDB的BulkWrite操作完全可以帮你拿到成功替换的文档ID，只需要稍微调整下代码逻辑就能实现。我结合你的C#代码场景，给你两种实用的解决方案：

方案一：利用请求与结果的顺序关联 #

MongoDB驱动会保证WriteModel的顺序和BulkWriteResult.ProcessedRequests的结果顺序完全一致，所以我们可以通过索引直接关联原始的Thing对象和对应的执行结果：

public async Task<IReadOnlyList<ThingUpdateResult>> UpdateAsync(
    [NotNull] IReadOnlyList<Thing> things, 
    CancellationToken cancellationToken = default(CancellationToken))
{
    if (things == null) throw new ArgumentNullException(nameof(things));

    // 将WriteModel转为List，确保顺序稳定
    var writeModels = things
        .Select(i => new ReplaceOneModel<Thing>(
            new ObjectFilterDefinition<Thing>(new {i.Id}), 
            i))
        .ToList();

    // 执行批量替换
    var bulkWriteResult = await _collection.BulkWriteAsync(
        writeModels, 
        new BulkWriteOptions(), 
        cancellationToken);

    // 遍历结果，关联原始ID并判断是否成功
    var updateResults = new List<ThingUpdateResult>();
    for (int i = 0; i < writeModels.Count; i++)
    {
        if (bulkWriteResult.ProcessedRequests[i] is ReplaceOneResult replaceResult)
        {
            // 根据业务需求选择判断条件：
            // - ModifiedCount > 0：文档确实被修改（内容有变化）
            // - MatchedCount > 0：文档被匹配到（即使内容无变化）
            bool isSuccess = replaceResult.ModifiedCount > 0;
            updateResults.Add(new ThingUpdateResult(things[i].Id, isSuccess));
        }
        else
        {
            updateResults.Add(new ThingUpdateResult(things[i].Id, false));
        }
    }

    return updateResults;
}

// 示例的ThingUpdateResult结构（可根据你的实际需求调整）
public class ThingUpdateResult
{
    public ObjectId Id { get; }
    public bool IsSuccess { get; }

    public ThingUpdateResult(ObjectId id, bool isSuccess)
    {
        Id = id;
        IsSuccess = isSuccess;
    }
}

方案二：通过Tag属性携带ID（更灵活） #

如果担心索引关联的可靠性，或者需要在复杂批量操作中区分不同请求，可以给每个ReplaceOneModel的Tag属性赋值为对应的文档ID，后续直接从结果中提取Tag：

public async Task<IReadOnlyList<ThingUpdateResult>> UpdateAsync(
    [NotNull] IReadOnlyList<Thing> things, 
    CancellationToken cancellationToken = default(CancellationToken))
{
    if (things == null) throw new ArgumentNullException(nameof(things));

    var writeModels = things
        .Select(i => 
        {
            var replaceModel = new ReplaceOneModel<Thing>(
                new ObjectFilterDefinition<Thing>(new {i.Id}), 
                i);
            // 将文档ID存入Tag属性
            replaceModel.Tag = i.Id;
            return replaceModel;
        })
        .ToList();

    var bulkWriteResult = await _collection.BulkWriteAsync(writeModels, cancellationToken);

    // 提取所有成功替换的ID
    var successfulResults = bulkWriteResult.ProcessedRequests
        .Where(entry => entry is ReplaceOneResult replaceResult && replaceResult.ModifiedCount > 0)
        .Select(entry => new ThingUpdateResult((ObjectId)entry.Tag, true))
        .ToList();

    // 如果你需要包含失败的结果，可以补充遍历原始列表，对比成功ID后添加
    var allResults = things
        .Select(thing => new ThingUpdateResult(
            thing.Id, 
            successfulResults.Any(r => r.Id == thing.Id)))
        .ToList();

    return allResults;
}

关键注意点 #

• ModifiedCount vs MatchedCount：ModifiedCount表示实际被修改的文档数（只有当文档内容和原内容不同时才会大于0）；MatchedCount表示被匹配到的文档数（即使内容无变化也会大于0），请根据你的业务需求选择判断条件。
• ID类型适配：如果你的文档ID不是ObjectId（比如Guid），只需要将代码中的类型替换为对应的类型即可。

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