Add more jasync parameters to config (#281)

Co-authored-by: Stefan Post <[email protected]>
Co-authored-by: Kazuhiro Sera <[email protected]>

Author: 3 people

core/src/main/scala/scalikejdbc/async/AsyncConnectionPoolSettings.scala

@@ -29,6 +29,11 @@ case class AsyncConnectionPoolSettings(
   maxPoolSize: Int = 8,
   maxQueueSize: Int = 8,
   maxIdleMillis: Long = 1000L,
+  validationInterval: Long = 5000L,
+  createTimeout: Long = 5000L,
+  testTimeout: Long = 5000L,
+  queryTimeout: Option[Long] = None,
+  maxObjectTtl: Option[Long] = None,
   connectionSettings: AsyncConnectionSettings = AsyncConnectionSettings()
 )
 
@@ -38,6 +43,5 @@ case class AsyncConnectionSettings(
   maximumMessageSize: Option[Int] = None,
   allocator: Option[ByteBufAllocator] = None,
   connectTimeout: Option[Duration] = None,
-  testTimeout: Option[Duration] = None,
   queryTimeout: Option[Duration] = None
 )

core/src/main/scala/scalikejdbc/async/internal/AsyncConnectionPoolCommonImpl.scala

@@ -32,6 +32,21 @@ abstract class AsyncConnectionPoolCommonImpl[T <: ConcreteConnection](
       builder.setMaxActiveConnections(settings.maxPoolSize)
       builder.setMaxIdleTime(settings.maxIdleMillis)
       builder.setMaxPendingQueries(settings.maxQueueSize)
+      builder.setConnectionValidationInterval(settings.validationInterval)
+      builder.setConnectionCreateTimeout(settings.createTimeout)
+      builder.setConnectionTestTimeout(settings.testTimeout)
+      settings.queryTimeout match {
+        case Some(timeout) =>
+          builder.setQueryTimeout(timeout)
+        case None =>
+          builder.setQueryTimeout(null)
+      }
+      settings.maxObjectTtl match {
+        case Some(ttl) =>
+          builder.setMaxConnectionTtl(ttl)
+        case None =>
+          builder.setMaxConnectionTtl(null)
+      }
       builder.build()
     }
   )