feat(web): 添加了数据库所有缓存

kt-web/src/main/java/org/matrix/autotest/controller/ConnectController.java

@@ -11,6 +11,10 @@ import org.matrix.database.entity.Connect;
 import org.matrix.database.service.IConnectService;
 import org.matrix.database.vo.CommonResult;
 import org.matrix.database.vo.CommonResultObj;
+import org.springframework.cache.annotation.CacheEvict;
+import org.springframework.cache.annotation.CachePut;
+import org.springframework.cache.annotation.Cacheable;
+import org.springframework.cache.annotation.Caching;
 import org.springframework.http.ResponseEntity;
 import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.*;
@@ -75,6 +79,10 @@ public class ConnectController {
      */
     @ApiOperation(value = "分页查询数据库信息")
     @GetMapping
+    @Cacheable(cacheNames = "connectPageCache",
+            key = "#pageSize + '_' + #pageNum + '_' + #projectId",
+            condition = "#pageNum != null && #pageSize != null",
+            unless = "#result.statusCodeValue != 200")
     public ResponseEntity<CommonResultObj<Page<Connect>>> findPageConnects(
             @RequestParam(defaultValue = "10") int pageSize,
             @RequestParam(defaultValue = "1") int pageNum,
@@ -95,6 +103,12 @@ public class ConnectController {
      */
     @ApiOperation(value = "添加连接池")
     @PostMapping
+    @Caching(
+            put = {@CachePut(cacheNames = "connectPageCache", key = "#result.body.data.id",
+                    condition = "#p0 != null", unless = "#result.statusCodeValue != 200")
+            },
+            evict = {@CacheEvict(cacheNames = "connectPageCache", allEntries = true)}
+    )
     public ResponseEntity<CommonResultObj<Connect>> insertConnect(@RequestBody Connect connect) {
         return CommonResult.pred(connectService::save, connect
                 , "添加成功", "添加失败");
@@ -108,6 +122,13 @@ public class ConnectController {
      */
     @ApiOperation(value = "修改连接池")
     @PutMapping
+    @Caching(
+            put = {@CachePut(cacheNames = "connectPageCache", key = "#result.body.data.id",
+                    condition = "#p0 != null", unless = "#result.statusCodeValue != 200")
+            },
+            evict = {@CacheEvict(cacheNames = "connectPageCache", key = "#p0.id",
+                    condition = "#p0 != null")}
+    )
     public ResponseEntity<CommonResultObj<Connect>> updateConnect(@RequestBody Connect connect) {
         return CommonResult.pred(connectService::updateById, connect
                 , "修改成功", "修改失败");
@@ -121,6 +142,7 @@ public class ConnectController {
      */
     @ApiOperation(value = "根据主键id删除连接池")
     @DeleteMapping("/{id}")
+    @CacheEvict(cacheNames = "connectPageCache", allEntries = true, condition = "#p0 != null")
     public ResponseEntity<CommonResultObj<Long>> deleteConnect(@PathVariable Long id) {
         return CommonResult.pred(connectService::removeById, id
                 , "删除成功", "删除失败或id不存在");