如何在Spring data中使用r2dbc详解

2023-07-12 21:12:03 348

前言

上篇文章我们讲到了怎么在SpringwebFlux中使用r2dbc,今天我们看一下怎么使用spring-data-r2dbc这个Springdata对r2dbc的封装来进行r2dbc操作。

依赖关系

要使用Spring-datea-r2dbc需要配置下面的依赖关系：



org.springframework.boot
spring-boot-starter-data-r2dbc
2.3.3.RELEASE




io.r2dbc
r2dbc-h2
${r2dbc-h2.version}



org.springframework.boot
spring-boot-starter-webflux

数据库连接配置

Spring-data-r2dbc使用的是R2dbcProperties来进行配置文件的读取：

简单看一下R2dbcProperties的定义：

@ConfigurationProperties(prefix="spring.r2dbc")
publicclassR2dbcProperties{

/**
*Databasename.Setifnonameisspecifiedintheurl.Defaultto"testdb"when
*usinganembeddeddatabase.
*/
privateStringname;

/**
*Whethertogeneratearandomdatabasename.Ignoreanyconfigurednamewhen
*enabled.
*/
privatebooleangenerateUniqueName;

/**
*R2DBCURLofthedatabase.databasename,username,passwordandpoolingoptions
*specifiedintheurltakeprecedenceoverindividualoptions.
*/
privateStringurl;

/**
*Loginusernameofthedatabase.Setifnousernameisspecifiedintheurl.
*/
privateStringusername;

/**
*Loginpasswordofthedatabase.Setifnopasswordisspecifiedintheurl.
*/
privateStringpassword;

相应的，看一下我们的配置文件是怎么样的：

spring.r2dbc.url=r2dbc:h2:mem://./testdb
spring.r2dbc.username=sa
spring.r2dbc.password=password

这里，我们使用的是H2数据库。

数据库初始化

数据库初始化过程中，我们需要创建一个users表格，这里我们在一个initDatabasebean中实现：

@Bean
publicApplicationRunnerinitDatabase(DatabaseClientclient,UsersDaousersDao){
Liststatements=Arrays.asList(
"DROPTABLEIFEXISTSUSERS;",
"CREATETABLEIFNOTEXISTSUSERS(idSERIALPRIMARYKEY,firstnameVARCHAR(100)NOTNULL,lastnameVARCHAR(100)NOTNULL);");

statements.forEach(sql->executeSql(client,sql)
.doOnSuccess(count->log.info("Schemacreated,rowsupdated:{}",count))
.doOnError(error->log.error("goterror:{}",error.getMessage(),error))
.subscribe()
);

returnargs->getUser().flatMap(usersDao::save).subscribe(user->log.info("Usersaved:{}",user));

}

privateFluxgetUser(){
returnFlux.just(newUsers(null,"John","Doe"),newUsers(null,"Jane","Doe"));
}

privateMonoexecuteSql(DatabaseClientclient,Stringsql){
returnclient.execute(sql).fetch().rowsUpdated();
}

上面的例子中，我们创建数据库分为了两部分，第一部分是数据库schema的操作，我们执行了drop和createtable的操作。

第二部分是向数据库表中插入数据。

注意，上面的两部分操作都需要执行subscribe操作，以触发真正的Reactive操作。

DAO操作

在DAO操作之前，我们需要创建Usersentity：

@Data
@AllArgsConstructor
publicclassUsers{

@Id
privateIntegerid;
privateStringfirstname;
privateStringlastname;

booleanhasId(){
returnid!=null;
}
}

再看一下我们创建的UserDao：

publicinterfaceUsersDaoextendsReactiveCrudRepository{

@Query("selectid,firstname,lastnamefromuserscwherec.lastname=:lastname")
FluxfindByLastname(Stringlastname);
}

注意，这里并不需要添加@Component注解，因为我们继承了ReactiveCrudRepository，会自动帮我们创建UsersDao的实例，我们直接使用就可以了。

ReactiveCrudRepository为我们封装了一些DAO的基本操作，比如save，saveAll,findById,existsById等基础操作。

当然，我们也可以自定义自己的SQL语句，比如上面的findByLastname。

Service操作和Transaction

我们看一下怎么使用UserDao来进行具体的方法操作：

@Component
publicclassUsersService{

@Resource
privateUsersDaousersDao;

@Transactional
publicMonosave(Usersuser){

returnusersDao.save(user).map(it->{

if(it.getFirstname().equals("flydean")){
thrownewIllegalStateException();
}else{
returnit;
}
});
}

}

上面我们创建了一个save方法，用来保存相应的User对象。

controller

最后，我们创建一个controller来对外暴露相应的方法：

@RestController
@RequiredArgsConstructor
publicclassUsersController{

privatefinalUsersDaousersDao;

@GetMapping("/users")
publicFluxfindAll(){
returnusersDao.findAll();
}
}

好了，现在我们的程序已经写好了，可以进行测试了。

运行程序，执行：

curl"localhost:8080/users"
[{"id":1,"firstname":"John","lastname":"Doe"},{"id":2,"firstname":"Jane","lastname":"Doe"}]%

可以看到取出了相应的结果。

完美，实验成功。

本文的代码：spring-data-r2dbc

总结

到此这篇关于如何在Springdata中使用r2dbc的文章就介绍到这了,更多相关Springdata使用r2dbc内容请搜索毛票票以前的文章或继续浏览下面的相关文章希望大家以后多多支持毛票票！

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

如何在Spring data中使用r2dbc详解

热门推荐

随机推荐