Spring Data 관련 클래스 정리

1. Spring Data 란?

Spring 프레임워크의 하위 프로젝트 중 하나로 모델을 기반으로 다양한 데이터 접근 기술을 지원한다. 

Repository 인터페이스를 통해 객체 매핑을 추상화 형태로 지원하기 때문에 좀 더 쉽게 데이터에 접근 및 사용이 가능하다.

 

Main Module

• Spring Data Commons : 모든 Spring Module을 뒷받침하는 핵심 Spring 개념
  • CrudRepository, PagingAndSortingRepository
• Spring Data JDBC : spring-jdbc에 대한 Spring Data 추상화를 제공하는 모듈
  • CrudRepository를 구현하는 SimpleJdbcRepository 클래스
• Spring Data JPA : JPA를 위한 스프링 데이터 저장소 지원
  • JpaRepository 인터페이스, SimpleJpaRepository 클래스
• Spring Data R2dbc : R2dbc 를 위한 스프링 데이터 저장소 지원
  • R2dbcRepository 인터페이스, SimpleR2dbcRepository 클래스
• Spring Data REST
• Spring Data Redis
• Spring Data MongoDB
• ... 

등 다양한 모듈을 지원한다.

그 외의 모듈은 아래 공식 문서를 통해 확인이 가능하다.

https://spring.io/projects/spring-data#overview

Spring Data

 

 

Spring 은 개발자가 사용하기 쉬운 형태로 Repository를 인터페이스 형태로 추상화하여 제공한다. 

이렇게 사용할 수 있도록 도와주는 대표적인 클래스들을 몇 개 알아보고자 한다.

 

 

2. RepositoryFactorySupport 추상 클래스

- 주어진 Repository 인터페이스의 실제 프록시 인스턴스를 생성

- 이 추상 클래스를 확장하여 다양한 spring-data-xxx 에서 Repository를 생성

- getRepository 함수에서 애플리케이션에 구현한 repository 인터페이스를 인자로 받아 내부적으로 proxy 를 생성하고 인스턴스를 반환

      

      

      

    
    

      <kotlin />
    
public abstract class RepositoryFactorySupport implements BeanClassLoaderAware, BeanFactoryAware {

	public <T> T getRepository(Class<T> repositoryInterface, RepositoryFragments fragments) {

		... (생략)

		Object target = getTargetRepository(information);

		// Create proxy (프록시 인스턴스 생성)
		ProxyFactory result = new ProxyFactory();
		result.setTarget(target);
		result.setInterfaces(repositoryInterface, Repository.class, TransactionalProxy.class);

		if (MethodInvocationValidator.supports(repositoryInterface)) {
			result.addAdvice(new MethodInvocationValidator());
		}

		result.addAdvisor(ExposeInvocationInterceptor.ADVISOR);

		postProcessors.forEach(processor -> processor.postProcess(result, information));

		if (DefaultMethodInvokingMethodInterceptor.hasDefaultMethods(repositoryInterface)) {
			result.addAdvice(new DefaultMethodInvokingMethodInterceptor());
		}

		ProjectionFactory projectionFactory = getProjectionFactory(classLoader, beanFactory);
		Optional<QueryLookupStrategy> queryLookupStrategy = getQueryLookupStrategy(queryLookupStrategyKey,
				evaluationContextProvider);
		result.addAdvice(new QueryExecutorMethodInterceptor(information, projectionFactory, queryLookupStrategy,
				namedQueries, queryPostProcessors));

		composition = composition.append(RepositoryFragment.implemented(target));
		result.addAdvice(new ImplementationMethodExecutionInterceptor(composition));

		T repository = (T) result.getProxy(classLoader);

	... (생략)
    
		return repository;
	}

 

RepositoryFactorySupport 상속 클래스 예시

 

JpaRepositoryFactory

- 내부적으로 SimpleJpaRepository(구현체) 반환

      

      

      

    
    

      <java />
    
@Override
	protected Class<?> getRepositoryBaseClass(RepositoryMetadata metadata) {
		return SimpleJpaRepository.class;
	}

- JpaRepositoryFactoryBean 클래스를 통해 RepositoryFactory 객체 생성 및 entityManager 주입 (RepositoryFactoryBeanSupport 인터페이스를 구현해 Factory 커스텀도 가능하다.)

 

 

R2dbcRepositoryFactory

- 내부적으로 SimpleR2dbcRepository(구현체) 반환

      

      

      

    
    

      <java />
    
@Override
	protected Class<?> getRepositoryBaseClass(RepositoryMetadata metadata) {
		return SimpleR2dbcRepository.class;
	}

 

 

3. Repository 커스텀하기

1. RepositoryFactorySupport 하위 커스텀 Factory 클래스 구현

2. RepositoryFactoryBeanSupport 의 하위 인터페이스들이 존재. 

    - 해당 Bean을 상속받아 getFactoryInstance를 오버라이드하여 RepositoryFactory 를 변경해줄 수 있다.

    ex) JPARepositoryFactoryBean, R2dbcRepositoryFactoryBean ..

3. RepositoryFactoryBeanSupport 클래스 또는 하위 클래스 상속받아 구체적인 프록시 인스턴스 생성

4. getFactoryInstance 함수에 커스텀한 Factory 클래스를 반환

      

      

      

    
    

      <kotlin />
    
class CustomRepositoryFactoryBean<T : Repository<S, ID>, S, ID : Serializable>(
    repositoryInterface: Class<T>
) : R2dbcRepositoryFactoryBean<T, S, ID>(repositoryInterface) {

    override fun setMappingContext(mappingContext: MappingContext<*, *>) {
        super.setMappingContext(mappingContext)
    }

    override fun getFactoryInstance(operations: R2dbcEntityOperations): RepositoryFactorySupport {
        return CustomRepositoryFactory(operations)
    }
}

/*
* Ex) R2dbcRepository를 커스텀했다면
*/
class CustomRepositoryFactory(
    operations: R2dbcEntityOperations
) : R2dbcRepositoryFactory(operations) {

    override fun getRepositoryBaseClass(metadata: RepositoryMetadata): Class<*> {
    	// 커스텀한 Repository 구현체 (런타임에 동적으로 실행될 Repository 구현체)
        return R2dbcCoroutineRepository::class.java
    }
}

 

 

참고

https://imbf.github.io/spring/2020/04/30/Spring-Data.html

https://brunch.co.kr/@anonymdevoo/40