스프링 데이터 R2DBC

1. R2DBC

1-1. R2DBC 이전

• 전통적인 방식의 JDBC(Java Database Connectivity) 드라이버는 하나의 커넥션에 하나의 스레드를 사용하는 Thread per Connection 방식

String selectSql = "SELECT * FROM employees";

try (ResultSet resultSet = stmt.executeQuery(selectSql)) {
  List<Employee> employees = new ArrayList<>();
  
  while (resultSet.next()) {
    Employee emp = new Employee();
    emp.setId(resultSet.getInt("emp_id"));
    emp.setName(resultSet.getString("name"));
    emp.setPosition(resultSet.getString("position"));
    emp.setSalary(resultSet.getDouble("salary"));
    employees.add(emp);
  }
}

• Thread Per Connection 방식은 데이터베이스로부터 응답을 받기 전까지 스레드는 블로킹 됨
• 높은 처리량과 대규모 애플리케이션을 위해 비동기-논블로킹 데이터베이스 API에 대한 요구가 생김
• 애플리케이션 로직이 비동기-논블로킹 이더라도 DB 드라이버가 JDBC라면 필연적으로 블로킹이 발생하므로 100% 비동기-논블로킹의 성능을 내기 어려웠음
• 오라클의 ADBA(Asynchronous Database Access API) 프로젝트가 표준화 진행 중 지원 종료 됨

 

1-2. R2DBC

• R2DBC(Reactive Relational Database Connectivity)는 빠르게 성장 중인 리액티브 기반의 비동기-논블로킹 데이터베이스 드라이버
• 다양한 데이터베이스를 지원한다.
  • Oracle, Postgresql, H2, MSSQL, Google Spanner, MariaDB 등
• 리액티브 스트림 구현체인 Project Reactor, RxJava등을 지원한다.

connection.createStatement("SELECT * FROM employees")
  .execute()
  .flatMap(r -> r.map((row, metadata) -> {
    Employee emp = new Employee();
    emp.setId(row.get("emp_id", Integer.class));
    emp.setName(row.get("name", String.class));
    emp.setPosition(row.get("position", String.class));
    emp.setSalary(row.get("salary", Double.class));
    return emp;
  }))
  .close()
  .subscribe();

 

2. 스프링 데이터 R2DBC

• 스프링 데이터 R2DBC는 R2DBC 기반의 스프링 데이터 프로젝트이다.
• 스프링 애플리케이션에 쉽게 통합할 수 있으며 스프링 데이터 JPA, 스프링 데이터 몽고 DB같은 프로젝트처럼 뛰어난 추상화를 제공한다.
• 스프링 WebFlux와 스프링 데이터 R2DBC를 같이 사용하면 전 구간 비동기-논블로킹 애플리케이션을 구현할 수 있다.
• 많은 ORM에서 제공하는 LazyLoading, Dirth-Checking, Cache 등을 지원하지 않으므로 ORM으로써의 기능은 적지만 오히려 더 심플하게 사용할 수 있다.

 

2-1. ReactiveCrudRepository 살펴보기

• ReactiveCrudRepository는 리액티브를 지원하는 CRUD 인터페이스이다.

public interface ReactiveCrudRepository<T, ID> extends Repository<T, Id> {
  <S extends T> Mono<S> save(S entity);
  
  <S extends T> Flux<S> saveAll(Iterable<S> entities);
  
  <S extends T> Flux<S> saveAll(Publisher<S> entityStream);
  
  Mono<T> findById(ID id);
  
  Mono<T> findById(Publisher<ID> id);
  
  Mono<Boolean> existsById(ID id);
  
  Mono<Boolean> existsById(Publisher<ID> id);
  
  Flux<T> findAll();
  
  Flux<T> findAllById(Iterable<ID> ids);
  
  Flux<T> findAllById(Publisher<ID> idStream);
  
  Mono<Long> count();
  
  Mono<Void> deleteById(ID id);
  
  Mono<Void> deleteById(Publisher<ID> id);
  
  Mono<Void> delete(T entity);
  
  Mono<Void> deleteAllById(Iterable<? extends ID> ids);
  
  Mono<Void> deleteAll(Iterable<? extends T> entities);
}

 

Reference

• https://fastcampus.co.kr/dev_online_kopring