如何在Spring data中使用r2dbc详解

前言

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

依赖关系

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

<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>

数据库连接配置

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

简单看一下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;

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

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

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

数据库初始化

数据库初始化过程中,我们需要创建一个users表格,这里我们在一个initDatabase bean中实现:

@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();
 }

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

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

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

DAO操作

在DAO操作之前,我们需要创建Users entity:

@Data
@AllArgsConstructor
public class Users {

 @Id
 private Integer id;
 private String firstname;
 private String lastname;

 boolean hasId() {
  return id != null;
 }
}

再看一下我们创建的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注解,因为我们继承了ReactiveCrudRepository,会自动帮我们创建UsersDao的实例,我们直接使用就可以了。

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

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

Service操作和Transaction

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

@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;
   }
  });
 }

}

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

controller

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

@RestController
@RequiredArgsConstructor
public class UsersController {

 private final UsersDao usersDao;

 @GetMapping("/users")
 public Flux<Users> findAll() {
  return usersDao.findAll();
 }
}

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

运行程序,执行:

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

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

完美,实验成功。

本文的代码: spring-data-r2dbc

总结

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

(0)

相关推荐

  • 如何在Spring data中使用r2dbc详解

    前言 上篇文章我们讲到了怎么在Spring webFlux中使用r2dbc,今天我们看一下怎么使用spring-data-r2dbc这个Spring data对r2dbc的封装来进行r2dbc操作. 依赖关系 要使用Spring-datea-r2dbc需要配置下面的依赖关系: <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>sp

  • Spring data elasticsearch使用方法详解

    这篇文章主要介绍了Spring data elasticsearch使用方法详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.准备 1.添加依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-elasticsearch</artifactId> &l

  • Dubbo在Spring和Spring Boot中的使用详解

    一.在Spring中使用Dubbo 1.Maven依赖 <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.5.3.6</version> <exclusions> <exclusion> <groupId>log4j</groupId> <artif

  • Spring Security 在 Spring Boot 中的使用详解【集中式】

    1.1 准备 1.1.1 创建 Spring Boot 项目   创建好一个空的 Spring Boot 项目之后,写一个 controller 验证此时是可以直接访问到该控制器的. 1.1.2 引入 Spring Security   在 Spring Boot 中引入 Spring Security 是相当简单的,可以在用脚手架创建项目的时候勾选,也可以创建完毕后在 pom 文件中加入相关依赖. <dependency> <groupId>org.springframework

  • Spring框架中@PostConstruct注解详解

    目录 初始化方式一:@PostConstruct注解 初始化方式二:实现InitializingBean接口 补充:@PostConstruct注释规则 总结 初始化方式一:@PostConstruct注解 假设类UserController有个成员变量UserService被@Autowired修饰,那么UserService的注入是在UserController的构造方法之后执行的. 如果想在UserController对象生成时候完成某些初始化操作,而偏偏这些初始化操作又依赖于依赖注入的对

  • SpringBoot整合Spring Data Elasticsearch的过程详解

    Spring Data Elasticsearch提供了ElasticsearchTemplate工具类,实现了POJO与elasticsearch文档之间的映射 elasticsearch本质也是存储数据,它不支持事物,但是它的速度远比数据库快得多, 可以这样来对比elasticsearch和数据库 索引(indices)--------数据库(databases) 类型(type)------------数据表(table) 文档(Document)---------------- 行(ro

  • Java反射机制在Spring IOC中的应用详解

    目录 Java反射机制在Spring IOC的应用 下面是Spring通过配置进行实例化对象 Spring的配置如下所示 实现一下Spring底层处理原理 反射机制.反射机制的作用.反射机制的功能 1.反射机制的作用 2.Java反射机制的功能 3.反射机制相关的重要的类有哪些? Java反射机制在Spring IOC的应用 IOC:即"控制反转",不是什么技术,而是一种思想.使用IOC意味着将你设计好的对象交给容器控制,而不是传统的在你的对象内部直接控制. 本篇文章主要讲解一下IOC

  • 如何在Spring Boot中使用MQTT

    为什么选择MQTT MQTT的定义相信很多人都能讲的头头是道,本文章也不讨论什么高大上的东西,旨在用最简单直观的方式让每一位刚接触的同行们可以最快的应用起来 先从使用MQTT需要什么开始分析: 消息服务器 不同应用/设备之间的频繁交互 可能涉及一对多的消息传递 根据上面列举的这三点,我们大概可以了解到, MQTT最适合的场景是消息做为系统的重要组成部分,且参与着系统关键业务逻辑的情形 MQTT, 启动! 既然决定使用它,我们首先要研究的是如何让MQTT正常工作,毕竟它不是简单的在maven里加入

  • C语言变长数组 struct中char data[0]的用法详解

    今天在看一段代码时出现了用结构体实现变长数组的写法,一开始因为忘记了这种技术,所以老觉得作者的源码有误,最后经过我深思之后,终于想起以前看过的用struct实现变长数组的技术.下面是我在网上找到的一篇讲解很清楚的文章. 在实际的编程中,我们经常需要使用变长数组,但是C语言并不支持变长的数组.此时,我们可以使用结构体的方法实现C语言变长数组. struct MyData { int nLen; char data[0];}; 在结构中,data是一个数组名:但该数组没有元素:该数组的真实地址紧随结

  • spring在IoC容器中装配Bean详解

    1.Spring配置概述 1.1.概述 Spring容器从xml配置.java注解.spring注解中读取bean配置信息,形成bean定义注册表: 根据bean定义注册表实例化bean: 将bean实例放入bean缓存池: 应用程序使用bean. 1.2.基于xml的配置 (1)xml文件概述 xmlns------默认命名空间 xmlns:xsi-------标准命名空间,用于指定自定义命名空间的schema文件 xmlns:xxx="aaaaa"-------自定义命名空间,xx

随机推荐