좋아요 기능 버그 해결을 위한 캐싱 자료구조 및 로직 변경

backend/src/main/java/hanglog/community/service/CommunityService.java

@@ -19,6 +19,7 @@
 import hanglog.community.dto.response.RecommendTripListResponse;
 import hanglog.global.exception.BadRequestException;
 import hanglog.like.domain.LikeInfo;
+import hanglog.like.domain.repository.CustomLikeRepository;
 import hanglog.like.domain.repository.LikeRepository;
 import hanglog.like.dto.LikeElement;
 import hanglog.like.dto.LikeElements;
@@ -49,11 +50,12 @@ public class CommunityService {
 
     private static final int RECOMMEND_AMOUNT = 5;
 
-    private final LikeRepository likeRepository;
     private final TripRepository tripRepository;
     private final TripCityRepository tripCityRepository;
     private final CityRepository cityRepository;
     private final PublishedTripRepository publishedTripRepository;
+    private final LikeRepository likeRepository;
+    private final CustomLikeRepository customLikeRepository;
     private final RecommendStrategies recommendStrategies;
     private final RedisTemplate<String, Object> redisTemplate;
 
@@ -136,7 +138,7 @@ private Map<Long, LikeInfo> getLikeInfoByTripIds(final Long memberId, final List
             }
         }
 
-        final List<LikeElement> likeElementByTripIds = likeRepository.findLikeElementByTripIds(nonCachedTripIds);
+        final List<LikeElement> likeElementByTripIds = customLikeRepository.findLikeElementByTripIds(nonCachedTripIds);
         likeElementByTripIds.addAll(getEmptyLikeElements(likeInfoByTrip, nonCachedTripIds));
         likeElementByTripIds.forEach(this::cachingLike);
         likeInfoByTrip.putAll(new LikeElements(likeElementByTripIds).toLikeMap(memberId));
@@ -149,7 +151,7 @@ private LikeInfo getLikeInfoByTripId(final Long memberId, final Long tripId) {
             return readLikeInfoFromCache(key, memberId);
         }
 
-        final LikeElement likeElement = likeRepository.findLikesElementByTripId(tripId)
+        final LikeElement likeElement = customLikeRepository.findLikesElementByTripId(tripId)
                 .orElse(LikeElement.empty(tripId));
         cachingLike(likeElement);
         return likeElement.toLikeMap(memberId);

backend/src/main/java/hanglog/like/domain/repository/CustomLikeRepository.java

@@ -1,9 +1,15 @@
 package hanglog.like.domain.repository;
 
 import hanglog.like.domain.Likes;
+import hanglog.like.dto.LikeElement;
 import java.util.List;
+import java.util.Optional;
 
 public interface CustomLikeRepository {
 
     void saveAll(final List<Likes> likes);
+
+    Optional<LikeElement> findLikesElementByTripId(final Long tripId);
+
+    List<LikeElement> findLikeElementByTripIds(final List<Long> tripIds);
 }

backend/src/main/java/hanglog/like/domain/repository/LikeRepository.java

@@ -1,32 +1,14 @@
 package hanglog.like.domain.repository;
 
 import hanglog.like.domain.Likes;
-import hanglog.like.dto.LikeElement;
-import java.util.List;
-import java.util.Optional;
 import java.util.Set;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
-import org.springframework.data.repository.query.Param;
 
 public interface LikeRepository extends JpaRepository<Likes, Long> {
 
-    @Query(value = """
-            SELECT l.trip_id AS tripId, COUNT(l.id) AS likeCount, GROUP_CONCAT(l.member_id) AS memberIds
-            FROM likes l
-            WHERE l.trip_id IN :tripIds
-            GROUP BY l.trip_id
-            """, nativeQuery = true)
-    List<LikeElement> findLikeElementByTripIds(@Param("tripIds") final List<Long> tripIds);
-
-    @Query(value = """
-            SELECT l.trip_id AS tripId, COUNT(l.id) AS likeCount, GROUP_CONCAT(l.member_id) AS memberIds
-            FROM likes l
-            WHERE l.trip_id = :tripId
-            GROUP BY l.trip_id
-            """, nativeQuery = true)
-    Optional<LikeElement> findLikesElementByTripId(@Param("tripId") final Long tripId);
-
+    @Modifying
     @Query("DELETE FROM Likes WHERE tripId IN :tripIds")
     void deleteByTripIds(final Set<Long> tripIds);
 }

backend/src/main/java/hanglog/like/infrastrcutrue/CustomLikeRepositoryImpl.java

@@ -2,16 +2,30 @@
 
 import hanglog.like.domain.Likes;
 import hanglog.like.domain.repository.CustomLikeRepository;
+import hanglog.like.dto.LikeElement;
+import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
+import java.util.Optional;
+import java.util.Set;
+import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
+import org.springframework.jdbc.core.RowMapper;
 import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
 import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
 import org.springframework.stereotype.Repository;
+import org.springframework.util.StringUtils;
 
 @RequiredArgsConstructor
 @Repository
 public class CustomLikeRepositoryImpl implements CustomLikeRepository {
 
+    private static final RowMapper<LikeElement> likeElementRowMapper = (rs, rowNum) ->
+            new LikeElement(
+                    rs.getLong("tripId"),
+                    rs.getLong("likeCount"),
+                    parseMemberIds(rs.getString("memberIds")));
+
     private final NamedParameterJdbcTemplate namedParameterJdbcTemplate;
 
     @Override
@@ -34,4 +48,46 @@ private MapSqlParameterSource getLikeToSqlParameterSource(final Likes likes) {
                 .addValue("tripId", likes.getTripId())
                 .addValue("memberId", likes.getMemberId());
     }
+
+    @Override
+    public Optional<LikeElement> findLikesElementByTripId(final Long tripId) {
+        final String sql = """
+                SELECT l.trip_id AS tripId, COUNT(l.id) AS likeCount, GROUP_CONCAT(l.member_id) AS memberIds
+                FROM likes l
+                WHERE l.trip_id = :tripId
+                GROUP BY l.trip_id
+                """;
+
+        final MapSqlParameterSource parameters = new MapSqlParameterSource();
+        parameters.addValue("tripId", tripId);
+        final List<LikeElement> results = namedParameterJdbcTemplate.query(sql, parameters, likeElementRowMapper);
+        if (results.isEmpty()) {
+            return Optional.empty();
+        }
+        return Optional.of(results.get(0));
+    }
+
+    @Override
+    public List<LikeElement> findLikeElementByTripIds(final List<Long> tripIds) {
+        final String sql = """
+                SELECT l.trip_id AS tripId, COUNT(l.id) AS likeCount, GROUP_CONCAT(l.member_id) AS memberIds
+                FROM likes l
+                WHERE l.trip_id IN (:tripIds)
+                GROUP BY l.trip_id
+                """;
+
+        final MapSqlParameterSource parameters = new MapSqlParameterSource();
+        parameters.addValue("tripIds", tripIds);
+        return namedParameterJdbcTemplate.query(sql, parameters, likeElementRowMapper);
+    }
+
+    private static Set<Long> parseMemberIds(final String memberIds) {
+        if (!StringUtils.hasText(memberIds)) {
+            return Collections.emptySet();
+        }
+        final String[] idArray = memberIds.split(",");
+        return Arrays.stream(idArray)
+                .map(Long::valueOf)
+                .collect(Collectors.toSet());
+    }
 }