如何在Spring data中使用r2dbc詳解
前言
上篇文章我們講到了怎么在Spring webFlux中使用r2dbc,今天我們看一下怎么使用spring-data-r2dbc這個(gè)Spring data對(duì)r2dbc的封裝來進(jìn)行r2dbc操作。
依賴關(guān)系
要使用Spring-datea-r2dbc需要配置下面的依賴關(guān)系：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-r2dbc</artifactId>
<version>2.3.3.RELEASE</version>
</dependency>
<!-- R2DBC H2 Driver -->
<dependency>
<groupId>io.r2dbc</groupId>
<artifactId>r2dbc-h2</artifactId>
<version>${r2dbc-h2.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
數(shù)據(jù)庫連接配置
Spring-data-r2dbc使用的是R2dbcProperties來進(jìn)行配置文件的讀取：
簡單看一下R2dbcProperties的定義：
@ConfigurationProperties(prefix = "spring.r2dbc")
public class R2dbcProperties {
/**
* Database name. Set if no name is specified in the url. Default to "testdb" when
* using an embedded database.
*/
private String name;
/**
* Whether to generate a random database name. Ignore any configured name when
* enabled.
*/
private boolean generateUniqueName;
/**
* R2DBC URL of the database. database name, username, password and pooling options
* specified in the url take precedence over individual options.
*/
private String url;
/**
* Login username of the database. Set if no username is specified in the url.
*/
private String username;
/**
* Login password of the database. Set if no password is specified in the url.
*/
private String password;
相應(yīng)的，看一下我們的配置文件是怎么樣的：
spring.r2dbc.url=r2dbc:h2:mem://./testdb spring.r2dbc.username=sa spring.r2dbc.password=password
這里，我們使用的是H2數(shù)據(jù)庫。
數(shù)據(jù)庫初始化
數(shù)據(jù)庫初始化過程中，我們需要?jiǎng)?chuàng)建一個(gè)users表格，這里我們?cè)谝粋€(gè)initDatabase bean中實(shí)現(xiàn)：
@Bean
public ApplicationRunner initDatabase(DatabaseClient client, UsersDao usersDao) {
List<String> statements = Arrays.asList(
"DROP TABLE IF EXISTS USERS;",
"CREATE TABLE IF NOT EXISTS USERS ( id SERIAL PRIMARY KEY, firstname VARCHAR(100) NOT NULL, lastname VARCHAR(100) NOT NULL);");
statements.forEach(sql -> executeSql(client,sql)
.doOnSuccess(count -> log.info("Schema created, rows updated: {}", count))
.doOnError(error -> log.error("got error : {}",error.getMessage(),error))
.subscribe()
);
return args ->getUser().flatMap(usersDao::save).subscribe(user -> log.info("User saved: {}", user));
}
private Flux<Users> getUser() {
return Flux.just(new Users(null, "John", "Doe"), new Users(null, "Jane", "Doe"));
}
private Mono<Integer> executeSql(DatabaseClient client, String sql) {
return client.execute(sql).fetch().rowsUpdated();
}
上面的例子中，我們創(chuàng)建數(shù)據(jù)庫分為了兩部分，第一部分是數(shù)據(jù)庫schema的操作，我們執(zhí)行了drop和create table的操作。
第二部分是向數(shù)據(jù)庫表中插入數(shù)據(jù)。
注意，上面的兩部分操作都需要執(zhí)行subscribe操作，以觸發(fā)真正的Reactive操作。
DAO操作
在DAO操作之前，我們需要?jiǎng)?chuàng)建Users entity：
@Data
@AllArgsConstructor
public class Users {
@Id
private Integer id;
private String firstname;
private String lastname;
boolean hasId() {
return id != null;
}
}
再看一下我們創(chuàng)建的UserDao：
public interface UsersDao extends ReactiveCrudRepository<Users, Long> {
@Query("select id, firstname, lastname from users c where c.lastname = :lastname")
Flux<Users> findByLastname(String lastname);
}
注意，這里并不需要添加@Component注解，因?yàn)槲覀兝^承了ReactiveCrudRepository，會(huì)自動(dòng)幫我們創(chuàng)建UsersDao的實(shí)例，我們直接使用就可以了。
ReactiveCrudRepository為我們封裝了一些DAO的基本操作，比如save，saveAll, findById ,existsById等基礎(chǔ)操作。
當(dāng)然，我們也可以自定義自己的SQL語句，比如上面的findByLastname。
Service操作和Transaction
我們看一下怎么使用UserDao來進(jìn)行具體的方法操作：
@Component
public class UsersService {
@Resource
private UsersDao usersDao;
@Transactional
public Mono<Users> save(Users user) {
return usersDao.save(user).map(it -> {
if (it.getFirstname().equals("flydean")) {
throw new IllegalStateException();
} else {
return it;
}
});
}
}
上面我們創(chuàng)建了一個(gè)save方法，用來保存相應(yīng)的User對(duì)象。
controller
最后，我們創(chuàng)建一個(gè)controller來對(duì)外暴露相應(yīng)的方法：
@RestController
@RequiredArgsConstructor
public class UsersController {
private final UsersDao usersDao;
@GetMapping("/users")
public Flux<Users> findAll() {
return usersDao.findAll();
}
}
好了，現(xiàn)在我們的程序已經(jīng)寫好了，可以進(jìn)行測試了。
運(yùn)行程序，執(zhí)行：
curl "localhost:8080/users"
[{"id":1,"firstname":"John","lastname":"Doe"},{"id":2,"firstname":"Jane","lastname":"Doe"}]%
可以看到取出了相應(yīng)的結(jié)果。
完美，實(shí)驗(yàn)成功。
本文的代碼： spring-data-r2dbc
總結(jié)
到此這篇關(guān)于如何在Spring data中使用r2dbc的文章就介紹到這了,更多相關(guān)Spring data使用r2dbc內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
這篇文章主要介紹了Java基于注解的Excel導(dǎo)出方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-01-01
Java整數(shù)和字符串相互轉(zhuǎn)化實(shí)例詳解
這篇文章主要介紹了Java整數(shù)和字符串相互轉(zhuǎn)化實(shí)例詳解,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-02-02
詳解Spring中@Component和@Configuration的區(qū)別
一直有同學(xué)搞不清Spring中@Component和@Configuration這兩個(gè)注解有什么區(qū)別，所以這篇文章小編就給大家簡單介紹一下@Component和@Configuration的區(qū)別,需要的朋友可以參考下2023-07-07
這篇文章主要介紹了如何用Spring發(fā)送電子郵件，幫助大家更好的理解和使用Java，感興趣的朋友可以了解下2021-02-02
這篇文章主要介紹了Java中stream的用法詳細(xì)解讀,Stream 是 Java8 中處理集合的關(guān)鍵抽象概念,它可以指定你希望對(duì)集合進(jìn)行的操作,可以執(zhí)行非常復(fù)雜的查找、過濾和映射數(shù)據(jù)等操作,使用Stream API 對(duì)集合數(shù)據(jù)進(jìn)行操作,就類似于使用SQL執(zhí)行的數(shù)據(jù)庫查詢,需要的朋友可以參考下2023-10-10
這篇文章主要為大家分享了十道java華為編程大賽題目，代碼經(jīng)過調(diào)試，經(jīng)典的java編程題，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2018-03-03
SpringBoot基于Sentinel在服務(wù)上實(shí)現(xiàn)接口限流
這篇文章主要介紹了SpringBoot基于Sentinel在服務(wù)上實(shí)現(xiàn)接口限流,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-10-10
詳解SpringMVC?HandlerInterceptor攔截器的使用與參數(shù)
本文主要介紹了詳解SpringMVC?HandlerInterceptor攔截器的使用與參數(shù)，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-01-01
netty?pipeline中的inbound和outbound事件傳播分析
這篇文章主要為大家介紹了netty?pipeline中的inbound和outbound事件傳播分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-04-04
SpringBoot如何配置Controller實(shí)現(xiàn)Web請(qǐng)求處理
這篇文章主要介紹了SpringBoot如何配置Controller實(shí)現(xiàn)Web請(qǐng)求處理，文中通過圖解示例介紹的很詳細(xì)，具有有一定的參考價(jià)值，需要的小伙伴可以參考一下2023-05-05