[BE] Refactor/#430 핀 복사 시 JdbcTemplate을 이용하여 bulk insert하도록 변경

backend/src/main/java/com/mapbefine/mapbefine/common/repository/PinBatchRepositoryCustom.java

@@ -0,0 +1,11 @@
+package com.mapbefine.mapbefine.common.repository;
+
+import com.mapbefine.mapbefine.pin.domain.Pin;
+import com.mapbefine.mapbefine.topic.domain.Topic;
+import java.util.List;
+
+public interface PinBatchRepositoryCustom {
+
+    int[] saveAllToTopic(Topic topicForCopy, List<Pin> originalPins);
+
+}

backend/src/main/java/com/mapbefine/mapbefine/common/repository/PinBatchRepositoryCustomImpl.java

@@ -0,0 +1,168 @@
+package com.mapbefine.mapbefine.common.repository;
+
+import com.mapbefine.mapbefine.pin.domain.Pin;
+import com.mapbefine.mapbefine.pin.domain.PinImage;
+import com.mapbefine.mapbefine.topic.domain.Topic;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.sql.Timestamp;
+import java.time.LocalDateTime;
+import java.util.Collection;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.IntStream;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+
+@Slf4j
+@Repository
+public class PinBatchRepositoryCustomImpl implements PinBatchRepositoryCustom {
+
+    private final JdbcTemplate jdbcTemplate;
+
+    public PinBatchRepositoryCustomImpl(JdbcTemplate jdbcTemplate) {
+        this.jdbcTemplate = jdbcTemplate;
+    }
+
+    public int[] saveAllToTopic(Topic topicForCopy, List<Pin> originalPins) {
+        int[] rowCount = batchUpdatePins(topicForCopy, originalPins);
+
+        Long firstIdFromBatch = jdbcTemplate.queryForObject("SELECT last_insert_id()", Long.class);
+        validateId(firstIdFromBatch);
+        List<PinImageInsertDto> pinImageInsertDtos = createPinImageDTOsToBatch(originalPins, rowCount,
+                firstIdFromBatch);
+
+        if (pinImageInsertDtos.isEmpty()) {
+            return rowCount;
+        }
+        return batchUpdatePinImages(pinImageInsertDtos);
+    }
+
+    private int[] batchUpdatePins(
+            Topic topicForCopy,
+            List<Pin> originalPins
+    ) {
+        LocalDateTime createdAt = topicForCopy.getLastPinUpdatedAt();
+
+        String bulkInsertSql = "INSERT INTO pin ("
+                + "name, description, member_id, topic_id, location_id,"
+                + " created_at, updated_at)"
+                + " VALUES ("
+                + " ?, ?, ?, ?, ?,"
+                + " ?, ?)";
+        log.debug("[Query] bulk insert size {} : {}", originalPins.size(), bulkInsertSql);
+
+        Long topicId = topicForCopy.getId();
+        Long creatorId = topicForCopy.getCreator().getId();
+
+        return jdbcTemplate.batchUpdate(bulkInsertSql, new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                Pin pin = originalPins.get(i);
+                ps.setString(1, pin.getName());
+                ps.setString(2, pin.getDescription());
+                ps.setLong(3, creatorId);
+                ps.setLong(4, topicId);
+                ps.setLong(5, pin.getLocation().getId());
+                ps.setTimestamp(6, Timestamp.valueOf(createdAt));
+                ps.setTimestamp(7, Timestamp.valueOf(createdAt));
+                log.trace("[Parameter Binding] {} : "
+                                + "name={}, description={}, member_id={}, topic_id={}, location_id={}, "
+                                + "created_at={}, updated_at={}",
+                        i, pin.getName(), pin.getDescription(), creatorId, topicId, pin.getLocation().getId(),
+                        createdAt, createdAt);
+            }
+
+            @Override
+            public int getBatchSize() {
+                return originalPins.size();
+            }
+        });
+    }
+
+    private void validateId(Long firstIdFromBatch) {
+        if (Objects.isNull(firstIdFromBatch)) {
+            throw new IllegalStateException("fail to batch update pins");
+        }
+    }
+
+    private List<PinImageInsertDto> createPinImageDTOsToBatch(
+            List<Pin> originalPins,
+            int[] rowCount,
+            Long firstIdFromBatch
+    ) {
+        return IntStream.range(0, originalPins.size())
+                .filter(index -> rowCount[index] != -3)
+                .mapToObj(index -> {
+                    Pin pin = originalPins.get(index);
+                    return PinImageInsertDto.of(pin.getPinImages(), firstIdFromBatch + index);
+                }).flatMap(Collection::stream)
+                .toList();
+    }
+
+    private int[] batchUpdatePinImages(List<PinImageInsertDto> pinImages) {
+        String bulkInsertSql = "INSERT INTO pin_image "
+                + "(image_url, pin_id) "
+                + "VALUES "
+                + "(?, ?)";
+        log.debug("[Query] bulk insert size {} : {}", pinImages.size(), bulkInsertSql);
+
+        return jdbcTemplate.batchUpdate(bulkInsertSql, new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                PinImageInsertDto pinImage = pinImages.get(i);
+                ps.setString(1, pinImage.getImageUrl());
+                ps.setLong(2, pinImage.getPinId());
+                log.trace("[Parameter Binding] {} : imageUrl={}, pinImage={} ",
+                        i, pinImage.getImageUrl(), pinImage.getPinId());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return pinImages.size();
+            }
+        });
+    }
+
+    private static class PinImageInsertDto {
+
+        private final String imageUrl;
+        private final Long pinId;
+        private final boolean isDeleted;
+
+        private PinImageInsertDto(String imageUrl, Long pinId, boolean isDeleted) {
+            this.imageUrl = imageUrl;
+            this.pinId = pinId;
+            this.isDeleted = isDeleted;
+        }
+
+        public static PinImageInsertDto of(PinImage pinImage, Long pinId) {
+            return new PinImageInsertDto(
+                    pinImage.getImageUrl(),
+                    pinId,
+                    pinImage.isDeleted()
+            );
+        }
+
+        private static List<PinImageInsertDto> of(List<PinImage> pinImages, Long pinId) {
+            return pinImages.stream()
+                    .map(pinImage -> PinImageInsertDto.of(pinImage, pinId))
+                    .toList();
+        }
+
+        public String getImageUrl() {
+            return imageUrl;
+        }
+
+        public Long getPinId() {
+            return pinId;
+        }
+
+        public boolean isDeleted() {
+            return isDeleted;
+        }
+    }
+
+}

backend/src/main/java/com/mapbefine/mapbefine/pin/domain/Pin.java

@@ -108,24 +108,6 @@ public void decreaseTopicPinCount() {
         topic.decreasePinCount();
     }
 
-    public void copyToTopic(Member creator, Topic topic) {
-        Pin copiedPin = Pin.createPinAssociatedWithLocationAndTopicAndMember(
-                pinInfo.getName(),
-                pinInfo.getDescription(),
-                location,
-                topic,
-                creator
-        );
-
-        copyPinImages(copiedPin);
-    }
-
-    private void copyPinImages(Pin pin) {
-        for (PinImage pinImage : pinImages) {
-            PinImage.createPinImageAssociatedWithPin(pinImage.getImageUrl(), pin);
-        }
-    }
-
     public void addPinImage(PinImage pinImage) {
         pinImages.add(pinImage);
     }
@@ -138,6 +120,10 @@ public double getLongitude() {
         return location.getLongitude();
     }
 
+    public String getName() {
+        return pinInfo.getName();
+    }
+
     public String getDescription() {
         return pinInfo.getDescription();
     }

backend/src/main/java/com/mapbefine/mapbefine/pin/domain/PinRepository.java

@@ -1,5 +1,6 @@
 package com.mapbefine.mapbefine.pin.domain;
 
+import com.mapbefine.mapbefine.common.repository.PinBatchRepositoryCustom;
 import java.util.List;
 import org.springframework.data.jpa.repository.EntityGraph;
 import org.springframework.data.jpa.repository.JpaRepository;
@@ -9,11 +10,14 @@
 import org.springframework.stereotype.Repository;
 
 @Repository
-public interface PinRepository extends JpaRepository<Pin, Long> {
+public interface PinRepository extends JpaRepository<Pin, Long>, PinBatchRepositoryCustom {
 
     @EntityGraph(attributePaths = {"location", "topic", "creator", "pinImages"})
     List<Pin> findAll();
 
+    @EntityGraph(attributePaths = {"location", "topic", "creator", "pinImages"})
+    List<Pin> findAllByIdIn(List<Long> pinIds);
+
     @EntityGraph(attributePaths = {"location", "topic", "creator", "pinImages"})
     List<Pin> findAllByTopicId(Long topicId);
 

backend/src/main/java/com/mapbefine/mapbefine/topic/application/TopicCommandService.java

@@ -22,6 +22,7 @@
 import com.mapbefine.mapbefine.topic.dto.request.TopicUpdateRequest;
 import com.mapbefine.mapbefine.topic.exception.TopicException.TopicBadRequestException;
 import com.mapbefine.mapbefine.topic.exception.TopicException.TopicForbiddenException;
+import java.time.LocalDateTime;
 import java.util.Collection;
 import java.util.List;
 import java.util.NoSuchElementException;
@@ -55,12 +56,12 @@ public Long saveTopic(AuthMember member, TopicCreateRequest request) {
         Topic topic = convertToTopic(member, request);
         List<Long> pinIds = request.pins();
 
+        topicRepository.save(topic);
+        topicRepository.flush();
         if (!pinIds.isEmpty()) {
             copyPinsToTopic(member, topic, pinIds);
         }
 
-        topicRepository.save(topic);
-
         return topic.getId();
     }
 
@@ -105,14 +106,15 @@ private void copyPinsToTopic(
     ) {
         List<Pin> originalPins = findAllPins(pinIds);
         validateCopyablePins(member, originalPins);
+        topic.increasePinCount(pinIds.size());
+        topic.updateLastPinUpdatedAt(LocalDateTime.now());
+        pinRepository.flush();
 
-        Member creator = findCreatorByAuthMember(member);
-
-        originalPins.forEach(pin -> pin.copyToTopic(creator, topic));
+        pinRepository.saveAllToTopic(topic, originalPins);
     }
 
     private List<Pin> findAllPins(List<Long> pinIds) {
-        List<Pin> findPins = pinRepository.findAllById(pinIds);
+        List<Pin> findPins = pinRepository.findAllByIdIn(pinIds);
 
         if (pinIds.size() != findPins.size()) {
             throw new PinBadRequestException(ILLEGAL_PIN_ID);
@@ -134,15 +136,14 @@ private void validateCopyablePins(AuthMember member, List<Pin> originalPins) {
     public Long merge(AuthMember member, TopicMergeRequest request) {
         Topic topic = convertToTopic(member, request);
         List<Topic> originalTopics = findAllTopics(request.topics());
-
         validateCopyableTopics(member, originalTopics);
-
-        Member creator = findCreatorByAuthMember(member);
         List<Pin> originalPins = getAllPinsFromTopics(originalTopics);
-        originalPins.forEach(pin -> pin.copyToTopic(creator, topic));
 
-        topicRepository.save(topic);
+        topic.increasePinCount(originalPins.size());
+        topic.updateLastPinUpdatedAt(LocalDateTime.now());
 
+        topicRepository.save(topic);
+        pinRepository.saveAllToTopic(topic, originalPins);
         return topic.getId();
     }
 

backend/src/main/java/com/mapbefine/mapbefine/topic/domain/Topic.java

@@ -152,6 +152,15 @@ public void removeImage() {
         this.topicInfo = topicInfo.removeImage();
     }
 
+    public void increasePinCount() {
+        pinCount++;
+    }
+
+
+    public void increasePinCount(int count) {
+        pinCount += count;
+    }
+
     public void decreasePinCount() {
         pinCount--;
     }

backend/src/test/java/com/mapbefine/mapbefine/TestDatabaseContainer.java

@@ -15,11 +15,15 @@ public abstract class TestDatabaseContainer {
 
     @DynamicPropertySource
     public static void overrideProps(DynamicPropertyRegistry registry) {
-        registry.add("spring.datasource.url", mySQLContainer::getJdbcUrl);
+        registry.add("spring.datasource.url", TestDatabaseContainer::getJdbcUrlWithQueryStrings);
         registry.add("spring.datasource.username", mySQLContainer::getUsername);
         registry.add("spring.datasource.password", mySQLContainer::getPassword);
         registry.add("spring.datasource.driver-class-name", mySQLContainer::getDriverClassName);
     }
 
+    private static String getJdbcUrlWithQueryStrings() {
+        return mySQLContainer.getJdbcUrl() + "?rewriteBatchedStatements=true";
+    }
+
 }
 

backend/src/test/java/com/mapbefine/mapbefine/pin/PinImageFixture.java

@@ -5,8 +5,10 @@
 
 public class PinImageFixture {
 
+    public static String IMAGE_URL = "https://example.com/image.jpg";
+
     public static PinImage create(Pin pin) {
-        return PinImage.createPinImageAssociatedWithPin("https://example.com/image.jpg", pin);
+        return PinImage.createPinImageAssociatedWithPin(IMAGE_URL, pin);
     }
 
 }