Connecting to Couchbase

shellCopy
cbc ping -u username -P "passworD#1" \
	-U "couchbases://cb.oawlpi4audpc6jp5.cloud.couchbase.com/travel-sample?certpath=cert.pem" \
	--count=1 \
	--table

consoleCopy
-----------------------------------------------------------------------------------------------------------------------------------
| type  | id             | status | latency, us | remote                                                      | local             |
-----------------------------------------------------------------------------------------------------------------------------------
| fts   | 0x7fecf9407a70 | ok     |      198657 | evb8loulphaibjnn.oawlpi4audpc6jp5.cloud.couchbase.com:18094 | 172.20.10.6:54394 |
| kv    | 0x7fecfb00d110 | ok     |       69737 | evb8loulphaibjnn.oawlpi4audpc6jp5.cloud.couchbase.com:11207 | 172.20.10.6:54391 |
| n1ql  | 0x7fecfb0110f0 | ok     |      210735 | evb8loulphaibjnn.oawlpi4audpc6jp5.cloud.couchbase.com:18093 | 172.20.10.6:54392 |
| views | 0x7fecf961e2e0 | ok     |      330057 | evb8loulphaibjnn.oawlpi4audpc6jp5.cloud.couchbase.com:18092 | 172.20.10.6:54393 |
-----------------------------------------------------------------------------------------------------------------------------------

csharpCopy
using System;
using System.Threading.Tasks;
using Couchbase;
using Couchbase.Query;
using Couchbase.Management.Query;
// using Microsoft.Extensions.DependencyInjection;
// using Microsoft.Extensions.Logging;
// using Serilog;
// using Serilog.Extensions.Logging;

namespace net3
{
    class Program
    {
        static async Task Main(string[] args)
        {
            // Update this to your cluster
            var endpoint = "cb.13d1a4bc-31a8-49c6-9ade-74073df0799f.dp.cloud.couchbase.com";
            var bucketName = "couchbasecloudbucket";
            var username = "user";
            var password = "password";
            // User Input ends here.

            // IServiceCollection serviceCollection = new ServiceCollection();
            // serviceCollection.AddLogging(builder => builder.AddFilter(level => level >= LogLevel.Trace));

            // var loggerFactory = serviceCollection.BuildServiceProvider().GetService<ILoggerFactory>();
            // loggerFactory.AddFile("Logs/myapp-{Date}.txt", LogLevel.Debug);

            // Initialize the Connection
            var opts = new ClusterOptions().WithCredentials(username, password);
            // opts = opts.WithLogging(loggerFactory);
            opts.IgnoreRemoteCertificateNameMismatch = true;

            var cluster = await Cluster.ConnectAsync("couchbases://"+endpoint, opts);
            var bucket = await cluster.BucketAsync(bucketName);
            var collection = bucket.DefaultCollection();

            // Store a Document
            var upsertResult = await collection.UpsertAsync("king_arthur", new {
                Name = "Arthur",
                Email = "kingarthur@couchbase.com",
                Interests = new[] { "Holy Grail", "African Swallows" }
            });

            // Load the Document and print it
            var getResult = await collection.GetAsync("king_arthur");
            Console.WriteLine(getResult.ContentAs<dynamic>());

            // Perform a N1QL Query
            var queryResult = await cluster.QueryAsync<dynamic>(
                String.Format("SELECT name FROM `{0}` WHERE $1 IN interests", bucketName), 
                new QueryOptions().Parameter("African Swallows")
            );

            // Print each found Row
            await foreach (var row in queryResult)
            {
                Console.WriteLine(row);
            }
        }
    }
}

javaCopy
Unresolved include directive in modules/guides/pages/connect.adoc - include::java-sdk:devguide:example$Cloud.java[]

nodejsCopy
var couchbase = require('couchbase')

const clusterConnStr =
  'couchbases://cb.abcdefab-cdef-abcd-efab-cdefabcdef.dp.cloud.couchbase.com'
const cloudRootCertificate = '/etc/x509-cert/SSLCA/clientdir/trust.pem'
const username = 'user'
const password = 'password'
const bucketName = 'couchbasecloudbucket'

async function go() {
  const cluster = await couchbase.connect(clusterConnStr, {
    username: username,
    password: password,
    trustStorePath: cloudRootCertificate,
  })

  const bucket = cluster.bucket(bucketName)
  const collection = bucket.defaultCollection()

  // Create a N1QL Primary Index (but ignore if it exists)
  await cluster
    .queryIndexes()
    .createPrimaryIndex(bucketName, { ignoreExists: true })

  // Create and store a document
  await collection.upsert('user:king_arthur', {
    name: 'Arthur',
    email: 'kingarthur@couchbase.com',
    interests: ['Holy Grail', 'African Swallows'],
  })

  // Load the Document and print it
  // Prints Content and Metadata of the stored Document
  let getResult = await collection.get('user:king_arthur')
  console.log('got: ', getResult)

  // Perform a N1QL Query
  let queryResult = await cluster.query(
    'SELECT name FROM ' + bucketName + ' WHERE $1 in interests LIMIT 1',
    { parameters: ['African Swallows'] }
  )
  queryResult.rows.forEach((row) => {
    console.log('query row: ', row)
  })
}
go()

pythonCopy
# tag::cloud_connect[]
from couchbase.cluster import Cluster, ClusterOptions
from couchbase.cluster import PasswordAuthenticator
from couchbase.cluster import QueryOptions

# Update this to your cluster
endpoint = "--your-instance--.dp.cloud.couchbase.com"
username = "username"
password = "password"
bucket_name = "bucketname"
cert_path = "path/to/certificate"
# User Input ends here.

# Initialize the Connection
cluster = Cluster("couchbases://{}".format(endpoint), ClusterOptions(
    PasswordAuthenticator(username, password, cert_path=cert_path)))
cb = cluster.bucket(bucket_name)
cb_coll = cb.default_collection()

# Create a N1QL Primary Index (but ignore if it exists)
cluster.query_indexes().create_primary_index(
    bucket_name, ignore_if_exists=True)

# Store a Document
cb_coll.upsert("u:king_arthur", {
               "name": "Arthur", "email": "kingarthur@couchbase.com", "interests": ["Holy Grail", "African Swallows"]})

# Load the Document and print it
print(cb_coll.get("u:king_arthur").content_as[str])

# Perform a N1QL Query
row_iter = cluster.query("SELECT cbc.* FROM {} cbc WHERE $1 IN cbc.interests".format(
    bucket_name), QueryOptions(positional_parameters=["African Swallows"]))

# Print each found Row
for row in row_iter.rows():
    print("Found row: {}".format(row))
# end::cloud_connect[]