Merge pull request #18 from couchbase-examples/adding-capella-method

adding method explaining how to connect with capella

Author: deniswsrosa

src/main/java/org/couchbase/quickstart/configs/CouchbaseConfig.java

@@ -1,9 +1,14 @@
 package org.couchbase.quickstart.configs;
 
+import com.couchbase.client.core.deps.io.netty.handler.ssl.util.InsecureTrustManagerFactory;
+import com.couchbase.client.core.env.IoConfig;
+import com.couchbase.client.core.env.SecurityConfig;
 import com.couchbase.client.core.error.BucketExistsException;
 import com.couchbase.client.core.msg.kv.DurabilityLevel;
 import com.couchbase.client.java.Bucket;
 import com.couchbase.client.java.Cluster;
+import com.couchbase.client.java.ClusterOptions;
+import com.couchbase.client.java.env.ClusterEnvironment;
 import com.couchbase.client.java.manager.bucket.BucketSettings;
 import com.couchbase.client.java.manager.bucket.BucketType;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -16,6 +21,24 @@ public class CouchbaseConfig {
     @Autowired
     private DBProperties dbProp;
 
+    /**
+     * NOTE: To connect with Couchbase CAPELLA please use the commented method bellow as it requires TLS
+     */
+/*  @Bean
+    public Cluster getCouchbaseCluster(){
+        ClusterEnvironment env = ClusterEnvironment.builder()
+                .securityConfig(SecurityConfig.enableTls(true)
+                        .trustManagerFactory(InsecureTrustManagerFactory.INSTANCE))
+                .ioConfig(IoConfig.enableDnsSrv(true))
+                .build();
+        return Cluster.connect(dbProp.getHostName(),
+                ClusterOptions.clusterOptions(dbProp.getUsername(), dbProp.getPassword()).environment(env));
+    }
+*/
+
+    /**
+     * NOTE: To connect with Couchbase locally use the methode bellow
+     */
     @Bean
     public Cluster getCouchbaseCluster(){
         return Cluster.connect(dbProp.getHostName(), dbProp.getUsername(), dbProp.getPassword());

src/main/java/org/couchbase/quickstart/runners/DBSetupRunner.java

@@ -69,5 +69,7 @@ public void run(String... args) {
         } catch (Exception e) {
           System.out.println(String.format("Failed to create secondary index on profile.firstName: %s", e.getMessage()));
         }
+
+        System.out.println("Application is ready.");
     }
 }