#52 lockmode - 기본, pessimistic 추가

f-lab-edu · Jun 18, 2022 · e2da222 · e2da222
1 parent 93f4d77
commit e2da222
Show file tree

Hide file tree

Showing 2 changed files with 36 additions and 1 deletion.
diff --git a/module-api/src/main/kotlin/com/example/event/vote/adapter/in/EventVoteController.kt b/module-api/src/main/kotlin/com/example/event/vote/adapter/in/EventVoteController.kt
@@ -16,8 +16,11 @@ class EventVoteController(
     @PostMapping(path = ["/api/event/vote"])
     fun vote(@Valid @RequestBody req: EventVoteRequest) {
         when (req.lockmode) {
+            LockModeType.READ -> eventVoteService.readVote(req.id)
+            LockModeType.WRITE -> eventVoteService.writeVote(req.id)
             LockModeType.PESSIMISTIC_WRITE -> eventVoteService.pessimisticWriteVote(req.id)
             LockModeType.PESSIMISTIC_READ -> eventVoteService.pessimisticReadVote(req.id)
+            LockModeType.PESSIMISTIC_FORCE_INCREMENT -> eventVoteService.pessimisticForceIncrementVote(req.id)
             else -> eventVoteService.vote(req.id)
         }
     }

diff --git a/module-api/src/main/kotlin/com/example/event/vote/domain/EventVoteService.kt b/module-api/src/main/kotlin/com/example/event/vote/domain/EventVoteService.kt
@@ -1,6 +1,7 @@
 package com.example.event.vote.domain
 
 import com.example.event.vote.adapter.out.EventVoteRepository
+import org.slf4j.Logger
 import org.springframework.data.jpa.repository.Lock
 import org.springframework.stereotype.Service
 import org.springframework.transaction.annotation.Transactional
@@ -9,11 +10,31 @@ import javax.persistence.LockModeType
 
 @Service
 class EventVoteService(
-    private val eventVoteRepository: EventVoteRepository
+    private val eventVoteRepository: EventVoteRepository,
+    private val log: Logger
 ) {
 
     @Transactional
     fun vote(id: UUID) {
+        log.info("### NONE")
+        val eventVoteEntity = eventVoteRepository.findById(id).orElse(EventVoteEntity(id = id))
+        eventVoteEntity.addCount()
+        eventVoteRepository.save(eventVoteEntity)
+    }
+
+    @Transactional
+    @Lock(value = LockModeType.READ)
+    fun readVote(id: UUID) {
+        log.info("### READ")
+        val eventVoteEntity = eventVoteRepository.findById(id).orElse(EventVoteEntity(id = id))
+        eventVoteEntity.addCount()
+        eventVoteRepository.save(eventVoteEntity)
+    }
+
+    @Transactional
+    @Lock(value = LockModeType.WRITE)
+    fun writeVote(id: UUID) {
+        log.info("### WRITE")
         val eventVoteEntity = eventVoteRepository.findById(id).orElse(EventVoteEntity(id = id))
         eventVoteEntity.addCount()
         eventVoteRepository.save(eventVoteEntity)
@@ -22,6 +43,7 @@ class EventVoteService(
     @Transactional
     @Lock(value = LockModeType.PESSIMISTIC_WRITE)
     fun pessimisticWriteVote(id: UUID) {
+        log.info("### PESSIMISTIC_WRITE")
         val eventVoteEntity = eventVoteRepository.findById(id).orElse(EventVoteEntity(id = id))
         eventVoteEntity.addCount()
         eventVoteRepository.save(eventVoteEntity)
@@ -30,6 +52,16 @@ class EventVoteService(
     @Transactional
     @Lock(value = LockModeType.PESSIMISTIC_READ)
     fun pessimisticReadVote(id: UUID) {
+        log.info("### PESSIMISTIC_READ")
+        val eventVoteEntity = eventVoteRepository.findById(id).orElse(EventVoteEntity(id = id))
+        eventVoteEntity.addCount()
+        eventVoteRepository.save(eventVoteEntity)
+    }
+
+    @Transactional
+    @Lock(value = LockModeType.PESSIMISTIC_FORCE_INCREMENT)
+    fun pessimisticForceIncrementVote(id: UUID) {
+        log.info("### PESSIMISTIC_FORCE_INCREMENT")
         val eventVoteEntity = eventVoteRepository.findById(id).orElse(EventVoteEntity(id = id))
         eventVoteEntity.addCount()
         eventVoteRepository.save(eventVoteEntity)