iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update example code for N1QL

Browse Source
This commit is contained in:
Seun Matt 2017-09-16 10:20:58 +01:00
parent 3f5bef6427
commit c6cf9546f6
1 changed files with 20 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
couchbase-sdk/src/main/java/com/baeldung/couchbase/n1ql/CodeSnippets.java
View File

@ -87,8 +87,9 @@ public class CodeSnippets {
private static void selectStatement1(Bucket bucket) { private static void selectStatement1(Bucket bucket) {
N1qlQueryResult result1 = bucket.query( String query = "SELECT name FROM `travel-sample` " +
N1qlQuery.simple("SELECT name FROM `travel-sample` WHERE type = 'airport' LIMIT 100")); "WHERE type = 'airport' LIMIT 100";
N1qlQueryResult result1 = bucket.query(N1qlQuery.simple(query));
System.out.println("Result Count " + result1.info().resultCount()); System.out.println("Result Count " + result1.info().resultCount());
@ -101,23 +102,28 @@ public class CodeSnippets {
private static void selectStatement2(Bucket bucket) { private static void selectStatement2(Bucket bucket) {
JsonObject pVal = JsonObject.create().put("type", "airport"); JsonObject pVal = JsonObject.create().put("type", "airport");
String query = "SELECT * FROM `travel-sample` WHERE type = $type LIMIT 100"; String query = "SELECT * FROM `travel-sample` " +
"WHERE type = $type LIMIT 100";
N1qlQueryResult r2 = bucket.query(N1qlQuery.parameterized(query, pVal)); N1qlQueryResult r2 = bucket.query(N1qlQuery.parameterized(query, pVal));
System.out.println(r2.allRows()); System.out.println(r2.allRows());
List<JsonNode> list = extractJsonResult(r2); List<JsonNode> list = extractJsonResult(r2);
System.out.println(list.get(0).get("travel-sample").get("airportname").asText()); System.out.println(
list.get(0).get("travel-sample").get("airportname").asText());
} }
private static void selectStatement3DSL(Bucket bucket) { private static void selectStatement3DSL(Bucket bucket) {
Statement statement Statement statement = select("*")
= select("*").from(i("travel-sample")).where(x("type").eq(s("airport"))).limit(100); .from(i("travel-sample"))
.where(x("type").eq(s("airport")))
.limit(100);
N1qlQueryResult r3 = bucket.query(N1qlQuery.simple(statement)); N1qlQueryResult r3 = bucket.query(N1qlQuery.simple(statement));
List<JsonNode> list2 = extractJsonResult(r3); List<JsonNode> list2 = extractJsonResult(r3);
System.out.println("First Airport Name: " + list2.get(0).get("travel-sample").get("airportname").asText()); System.out.println("First Airport Name: " + list2.get(0).get("travel-sample").get("airportname").asText());
} }
private static void selectStatement4(Bucket bucket) { private static void selectStatement4(Bucket bucket) {
@ -154,7 +160,9 @@ public class CodeSnippets {
private static void insertStatement1(Bucket bucket) { private static void insertStatement1(Bucket bucket) {
String query = "INSERT INTO `travel-sample` (KEY, VALUE) " + String query = "INSERT INTO `travel-sample` (KEY, VALUE) " +
" VALUES(\"cust1293\", {\"id\":\"1293\",\"name\":\"Sample Airline\", \"type\":\"airline\"})" + " VALUES(" +
"\"cust1293\", " +
"{\"id\":\"1293\",\"name\":\"Sample Airline\", \"type\":\"airline\"})" +
" RETURNING META().id as docid, *"; " RETURNING META().id as docid, *";
N1qlQueryResult r1 = bucket.query(N1qlQuery.simple(query)); N1qlQueryResult r1 = bucket.query(N1qlQuery.simple(query));
r1.forEach(System.out::println); r1.forEach(System.out::println);
@ -226,10 +234,11 @@ public class CodeSnippets {
} }
private static List<JsonNode> extractJsonResult(N1qlQueryResult result) { private static List<JsonNode> extractJsonResult(N1qlQueryResult result) {
ObjectMapper objectMapper = new ObjectMapper(); ObjectMapper objectMapper = new ObjectMapper();
return result.allRows().stream() return result.allRows().stream()
.map(row -> Try.of(() -> objectMapper.readTree(row.value().toString())).getOrNull()) .map(row -> Try.of(() -> objectMapper.readTree(row.value().toString()))
.collect(Collectors.toList()); .getOrNull())
.collect(Collectors.toList());
} }
} }