From 57308eeb3f08656b25f41a880c6b1ee2b57e3446 Mon Sep 17 00:00:00 2001
From: swordmeng <swordmeng8@163.com>
Date: Wed, 12 Feb 2025 17:47:55 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9Efeign=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/huaxing/feign/IDatabaseClientFeign.java    | 58 ++++++++++++++++++++++
 .../fallback/DatabaseFeignFallbackFactory.java     | 35 +++++++++++++
 2 files changed, 93 insertions(+)

diff --git a/data-storage-api/src/main/java/com/huaxing/feign/IDatabaseClientFeign.java b/data-storage-api/src/main/java/com/huaxing/feign/IDatabaseClientFeign.java
index 5ff2902..04186d4 100644
--- a/data-storage-api/src/main/java/com/huaxing/feign/IDatabaseClientFeign.java
+++ b/data-storage-api/src/main/java/com/huaxing/feign/IDatabaseClientFeign.java
@@ -69,5 +69,63 @@ public interface IDatabaseClientFeign {
 	ResultVo<?> createDfsTable(@RequestBody @Validated TableDTO tableDTO);
 
 
+	/**
+	 * 创建stream表
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(CREATE_STREAM_TABLE)
+	ResultVo<?> createStreamTable(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 创建dfs和stream表并订阅
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(CREATE_DFS_AND_STREAM_TABLE_SUBSCRIBE)
+	ResultVo<?> createDfsAndStreamTableSubscribe(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 创建dfs和stream表不订阅
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(CREATE_DFS_AND_STREAM_TABLE_UNSUBSCRIBE)
+	ResultVo<?> createDfsAndStreamTableUnsubscribe(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 订阅流表
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(SUBSCRIBE_STREAM_TABLE)
+	ResultVo<?> subscribeStreamTable(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 取消订阅流表
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(UNSUBSCRIBE_STREAM_TABLE)
+	ResultVo<?> unsubscribeStreamTable(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 新增dfs表字段
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(ADD_DFS_COLUMNS)
+	ResultVo<?> addDfsColumns(@RequestBody @Validated TableDTO tableDTO);
+
+	/**
+	 * 新增stream表字段
+	 * @param tableDTO
+	 * @return ResultVo
+	 */
+	@PostMapping(ADD_STREAM_COLUMNS)
+	ResultVo<?> addStreamColumns(@RequestBody @Validated TableDTO tableDTO);
+
+
+
 
 }
diff --git a/data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java b/data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java
index 994c0fe..b339f6b 100644
--- a/data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java
+++ b/data-storage-api/src/main/java/com/huaxing/feign/fallback/DatabaseFeignFallbackFactory.java
@@ -36,6 +36,41 @@ public class DatabaseFeignFallbackFactory implements FallbackFactory<IDatabaseCl
             public ResultVo<?> createDfsTable(TableDTO tableDTO) {
                 return null;
             }
+
+            @Override
+            public ResultVo<?> createStreamTable(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> createDfsAndStreamTableSubscribe(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> createDfsAndStreamTableUnsubscribe(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> subscribeStreamTable(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> unsubscribeStreamTable(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> addDfsColumns(TableDTO tableDTO) {
+                return null;
+            }
+
+            @Override
+            public ResultVo<?> addStreamColumns(TableDTO tableDTO) {
+                return null;
+            }
         };
     }
 }