如何通过Java API或Angular修改Couchbase文档的Channel字段

Couchbase Java SDK提供了mutateIn操作，可高效对文档指定字段做部分更新，无需全量读写。以下是给channel数组追加job2的代码示例：

import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.Collection;
import com.couchbase.client.java.kv.MutateInResult;
import com.couchbase.client.java.kv.MutateInSpec;
import com.couchbase.client.java.kv.MutateInOptions;
import java.util.Arrays;

public class CouchbaseArrayUpdate {
    public static void main(String[] args) {
        // 初始化集群连接
        Cluster cluster = Cluster.connect("你的集群地址", "用户名", "密码");
        Collection collection = cluster.bucket("目标桶名").defaultCollection();
        
        String docId = "要更新的文档ID";
        
        try {
            // 执行数组追加操作
            MutateInResult result = collection.mutateIn(
                    docId,
                    Arrays.asList(MutateInSpec.arrayAppend("channel", "job2")),
                    MutateInOptions.mutateInOptions().upsertDocument(false) // 仅更新已存在的文档
            );
            
            System.out.println("更新成功，CAS值：" + result.cas());
        } catch (Exception e) {
            System.err.println("更新失败：" + e.getMessage());
        } finally {
            cluster.disconnect();
        }
    }
}

说明：

• 若要避免重复添加相同元素，可将arrayAppend替换为arrayAddUnique（SDK 3.x及以上版本支持）。
• 替换代码中的集群地址、账号信息、桶名和文档ID为实际值。

在Angular项目中，可通过Couchbase JavaScript SDK实现字段更新，以下是基于Couchbase Server JS SDK的示例：

首先安装依赖：

npm install couchbase

然后在Angular组件中编写逻辑：

import { Component, OnInit } from '@angular/core';
import { Cluster } from 'couchbase';

@Component({
  selector: 'app-couchbase-update',
  templateUrl: './couchbase-update.component.html'
})
export class CouchbaseUpdateComponent implements OnInit {

  ngOnInit(): void {
    this.appendChannelValue();
  }

  async appendChannelValue(): Promise<void> {
    // 连接集群
    const cluster = await Cluster.connect('你的集群地址', {
      username: '用户名',
      password: '密码'
    });

    const bucket = cluster.bucket("目标桶名");
    const collection = bucket.defaultCollection();
    const docId = "要更新的文档ID";

    try {
      // 追加元素到channel数组
      const result = await collection.mutateIn(docId, [
        { arrayAppend: 'channel', value: 'job2' }
      ], { upsertDocument: false });

      console.log("更新成功，CAS值：", result.cas);
    } catch (err) {
      console.error("更新失败：", err);
    } finally {
      await cluster.disconnect();
    }
  }
}

说明：

• 若使用Couchbase Lite（离线/移动端场景），需改用Database和Document对象，先读取文档、修改数组后再保存。
• 同样可使用arrayAddUnique替代arrayAppend实现去重追加。

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