通过 Java SDK 动态管理 Couchbase 存储桶
Managing Couchbase buckets dynamically through Java SDK
我想知道是否有一些方法可以使用 Couchbase Java SDK 执行诸如列出 Couchbase 集群中现有存储桶、创建新存储桶、检索集群信息等功能?
我知道这可以通过 REST API 完成,但我正在尝试使用 Java 动态管理集群。
是的,可以通过 Cluster
对象的 clusterManager()
方法访问 ClusterManager
class。您需要管理凭据。
要创建新的存储桶,您可以使用集群管理器 class 的 insertBucket() 方法,该方法接收 BucketSettings 对象。例如,您可以像这样创建一个存储桶:
..
BucketSettings PrashantSampleBucket = new
DefaultBucketSettings.Builder()
.type(BucketType.COUCHBASE)
.name("PrashantSampleBucket")
.password("")
.quota(2048) // megabytes
.replicas(1)
.indexReplicas(true)
.enableFlush(true)
.build();
.....
现在您需要将存储桶插入集群中,这可以通过以下方式完成:
cluster.clusterManager().insertBucket(PrashantSampleBucket);
我想知道是否有一些方法可以使用 Couchbase Java SDK 执行诸如列出 Couchbase 集群中现有存储桶、创建新存储桶、检索集群信息等功能?
我知道这可以通过 REST API 完成,但我正在尝试使用 Java 动态管理集群。
是的,可以通过 Cluster
对象的 clusterManager()
方法访问 ClusterManager
class。您需要管理凭据。
要创建新的存储桶,您可以使用集群管理器 class 的 insertBucket() 方法,该方法接收 BucketSettings 对象。例如,您可以像这样创建一个存储桶:
..
BucketSettings PrashantSampleBucket = new
DefaultBucketSettings.Builder()
.type(BucketType.COUCHBASE)
.name("PrashantSampleBucket")
.password("")
.quota(2048) // megabytes
.replicas(1)
.indexReplicas(true)
.enableFlush(true)
.build();
..... 现在您需要将存储桶插入集群中,这可以通过以下方式完成:
cluster.clusterManager().insertBucket(PrashantSampleBucket);