[Spring] MySQL과 mongoDB 데이터베이스 2개 연동하기

🧐 상황

 

현재 운영중인 Hous- (하우스) 공동생활 도우미 서비스에서 기존에는 MySQL만을 사용하고 있었습니다.

하지만 불필요하게 쌓이는 오래된 알림 데이터를 지우기 위한 방법을 고민해야했습니다.

가난한 대학생이기 때문에.. 사용자가 약 200명 정도에 불과한데 잘 보지도 않는 알림 데이터가 10,000개 이상 쌓이니..

이렇게 계속 필요없는 데이터가 쌓이다 보면 AWS 프리티어 기준을 초과할까봐 겁이났거든요 🥲

 

서버 파트 팀원과 논의를 통해

1. Spring Batch를 활용하는 방법

2. 스케줄러를 사용해 오래된 데이터를 지우는 방법

3. 그리고 mongoDB를 도입하는 방법을 고민했습니다.

 

mongoDB에서는 TTL index를 지원하여 데이터의 유효기간을 설정해서 오래된 데이터는 별도의 처리 없이 자동으로 지워지게 할 수 있거든요!

 

Spring Batch를 활용하기에는 데이터의 양이 너무 적어서 오버스펙이라고 판단했고,

스케줄러를 활용하는 방안은 서버에 불필요한 부하를 줄 수 있다고 생각했습니다.

 

또한 mongoDB를 이번 기회에 도입한다면, NoSQL이 더 적합한 도메인들은 이후에 전환을 해서 성능을 더 높일 수 있다고 판단했습니다!

그래서 저희는 mongoDB를 기존에 사용하던 MySQL과 함께 사용하기로 결정했습니다.

 

 

🛠 코드

 

⭐️ 1. build.gradle 수정

 

mongoDB 도입을 위해서는 첫번째로 build.gradle 에 mongoDB 를 추가해줍니다.

 

dependencies {
		// ...
    runtimeOnly "mysql:mysql-connector-java"
    implementation "org.springframework.boot:spring-boot-starter-data-jpa"
    implementation "org.springframework.boot:spring-boot-starter-data-mongodb"
}

 

가장 아랫줄이 mongoDB를 추가한 부분입니다.

 

 

⭐️ 2. Document 추가

 

MySQL을 사용할 때 @Entity 와 비슷한 역할을 하는 것이 @Document 입니다.

@Column 과 비슷한 역할을 하는 것은 @Field 입니다.

 

@Document(collection = "notification")
public class Notification {

	@Id
	private String id;

	@Field(name = "type")
	private String type;

	@Field(name = "content")
	private String content;

	@Field(name = "is_read")
	private boolean isRead;
}

 

다음과 같이 Document 를 생성할 수 있습니다.

주의할 점으로는 mongoDB 의 경우, id 를 String, ObjectId, BigInteger 중 하나로 사용해야 한다는 것입니다!

 

 

⭐️ 3. Repository 추가

 

mongoDB의 경우, JpaRepository 대신 MongoRepository 를 사용합니다.

 

public interface NotificationRepository extends MongoRepository<Notification, String> {

}

 

 

⭐️ 4. Config 파일 추가

 

Jpa 설정 파일

@Configuration
@EnableJpaAuditing
@EnableJpaRepositories(basePackages = "hous.core.domain.*.mysql")
public class JpaConfig {
}

 

mongoDB 설정 파일

@Configuration
@RequiredArgsConstructor
@EnableMongoAuditing
@EnableMongoRepositories(basePackages = "hous.core.domain.*.mongo")
public class MongoDbConfig {

	private final MongoMappingContext mongoMappingContext;

	@Bean
	public MappingMongoConverter mappingMongoConverter(MongoDatabaseFactory mongoDatabaseFactory,
		MongoMappingContext mongoMappingContext) {
		DbRefResolver dbRefResolver = new DefaultDbRefResolver(mongoDatabaseFactory);
		MappingMongoConverter converter = new MappingMongoConverter(dbRefResolver, mongoMappingContext);
		converter.setTypeMapper(new DefaultMongoTypeMapper(null));
		return converter;
	}
}

 

여기서 주의 깊게 봐야할 부분은

 

• @EnableJpaRepositories(basePackages = "hous.core.domain.*.mysql")

• @EnableMongoRepositories(basePackages = "hous.core.domain.*.mongo")

 

두 어노테이션입니다.

 

basePackages 를 자세히 보면

JpaRepository 의 경우 mysql 패키지로 설정되어있고,

MongoRepository 의 경우 mongo 패키지로 설정되어있습니다.

 

해당 설정을 통해 Spring 은 각각의 repository 들을

Jpa 설정을 기준으로 Bean 을 등록할지, mongoDB 설정 기준으로 Bean 을 등록할지 구분 할 수 있게 됩니다!

 

패키지 구조는 다음과 같습니다.

 

 

MappingMongoConverter 는 부가적인 설정입니다.

해당 설정 없이 실행하면 _class 가 자동으로 생성되기 때문에 그걸 방지하기 위한 설정입니다.

(궁금하신 분들은 설정을 지우고 Document 를 하나 생성해보세요!)

 

 

⭐️ 5. yml 파일 수정

 

마지막으로 mongoDB 에 연결하기 위한 정보를 추가해주면 됩니다.

 

application.yml

spring:

  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: MySQL url
    username: 유저네임
    password: 패스워드

  data:
    mongodb:
      uri: mongoDB uri

 

다음과 같이 설정하면 끝입니다! 🤩