Nlqlqry - srujanabala/springboot-couchbase GitHub Wiki

@GetMapping(path = "/sdk/get/n1ql2/{age}") public String getAllUsingSDKN1QL1(@PathVariable("age")final int age) throws Exception { Bucket bucket = CouchBaseHelper.getBucket(); String query = "SELECT MAX(n1.age) FROM New n1 where n1.age NOT IN (SELECT RAW MAX(New.age) FROM New)"; N1qlQueryResult result = bucket.query(N1qlQuery.simple(query)); result.forEach(System.out::println); Statement statement = select("name", "course", "age").from(i("New")).where(x("age").gt(x("$age"))); JsonObject placeholderValues = JsonObject.create().put("age", age); ParameterizedN1qlQuery q = N1qlQuery.parameterized(statement, placeholderValues); for (N1qlQueryRow row : bucket.query(q)) { System.out.println(row); } bucket.query(q).allRows().stream() .filter(Objects::nonNull) .forEach(row ->{ System.out.println(":::"+row); }); return bucket.query(q).toString(); }

@GetMapping(path = "/sdk/get/n1ql1")
public String getAllUsingSDKN1QL() throws Exception {
	Bucket bucket = CouchBaseHelper.getBucket();
	String query = "SELECT name FROM `New` " + "WHERE name = 'Abhishek' LIMIT 100";
	N1qlQueryResult result = bucket.query(N1qlQuery.simple(query));
	System.out.println(result.allRows().get(0).value());
	System.out.println(result.allRows().get(0).value().get("name"));
	JsonObject pVal = JsonObject.create().put("name", "Shankle");
	String query1 = "SELECT * FROM `New` " + "WHERE name = $name LIMIT 50";
	N1qlQueryResult r2 = bucket.query(N1qlQuery.parameterized(query1, pVal));
	System.out.println(r2.toString());
	System.out.println(r2.allRows().get(0).value().get("New"));
	return result.toString();
}