java - 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);
}