update: batch insert exposed dsl

Author: vumrra

build.gradle.kts

@@ -54,6 +54,10 @@ dependencies {
     testImplementation("org.jetbrains.kotlin:kotlin-test-junit5")
     testImplementation("org.springframework.security:spring-security-test")
     testRuntimeOnly("org.junit.platform:junit-platform-launcher")
+    implementation("org.jetbrains.exposed:exposed-core:0.45.0")
+    implementation("org.jetbrains.exposed:exposed-dao:0.45.0")
+    implementation("org.jetbrains.exposed:exposed-jdbc:0.45.0")
+    implementation("org.jetbrains.exposed:exposed-java-time:0.45.0")
 }
 
 dependencyManagement {

src/main/kotlin/gogo/gogobetting/domain/betting/result/persistence/BettingResultTable.kt

@@ -0,0 +1,10 @@
+package gogo.gogobetting.domain.betting.result.persistence
+
+import org.jetbrains.exposed.sql.Table
+
+object BettingResultTable : Table("tbl_betting_result") {
+    val bettingId = long("betting_id")
+    val earnedPoint = long("earned_point")
+    val isCancelled = bool("is_cancelled")
+    val isPredicted = bool("is_predicted")
+}

…/infra/batch/dto/BettingResultJdbcDto.kt …fra/batch/dto/BettingResultExposedDto.ktsrc/main/kotlin/gogo/gogobetting/infra/batch/dto/BettingResultJdbcDto.kt renamed to src/main/kotlin/gogo/gogobetting/infra/batch/dto/BettingResultExposedDto.kt src/main/kotlin/gogo/gogobetting/infra/batch/dto/BettingResultJdbcDto.kt renamed to src/main/kotlin/gogo/gogobetting/infra/batch/dto/BettingResultExposedDto.kt

@@ -1,6 +1,6 @@
 package gogo.gogobetting.infra.batch.dto
 
-data class BettingResultJdbcDto(
+data class BettingResultExposedDto(
     val bettingId: Long,
     val earnedPoint: Long,
     val isPredicted: Boolean,

src/main/kotlin/gogo/gogobetting/infra/batch/service/BettingProcessor.kt

@@ -2,31 +2,31 @@ package gogo.gogobetting.infra.batch.service
 
 import gogo.gogobetting.domain.batch.detail.persistence.BatchDetail
 import gogo.gogobetting.domain.batch.detail.persistence.BatchDetailRepository
-import gogo.gogobetting.domain.batch.root.event.MatchBatchEvent
-import gogo.gogobetting.domain.batch.root.event.StudentBettingDto
 import gogo.gogobetting.domain.batch.root.persistence.BatchRepository
+import gogo.gogobetting.domain.betting.result.persistence.BettingResultTable
 import gogo.gogobetting.domain.betting.root.persistence.BettingRepository
 import gogo.gogobetting.global.kafka.publisher.BatchPublisher
-import gogo.gogobetting.infra.batch.dto.BettingResultJdbcDto
+import gogo.gogobetting.infra.batch.dto.BettingResultExposedDto
 import gogo.gogobetting.infra.batch.dto.BettingRow
+import org.jetbrains.exposed.sql.Database
+import org.jetbrains.exposed.sql.batchInsert
+import org.jetbrains.exposed.sql.transactions.transaction
 import org.slf4j.LoggerFactory
 import org.springframework.batch.core.StepExecution
 import org.springframework.batch.core.annotation.AfterStep
 import org.springframework.batch.core.annotation.BeforeStep
 import org.springframework.batch.core.configuration.annotation.StepScope
 import org.springframework.batch.item.Chunk
 import org.springframework.batch.item.ItemWriter
-import org.springframework.batch.item.database.JdbcBatchItemWriter
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.data.repository.findByIdOrNull
 import org.springframework.stereotype.Component
-import java.util.UUID
+import javax.sql.DataSource
 import kotlin.math.ceil
 
 @Component("springBatchBettingWriter")
 @StepScope
 class BettingResultWriter(
-    private val jdbcWriter: JdbcBatchItemWriter<BettingResultJdbcDto>,
     private val batchDetailRepository: BatchDetailRepository,
     private val batchRepository: BatchRepository,
     private val bettingRepository: BettingRepository,
@@ -35,11 +35,12 @@ class BettingResultWriter(
     @Value("#{jobParameters['bettingOdds']}") private val bettingOdds: Double,
     @Value("#{jobParameters['matchId']}") private val matchId: Long,
     @Value("#{jobParameters['aTeamScore']}") private val aTeamScore: Int,
-    @Value("#{jobParameters['bTeamScore']}") private val bTeamScore: Int
+    @Value("#{jobParameters['bTeamScore']}") private val bTeamScore: Int,
+    private val dataSource: DataSource
 ) : ItemWriter<BettingRow> {
 
     private var batchId: Long = 0
-    private val accumulated = mutableListOf<BettingResultJdbcDto>()
+    private val accumulated = mutableListOf<BettingResultExposedDto>()
     private val log = LoggerFactory.getLogger(this::class.java)
 
     @BeforeStep
@@ -52,14 +53,23 @@ class BettingResultWriter(
         val dtoList = items.map { row ->
             val isPredicted = row.predictedWinTeamId == winTeamId
             val earnedPoint = if (isPredicted) ceil(row.point * bettingOdds).toLong() + row.point else 0L
-            BettingResultJdbcDto(
+            BettingResultExposedDto(
                 bettingId = row.id,
                 earnedPoint = earnedPoint,
                 isPredicted = isPredicted,
             )
         }
 
-        jdbcWriter.write(Chunk(dtoList))
+        Database.connect(dataSource)
+        transaction {
+            BettingResultTable.batchInsert(dtoList) { item ->
+                this[BettingResultTable.bettingId] = item.bettingId
+                this[BettingResultTable.earnedPoint] = item.earnedPoint
+                this[BettingResultTable.isCancelled] = false
+                this[BettingResultTable.isPredicted] = item.isPredicted
+            }
+        }
+
         accumulated.addAll(dtoList)
     }