Switch to pure R2DBC

build.gradle

@@ -25,7 +25,7 @@ dependencies {
 	compileOnly 'org.projectlombok:lombok'
 	annotationProcessor 'org.projectlombok:lombok'
 
-	implementation 'org.springframework.boot:spring-boot-starter-data-r2dbc'
+	implementation 'org.springframework.data:spring-data-r2dbc'
 	implementation 'org.springframework.boot:spring-boot-starter-webflux'
 
 	developmentOnly 'org.springframework.boot:spring-boot-devtools'

src/main/java/com/example/demo/Book.java

@@ -1,13 +1,11 @@
 package com.example.demo;
 
 import lombok.Data;
-import org.springframework.data.annotation.Id;
 
 @Data
 public class Book {
 
-	@Id
-    private final Long id;
+    private final Integer id;
  	private final String title;
 
 }

src/main/java/com/example/demo/DemoApplication.java

@@ -10,7 +10,7 @@
 import org.springframework.boot.autoconfigure.web.reactive.error.ErrorWebFluxAutoConfiguration;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.context.support.GenericApplicationContext;
-import org.springframework.data.r2dbc.repository.config.EnableR2dbcRepositories;
+import org.springframework.r2dbc.core.DatabaseClient;
 import org.springframework.web.reactive.function.server.RouterFunction;
 import org.springframework.web.reactive.function.server.ServerResponse;
 
@@ -19,7 +19,6 @@
 import org.springframework.r2dbc.connection.init.ConnectionFactoryInitializer;
 import org.springframework.r2dbc.connection.init.ResourceDatabasePopulator;
 
-@EnableR2dbcRepositories
 public class DemoApplication {
 
     private final static Class[] autoConfigurationClasses = {ReactiveWebServerFactoryAutoConfiguration.class,
@@ -49,12 +48,14 @@ public static SpringApplication buildApp() {
                     });
 
                     applicationContext.registerBean(RouterFunction.class, () -> {
-                        var repo = applicationContext.getBean(BookRepository.class);
+                        var repo = applicationContext.getBean(DatabaseClient.class);
                         return route()
                                 .GET("/book", request -> {
                                     var lang = request.queryParam("lang").orElse("");
                                     var translatedBooks = repo
-                                            .findAll()
+                                            .sql("select * from book")
+                                            .map(row -> new Book(row.get("id", Integer.class), row.get("title", String.class)))
+                                            .all()
                                             .map(book -> new Book(
                                                     book.getId(),
                                                     translationService.translateTitle(lang, book.getTitle())

src/main/java/com/example/demo/TranslationService.java

@@ -1,9 +1,5 @@
 package com.example.demo;
 
-import org.springframework.stereotype.Component;
-import reactor.core.publisher.Mono;
-
-@Component
 public class TranslationService {
 
 	String translateTitle(String lang, String title) {