sdk-connection-nodejs.js

/**
 * Couchbase SDK connection singleton — Node.js
 * Copy and adapt for your application.
 *
 * Dependencies:
 *   npm install couchbase
 */

'use strict';

const couchbase = require('couchbase');

// --- Configuration ---
const CB_HOST       = 'localhost';          // or 'cb.xxxxx.cloud.couchbase.com' for Capella
const CB_USER       = 'app-service-user';
const CB_PASSWORD   = 'AppSecret123!';
const CB_BUCKET     = 'myapp';
const CB_SCOPE      = '_default';
const CB_COLLECTION = '_default';

let cluster    = null;
let collection = null;

/**
 * Returns the singleton Collection, initializing the cluster on first call.
 * @returns {Promise<couchbase.Collection>}
 */
async function getCollection() {
  if (collection) return collection;
  await init();
  return collection;
}

/**
 * Returns the singleton Cluster (needed for queries and transactions).
 * @returns {Promise<couchbase.Cluster>}
 */
async function getCluster() {
  await getCollection(); // ensures cluster is initialized
  return cluster;
}

async function init() {
  // Use 'couchbases://' for TLS (required for Capella, recommended for production)
  cluster = await couchbase.connect(`couchbase://${CB_HOST}`, {
    username: CB_USER,
    password: CB_PASSWORD,
    timeouts: {
      connectTimeout:  10_000,   // ms
      kvTimeout:        2_500,
      queryTimeout:    75_000,
      searchTimeout:   75_000,
    },
  });

  const bucket = cluster.bucket(CB_BUCKET);
  collection   = bucket.scope(CB_SCOPE).collection(CB_COLLECTION);
}

/** Call on application shutdown to release resources. */
async function close() {
  if (cluster) await cluster.close();
}

module.exports = { getCollection, getCluster, close };

// --- Usage example ---
if (require.main === module) {
  (async () => {
    const col = await getCollection();
    const cl  = await getCluster();

    // KV upsert
    await col.upsert('doc_1', { type: 'example', value: 42 });

    // KV get
    const result = await col.get('doc_1');
    console.log(result.content);

    // SQL++ query
    const rows = await cl.query(
      'SELECT * FROM `myapp`._default._default WHERE type = $type LIMIT 5',
      { parameters: { type: 'example' } }
    );
    for (const row of rows.rows) console.log(row);

    await close();
  })();
}