Skip to content

Commit 7556ceb

Browse files
authored
Update QueryRequest usage to include try-with-resources block
1 parent d58327f commit 7556ceb

File tree

5 files changed

+53
-36
lines changed

5 files changed

+53
-36
lines changed

README.md

Lines changed: 23 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -437,15 +437,14 @@ public class Quickstart {
437437
438438
/*
439439
* Perform a query using iterable and iterator
440-
*/
441-
QueryRequest queryRequest = new QueryRequest()
442-
.setStatement("select * from " + tableName);
443-
444-
/*
440+
*
445441
* To ensure the query resources are closed properly, use
446442
* try-with-resources statement.
447443
*/
448-
try (QueryIterableResult results =
444+
try (
445+
QueryRequest queryRequest = new QueryRequest()
446+
.setStatement("select * from " + tableName);
447+
QueryIterableResult results =
449448
handle.queryIterable(queryRequest)) {
450449
System.out.println("Query results:");
451450
for (MapValue res : results) {
@@ -456,23 +455,25 @@ public class Quickstart {
456455
/*
457456
* Perform a query using partial results
458457
*/
459-
queryRequest = new QueryRequest()
460-
.setStatement("select * from " + tableName);
461-
462-
/*
463-
* Because a query can return partial results execution must occur
464-
* in a loop, accumulating or processing results
465-
*/
466-
ArrayList<MapValue> results = new ArrayList<MapValue>();
467-
do {
468-
QueryResult queryResult = handle.query(queryRequest);
469-
results.addAll(queryResult.getResults());
470-
} while (!queryRequest.isDone());
471-
System.out.println("Query results again:");
472-
for (MapValue res : results) {
473-
System.out.println("\t" + res);
458+
try (
459+
QueryRequest queryRequest = new QueryRequest()
460+
.setStatement("select * from " + tableName) ) {
461+
462+
/*
463+
* Because a query can return partial results execution must occur
464+
* in a loop, accumulating or processing results
465+
*/
466+
ArrayList<MapValue> results = new ArrayList<MapValue>();
467+
do {
468+
QueryResult queryResult = handle.query(queryRequest);
469+
results.addAll(queryResult.getResults());
470+
} while (!queryRequest.isDone());
471+
System.out.println("Query results again:");
472+
for (MapValue res : results) {
473+
System.out.println("\t" + res);
474+
}
474475
}
475-
476+
476477
/*
477478
* Drop the table
478479
*/

driver/src/main/java/oracle/nosql/driver/ops/QueryIterableResult.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,10 +33,12 @@
3333
* <pre>
3434
* NoSQLHandle handle = ...;
3535
*
36-
* QueryRequest qreq = new QueryRequest().setStatement("select * from foo");
36+
* try (QueryRequest qreq = new QueryRequest()
37+
* .setStatement("select * from foo") ) {
3738
*
38-
* for (MapValue row : handle.queryIterable(qreq)) {
39-
* // do something with row
39+
* for (MapValue row : handle.queryIterable(qreq)) {
40+
* // do something with row
41+
* }
4042
* }
4143
* </pre>
4244
*

driver/src/main/java/oracle/nosql/driver/ops/QueryRequest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@
7373
* of the rows read satisfied the query conditions).
7474
* <p>
7575
* If an application wishes to terminate query execution before retrieving all
76-
* of the query results, it should call {@link #close} in order to release any
76+
* the query results, it should call {@link #close} in order to release any
7777
* local resources held by the query. This also allows the application to reuse
7878
* the QueryRequest instance to run the same query from the beginning or a
7979
* different query.

examples/src/main/java/BasicTableExample.java

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -139,9 +139,10 @@ public static void main(String[] args) {
139139
" \"audience_segment\": { " +
140140
" \"sports_lover\":\"2020-05-10\", " +
141141
" \"foodie\":\"2020-06-01\"}})";
142-
QueryRequest queryRequest = new QueryRequest();
143-
queryRequest.setStatement(insertQuery);
144-
try (QueryIterableResult results =
142+
try (
143+
QueryRequest queryRequest = new QueryRequest()
144+
.setStatement(insertQuery);
145+
QueryIterableResult results =
145146
handle.queryIterable(queryRequest)) {
146147
System.out.println("Inserted row via query, result:");
147148
for (MapValue qval : results) {
@@ -195,9 +196,10 @@ public static void main(String[] args) {
195196
String query = "SELECT * from " + tableName +
196197
" WHERE cookie_id = 456";
197198

198-
queryRequest = new QueryRequest();
199-
queryRequest.setStatement(query);
200-
try (QueryIterableResult results =
199+
try (
200+
QueryRequest queryRequest = new QueryRequest()
201+
.setStatement(query);
202+
QueryIterableResult results =
201203
handle.queryIterable(queryRequest)) {
202204
System.out.println("Query results for " + query + ": ");
203205
for (MapValue qval : results) {

examples/src/main/java/DocSnippets.java

Lines changed: 16 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -358,15 +358,27 @@ static void yetMore(NoSQLHandle handle) {
358358

359359
/* Snippet start "Query iterable/iterator" */
360360

361-
QueryRequest qreq = new QueryRequest();
362-
qreq.setStatement("select * from MyTable");
363-
364-
try (QueryIterableResult qir = handle.queryIterable(qreq)) {
361+
try (
362+
QueryRequest qreq = new QueryRequest()
363+
.setStatement("select * from MyTable");
364+
QueryIterableResult qir = handle.queryIterable(qreq)) {
365365
for( MapValue row : qir) {
366366
// do something with row
367367
}
368368
}
369369

370370
/* ------ Snippet end -------*/
371+
372+
/* Snippet start "QueryIterableResult iterable/iterator" */
373+
374+
try (QueryRequest qreq = new QueryRequest()
375+
.setStatement("select * from foo") ) {
376+
377+
for (MapValue row : handle.queryIterable(qreq)) {
378+
// do something with row
379+
}
380+
}
381+
382+
/* ------ Snippet end -------*/
371383
}
372384
}

0 commit comments

Comments
 (0)