[#3562] Migrate to Quarkus JDBC implementation

services/base-jdbc/pom.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--
-    Copyright (c) 2020, 2021 Contributors to the Eclipse Foundation
+    Copyright (c) 2020, 2023 Contributors to the Eclipse Foundation
    
     See the NOTICE file(s) distributed with this work for additional
     information regarding copyright ownership.
@@ -86,6 +86,10 @@
       <scope>provided</scope>
       <optional>true</optional>
     </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-agroal</artifactId>
+    </dependency>
 
     <!-- testing -->
     <dependency>

services/base-jdbc/src/main/java/org/eclipse/hono/service/base/jdbc/client/JdbcClient.java

@@ -0,0 +1,132 @@
+/*******************************************************************************
+ * Copyright (c) 2023 Contributors to the Eclipse Foundation
+ *
+ * See the NOTICE file(s) distributed with this work for additional
+ * information regarding copyright ownership.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0
+ *
+ * SPDX-License-Identifier: EPL-2.0
+ *******************************************************************************/
+
+package org.eclipse.hono.service.base.jdbc.client;
+
+import java.sql.SQLException;
+
+import io.agroal.api.AgroalDataSource;
+import io.vertx.codegen.annotations.Nullable;
+import io.vertx.core.AsyncResult;
+import io.vertx.core.Future;
+import io.vertx.core.Handler;
+import io.vertx.core.Promise;
+import io.vertx.core.json.JsonArray;
+import io.vertx.ext.sql.ResultSet;
+
+/**
+ * Quarkus AgroalDataSource based JDBC client.
+ */
+public class JdbcClient implements JdbcOperations {
+    private final AgroalDataSource dataSource;
+
+    /**
+     * JdbcClient constructor.
+     * @param dataSource Quarkus Argoal data source
+     */
+    public JdbcClient(final AgroalDataSource dataSource) {
+        this.dataSource = dataSource;
+    }
+
+    /**
+     * Open connection asynchronously.
+     * @param handler Asynchronous listener
+     */
+    public void getConnection(final Handler<AsyncResult<JdbcConnection>> handler) {
+        try {
+            final JdbcConnection conn = new JdbcConnection(dataSource.getConnection());
+
+            handler.handle(Future.succeededFuture(conn));
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    /**
+     * Close connection asynchronously.
+     * @param handler Asynchronous listener
+     */
+    public void close(final Handler<AsyncResult<Void>> handler) {
+        dataSource.close();
+
+        handler.handle(Future.succeededFuture());
+    };
+
+    /**
+     * Close connection synchronously.
+     */
+     public void close() {
+         dataSource.close();
+    }
+
+    @Override
+    public void queryWithParams(final String sql, final JsonArray jsonArray, final Handler<AsyncResult<ResultSet>> handler) {
+        final Promise<JdbcConnection> promise = Promise.promise();
+        getConnection(promise);
+        promise.future()
+                .compose(connection -> {
+                    connection.queryWithParams(sql, jsonArray, handler);
+                    connection.close();
+                    return Future.succeededFuture();
+                });
+    }
+
+    @Override
+    public void querySingle(final String sql, final Handler<AsyncResult<@Nullable JsonArray>> handler) {
+        final Promise<JdbcConnection> promise = Promise.promise();
+        getConnection(promise);
+        promise.future()
+                .compose(connection -> {
+                    connection.querySingle(sql, handler);
+                    connection.close();
+                    return Future.succeededFuture();
+                });
+    }
+
+    @Override
+    public void querySingleWithParams(final String sql, final JsonArray arguments, final Handler<AsyncResult<@Nullable JsonArray>> handler) {
+        final Promise<JdbcConnection> promise = Promise.promise();
+        getConnection(promise);
+        promise.future()
+                .compose(connection -> {
+                    connection.querySingleWithParams(sql, arguments, handler);
+                    connection.close();
+                    return Future.succeededFuture();
+                });
+    }
+
+    @Override
+    public void updateWithParams(final String sql, final JsonArray jsonArray, final Handler<AsyncResult<Integer>> handler) {
+        final Promise<JdbcConnection> promise = Promise.promise();
+        getConnection(promise);
+        promise.future()
+                .compose(connection -> {
+                    connection.updateWithParams(sql, jsonArray, handler);
+                    connection.close();
+                    return Future.succeededFuture();
+                });
+    }
+
+    @Override
+    public void call(final String sql, final Handler<AsyncResult<Void>> handler) {
+        final Promise<JdbcConnection> promise = Promise.promise();
+        getConnection(promise);
+        promise.future()
+                .compose(connection -> {
+                    connection.call(sql, handler);
+                    connection.close();
+                    return Future.succeededFuture();
+                });
+    }
+
+}

services/base-jdbc/src/main/java/org/eclipse/hono/service/base/jdbc/client/JdbcConnection.java

@@ -0,0 +1,214 @@
+/*******************************************************************************
+ * Copyright (c) 2023 Contributors to the Eclipse Foundation
+ *
+ * See the NOTICE file(s) distributed with this work for additional
+ * information regarding copyright ownership.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0
+ *
+ * SPDX-License-Identifier: EPL-2.0
+ *******************************************************************************/
+
+package org.eclipse.hono.service.base.jdbc.client;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.List;
+
+import io.vertx.codegen.annotations.Nullable;
+import io.vertx.core.AsyncResult;
+import io.vertx.core.Future;
+import io.vertx.core.Handler;
+import io.vertx.core.json.JsonArray;
+import io.vertx.ext.sql.ResultSet;
+
+/**
+ * Quarkus based SQL connection.
+ */
+public class JdbcConnection implements JdbcOperations {
+
+    private final Connection connection;
+
+    /**
+     * SQL connection constructor.
+     * @param connection SQL connection
+     */
+    public JdbcConnection(final Connection connection) {
+        this.connection = connection;
+    }
+
+    /**
+     * Asynchronous auto commit setter.
+     * @param autoCommit True for auto commit
+     * @param handler Asynchronous operation listener
+     */
+    public void setAutoCommit(final boolean autoCommit, final Handler<AsyncResult<Void>> handler) {
+        try {
+            connection.setAutoCommit(autoCommit);
+
+            handler.handle(Future.succeededFuture());
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    /**
+     * Close the underlying connection.
+     * @throws RuntimeException Thrown if closing connection fails
+     */
+    public void close() {
+        try {
+            connection.close();
+        } catch (SQLException ex) {
+            throw new RuntimeException(ex);
+        }
+    }
+
+    /**
+     * Commit asynchronously.
+     * @param handler Asynchronous commit handler
+     */
+    public void commit(final Handler<AsyncResult<Void>> handler) {
+        try {
+            connection.commit();
+
+            handler.handle(Future.succeededFuture());
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    /**
+     * Test.
+     * @param handler test
+     */
+    public void rollback(final Handler<AsyncResult<Void>> handler) {
+        try {
+            connection.rollback();
+
+            handler.handle(Future.succeededFuture());
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    @Override
+    public void queryWithParams(final String sql, final JsonArray jsonArray, final Handler<AsyncResult<ResultSet>> handler) {
+        try {
+            final PreparedStatement stmt = this.connection.prepareStatement(sql);
+            for (int index = 0; index < jsonArray.size(); index++) {
+                stmt.setObject(index + 1, jsonArray.getValue(index));
+            }
+            final ResultSet rs = readResultSet(stmt.executeQuery());
+            stmt.close();
+
+            handler.handle(Future.succeededFuture(rs));
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    @Override
+    public void querySingle(final String sql, final Handler<AsyncResult<@Nullable JsonArray>> handler) {
+        try {
+            final PreparedStatement stmt = this.connection.prepareStatement(sql);
+            final java.sql.ResultSet rs = stmt.executeQuery();
+            JsonArray result = null;
+            if (rs.next()) {
+                result = readRow(rs);
+            }
+            stmt.close();
+
+            handler.handle(Future.succeededFuture(result));
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    @Override
+    public void querySingleWithParams(final String sql, final JsonArray jsonArray, final Handler<AsyncResult<@Nullable JsonArray>> handler) {
+        try {
+            final PreparedStatement stmt = this.connection.prepareStatement(sql);
+            for (int index = 0; index < jsonArray.size(); index++) {
+                stmt.setObject(index + 1, jsonArray.getValue(index));
+            }
+            final java.sql.ResultSet rs = stmt.executeQuery();
+            JsonArray result = null;
+            if (rs.next()) {
+                result = readRow(rs);
+            }
+            stmt.close();
+
+            handler.handle(Future.succeededFuture(result));
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    @Override
+    public void updateWithParams(final String sql, final JsonArray jsonArray, final Handler<AsyncResult<Integer>> handler) {
+        try {
+            final PreparedStatement stmt = this.connection.prepareStatement(sql);
+            for (int index = 0; index < jsonArray.size(); index++) {
+                stmt.setObject(index + 1, jsonArray.getValue(index));
+            }
+            final int updated = stmt.executeUpdate();
+            stmt.close();
+
+            handler.handle(Future.succeededFuture(updated));
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    @Override
+    public void call(final String sql, final Handler<AsyncResult<Void>> handler) {
+        try {
+            final PreparedStatement stmt = this.connection.prepareStatement(sql);
+            stmt.execute();
+            stmt.close();
+
+            handler.handle(Future.succeededFuture());
+        } catch (SQLException ex) {
+            handler.handle(Future.failedFuture(ex));
+        }
+    }
+
+    private JsonArray readRow(final java.sql.ResultSet rs) throws SQLException {
+        final int colCount = rs.getMetaData().getColumnCount();
+        final JsonArray result = new JsonArray();
+        for (int idx = 1; idx <= colCount; idx++) {
+            Object resultObj = rs.getObject(idx);
+            if (resultObj instanceof Timestamp ts) {
+                resultObj = ts.toLocalDateTime().toString();
+            }
+            result.add(resultObj);
+        }
+        return result;
+    }
+
+    private ResultSet readResultSet(final java.sql.ResultSet rs) throws SQLException {
+        final int colCount = rs.getMetaData().getColumnCount();
+        final List<String> colNames = new ArrayList<>();
+        final List<JsonArray> results = new ArrayList<>();
+
+        for (int idx = 1; idx <= colCount; ++idx) {
+            colNames.add(rs.getMetaData().getColumnName(idx));
+        }
+
+        while (rs.next()) {
+            results.add(readRow(rs));
+        }
+
+        final ResultSet rsOut = new ResultSet();
+        rsOut.setColumnNames(colNames);
+        rsOut.setResults(results);
+        return rsOut;
+    }
+
+}