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