From 67db4da31575fb660563818d11fb1294bfa647fe Mon Sep 17 00:00:00 2001
From: wangyu <727842003@qq.com>
Date: Thu, 4 Jul 2024 18:04:41 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E5=87=86=E5=A4=87=E6=94=AF=E6=8C=81flu?=
 =?UTF-8?q?ent=20sql?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 flyfish-data/flyfish-data-r2dbc/pom.xml       |  5 +++
 .../operations/R2dbcFluentOperations.java     | 42 +++++++++++++++++++
 2 files changed, 47 insertions(+)
 create mode 100644 flyfish-data/flyfish-data-r2dbc/src/main/java/dev/flyfish/framework/r2dbc/operations/R2dbcFluentOperations.java

diff --git a/flyfish-data/flyfish-data-r2dbc/pom.xml b/flyfish-data/flyfish-data-r2dbc/pom.xml
index 2a15cdd..ab75604 100644
--- a/flyfish-data/flyfish-data-r2dbc/pom.xml
+++ b/flyfish-data/flyfish-data-r2dbc/pom.xml
@@ -33,5 +33,10 @@
             <groupId>dev.flyfish.framework</groupId>
             <artifactId>flyfish-data-common</artifactId>
         </dependency>
+        <dependency>
+            <groupId>group.flyfish.framework</groupId>
+            <artifactId>fluent-sql-core</artifactId>
+            <version>0.0.5</version>
+        </dependency>
     </dependencies>
 </project>
diff --git a/flyfish-data/flyfish-data-r2dbc/src/main/java/dev/flyfish/framework/r2dbc/operations/R2dbcFluentOperations.java b/flyfish-data/flyfish-data-r2dbc/src/main/java/dev/flyfish/framework/r2dbc/operations/R2dbcFluentOperations.java
new file mode 100644
index 0000000..232dba9
--- /dev/null
+++ b/flyfish-data/flyfish-data-r2dbc/src/main/java/dev/flyfish/framework/r2dbc/operations/R2dbcFluentOperations.java
@@ -0,0 +1,42 @@
+package dev.flyfish.framework.r2dbc.operations;
+
+import group.flyfish.fluent.chain.common.ExecutableSql;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * 我们为实际开发提供了响应式链，避免写sql
+ *
+ * @author wangyu
+ */
+public interface R2dbcFluentOperations {
+
+    /**
+     * 查询单个
+     *
+     * @param sql 可执行sql
+     * @param <T> 泛型
+     * @return 结果
+     */
+    <T> Mono<T> findOne(ExecutableSql sql);
+
+    /**
+     * 查询单个
+     *
+     * @param sql 可执行sql
+     * @param <T> 泛型
+     * @return 结果
+     */
+    <T> Flux<T> find(ExecutableSql sql);
+
+    /**
+     * 查询分页对象
+     *
+     * @param sql 可执行sql
+     * @param <T> 泛型
+     * @return 结果
+     */
+    <T> Mono<Page<T>> find(ExecutableSql sql, Pageable pageable);
+}