io.flamingock.internal.common.couchbase

Class CouchbaseCollectionHelper

java.lang.Object

io.flamingock.internal.common.couchbase.CouchbaseCollectionHelper

public final class CouchbaseCollectionHelper
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static boolean	collectionExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName)
static boolean	collectionHasPrimaryIndex(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName)
static void	createCollectionIfNotExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName)
static void	createPrimaryIndexIfNotExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName)
static void	createScopeIfNotExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName)
static void	deleteAllDocuments(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName)
static void	dropCollectionIfExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName)
static void	dropIndexIfExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName, java.lang.String indexName)
static void	dropPrimaryIndexIfExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName)
static boolean	indexExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName, java.lang.String indexName)
static boolean	scopeExists(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName)
static java.util.List<com.couchbase.client.java.json.JsonObject>	selectAllDocuments(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName)
static void	waitForQueryableCollection(com.couchbase.client.java.Cluster cluster, java.lang.String bucketName, java.lang.String scopeName, java.lang.String collectionName, int maxAttempts, java.time.Duration delay)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

scopeExists

public static boolean scopeExists(com.couchbase.client.java.Cluster cluster,
                                  java.lang.String bucketName,
                                  java.lang.String scopeName)

collectionExists

public static boolean collectionExists(com.couchbase.client.java.Cluster cluster,
                                       java.lang.String bucketName,
                                       java.lang.String scopeName,
                                       java.lang.String collectionName)

indexExists

public static boolean indexExists(com.couchbase.client.java.Cluster cluster,
                                  java.lang.String bucketName,
                                  java.lang.String scopeName,
                                  java.lang.String collectionName,
                                  java.lang.String indexName)

collectionHasPrimaryIndex

public static boolean collectionHasPrimaryIndex(com.couchbase.client.java.Cluster cluster,
                                                java.lang.String bucketName,
                                                java.lang.String scopeName,
                                                java.lang.String collectionName)

createScopeIfNotExists

public static void createScopeIfNotExists(com.couchbase.client.java.Cluster cluster,
                                          java.lang.String bucketName,
                                          java.lang.String scopeName)

createCollectionIfNotExists

public static void createCollectionIfNotExists(com.couchbase.client.java.Cluster cluster,
                                               java.lang.String bucketName,
                                               java.lang.String scopeName,
                                               java.lang.String collectionName)

dropCollectionIfExists

public static void dropCollectionIfExists(com.couchbase.client.java.Cluster cluster,
                                          java.lang.String bucketName,
                                          java.lang.String scopeName,
                                          java.lang.String collectionName)

waitForQueryableCollection

public static void waitForQueryableCollection(com.couchbase.client.java.Cluster cluster,
                                              java.lang.String bucketName,
                                              java.lang.String scopeName,
                                              java.lang.String collectionName,
                                              int maxAttempts,
                                              java.time.Duration delay)

selectAllDocuments

public static java.util.List<com.couchbase.client.java.json.JsonObject> selectAllDocuments(com.couchbase.client.java.Cluster cluster,
                                                                                           java.lang.String bucketName,
                                                                                           java.lang.String scopeName,
                                                                                           java.lang.String collectionName)

deleteAllDocuments

public static void deleteAllDocuments(com.couchbase.client.java.Cluster cluster,
                                      java.lang.String bucketName,
                                      java.lang.String scopeName,
                                      java.lang.String collectionName)

createPrimaryIndexIfNotExists

public static void createPrimaryIndexIfNotExists(com.couchbase.client.java.Cluster cluster,
                                                 java.lang.String bucketName,
                                                 java.lang.String scopeName,
                                                 java.lang.String collectionName)

dropPrimaryIndexIfExists

public static void dropPrimaryIndexIfExists(com.couchbase.client.java.Cluster cluster,
                                            java.lang.String bucketName,
                                            java.lang.String scopeName,
                                            java.lang.String collectionName)

dropIndexIfExists

public static void dropIndexIfExists(com.couchbase.client.java.Cluster cluster,
                                     java.lang.String bucketName,
                                     java.lang.String scopeName,
                                     java.lang.String collectionName,
                                     java.lang.String indexName)