如何用Couchbase .NET SDK按Id删除Bucket所有文档children数组指定节点

完全可以通过.NET SDK的子文档操作能力实现需求，且性能远高于跨文档全量N1QL扫描——子文档操作是单文档级的局部字段修改，不需要走查询引擎的全索引/全扫描流程，处理数千份文档时的延迟和资源开销会有数量级的下降。

分版本适配实现 #

适配Couchbase 7.0及以上版本（最优性能） #

该版本的子文档操作原生支持数组路径条件谓词，不需要客户端提前拉取数组内容，可直接在服务端完成元素匹配和删除，全程只做局部修改，无额外数据传输开销。

• 针对你的文档结构，要定位results[0].tutorial.children数组中Id值为"100"的元素，直接使用带条件的路径即可完成删除，删除范围自动覆盖该元素下的所有子节点（包含全部Details内容）
• 实现代码示例：

// 初始化获取目标Collection实例（7.0+推荐直接操作Collection级别，跳过Bucket层冗余逻辑）
var bucket = await cluster.BucketAsync("你的Bucket名称");
var collection = await bucket.DefaultCollectionAsync();

// 获取需要处理的文档ID列表：使用轻量N1QL仅查文档元数据，开销极低
string[] targetDocIds = await GetMatchedDocIds();

// 适当控制并发度（建议每批次20-50个并发请求）批量处理，SDK自带连接池不需要额外封装
var parallelOption = new ParallelOptions { MaxDegreeOfParallelism = 30 };
Parallel.ForEach(targetDocIds, parallelOption, async docId =>
{
    try
    {
        await collection.MutateInAsync(docId, builder =>
        {
            // 路径直接匹配children数组中Id为"100"的元素，删除整个节点
            builder.Remove("results[0].tutorial.children[?].Id = \"100\"");
        });
    }
    catch (PathNotFoundException)
    {
        // 文档中无匹配路径/元素，直接跳过即可
        return;
    }
});

适配Couchbase 6.x及更早版本（兼容方案） #

老版本子文档操作不支持数组路径条件谓词，无法直接通过路径定位匹配元素，需要两步操作，但依然比“全量读文档-客户端修改-全量回写”的方案性能高很多：

1. 客户端通过子文档LookupIn，仅读取目标children数组节点的内容，不拉取整个文档
2. 在客户端内存中遍历数组，找到Id == "100"的元素对应的数组索引
3. 调用MutateIn接口，按明确的索引位置删除对应数组元素，仅做局部修改不回写全文档

• 实现代码示例：

var parallelOption = new ParallelOptions { MaxDegreeOfParallelism = 30 };
Parallel.ForEach(targetDocIds, parallelOption, async docId =>
{
    // 第一步：仅拉取children数组节点，传输数据量极小
    var lookupResult = await collection.LookupInAsync(docId, builder =>
    {
        builder.Get("results[0].tutorial.children");
    });

    if (!lookupResult.Exists("results[0].tutorial.children")) return;

    // 内存中匹配目标元素的索引
    var childrenList = lookupResult.ContentAs<Newtonsoft.Json.Linq.JArray>("results[0].tutorial.children");
    int targetIndex = -1;
    for (int i = 0; i < childrenList.Count; i++)
    {
        if (childrenList[i]["Id"]?.ToString() == "100")
        {
            targetIndex = i;
            break;
        }
    }

    if (targetIndex == -1) return;

    // 按索引删除对应数组元素，局部修改无全量文档传输
    await collection.MutateInAsync(docId, builder =>
    {
        builder.Remove($"results[0].tutorial.children[{targetIndex}]");
    });
});

性能优化注意点 #

• 获取待处理文档ID时，不要跑全字段扫描的N1QL，仅返回META().id即可，配合覆盖索引可以让查询完全走索引层，不扫描实际文档，这一步的开销可以忽略。参考的轻量查询逻辑：

  SELECT META().id 
  FROM `你的Bucket名称` 
  WHERE ANY c IN results[0].tutorial.children SATISFIES c.Id = "100" END
  

• 批量处理时不要单线程串行请求，根据自己集群的负载适当调整并发度，通常30左右的并发就可以打满单节点的写入能力
• 子文档操作是局部块修改，相比全文档回写的版本冲突概率低很多，适合批量更新场景

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