-
Notifications
You must be signed in to change notification settings - Fork 2k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #9556 from spericas/helidon-4.1.5-test2
Upgrades to Helidon 4.1.5
- Loading branch information
Showing
11 changed files
with
313 additions
and
158 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
143 changes: 143 additions & 0 deletions
143
...a/helidon/nima/src/main/java/io/helidon/benchmark/nima/models/PgClientConnectionPool.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,143 @@ | ||
|
|
||
| package io.helidon.benchmark.nima.models; | ||
|
|
||
| import java.util.HashMap; | ||
| import java.util.Map; | ||
| import java.util.concurrent.locks.ReentrantLock; | ||
|
|
||
| import io.vertx.core.Vertx; | ||
| import io.vertx.pgclient.PgConnectOptions; | ||
| import io.vertx.pgclient.PgConnection; | ||
| import io.vertx.sqlclient.PreparedQuery; | ||
| import io.vertx.sqlclient.Row; | ||
| import io.vertx.sqlclient.RowSet; | ||
|
|
||
| class PgClientConnectionPool implements AutoCloseable { | ||
|
|
||
| private final Vertx vertx; | ||
| private final PgConnectOptions options; | ||
| private final ReentrantLock lock = new ReentrantLock(); | ||
| private final Map<String, PgClientConnection> connectionMap = new HashMap<>(); | ||
|
|
||
| public PgClientConnectionPool(Vertx vertx, PgConnectOptions options) { | ||
| this.vertx = vertx; | ||
| this.options = options; | ||
| } | ||
|
|
||
| public PgClientConnection clientConnection() { | ||
| String carrierThread = carrierThread(); | ||
| PgClientConnection connection = connectionMap.get(carrierThread); | ||
| if (connection == null) { | ||
| try { | ||
| lock.lock(); | ||
| connection = connectionMap.get(carrierThread); | ||
| if (connection == null) { | ||
| connection = newConnection(); | ||
| connectionMap.put(carrierThread, connection); | ||
| } | ||
| } finally { | ||
| lock.unlock(); | ||
| } | ||
| } | ||
| return connection; | ||
| } | ||
|
|
||
| @Override | ||
| public void close() { | ||
| try { | ||
| for (PgClientConnection connection : connectionMap.values()) { | ||
| connection.close(); | ||
| } | ||
| } catch (Exception e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
|
|
||
| private PgClientConnection newConnection() { | ||
| try { | ||
| PgConnection conn = PgConnection.connect(vertx, options) | ||
| .toCompletionStage().toCompletableFuture().get(); | ||
| PgClientConnection clientConn = new PgClientConnection(conn); | ||
| clientConn.prepare(); | ||
| return clientConn; | ||
| } catch (Exception e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
|
|
||
| static String carrierThread() { | ||
| String threadName = Thread.currentThread().toString(); | ||
| return threadName.substring(threadName.indexOf('@') + 1); | ||
| } | ||
|
|
||
| public static class PgClientConnection implements AutoCloseable { | ||
| static final int UPDATE_QUERIES = 500; | ||
| private static String SELECT_WORLD = "SELECT id, randomnumber from WORLD where id=$1"; | ||
| private static String SELECT_FORTUNE = "SELECT * from FORTUNE"; | ||
|
|
||
| private PreparedQuery<RowSet<Row>> worldQuery; | ||
| private PreparedQuery<RowSet<Row>> fortuneQuery; | ||
| private PreparedQuery<RowSet<Row>>[] updateQuery; | ||
|
|
||
| private final PgConnection conn; | ||
|
|
||
| PgClientConnection(PgConnection conn) { | ||
| this.conn = conn; | ||
| } | ||
|
|
||
| public PgConnection pgConnection() { | ||
| return conn; | ||
| } | ||
|
|
||
| @Override | ||
| public void close() { | ||
| conn.close(); | ||
| } | ||
|
|
||
| public PreparedQuery<RowSet<Row>> worldQuery() { | ||
| return worldQuery; | ||
| } | ||
|
|
||
| public PreparedQuery<RowSet<Row>> fortuneQuery() { | ||
| return fortuneQuery; | ||
| } | ||
|
|
||
| public PreparedQuery<RowSet<Row>> updateQuery(int queryCount) { | ||
| return updateQuery[queryCount - 1]; | ||
| } | ||
|
|
||
| @SuppressWarnings("unchecked") | ||
| void prepare() { | ||
| try { | ||
| worldQuery = conn.prepare(SELECT_WORLD) | ||
| .toCompletionStage().toCompletableFuture().get().query(); | ||
| fortuneQuery = conn.prepare(SELECT_FORTUNE) | ||
| .toCompletionStage().toCompletableFuture().get().query(); | ||
| updateQuery = (PreparedQuery<RowSet<Row>>[]) new PreparedQuery<?>[UPDATE_QUERIES]; | ||
| for (int i = 0; i < UPDATE_QUERIES; i++) { | ||
| updateQuery[i] = conn.prepare(singleUpdate(i + 1)) | ||
| .toCompletionStage().toCompletableFuture().get().query(); | ||
| } | ||
| } catch (Exception e) { | ||
| throw new RuntimeException(e); | ||
| } | ||
| } | ||
|
|
||
| private static String singleUpdate(int count) { | ||
| StringBuilder sql = new StringBuilder(); | ||
| sql.append("UPDATE WORLD SET RANDOMNUMBER = CASE ID"); | ||
| for (int i = 0; i < count; i++) { | ||
| int k = i * 2 + 1; | ||
| sql.append(" WHEN $").append(k).append(" THEN $").append(k + 1); | ||
| } | ||
| sql.append(" ELSE RANDOMNUMBER"); | ||
| sql.append(" END WHERE ID IN ($1"); | ||
| for (int i = 1; i < count; i++) { | ||
| int k = i * 2 + 1; | ||
| sql.append(",$").append(k); | ||
| } | ||
| sql.append(")"); | ||
| return sql.toString(); | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.