dataceter增加清楚缓存接口

base-servers/datacenter/datacenter-server/pom.xml

@@ -49,6 +49,10 @@
             <artifactId>test-starter</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>com.usoftchina.saas</groupId>
+            <artifactId>datacenter-api</artifactId>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

base-servers/datacenter/datacenter-server/src/main/java/com/usoftchina/saas/dc/controller/DataSourceInfoController.java

@@ -25,4 +25,16 @@ public class DataSourceInfoController {
                                                 @RequestParam("dbName") String dbName) {
         return Result.success(dataSourceInfoService.findDataSourceInfo(dcName, dbName));
     }
+
+    /**
+     * 数据库缓存清除
+     *
+     * @return
+     */
+    @GetMapping("/cache/clear")
+    public Result clearCache(@RequestParam("dcName") String dcName,
+                             @RequestParam("dbName") String dbName) {
+        dataSourceInfoService.clearCache(dcName, dbName);
+        return Result.success();
+    }
 }

base-servers/datacenter/datacenter-server/src/main/java/com/usoftchina/saas/dc/service/DataSourceInfoService.java

@@ -16,4 +16,6 @@ public interface DataSourceInfoService {
      * @return
      */
     DataSourceInfo findDataSourceInfo(String dcName, String dbName);
+
+    void clearCache(String dcName, String dbName);
 }

base-servers/datacenter/datacenter-server/src/main/java/com/usoftchina/saas/dc/service/impl/DataSourceInfoServiceImpl.java

@@ -1,5 +1,6 @@
 package com.usoftchina.saas.dc.service.impl;
 
+import com.usoftchina.saas.dc.cache.DataSourceCache;
 import com.usoftchina.saas.dc.mapper.DataSourceInfoMapper;
 import com.usoftchina.saas.dc.po.DataSourceInfo;
 import com.usoftchina.saas.dc.service.DataSourceInfoService;
@@ -20,4 +21,9 @@ public class DataSourceInfoServiceImpl implements DataSourceInfoService{
     public DataSourceInfo findDataSourceInfo(String dcName, String dbName) {
         return dataSourceInfoMapper.selectByDcNameAndDbName(dcName, dbName);
     }
+
+    @Override
+    public void clearCache(String dcName, String dbName) {
+        DataSourceCache.of(dcName, dbName).hdel();
+    }
 }