1. Lời nói đầu

Với việc phát hành Solon 3.0 và Solon-Rx 3.0, plug-in mở rộng RxSqlUtils được đưa vào hoạt động cơ sở dữ liệu "đáp ứng". RxSqlUtils được xây dựng dựa trên giao diện R2dbc và Reactor. Phong cách tối giản, giống như một lớp công cụ, do đó có tên: RxSqlUtils.

Đặc biệt khi phát triển các kịch bản như solon-web-rx và Solon Cloud Gateway (dựa trên khả năng phản hồi thuần túy), RxSqlUtils sẽ là lựa chọn phù hợp nhất.

2. Sử dụng RxSqlUtils

1. Giới thiệu các phụ thuộc

 org.noear solon-data-rx-sqlutils 

2. Tạo bảng cơ sở dữ liệu mới (đối với H2)

TẠO BẢNG `user` ( `id` bigint(20) not null, `name` varchar(255) DEFAULT NULL, `title` varchar(255) DEFAULT NULL, PRIMARY KEY (`id`) );

3. Xác định các lớp thực thể

Sử dụng chú thích lombok.

@Data Lớp công khai Người dùng { id dài riêng tư; Tên chuỗi riêng tư;

4. Thêm cấu hình nguồn dữ liệu

solo.dataSources: user!: # Phần cuối của '!' cho biết lớp nguồn dữ liệu mặc định: "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. Tiêm RxSqlUtils và sử dụng

Tiêm (để nó sẵn sàng để sử dụng).

@Component lớp công khai UserDao { @Inject RxSqlUtils sqlUtils }

Các thao tác truy vấn.

public Flux getAllUsers() { return sqlUtils.sql("select * from user") .queryRowList(User.class }

Thêm hoạt động mới.

public Mono addUser(User user) { return sqlUtils.sql("INSERT INTO user (name , title) GIÁ TRỊ (?,?)", user.getName(), user.getTitle()) .updateReturnKey(Long. lớp học); }

Cập nhật hoạt động.

public Mono updateUser(User user) { return sqlUtils.sql("CẬP NHẬT người dùng SET name=?, title=? WHERE id=?", user.getName(), user.getTitle(), user.getId() ) .cập nhật(); }

Tóm tắt

Sử dụng RxSqlUtils có thể hoàn thành các hoạt động đáp ứng của cơ sở dữ liệu với độ minh bạch tốt hơn, sử dụng đơn giản và trực tiếp.

Cuối cùng, bài viết về RxSqlUtils (baseR2dbc) này kết thúc tại đây. Nếu bạn muốn biết thêm về RxSqlUtils (baseR2dbc), vui lòng tìm kiếm bài viết CFSDN hoặc tiếp tục duyệt các bài viết liên quan. Tôi hy vọng bạn sẽ ủng hộ blog của tôi trong tương lai! .