Ktor optimize and update (#9444)

* fixed batch writes

* upgraded Ktor to latest

---------

Co-authored-by: Ilya Nemtsev <[email protected]>

Author: inemtsev

frameworks/Kotlin/ktor/ktor/pom.xml

@@ -13,7 +13,7 @@
 
     <properties>
         <kotlin.version>2.0.21</kotlin.version>
-        <ktor.version>3.0.1</ktor.version>
+        <ktor.version>3.0.2</ktor.version>
         <serialization.version>1.7.3</serialization.version>
         <kotlinx.html.version>0.11.0</kotlinx.html.version>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

frameworks/Kotlin/ktor/ktor/src/main/kotlin/org/jetbrains/ktor/benchmarks/Hello.kt

@@ -19,6 +19,7 @@ import org.jetbrains.ktor.benchmarks.Constants.UPDATE_QUERY
 import org.jetbrains.ktor.benchmarks.Constants.WORLD_QUERY
 import java.sql.Connection
 import java.util.concurrent.ThreadLocalRandom
+import kotlin.random.Random
 
 @Serializable
 data class Message(val message: String)
@@ -49,7 +50,7 @@ fun Application.main() {
         }
 
         get("/db") {
-            val random = ThreadLocalRandom.current()
+            val random = Random.Default
 
             val world = withContext(databaseDispatcher) {
                 pool.connection.use { connection ->
@@ -67,7 +68,7 @@ fun Application.main() {
             call.respondText(Json.encodeToString(world), ContentType.Application.Json)
         }
 
-        fun Connection.selectWorlds(queries: Int, random: ThreadLocalRandom): List<World> {
+        fun Connection.selectWorlds(queries: Int, random: Random): List<World> {
             val result = ArrayList<World>(queries)
             prepareStatement(WORLD_QUERY).use { statement ->
                 repeat(queries) {
@@ -85,7 +86,7 @@ fun Application.main() {
 
         get("/queries") {
             val queries = call.queries()
-            val random = ThreadLocalRandom.current()
+            val random = Random.Default
 
             val result = withContext(databaseDispatcher) {
                 pool.connection.use { it.selectWorlds(queries, random) }
@@ -130,7 +131,7 @@ fun Application.main() {
 
         get("/updates") {
             val queries = call.queries()
-            val random = ThreadLocalRandom.current()
+            val random = Random.Default
             val result: List<World>
 
             withContext(databaseDispatcher) {
@@ -139,14 +140,14 @@ fun Application.main() {
 
                     result.forEach { it.randomNumber = random.nextInt(dbRows) + 1 }
 
-                    connection.prepareStatement(UPDATE_QUERY)
-                        .use { updateStatement ->
+                    connection.prepareStatement(UPDATE_QUERY).use { updateStatement ->
                             for ((id, randomNumber) in result) {
                                 updateStatement.setInt(1, randomNumber)
                                 updateStatement.setInt(2, id)
-
-                                updateStatement.executeUpdate()
+                                updateStatement.addBatch()
                             }
+
+                            updateStatement.executeBatch()
                         }
                 }
             }