[ERR] r2dbcRepository.save()가 안돼...

개발환경

OS: Windows 11
IDE: IntellJ IDEA 2022.2.4 (Ultimate Edition)
Java: 1.8

Framework: Springframework.boot version: 2.4.3
Dependencies:

implementation "org.springframework.boot:spring-boot-starter-data-r2dbc"
implementation 'dev.miku:r2dbc-mysql:0.8.2.RELEASE'
implementation group: 'javax.persistence', name: 'javax.persistence-api', version: '2.2'

...

---

상황

• R2dbcRepository 상속 후 save(Entity) 실행했으나 오류는 안 나지만 insert나 update 반영이 안되어있음.

기존 코드

FruitRepository.java

public interface FruitRepository extends R2dbcRepository<FruitEntity, String> {

    // 커스텀 메소드 생성 예시
    // Mono나 Flux 타입으로 받아야 함.
    Mono<FruitEntity> findByName(String name);
    Mono<Void> deleteByName(String name);

}

@service FruitClient.java

fruitRepository.save(fruitEntity);

---

해결

이렇게 실행하면 오류는 안 나는데 insert나 update 반영이 안되어있음.
→ subscribe()를 붙이면 된다.

fruitRepository.save(fruitEntity).subscribe();

---

참고

• Save in ReactiveCrudRepository not inserting or updating records