Back
To Top
RxSqlUtils（base R2dbc）
2024/12/28
RxSqlUtils（base R2dbc）
RxSqlUtils 是基于 R2dbc 和 Reactor 接口的封装。极简风格，就像个工具类，故名：RxSqlUtils。
一、前言
随着 Solon 3.0 和 Solon-Rx 3.0 发布，又迎来了的 RxSqlUtils 扩展插件，用于“响应式”操作数据库。RxSqlUtils 是基于 R2dbc 和 Reactor 接口构建。极简风格，就像个工具类，故名：RxSqlUtils。
尤其在 solon-web-rx 和 Solon Cloud Gateway（基于纯响应式构建） 场景开发时，RxSqlUtils 会是最好的良配。
二、RxSqlUtils 使用
1、引入依赖
<dependency>
<groupId>org.noear</groupId>
<artifactId>solon-data-rx-sqlutils</artifactId>
</dependency>
2、新建数据库表（for H2）
CREATE TABLE `user` (
`id` bigint(20) not null,
`name` varchar(255) DEFAULT NULL,
`title` varchar(255) DEFAULT NULL,
PRIMARY KEY (`id`)
);
3、定义实体类
使用了 lombok 的注解。
@Data
public class User {
private Long id;
private String name;
private String title;
}
4、添加数据源配置
solon.dataSources:
user!: # ‘!’结尾表示默认数据源
class: "org.noear.solon.data.datasource.R2dbcConnectionFactory"
r2dbcUrl: "r2dbc:h2:mem:///test;DB_CLOSE_ON_EXIT=FALSE;MODE=MYSQL;DATABASE_TO_LOWER=TRUE;IGNORECASE=TRUE;CASE_INSENSITIVE_IDENTIFIERS=TRUE"
5、注入 RxSqlUtils 并使用
注入（这样就可以用了）
@Component
public class UserDao {
@Inject
private RxSqlUtils sqlUtils;
}
查询操作
public Flux<User> getAllUsers() {
return sqlUtils.sql("select * from user")
.queryRowList(User.class);
}
新增操作
public Mono<Long> addUser(User user) {
return sqlUtils.sql("INSERT INTO user (name , title) VALUES (?,?)", user.getName(), user.getTitle())
.updateReturnKey(Long.class);
}
更新操作
public Mono<Long> updateUser(User user) {
return sqlUtils.sql("UPDATE user SET name=?, title=? WHERE id=?", user.getName(), user.getTitle(), user.getId())
.update();
}
总结
使用 RxSqlUtils 可以完成数据库的响应式操作，也有更好的透明性，使用简单和直接。