[#11] Demo code should link to relevant sections of the manual - Demo…

…13Reactive

jOOQ-demo-oss/jOOQ-demo-java/src/test/java/org/jooq/demo/java/Demo13Reactive.java

@@ -15,6 +15,10 @@ public class Demo13Reactive extends AbstractDemo {
 
     @Test
     public void reactiveQuerying() {
+        // If you configure jOOQ with an R2DBC connection as in this demo, then you can use jOOQ's reactive APIs via
+        // its various Publisher implementations. For example, a ResultQuery<R> is a Publisher<R>, and can be used with
+        // any RS compliant streaming library, such as Reactor, below:
+
         record Actor(String firstName, String lastName) {}
 
         Flux.from(ctx
@@ -26,6 +30,9 @@ record Actor(String firstName, String lastName) {}
             .collectList()
             .block()
             .forEach(System.out::println);
+
+        // More information here:
+        // https://www.jooq.org/doc/latest/manual/sql-execution/fetching/reactive-fetching/
     }
 
     @Test
@@ -64,6 +71,9 @@ public void reactiveTransactions() {
             .collectList()
             .block()
             .forEach(System.out::println);
+
+        // More information here:
+        // https://www.jooq.org/doc/latest/manual/sql-execution/transaction-management/
     }
 
     @After

jOOQ-demo-oss/jOOQ-demo-kotlin/src/test/kotlin/org/jooq/demo/kotlin/Demo13Reactive.kt

@@ -18,6 +18,10 @@ class Demo13Reactive : AbstractDemo() {
 
     @Test
     fun reactiveQuerying() {
+        // If you configure jOOQ with an R2DBC connection as in this demo, then you can use jOOQ's reactive APIs via
+        // its various Publisher implementations. For example, a ResultQuery<R> is a Publisher<R>, and can be used with
+        // any RS compliant streaming library, such as Reactor, below:
+
         data class Actor(val firstName: String?, val lastName: String?)
 
         Flux.from(ctx
@@ -28,6 +32,9 @@ class Demo13Reactive : AbstractDemo() {
             .map(mapping(::Actor))
             .toIterable()
             .forEach { println(it) }
+
+        // More information here:
+        // https://www.jooq.org/doc/latest/manual/sql-execution/fetching/reactive-fetching/
     }
 
     @Test
@@ -69,6 +76,9 @@ class Demo13Reactive : AbstractDemo() {
                 .where(ACTOR.ACTOR_ID.eq(201L)))
             .toIterable()
             .forEach { println(it) }
+
+        // More information here:
+        // https://www.jooq.org/doc/latest/manual/sql-execution/transaction-management/
     }
 
     @Test

jOOQ-demo-oss/jOOQ-demo-scala/src/test/scala/org/jooq/demo/skala/Demo13Reactive.scala

@@ -11,6 +11,10 @@ class Demo13Reactive extends AbstractDemo {
 
   @Test
   def reactiveQuerying(): Unit = {
+    // If you configure jOOQ with an R2DBC connection as in this demo, then you can use jOOQ's reactive APIs via
+    // its various Publisher implementations. For example, a ResultQuery<R> is a Publisher<R>, and can be used with
+    // any RS compliant streaming library, such as Reactor, below:
+
     case class Actor(firstName: String, lastName: String)
 
     Flux
@@ -23,6 +27,9 @@ class Demo13Reactive extends AbstractDemo {
       .collectList
       .block
       .forEach(println(_))
+
+    // More information here:
+    // https://www.jooq.org/doc/latest/manual/sql-execution/fetching/reactive-fetching/
   }
 
   @Test
@@ -64,6 +71,9 @@ class Demo13Reactive extends AbstractDemo {
       .collectList
       .block
       .forEach(println(_))
+
+    // More information here:
+    // https://www.jooq.org/doc/latest/manual/sql-execution/transaction-management/
   }
 
   @After

jOOQ-demo-pro/jOOQ-demo-java/src/test/java/org/jooq/demo/java/Demo13Reactive.java

@@ -15,6 +15,10 @@ public class Demo13Reactive extends AbstractDemo {
 
     @Test
     public void reactiveQuerying() {
+        // If you configure jOOQ with an R2DBC connection as in this demo, then you can use jOOQ's reactive APIs via
+        // its various Publisher implementations. For example, a ResultQuery<R> is a Publisher<R>, and can be used with
+        // any RS compliant streaming library, such as Reactor, below:
+
         record Actor(String firstName, String lastName) {}
 
         Flux.from(ctx
@@ -26,6 +30,9 @@ record Actor(String firstName, String lastName) {}
             .collectList()
             .block()
             .forEach(System.out::println);
+
+        // More information here:
+        // https://www.jooq.org/doc/latest/manual/sql-execution/fetching/reactive-fetching/
     }
 
     @Test
@@ -64,6 +71,9 @@ public void reactiveTransactions() {
             .collectList()
             .block()
             .forEach(System.out::println);
+
+        // More information here:
+        // https://www.jooq.org/doc/latest/manual/sql-execution/transaction-management/
     }
 
     @After

jOOQ-demo-pro/jOOQ-demo-kotlin/src/test/kotlin/org/jooq/demo/kotlin/Demo13Reactive.kt

@@ -18,6 +18,10 @@ class Demo13Reactive : AbstractDemo() {
 
     @Test
     fun reactiveQuerying() {
+        // If you configure jOOQ with an R2DBC connection as in this demo, then you can use jOOQ's reactive APIs via
+        // its various Publisher implementations. For example, a ResultQuery<R> is a Publisher<R>, and can be used with
+        // any RS compliant streaming library, such as Reactor, below:
+
         data class Actor(val firstName: String?, val lastName: String?)
 
         Flux.from(ctx
@@ -28,6 +32,9 @@ class Demo13Reactive : AbstractDemo() {
             .map(mapping(::Actor))
             .toIterable()
             .forEach { println(it) }
+
+        // More information here:
+        // https://www.jooq.org/doc/latest/manual/sql-execution/fetching/reactive-fetching/
     }
 
     @Test
@@ -69,6 +76,9 @@ class Demo13Reactive : AbstractDemo() {
                 .where(ACTOR.ACTOR_ID.eq(201L)))
             .toIterable()
             .forEach { println(it) }
+
+        // More information here:
+        // https://www.jooq.org/doc/latest/manual/sql-execution/transaction-management/
     }
 
     @Test

jOOQ-demo-pro/jOOQ-demo-scala/src/test/scala/org/jooq/demo/skala/Demo13Reactive.scala

@@ -11,6 +11,10 @@ class Demo13Reactive extends AbstractDemo {
 
   @Test
   def reactiveQuerying(): Unit = {
+    // If you configure jOOQ with an R2DBC connection as in this demo, then you can use jOOQ's reactive APIs via
+    // its various Publisher implementations. For example, a ResultQuery<R> is a Publisher<R>, and can be used with
+    // any RS compliant streaming library, such as Reactor, below:
+
     case class Actor(firstName: String, lastName: String)
 
     Flux
@@ -23,6 +27,9 @@ class Demo13Reactive extends AbstractDemo {
       .collectList
       .block
       .forEach(println(_))
+
+    // More information here:
+    // https://www.jooq.org/doc/latest/manual/sql-execution/fetching/reactive-fetching/
   }
 
   @Test
@@ -64,6 +71,9 @@ class Demo13Reactive extends AbstractDemo {
       .collectList
       .block
       .forEach(println(_))
+
+    // More information here:
+    // https://www.jooq.org/doc/latest/manual/sql-execution/transaction-management/
   }
 
   @After