Merge branch 'performance/db-connection-pool'

.gitignore

@@ -118,3 +118,4 @@ dist
 
 # Service worker
 sw.*
+*.private.env.json

api/http/test.http

@@ -1,10 +1,10 @@
 # Register a new user
-POST http://localhost:8081/login
+POST http://localhost:8081/user/login
 Content-Type: application/json
 
 {
-  "username": "hubert",
+  "username": "{{username}}",
-  "password": "test"
+  "password": "{{password}}"
 }
 
 > {%
@@ -23,32 +23,3 @@ client.test("Request executed successfully", function() {
    client.assert(response.status === 200, "Response status is not 200");
 });
 %}
-
-### Create a note
-POST http://localhost:8081/notes/tortue
-Content-Type: application/json
-Authorization: Bearer {{token}}
-
-{
-    "tags": [
-        "Dev",
-        "Server"
-    ]
-}
-
-> {%
-client.test("Request executed successfully", function() {
-   client.assert(response.status === 201, "Response status is not 200");
-});
-%}
-
-### Read a note
-GET http://localhost:8081/notes/babar
-Content-Type: application/json
-Authorization: Bearer {{token}}
-
-> {%
-client.test("Request executed successfully", function() {
-   client.assert(response.status === 200, "Response status is not 200");
-});
-%}

api/pom.xml

@@ -49,6 +49,16 @@
                 <enabled>true</enabled>
             </snapshots>
         </repository>
+        <repository>
+            <id>jitpack</id>
+            <url>https://jitpack.io</url>
+            <releases>
+                <enabled>true</enabled>
+            </releases>
+            <snapshots>
+                <enabled>true</enabled>
+            </snapshots>
+        </repository>
     </repositories>
     <dependencies>
         <dependency>
@@ -118,6 +128,11 @@
             <artifactId>ktorm-support-mysql</artifactId>
             <version>${ktorm_version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.github.hekeki</groupId>
+            <artifactId>huckleberry</artifactId>
+            <version>0.0.2-beta</version>
+        </dependency>
         <dependency>
             <groupId>org.flywaydb</groupId>
             <artifactId>flyway-core</artifactId>
@@ -128,6 +143,11 @@
             <artifactId>jbcrypt</artifactId>
             <version>${jbcrypt_version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+            <version>3.4.2</version>
+        </dependency>
     </dependencies>
     <build>
         <sourceDirectory>${project.basedir}/src</sourceDirectory>

api/resources/logback.xml

@@ -4,7 +4,7 @@
             <pattern>%d{YYYY-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
         </encoder>
     </appender>
-    <root level="trace">
+    <root level="INFO">
         <appender-ref ref="STDOUT"/>
     </root>
     <logger name="org.eclipse.jetty" level="INFO"/>

api/src/features/ConfigurationFeature.kt

@@ -1,11 +1,12 @@
 package be.vandewalleh.features
 
 import be.vandewalleh.auth.SimpleJWT
+import com.zaxxer.hikari.HikariConfig
+import com.zaxxer.hikari.HikariDataSource
 import io.ktor.application.*
 import org.kodein.di.Kodein
 import org.kodein.di.generic.bind
 import org.kodein.di.generic.instance
-import org.mariadb.jdbc.MariaDbDataSource
 import javax.sql.DataSource
 
 /**
@@ -18,15 +19,14 @@ fun Application.configurationFeature() {
         val host = property("database.host").getString()
         val port = property("database.port").getString()
         val name = property("database.name").getString()
-        val user = property("database.user").getString()
-        val password = property("database.password").getString()
 
-        val url = "jdbc:mariadb://$host:$port/$name"
+        val hikariConfig = HikariConfig().apply {
-
+            jdbcUrl = "jdbc:mariadb://$host:$port/$name"
-        MariaDbDataSource(url).apply {
+            username = this@with.property("database.user").getString()
-            this.user = user
+            password = this@with.property("database.password").getString()
-            setPassword(password)
         }
+
+        HikariDataSource(hikariConfig)
     }
 
     val simpleJwt = SimpleJWT(environment.config.property("jwt.secret").getString())

api/test/NotesRetrievePerformanceTest.kt

@@ -0,0 +1,50 @@
+import be.vandewalleh.services.NotesService
+import be.vandewalleh.services.UserService
+import com.hekeki.huckleberry.Benchmark
+import com.hekeki.huckleberry.BenchmarkRunner
+import com.hekeki.huckleberry.BenchmarkTest
+import com.hekeki.huckleberry.TimeUnit
+import com.zaxxer.hikari.HikariConfig
+import com.zaxxer.hikari.HikariDataSource
+import me.liuwj.ktorm.database.*
+import org.junit.jupiter.api.Assertions.*
+import org.junit.jupiter.api.Test
+import org.kodein.di.Kodein
+import org.kodein.di.generic.bind
+import org.kodein.di.generic.instance
+import org.kodein.di.generic.singleton
+
+
+val hikariConfig = HikariConfig().apply {
+    jdbcUrl = "jdbc:mariadb://localhost:3306/Notes"
+    username = "test"
+    password = "test"
+}
+
+val dataSource = HikariDataSource(hikariConfig)
+
+val db = Database.Companion.connect(dataSource)
+
+val kodein = Kodein {
+    bind<Database>() with singleton { db }
+    bind<UserService>() with singleton { UserService(this.kodein) }
+    bind<NotesService>() with singleton { NotesService(this.kodein) }
+}
+
+val notesService by kodein.instance<NotesService>()
+
+@Benchmark(threads = 1, iterations = 30, warmup = true, warmupIterations = 1000, timeUnit = TimeUnit.MILLIS)
+class RetrieveNotesBenchmarkTest : BenchmarkTest {
+
+    override fun execute() {
+        notesService.getNotes(15)
+    }
+
+    @Test
+    fun compute() {
+        val benchmarkResult = BenchmarkRunner(RetrieveNotesBenchmarkTest::class.java).run()
+        assertTrue(benchmarkResult.median(2, TimeUnit.MILLIS))
+        assertTrue(benchmarkResult.maxTime(4, TimeUnit.MILLIS))
+    }
+
+}