🐛 Fix: 메모리 오류 수정

Author: thelightway24

src/main/java/com/likelion/backendplus4/yakplus/drug/application/service/port/out/DrugDetailRepositoryPort.java

@@ -2,6 +2,9 @@
 
 import java.util.List;
 
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+
 import com.likelion.backendplus4.yakplus.drug.domain.model.DrugDetail;
 import com.likelion.backendplus4.yakplus.drug.infrastructure.persistence.dto.DrugDetailRequest;
 
@@ -38,4 +41,6 @@ public interface DrugDetailRepositoryPort {
 	 * @since 2025-04-21
 	 */
 	List<DrugDetail> getAllGovDrugDetail();
+
+	Page<DrugDetail> getGovDrugDetailByPage(Pageable pageable);
 }

src/main/java/com/likelion/backendplus4/yakplus/drug/application/service/scraper/combiner/DrugCombiner.java

@@ -2,6 +2,8 @@
 
 import java.util.List;
 
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
 import org.springframework.stereotype.Component;
 
 import static com.likelion.backendplus4.yakplus.common.util.log.LogUtil.log;
@@ -29,20 +31,33 @@ public class DrugCombiner implements DrugCombineUsecase {
 	private final DrugDetailRepositoryPort drugDetailRepository;
 	private final DrugImageRepositoryPort drugImageRepositoryPort;
 	private final DrugRawDataRepositoryPort	drugRawDataRepositoryPort;
-	
-	@Override
-	public void mergeTable(){
+
+	public void mergeTable() {
 		log("API 요청 결과 테이블 병합 시작: 상세 정보 + 이미지");
 
-		List<DrugDetail> drugDetails = drugDetailRepository.getAllGovDrugDetail();
-		log(LogLevel.DEBUG, "DrugDetail Raw Data: \n" + drugDetails);
+		int pageSize = 1_000;
+		Page<DrugDetail> firstPage = drugDetailRepository.getGovDrugDetailByPage(PageRequest.of(0, pageSize));
+		int totalPages = firstPage.getTotalPages();
+
+		processDrugDetails(firstPage.getContent(), 1);
+
+		for (int i = 1; i < totalPages; i++) {
+			Page<DrugDetail> page = drugDetailRepository.getGovDrugDetailByPage(PageRequest.of(i, pageSize));
+			processDrugDetails(page.getContent(), i + 1);
+		}
 
-		drugDetails.stream()
-			.map(detail -> buildMergeRawData(detail, getImageDataByDrugDetail(detail)))
-			.forEach(drugRawDataRepositoryPort::save);
 		log("API 요청 결과 테이블 병합 완료");
 	}
 
+	private void processDrugDetails(List<DrugDetail> drugDetails, int pageNumber) {
+		log("Processing Page = " + pageNumber);
+		log(LogLevel.DEBUG, "DrugDetail Raw Data (Page " + pageNumber + "): \n" + drugDetails);
+
+		List<DrugRawData> rawData = drugDetails.stream()
+			.map(detail -> buildMergeRawData(detail, getImageDataByDrugDetail(detail))).toList();
+		drugRawDataRepositoryPort.saveAll(rawData);
+	}
+
 	/**
 	 * 주어진 의약품 상세 정보에 해당하는 이미지 정보를 조회합니다.
 	 *

src/main/java/com/likelion/backendplus4/yakplus/drug/infrastructure/persistence/adapter/out/DrugDetailRepositoryAdapter.java

@@ -3,6 +3,8 @@
 import java.util.List;
 import java.util.stream.Collectors;
 
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
 import org.springframework.stereotype.Component;
 
 import com.likelion.backendplus4.yakplus.drug.application.service.port.out.DrugDetailRepositoryPort;
@@ -38,4 +40,10 @@ public List<DrugDetail> getAllGovDrugDetail(){
 			.map(DrugDetailMapper::toDomainFromEntity)
 			.collect(Collectors.toList());
 	}
+
+	@Override
+	public Page<DrugDetail> getGovDrugDetailByPage(Pageable pageable) {
+		return drugdetailJpaRepository.findAll(pageable)
+			.map(DrugDetailMapper::toDomainFromEntity);
+	}
 }

src/main/java/com/likelion/backendplus4/yakplus/drug/infrastructure/persistence/adapter/out/DrugRawDataRepositoryAdapter.java

@@ -10,6 +10,7 @@
 import com.likelion.backendplus4.yakplus.drug.infrastructure.persistence.repository.jpa.GovDrugJpaRepository;
 import com.likelion.backendplus4.yakplus.drug.infrastructure.support.mapper.DrugRawDataMapper;
 
+import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
 
 @Component
@@ -18,12 +19,14 @@ public class DrugRawDataRepositoryAdapter implements DrugRawDataRepositoryPort {
 
 	private final GovDrugJpaRepository jpaDrugRepository;
 
+	@Transactional
 	@Override
 	public void save(DrugRawData drug){
 		DrugRawDataEntity entity = DrugRawDataMapper.toEntityFromDomain(drug);
 		jpaDrugRepository.save(entity);
 	}
 
+	@Transactional
 	@Override
 	public void saveAll(List<DrugRawData> rawData) {
 		jpaDrugRepository.saveAll(