feat/ #33 코드 리뷰 반영

Author: warcat12

src/main/java/com/closetnangam/be/domain/user/repository/UserRepository.java

@@ -1,7 +1,11 @@
 package com.closetnangam.be.domain.user.repository;
 
 import com.closetnangam.be.domain.user.entity.User;
+import jakarta.persistence.LockModeType;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Lock;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 
 import java.util.Optional;
 
@@ -10,4 +14,8 @@ public interface UserRepository extends JpaRepository<User, Long> {
     Optional<User> findByEmail(String email);
 
     boolean existsByNickname(String nickname);
+
+    @Lock(LockModeType.PESSIMISTIC_WRITE)
+    @Query("SELECT u FROM User u WHERE u.id = :userId")
+    Optional<User> findByIdForUpdate(@Param("userId") Long userId);
 }

src/main/java/com/closetnangam/be/domain/wardrobe/service/WardrobeService.java

@@ -33,9 +33,13 @@ public WardrobeResponse createWardrobe(Long userId) {
 
     @Transactional
     public Wardrobe getOrCreateWardrobe(Long userId) {
-        // FOR UPDATE: 동일 userId로 동시 요청이 들어올 때 중복 INSERT → DataIntegrityViolationException 방지
-        return wardrobeRepository.findByUser_IdForUpdate(userId)
-                .orElseGet(() -> createWardrobeEntity(userId));
+        // User row에 FOR UPDATE lock: User는 항상 존재하므로 신규 사용자에게도 lock이 보장됨.
+        // 같은 userId로 동시 요청이 들어올 때 두 트랜잭션이 직렬화되어
+        // 중복 INSERT → DataIntegrityViolationException을 방지함.
+        User user = userRepository.findByIdForUpdate(userId)
+                .orElseThrow(() -> new IllegalArgumentException("사용자를 찾을 수 없습니다."));
+        return wardrobeRepository.findByUser_Id(userId)
+                .orElseGet(() -> wardrobeRepository.save(Wardrobe.create(user)));
     }
 
     private Wardrobe createWardrobeEntity(Long userId) {