Couchbase SDK 3.0 从 java 启用/禁用刷新选项

Question

我正在尝试使用以下代码启用/禁用存储桶刷新选项，但它不起作用。 (SDK 3.0)

public static void main(String... args) {
    Cluster cluster = Cluster.connect("host", "user", "password");
    cluster.bucket("bucketName").async();
    cluster.buckets().getBucket("bucketName").flushEnabled(true);
    cluster.buckets().flushBucket("bucketName");
}

还有其他方法吗？ （如果我启用桶选项来刷新，我可以使用上面的代码来刷新桶。）

Answer 1

您错过了对 updateBucket 的调用，它保存了修改后的设置：

public void setFlushable(Cluster cluster, String bucket, boolean flushable) {
  BucketSettings settings = cluster.buckets().getBucket(bucket);
  settings.flushEnabled(flushable);
  cluster.buckets().updateBucket(settings);
}