Code sample - 23c JDBC Reactive Extensions

java/jdbc-reactive-extensions-intro/pom.xml

@@ -0,0 +1,79 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <groupId>com.oracle.jdbc.reactive</groupId>
+  <artifactId>jdbc-reactive-extensions-intro</artifactId>
+  <version>1.0-SNAPSHOT</version>
+
+  <name>jdbc-reactive-extensions-intro</name>
+  <description>Introduction to JDBC Reactive Extensions with the Oracle
+    Database</description>
+  <url>
+    https://juarezjunior.medium.com/introduction-to-jdbc-reactive-extensions-with-the-oracle-database-23c-free-developer-release-b5a64ac5d194/</url>
+
+  <properties>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    <maven.compiler.source>21</maven.compiler.source>
+    <maven.compiler.target>21</maven.compiler.target>
+  </properties>
+
+  <dependencies>
+    <dependency>
+      <groupId>com.oracle.database.jdbc</groupId>
+      <artifactId>ojdbc11-production</artifactId>
+      <version>23.4.0.24.05</version>
+      <type>pom</type>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <pluginManagement><!-- lock down plugins versions to avoid using Maven
+			defaults (may be moved to parent pom) -->
+      <plugins>
+        <plugin>
+          <artifactId>maven-clean-plugin</artifactId>
+          <version>3.1.0</version>
+        </plugin>
+        <plugin>
+          <artifactId>maven-site-plugin</artifactId>
+          <version>3.7.1</version>
+        </plugin>
+        <plugin>
+          <artifactId>maven-project-info-reports-plugin</artifactId>
+          <version>3.0.0</version>
+        </plugin>
+        <!-- see
+        http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_jar_packaging -->
+        <plugin>
+          <artifactId>maven-resources-plugin</artifactId>
+          <version>3.0.2</version>
+        </plugin>
+        <plugin>
+          <artifactId>maven-compiler-plugin</artifactId>
+          <version>3.8.0</version>
+        </plugin>
+        <plugin>
+          <artifactId>maven-surefire-plugin</artifactId>
+          <version>2.22.1</version>
+        </plugin>
+        <plugin>
+          <artifactId>maven-jar-plugin</artifactId>
+          <version>3.0.2</version>
+        </plugin>
+        <plugin>
+          <artifactId>maven-install-plugin</artifactId>
+          <version>2.5.2</version>
+        </plugin>
+        <plugin>
+          <artifactId>maven-deploy-plugin</artifactId>
+          <version>2.8.2</version>
+        </plugin>
+      </plugins>
+    </pluginManagement>
+  </build>
+
+</project>

java/jdbc-reactive-extensions-intro/src/main/java/com/oracle/jdbc/reactive/SQLStatementWithAsynchronousJDBC.java

@@ -0,0 +1,97 @@
+/*
+  Copyright (c) 2024, Oracle and/or its affiliates.
+
+  This software is dual-licensed to you under the Universal Permissive License
+  (UPL) 1.0 as shown at https://oss.oracle.com/licenses/upl or Apache License
+  2.0 as shown at http://www.apache.org/licenses/LICENSE-2.0. You may choose
+  either license.
+
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+     https://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+*/
+
+package com.oracle.jdbc.reactive;
+
+import java.sql.SQLException;
+import java.util.concurrent.Flow;
+
+import oracle.jdbc.OracleConnection;
+import oracle.jdbc.OraclePreparedStatement;
+import oracle.jdbc.pool.OracleDataSource;
+
+public class SQLStatementWithAsynchronousJDBC {
+
+  public static void main(String[] args) throws SQLException {
+    OracleDataSource ods = new OracleDataSource();
+    // jdbc:oracle:thin@[hostname]:[port]/[DB service/name]
+    ods.setURL("jdbc:oracle:thin@[hostname]:[port]/[DB service/name");
+    ods.setUser("[Username]");
+    ods.setPassword("[Password]");
+    OracleConnection conn = (OracleConnection) ods.getConnection();
+    SQLStatementWithAsynchronousJDBC asyncSQL = new SQLStatementWithAsynchronousJDBC();
+    // Execute a SQL DDL statement to create a database table
+    // asynchronously
+    asyncSQL.createTable(conn);
+  }
+
+  /**
+   * Asynchronously creates a new table by executing a DDL SQL statement
+   * 
+   * @param connection
+   *          Connection to a database where the table is created
+   * @return A Publisher that emits the result of executing DDL SQL
+   * @throws SQLException
+   *           If a database access error occurs before the DDL SQL can be
+   *           executed
+   */
+  private Flow.Publisher<Boolean> createTable(OracleConnection connection)
+      throws SQLException {
+
+    OraclePreparedStatement createTableStatement = (OraclePreparedStatement) connection
+        .prepareStatement(
+            "CREATE TABLE employee_names (" + "id NUMBER PRIMARY KEY, "
+                + "first_name VARCHAR(50), " + "last_name VARCHAR2(50))");
+
+    Flow.Publisher<Boolean> createTablePublisher = createTableStatement
+        .unwrap(OraclePreparedStatement.class).executeAsyncOracle();
+
+    createTablePublisher.subscribe(
+        // This subscriber will close the PreparedStatement
+        new Flow.Subscriber<Boolean>() {
+          public void onSubscribe(Flow.Subscription subscription) {
+            subscription.request(1L);
+          }
+
+          public void onNext(Boolean item) {
+          }
+
+          public void onError(Throwable throwable) {
+            closeStatement();
+          }
+
+          public void onComplete() {
+            closeStatement();
+          }
+
+          void closeStatement() {
+            try {
+              createTableStatement.close();
+            } catch (SQLException closeException) {
+              closeException.printStackTrace();
+            }
+          }
+        });
+
+    return createTablePublisher;
+  }
+
+}