Browse Source

增加清楚全部缓存接口

guq 7 years ago
parent
commit
6bbe5bb337

+ 0 - 1
base-servers/datacenter/datacenter-client/src/main/java/com/usoftchina/saas/dc/client/interceptor/DataSourceInterceptor.java

@@ -37,7 +37,6 @@ public class DataSourceInterceptor extends HandlerInterceptorAdapter {
             // 该公司绑定到了指定数据中心
             if (StringUtils.hasText(dcName)) {
                 String dbName = dataSourceRegister.getDefaultDatabaseName();
-                DataSourceCache.of(dcName, dbName).hdel();
                 DataSourceInfoDTO dataSourceInfoDTO = DataSourceCache.of(dcName, dbName).getDataSourceInfo();
                 logger.info("DbName={} hostname={} DbRealName={}", dataSourceInfoDTO.getDbName(), dataSourceInfoDTO.getDbHost(),
                         dataSourceInfoDTO.getDbRealName());

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

@@ -1,6 +1,7 @@
 package com.usoftchina.saas.dc.controller;
 
 import com.usoftchina.saas.base.Result;
+import com.usoftchina.saas.dc.cache.DataSourceCache;
 import com.usoftchina.saas.dc.dto.DataSourceInfoDTO;
 import com.usoftchina.saas.dc.service.DataSourceInfoService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -37,4 +38,16 @@ public class DataSourceInfoController {
         dataSourceInfoService.clearCache(dcName, dbName);
         return Result.success();
     }
+
+    /**
+     * 数据库缓存清除
+     *
+     * @return
+     */
+    @GetMapping("/cache/clearAll")
+    public Result clearCacheAll(@RequestParam("dcName") String dcName,
+                                @RequestParam("dbName") String dbName) {
+        DataSourceCache.of(dcName, dbName).clear();
+        return Result.success();
+    }
 }