Skip to content

Instantly share code, notes, and snippets.

@TalhaAwan
Created August 3, 2017 20:41
Show Gist options
  • Save TalhaAwan/f987df5380a5d2804619dc92fb727d71 to your computer and use it in GitHub Desktop.
Save TalhaAwan/f987df5380a5d2804619dc92fb727d71 to your computer and use it in GitHub Desktop.
Couchbase CRUD operations Node js
var uuid = require('uuid');
var couchbase = require("couchbase");
var cluster = new couchbase.Cluster("127.0.0.1:8091");
var CbBucket = "aBucket";
var pass = "12345678";
//get
var bucket = cluster.openBucket(CbBucket, pass, function(err) {
if (err) {
throw err;
}
else {
bucket.get("User_6da5b3a7-5ab6-40a3-b0b4-95cb32237978", function(err, user) {
if (err) {
throw err;
}
else{
console.log(user.value)
}
})
}
})
//create
var bucket = cluster.openBucket(CbBucket, pass, function(err) {
if (err) {
throw err;
}
else {
var user = {
"type": "User",
"id": "User_"+uuid.v4(),
"name": "user",
"email": "user@testemail.com",
"deleted": false
}
bucket.insert(user.id, user, function(err, result) {
if(err){
throw err;
}
else{
console.log("User Added");
}
});
}
})
//update
var bucket = cluster.openBucket(CbBucket, pass, function(err) {
if (err) {
throw err;
}
else {
bucket.get("User_6da5b3a7-5ab6-40a3-b0b4-95cb32237978", function(err, user) {
if (err) {
throw err;
}
else{
user.value.name = "User";
bucket.replace(user.value.id, user.value, function(err) {
if(err){
throw err;
}
else{
console.log("user updated")
}
})
}
})
}
})
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment