[실습] MySQL에 데이터 삽입/삭제 시 Elasticsearch에도 같이 반영되게 만들기

JSCODE 박재성

2026. 04. 04.

✅ MySQL에 데이터 삽입/삭제 시 Elasticsearch에도 같이 반영되게 만들기

1. ProductDocumentRepository 의존성 추가
ProductService

@Service
public class ProductService {

  private final ProductRepository productRepository;
  private final ProductDocumentRepository productDocumentRepository;
  
  public ProductService(ProductRepository productRepository,
      ProductDocumentRepository productDocumentRepository) {
    this.productRepository = productRepository;
    this.productDocumentRepository = productDocumentRepository;
  }
  

 

2. 상품 등록 로직 수정하기
ProductService

public Product createProduct(CreateProductRequestDto createProductRequestDto) {
	  Product product = new Product(
	      createProductRequestDto.getName(),
	      createProductRequestDto.getDescription(),
	      createProductRequestDto.getPrice(),
	      createProductRequestDto.getRating(),
	      createProductRequestDto.getCategory()
	  );
	  Product savedProduct = productRepository.save(product);
	
	  ProductDocument productDocument = new ProductDocument(
	      savedProduct.getId().toString(),
	      savedProduct.getName(),
	      savedProduct.getDescription(),
	      savedProduct.getPrice(),
	      savedProduct.getRating(),
	      savedProduct.getCategory()
	  );
	  
	  productDocumentRepository.save(productDocument);
	  
	  return savedProduct;
}

 

3. 상품 삭제 로직 수정하기

 public void deleteProduct(Long id) {
	  productRepository.deleteById(id);
	  
	  productDocumentRepository.deleteById(id.toString());
}

✅ 잘 작동하는 지 테스트해보기

1. 기존 MySQL 테이블 삭제하기

2. Kibana에서 Elasticsearch 인덱스 삭제하기

DELETE /products

 

2. Spring Boot 서버 실행시키기
Spring Data JPA와 Spring Data Elasticsearch에 의해 Spring Boot 프로젝트에서 정의한 객체에 맞게 MySQL에 테이블이 생성되고, Elasticsearch에 인덱스가 생성됐을 것이다.
 

3. Postman으로 데이터 넣어보기
localhost:8080/products

{
  "name": "삼성 갤럭시 S25",
  "description": "<h2>최신 스마트폰</h2><p>AI 기능과 강력한 배터리를 갖춘 프리미엄 스마트폰입니다.</p>",
  "price": 1290000,
  "rating": 4.8,
  "category": "ELECTRONICS"
}



 

4. 데이터 잘 들어갔는 지 확인하기
MySQL (Datagrip)



 
Elasticsearch (Kibana)



 

7. Postman으로 데이터 삭제해보기

7. 데이터 잘 삭제됐는 지 확인하기
MySQL (Datagrip)



 
Elasticsearch (Kibana)