tweak hikari

Author: SentryMan

frameworks/Java/avaje-jex/src/main/java/benchmark/repository/HikariFactory.java

@@ -5,6 +5,7 @@
 import io.avaje.config.Config;
 import io.avaje.inject.Bean;
 import io.avaje.inject.Factory;
+import java.util.concurrent.Executors;
 import javax.sql.DataSource;
 
 @Factory
@@ -22,8 +23,21 @@ DataSource dataSource() {
       maxPoolSize = Config.getInt("postgresDefaultPoolSize");
     }
 
-    var hikari = new HikariDataSource(new HikariConfig("hikari.properties"));
-    hikari.setMaximumPoolSize(maxPoolSize);
-    return hikari;
+    maxPoolSize = Math.max(maxPoolSize, Runtime.getRuntime().availableProcessors() * 2);
+    HikariConfig hikariConfig = new HikariConfig("hikari.properties");
+
+    var vtThreadFactory = Thread.ofVirtual().factory();
+    hikariConfig.setThreadFactory(vtThreadFactory);
+    hikariConfig.setScheduledExecutor(
+        Executors.newScheduledThreadPool(maxPoolSize, vtThreadFactory));
+
+    // data source properties
+    hikariConfig.addDataSourceProperty("cachePrepStmts", "true");
+    hikariConfig.addDataSourceProperty("prepStmtCacheSize", "250");
+    hikariConfig.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
+    hikariConfig.addDataSourceProperty("ssl", "false");
+    hikariConfig.addDataSourceProperty("tcpKeepAlive", "true");
+    hikariConfig.setMaximumPoolSize(maxPoolSize);
+    return new HikariDataSource(hikariConfig);
   }
 }

frameworks/Java/avaje-jex/src/main/java/benchmark/repository/JDBCDbService.java

@@ -22,23 +22,20 @@ public JDBCDbService(DataSource connectionFactory) {
   }
 
   @Override
-  public List<World> getWorld(int num) {
+  public List<World> getWorld(int num) throws SQLException {
 
-    String select = "select id, randomNumber from World where id = ?";
+    String select = "select id, randomNumber from World where id IN (?)";
     List<World> worldList = new ArrayList<>();
 
     try (Connection conn = datasource.getConnection();
         PreparedStatement pstm = conn.prepareStatement(select)) {
 
-      for (int randomId : getRandomNumberSet(num)) {
-        pstm.setInt(1, randomId);
-        try (ResultSet rs = pstm.executeQuery()) {
-          rs.next();
-          worldList.add(new World(rs.getInt("id"), rs.getInt("randomNumber")));
+      pstm.setObject(1, getRandomNumberSet(num));
+      try (ResultSet rs = pstm.executeQuery()) {
+        while (rs.next()) {
+          worldList.add(new World(rs.getInt(0), rs.getInt(1)));
         }
       }
-    } catch (SQLException e) {
-      throw new RuntimeException(e);
     }
 
     return worldList;
@@ -55,7 +52,7 @@ public List<Fortune> getFortune() throws SQLException {
         ResultSet rs = pstm.executeQuery()) {
 
       while (rs.next()) {
-        fortuneList.add(new Fortune(rs.getInt("id"), rs.getString("message")));
+        fortuneList.add(new Fortune(rs.getInt(1), rs.getString(2)));
       }
       fortuneList.add(new Fortune(defaultFortuneId, defaultFortuneMessage));
     }

frameworks/Java/avaje-jex/src/main/resources/application.properties

@@ -1,6 +1,6 @@
 physicalTag=Citrine
 cloudTag=Azure
 
-postgresPhysicalPoolSize=56
+postgresPhysicalPoolSize=64
 postgresCloudPoolSize=16
 postgresDefaultPoolSize=10