diff --git a/jOOQ-demo-oss/jOOQ-demo-java/src/test/java/org/jooq/demo/java/Demo13Reactive.java b/jOOQ-demo-oss/jOOQ-demo-java/src/test/java/org/jooq/demo/java/Demo13Reactive.java index 1bfbe27..ae03a06 100644 --- a/jOOQ-demo-oss/jOOQ-demo-java/src/test/java/org/jooq/demo/java/Demo13Reactive.java +++ b/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 is a Publisher, 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 diff --git a/jOOQ-demo-oss/jOOQ-demo-kotlin/src/test/kotlin/org/jooq/demo/kotlin/Demo13Reactive.kt b/jOOQ-demo-oss/jOOQ-demo-kotlin/src/test/kotlin/org/jooq/demo/kotlin/Demo13Reactive.kt index 8462fd0..c4261f4 100644 --- a/jOOQ-demo-oss/jOOQ-demo-kotlin/src/test/kotlin/org/jooq/demo/kotlin/Demo13Reactive.kt +++ b/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 is a Publisher, 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 diff --git a/jOOQ-demo-oss/jOOQ-demo-scala/src/test/scala/org/jooq/demo/skala/Demo13Reactive.scala b/jOOQ-demo-oss/jOOQ-demo-scala/src/test/scala/org/jooq/demo/skala/Demo13Reactive.scala index 21ccabe..355ec88 100644 --- a/jOOQ-demo-oss/jOOQ-demo-scala/src/test/scala/org/jooq/demo/skala/Demo13Reactive.scala +++ b/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 is a Publisher, 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 diff --git a/jOOQ-demo-pro/jOOQ-demo-java/src/test/java/org/jooq/demo/java/Demo13Reactive.java b/jOOQ-demo-pro/jOOQ-demo-java/src/test/java/org/jooq/demo/java/Demo13Reactive.java index 1bfbe27..ae03a06 100644 --- a/jOOQ-demo-pro/jOOQ-demo-java/src/test/java/org/jooq/demo/java/Demo13Reactive.java +++ b/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 is a Publisher, 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 diff --git a/jOOQ-demo-pro/jOOQ-demo-kotlin/src/test/kotlin/org/jooq/demo/kotlin/Demo13Reactive.kt b/jOOQ-demo-pro/jOOQ-demo-kotlin/src/test/kotlin/org/jooq/demo/kotlin/Demo13Reactive.kt index 8462fd0..c4261f4 100644 --- a/jOOQ-demo-pro/jOOQ-demo-kotlin/src/test/kotlin/org/jooq/demo/kotlin/Demo13Reactive.kt +++ b/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 is a Publisher, 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 diff --git a/jOOQ-demo-pro/jOOQ-demo-scala/src/test/scala/org/jooq/demo/skala/Demo13Reactive.scala b/jOOQ-demo-pro/jOOQ-demo-scala/src/test/scala/org/jooq/demo/skala/Demo13Reactive.scala index 21ccabe..355ec88 100644 --- a/jOOQ-demo-pro/jOOQ-demo-scala/src/test/scala/org/jooq/demo/skala/Demo13Reactive.scala +++ b/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 is a Publisher, 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