PreparedStatement should be closed when using RowStream in examples

Closes #1137

Signed-off-by: Thomas Segismont <tsegismont@gmail.com>

Author: tsegismont

vertx-db2-client/src/main/java/examples/SqlClientExamples.java

@@ -322,7 +322,7 @@ public void usingCursors03(SqlConnection connection) {
       .prepare("SELECT * FROM users WHERE first_name LIKE ?")
       .onComplete(ar0 -> {
       if (ar0.succeeded()) {
-        PreparedStatement pq = ar0.result();
+        PreparedStatement ps = ar0.result();
 
         // Streams require to run within a transaction
         connection
@@ -332,15 +332,17 @@ public void usingCursors03(SqlConnection connection) {
             Transaction tx = ar1.result();
 
             // Fetch 50 rows at a time
-            RowStream<Row> stream = pq.createStream(50, Tuple.of("julien"));
+            RowStream<Row> stream = ps.createStream(50, Tuple.of("julien"));
 
             // Use the stream
             stream.exceptionHandler(err -> {
               System.out.println("Error: " + err.getMessage());
+              ps.close();
             });
             stream.endHandler(v -> {
               tx.commit();
               System.out.println("End of stream");
+              ps.close();
             });
             stream.handler(row -> {
               System.out.println("User: " + row.getString("last_name"));

vertx-mssql-client/src/main/java/examples/SqlClientExamples.java

@@ -341,17 +341,19 @@ public void usingCursors03(SqlConnection connection) {
       .prepare("SELECT * FROM users WHERE age > @p1")
       .onComplete(ar1 -> {
       if (ar1.succeeded()) {
-        PreparedStatement pq = ar1.result();
+        PreparedStatement ps = ar1.result();
 
         // Fetch 50 rows at a time
-        RowStream<Row> stream = pq.createStream(50, Tuple.of(18));
+        RowStream<Row> stream = ps.createStream(50, Tuple.of(18));
 
         // Use the stream
         stream.exceptionHandler(err -> {
           System.out.println("Error: " + err.getMessage());
+          ps.close();
         });
         stream.endHandler(v -> {
           System.out.println("End of stream");
+          ps.close();
         });
         stream.handler(row -> {
           System.out.println("User: " + row.getString("last_name"));

vertx-mysql-client/src/main/java/examples/SqlClientExamples.java

@@ -312,17 +312,19 @@ public void usingCursors03(SqlConnection connection) {
       .prepare("SELECT * FROM users WHERE age > ?")
       .onComplete(ar1 -> {
       if (ar1.succeeded()) {
-        PreparedStatement pq = ar1.result();
+        PreparedStatement ps = ar1.result();
 
         // Fetch 50 rows at a time
-        RowStream<Row> stream = pq.createStream(50, Tuple.of(18));
+        RowStream<Row> stream = ps.createStream(50, Tuple.of(18));
 
         // Use the stream
         stream.exceptionHandler(err -> {
           System.out.println("Error: " + err.getMessage());
+          ps.close();
         });
         stream.endHandler(v -> {
           System.out.println("End of stream");
+          ps.close();
         });
         stream.handler(row -> {
           System.out.println("User: " + row.getString("last_name"));

vertx-oracle-client/src/main/java/examples/SqlClientExamples.java

@@ -313,17 +313,19 @@ public void usingCursors03(SqlConnection connection) {
       .prepare("SELECT * FROM users WHERE age > ?")
       .onComplete(ar1 -> {
       if (ar1.succeeded()) {
-        PreparedStatement pq = ar1.result();
+        PreparedStatement ps = ar1.result();
 
         // Fetch 50 rows at a time
-        RowStream<Row> stream = pq.createStream(50, Tuple.of(18));
+        RowStream<Row> stream = ps.createStream(50, Tuple.of(18));
 
         // Use the stream
         stream.exceptionHandler(err -> {
           System.out.println("Error: " + err.getMessage());
+          ps.close();
         });
         stream.endHandler(v -> {
           System.out.println("End of stream");
+          ps.close();
         });
         stream.handler(row -> {
           System.out.println("User: " + row.getString("last_name"));

vertx-pg-client/src/main/java/examples/SqlClientExamples.java

@@ -319,7 +319,7 @@ public void usingCursors03(SqlConnection connection) {
       .prepare("SELECT * FROM users WHERE first_name LIKE $1")
       .onComplete(ar0 -> {
       if (ar0.succeeded()) {
-        PreparedStatement pq = ar0.result();
+        PreparedStatement ps = ar0.result();
 
         // Streams require to run within a transaction
         connection
@@ -329,11 +329,12 @@ public void usingCursors03(SqlConnection connection) {
             Transaction tx = ar1.result();
 
             // Fetch 50 rows at a time
-            RowStream<Row> stream = pq.createStream(50, Tuple.of("julien"));
+            RowStream<Row> stream = ps.createStream(50, Tuple.of("julien"));
 
             // Use the stream
             stream.exceptionHandler(err -> {
               System.out.println("Error: " + err.getMessage());
+              ps.close();
             });
             stream.endHandler(v -> {
               // Close the stream to release the resources in the database
@@ -342,7 +343,8 @@ public void usingCursors03(SqlConnection connection) {
                 .onComplete(closed -> {
                 tx.commit()
                   .onComplete(committed -> {
-                  System.out.println("End of stream");
+                    System.out.println("End of stream");
+                    ps.close();
                 });
               });
             });