Spring Data and R2DBC by Example
Take a look at this tutorial that show you how use R2DBC in a Spring project.
By
·
·
Tutorial
Likes
(1)
Likes
There are no likes...yet! 👀
Be the first to like this post!
It looks like you're not logged in.
Sign in to see who liked this post!
Comment
Save
10.8K Views
Join the DZone community and get the full member experience.
Join For FreeR2DBC is a project that enables us to develop reactive programs API with relational databases, as we can do with databases that natively offer reactive drivers, like for example, Mongo or Cassandra.
Spring Data R2DBC is an abstraction of Spring to use repositories that support R2DBC and allows us a functional approach to interact with a relational database.
I use the following:
- Gradle 6.7.1
- Scala 2.12.6 ( I like this language :) )
- JDK 15
- Intellij IDEA
- Spring Boot 2.4.4
The project structure is:
The Gradle file contains:
Groovy
xxxxxxxxxx
1
42
1
plugins {
2
id 'org.springframework.boot' version '2.4.4'
3
id 'io.spring.dependency-management' version '1.0.11.RELEASE'
4
id 'java'
5
id 'scala'
6
}
7
8
group 'org.mazp.admin'
9
version '1.0-SNAPSHOT'
10
11
repositories {
12
mavenCentral()
13
maven { url 'https://repo.spring.io/milestone' }
14
maven { url 'https://repo.spring.io/snapshot' }
15
}
16
17
dependencies {
18
testImplementation 'org.junit.jupiter:junit-jupiter-api:5.7.0'
19
testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.7.0'
20
21
implementation 'org.scala-lang:scala-library:2.12.6'
22
testImplementation 'org.scalatest:scalatest_2.12:3.2.3'
23
testImplementation 'org.scala-lang:scala-library:2.12.6'
24
25
implementation 'org.springframework.boot:spring-boot-starter-webflux'
26
implementation 'org.springframework.boot:spring-boot-starter-data-r2dbc'
27
28
implementation 'dev.miku:r2dbc-mysql'
29
implementation 'mysql:mysql-connector-java'
30
31
}
32
33
test { useJUnitPlatform() }
34
35
sourceSets {
36
main { scala { srcDirs = ['src/main/scala'] } }
37
test { scala { srcDirs = ['src/test/scala'] } }
38
}
39
40
springBoot {
41
mainClass = 'com.mazp.admin.Main'
42
}
The properties files is:
Properties files
x
1
spring.r2dbc.url=r2dbc:mysql://localhost:3306/admin_r2dbc
2
spring.r2dbc.username=user_mysql
3
spring.r2dbc.password=password_user_mysql
The next class is used to map a row with an object:
Scala
xxxxxxxxxx
1
22
1
package com.mazp.admin.model
2
3
import org.springframework.data.annotation.Id
4
import org.springframework.data.relational.core.mapping.Table
5
6
("admin")
7
class AdminObject {
8
private var idAdmin:Integer = null
9
10
private var adminCode:String = null
11
private var description:String = null
12
13
def getDescription() = description
14
def setDescription(usr:String) = this.description = usr
15
16
def getAdminCode() = adminCode
17
def setAdminCode(ctId:String) = adminCode = ctId
18
19
def getIdAdmin() = idAdmin
20
def setIdAdmin(ctId:Integer) = idAdmin = ctId
21
}
22
The repository is:
Scala
xxxxxxxxxx
1
16
1
package com.mazp.admin.respository
2
3
import com.mazp.admin.model.AdminObject
4
import org.springframework.data.repository.reactive.ReactiveCrudRepository
5
import reactor.core.publisher.Flux
6
7
trait AdminRepository extends ReactiveCrudRepository[AdminObject, Integer ]{
8
9
/**
10
* This method uses the convention name
11
* @param adminCode
12
* @return
13
*/
14
def findByAdminCode(adminCode:String):Flux[AdminObject]
15
}
The service class is:
Scala
xxxxxxxxxx
1
13
1
package com.mazp.admin.service
2
3
import com.mazp.admin.respository.AdminRepository
4
import org.springframework.beans.factory.annotation.Autowired
5
import org.springframework.stereotype.Service
6
7
8
class AdminService ( val adminRepository: AdminRepository) {
9
10
def getAdmin(adminCode:String) =
11
adminRepository.findByAdminCode(adminCode)
12
13
}
The controller class is:
Scala
xxxxxxxxxx
1
17
1
package com.mazp.admin.controller
2
3
import com.mazp.admin.service.AdminService
4
import org.springframework.beans.factory.annotation.Autowired
5
import org.springframework.web.bind.annotation.{GetMapping, PathVariable, RequestMapping, RestControllerAdvice}
6
7
8
9
(Array("/admin"))
10
class AdminController( val adminService: AdminService) {
11
12
(Array("/{adminCode}"))
13
def route( adminCode: String) = {
14
adminService.getAdmin(adminCode)
15
}
16
17
}
The main class:
Scala
xxxxxxxxxx
1
12
1
package com.mazp.admin
2
3
import org.springframework.boot.SpringApplication
4
import org.springframework.boot.autoconfigure.{SpringBootApplication}
5
6
7
class Main
8
9
object Main extends App{
10
SpringApplication.run(classOf[Main], args:_*)
11
}
The table admin is:
MySQL
xxxxxxxxxx
1
10
1
CREATE TABLE `admin` (
2
`id_admin` int NOT NULL AUTO_INCREMENT,
3
`admin_code` varchar(45) NOT NULL,
4
`description` varchar(45) DEFAULT NULL,
5
PRIMARY KEY (`id_admin`),
6
UNIQUE KEY `admin_code_UNIQUE` (`admin_code`)
7
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
8
9
INSERT INTO `admin_r2dbc`.`admin`(`admin_code`,`description`)
10
VALUES('ADMIN','Esto es para prueba R2DBC');
When you run the project, you can call:
Now, we use the curl command to test the service:
Spring Framework
Spring Data
Data (computing)
Opinions expressed by DZone contributors are their own.
Comments