index.js

var cb = require("couchbase")
var async = require("async")

var cluster = new cb.Cluster("couchbase://localhost/")
var bucket = cluster.openBucket("default")
bucket.queryhosts = ["localhost:8093"]

var log = function () {
  var args = Array.prototype.slice.call(arguments, 0)
  console.log.apply(null, args.filter(function (e) { return e != null }))
}

async.series([
  function(cb) {
    bucket.upsert("foo", JSON.stringify({bar: "baz"}), function (err, res) {
      log(err, res)
      cb()
    })
  },

  function(cb) {
    bucket.get("foo", function (err, res) {
      log(err, res)
      cb()
    })
  },

  function(cb) {
    bucket.query("SELECT * FROM default LIMIT 1", function (err, res) {
      log(err, res)
      cb()
    })
  },

  function(cb) {
    bucket.query("SELECT * FROM default WHERE bar = ? LIMIT 1", ['baz'], function (err, res) {
      log(err, res)
      cb()
    })
  },

  bucket.shutdown.bind(bucket)
])