Data structures - srujanabala/springboot-couchbase GitHub Wiki

to me 12 hours agoDetails @GetMapping(path = "/sdk/get/course/{id}") public String getCourseNameByIdUsingSDK(@PathVariable("id") final String id) throws Exception { //ObjectMapper objectMapper = new ObjectMapper(); DocumentFragment document = CouchBaseHelper.getBucket() .lookupIn(id) .get("course.name") .execute(); //.get("course.id") //.execute();

	//return objectMapper.readValue(document.content().toString(), Student.class);
	return document.content("course.name", String.class);
	
}

@GetMapping(path = "/sdk/get/course/change/{id}")
public Course updateCourseNameByIdUsingSDK(@PathVariable("id") final String id) throws Exception {
	//ObjectMapper objectMapper = new ObjectMapper();
	DocumentFragment<Mutation> document = CouchBaseHelper.getBucket()
											.mutateIn(id)
											.replace("course.courseId","500")
											.insert("course.hours", "80 hours")

execute(); return document.content("course", Course.class);

}

@GetMapping(path = "sdk/get/ds")
public List<ViewRow> getAllDataStructuresUsingSDK() {
	Bucket bucket = CouchBaseHelper.getBucket();
	bucket.mapAdd("map_id", "name", "Mark Nunberg", MutationOptionBuilder.builder().createDocument(true)); //map
	bucket.listAppend("list_id", "hello", MutationOptionBuilder.builder().createDocument(true)); //list
	bucket.insert(JsonArrayDocument.create("list_id1", JsonArray.empty())); //To create a new empty list, set, or queue
	bucket.insert(JsonDocument.create("map_id1", JsonObject.empty())); // To create 

an empty map //List List names = new CouchbaseArrayList("listDocId", bucket); names.add("Alice"); names.add("Bob"); names.add("Alice"); System.out.println(bucket.get(JsonArrayDocument.create("listDocId")).content()); //Set Set uniqueNames = new CouchbaseArraySet("setDocId", bucket); uniqueNames.add("Alice"); uniqueNames.add("Bob"); uniqueNames.add("Alice"); System.out.println(bucket.get(JsonArrayDocument.create("setDocId")).content()); //Queue Queue shoppingList = new CouchbaseQueue("queueDocId", bucket); shoppingList.add("loaf of bread"); shoppingList.add("container of milk"); shoppingList.add("stick of butter");

	System.out.println(bucket.get(JsonArrayDocument.create("queueDocId")).content());
	//Map
	Map<String, String> favorites = new CouchbaseMap<String>("mapDocId", bucket);
	favorites.put("color", "Blue");
	favorites.put("flavor", "Chocolate");
	System.out.println(bucket.get("mapDocId").content());
	return bucket.query(ViewQuery.from("#primary", "all")).allRows();
}


@PostMapping(path = "/sdk/post/list",consumes = "application/json")
public ResponseEntity<List<Student>> testSDKPostList(@RequestBody List<Student> students) throws JsonProcessingException  {
	ObjectMapper mapper = new ObjectMapper();

er(); students.stream() .filter(Objects::nonNull) .forEach(student -> { try { JsonObject content = JsonObject.fromJson(mapper.writeValueAsString(student)); CouchBaseHelper.getBucket().listAppend(student.getId(), content, MutationOptionBuilder.builder().createDocument(true)); } catch (JsonProcessingException e) { e.printStackTrace(); } }); return new ResponseEntity<>(students, HttpStatus.CREATED); } @GetMapping(path = "/sdk/get/n1ql") public String getCourseNameByIdUsingSDKN1QL() throws Exception { Bucket bucket = CouchBaseHelper.getBucket(); bucket.bucketManager().createN1qlPrimaryIndex(true, false); N1qlQueryResult result = bucket.query(N1qlQuery.simple("SELECT * FROM New")); result.forEach(System.out::println); return result.toString(); }