[Fix] 리뷰 조회 방식 변경 (#238)

* 리뷰 조회 방식 변경

# Conflicts:
#	src/test/java/com/backend/domain/review/controller/ApiV1ReviewControllerTest.java

* 리뷰 조회 방식 변경

Author: CYW815

src/main/java/com/backend/domain/review/controller/ApiV1ReviewController.java

@@ -13,6 +13,8 @@
 import org.springframework.security.core.userdetails.User;
 import org.springframework.web.bind.annotation.*;
 
+import java.util.List;
+
 @RestController
 @RequestMapping("/api/v1/reviews")
 @RequiredArgsConstructor
@@ -38,6 +40,12 @@ public ResponseEntity<RsData<ReviewResponse>> getReview(@PathVariable Long revie
         return ResponseEntity.ok(RsData.ok("리뷰를 성공적으로 조회했습니다.", response));
     }
 
+    @GetMapping("/products/{productId}")
+    public ResponseEntity<RsData<List<ReviewResponse>>> getReviewsByProductId(@PathVariable Long productId) {
+        List<ReviewResponse> responses = reviewService.getReviewsByProductId(productId);
+        return ResponseEntity.ok(RsData.ok("리뷰를 성공적으로 조회했습니다.", responses));
+    }
+
     @PutMapping("/{reviewId}")
     public ResponseEntity<RsData<ReviewResponse>> updateReview(@AuthenticationPrincipal User user, @PathVariable Long reviewId, @RequestBody ReviewRequest request) {
         Member member = getMember(user);

src/main/java/com/backend/domain/review/entity/Review.java

@@ -20,7 +20,7 @@ public class Review extends BaseEntity {
     @Column(name = "is_satisfied", nullable = false)
     private Boolean isSatisfied;
 
-    @OneToOne(fetch = FetchType.LAZY)
+    @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "product_id")
     private Product product;
 

src/main/java/com/backend/domain/review/repository/ReviewRepository.java

@@ -3,8 +3,8 @@
 import com.backend.domain.review.entity.Review;
 import org.springframework.data.jpa.repository.JpaRepository;
 
-import java.util.Optional;
+import java.util.List;
 
 public interface ReviewRepository extends JpaRepository<Review, Long> {
-    Optional<Review> findByProductId(Long productId);
+    List<Review> findAllByProductId(Long productId);
 }

src/main/java/com/backend/domain/review/service/ReviewService.java

@@ -15,6 +15,9 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.List;
+import java.util.stream.Collectors;
+
 @Service
 @RequiredArgsConstructor
 @Transactional
@@ -32,10 +35,6 @@ public ReviewResponse createReview(Long memberId, ReviewRequest request) {
         Product product = productRepository.findById(request.productId())
                 .orElseThrow(() -> new ReviewException(RsStatus.PRODUCT_NOT_FOUND));
 
-        reviewRepository.findByProductId(product.getId()).ifPresent(review -> {
-            throw ReviewException.alreadyExists();
-        });
-
         Review review = Review.builder()
                 .reviewer(member)
                 .product(product)
@@ -56,6 +55,14 @@ public ReviewResponse getReview(Long reviewId) {
         return ReviewResponse.from(review);
     }
 
+    @Transactional(readOnly = true)
+    public List<ReviewResponse> getReviewsByProductId(Long productId) {
+        List<Review> reviews = reviewRepository.findAllByProductId(productId);
+        return reviews.stream()
+                .map(ReviewResponse::from)
+                .collect(Collectors.toList());
+    }
+
     public ReviewResponse updateReview(Long memberId, Long reviewId, ReviewRequest request) {
         Review review = reviewRepository.findById(reviewId)
                 .orElseThrow(ReviewException::reviewNotFound);

src/main/resources/application-test.yml

@@ -25,7 +25,7 @@ spring:
       ddl-auto: create
 logging:
   level:
-    org.hibernate.orm.jdbc.bind: TRACE
+    org.springframework: DEBUG
     org.hibernate.orm.jdbc.extract: TRACE
     org.springframework.transaction.interceptor: TRACE
     com.back: DEBUG

src/test/java/com/backend/domain/review/controller/ApiV1ReviewControllerTest.java

@@ -12,7 +12,6 @@
 import com.backend.domain.review.entity.Review;
 import com.backend.domain.review.repository.ReviewRepository;
 import com.backend.global.elasticsearch.TestElasticsearchConfiguration;
-import com.backend.global.redis.TestRedisConfiguration;
 import com.backend.global.security.JwtUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.junit.jupiter.api.BeforeEach;
@@ -39,7 +38,7 @@
 @SpringBootTest
 @AutoConfigureMockMvc
 @ActiveProfiles("test")
-@Import({TestElasticsearchConfiguration.class, TestRedisConfiguration.class})
+@Import({TestElasticsearchConfiguration.class, com.backend.global.redis.TestRedisConfig.class, com.backend.global.config.TestRedissonConfig.class})
 @Transactional
 class ApiV1ReviewControllerTest {
 
@@ -107,7 +106,7 @@ void createReview_Success() throws Exception {
                 .andExpect(jsonPath("$.data.isSatisfied").value(true));
 
         // DB 검증
-        Review review = reviewRepository.findByProductId(testProduct.getId()).orElseThrow();
+        Review review = reviewRepository.findAllByProductId(testProduct.getId()).get(0);
         assertThat(review.getComment()).isEqualTo("Great product!");
         assertThat(review.getReviewer().getId()).isEqualTo(testUser.getId());
     }
@@ -137,6 +136,36 @@ void getReview_Success() throws Exception {
                 .andExpect(jsonPath("$.data.reviewerNickname").value(testUser.getNickname()));
     }
 
+    @Test
+    @DisplayName("상품 ID로 리뷰 목록 조회 성공")
+    void getReviewsByProductId_Success() throws Exception {
+        // Given
+        reviewRepository.save(Review.builder()
+                .reviewer(testUser)
+                .product(testProduct)
+                .comment("First review")
+                .isSatisfied(true)
+                .build());
+
+        reviewRepository.save(Review.builder()
+                .reviewer(anotherUser)
+                .product(testProduct)
+                .comment("Second review")
+                .isSatisfied(false)
+                .build());
+
+        // When & Then
+        mockMvc.perform(get("/api/v1/reviews/products/{productId}", testProduct.getId())
+                        .header("Authorization", "Bearer " + testUserToken))
+                .andDo(print())
+                .andExpect(status().isOk())
+                .andExpect(jsonPath("$.resultCode").value("200"))
+                .andExpect(jsonPath("$.data").isArray())
+                .andExpect(jsonPath("$.data.length()").value(2))
+                .andExpect(jsonPath("$.data[0].comment").value("First review"))
+                .andExpect(jsonPath("$.data[1].comment").value("Second review"));
+    }
+
     @Test
     @DisplayName("리뷰 수정 성공")
     void updateReview_Success() throws Exception {

src/test/java/com/backend/global/config/TestRedissonConfig.java

@@ -0,0 +1,29 @@
+package com.backend.global.config;
+
+import org.redisson.Redisson;
+import org.redisson.api.RedissonClient;
+import org.redisson.config.Config;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.test.context.TestConfiguration;
+import org.springframework.context.annotation.Bean;
+
+@TestConfiguration
+public class TestRedissonConfig {
+
+    @Value("${spring.data.redis.host}")
+    private String redisHost;
+
+    @Value("${spring.data.redis.port}")
+    private int redisPort;
+
+    private static final String REDISSON_HOST_PREFIX = "redis://";
+
+    @Bean
+    public RedissonClient redissonClient() {
+        Config config = new Config();
+        config.useSingleServer()
+                .setAddress(REDISSON_HOST_PREFIX + redisHost + ":" + redisPort);
+
+        return Redisson.create(config);
+    }
+}

src/test/java/com/backend/global/redis/TestRedisConfig.java

@@ -0,0 +1,59 @@
+package com.backend.global.redis;
+
+import jakarta.annotation.PostConstruct;
+import jakarta.annotation.PreDestroy;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.test.context.TestConfiguration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+import redis.embedded.RedisServer;
+
+import java.io.IOException;
+
+@TestConfiguration
+public class TestRedisConfig {
+
+    private final RedisServer redisServer;
+
+    public TestRedisConfig(@Value("${spring.data.redis.port}") int redisPort) {
+        try {
+            this.redisServer = new RedisServer(redisPort);
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    @PostConstruct
+    public void startRedis() {
+        try {
+            this.redisServer.start();
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    @PreDestroy
+    public void stopRedis() {
+        try {
+            this.redisServer.stop();
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    @Bean
+    public LettuceConnectionFactory redisConnectionFactory(@Value("${spring.data.redis.host}") String host, @Value("${spring.data.redis.port}") int port) {
+        return new LettuceConnectionFactory(host, port);
+    }
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory connectionFactory) {
+        RedisTemplate<String, Object> template = new RedisTemplate<>();
+        template.setConnectionFactory(connectionFactory);
+        template.setKeySerializer(new StringRedisSerializer());
+        template.setValueSerializer(new StringRedisSerializer());
+        return template;
+    }
+}