Core operations - srujanabala/springboot-couchbase GitHub Wiki

1. Maven

2. Helper class

3. In view controller class

@GetMapping(path = "/sdk/get") public ResponseEntity testApi() { String id = UUID.randomUUID().toString(); Course course = new Course("100","Java",50000.00); Student student = new Student("1", "Abhi", 5,course); //ObjectMapper mapper = new ObjectMapper(); JsonObject content = JsonObject.empty() .put("name", "John Doe") .put("type", "Person") .put("email", "[email protected]") .put("homeTown", "Chicago");

	//JsonObject content = JsonObject.create().put("1", student);
	JsonDocument document = JsonDocument.create(id, content);
	JsonDocument  insertedDocument= CouchBaseHelper.getBucket().insert(document);		
	return new ResponseEntity<>(insertedDocument.toString(), HttpStatus.CREATED);
	
}

Couchbasehelper.java package com.example.helper;

import com.couchbase.client.java.Bucket; import com.couchbase.client.java.Cluster; import com.couchbase.client.java.CouchbaseCluster; import com.couchbase.client.java.env.CouchbaseEnvironment; import com.couchbase.client.java.env.DefaultCouchbaseEnvironment;

public class CouchBaseHelper {

private static CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder()
		  .connectTimeout(10000)
		  .kvTimeout(3000)
		  .build();
private static Cluster cluster = CouchbaseCluster.create(env, "localhost");
private static Bucket bucket = cluster.openBucket("New", "welcome");

public static Bucket getBucket() {
	return bucket;
}

}