新增监控指标展示功能

- 该版本适配低于0.13版本的iotdb并提供数据库管理功能，但不提供监控管理(低于0.13版本iotdb不支持监控);
- 仍然存在部分接口返回后端假数据，等待清华提供接口后替换为真实数据。

Author: loveher147

backend/pom.xml

@@ -145,7 +145,7 @@
     <dependency>
       <groupId>org.apache.iotdb</groupId>
       <artifactId>iotdb-session</artifactId>
-      <version>0.12.1</version>
+      <version>0.12.5</version>
       <exclusions>
         <exclusion>
           <artifactId>logback-classic</artifactId>
@@ -157,7 +157,7 @@
     <dependency>
       <groupId>org.apache.iotdb</groupId>
       <artifactId>iotdb-jdbc</artifactId>
-      <version>0.12.1</version>
+      <version>0.12.5</version>
       <exclusions>
         <exclusion>
           <artifactId>logback-classic</artifactId>

backend/src/main/java/org/apache/iotdb/admin/common/exception/ErrorCode.java

@@ -158,6 +158,10 @@ public class ErrorCode {
   public static final String SET_GROUP_FAIL = "IOTDB-0022";
   public static final String SET_GROUP_FAIL_MSG = "Failed to create storage group";
 
+  public static final String SET_GROUP_FAIL_EXISTS = "IOTDB-0095";
+  public static final String SET_GROUP_FAIL__EXISTS_MSG =
+      "Failed to create storage group, the storage group already exists";
+
   public static final String DELETE_GROUP_FAIL = "IOTDB-0023";
   public static final String DELETE_GROUP_FAIL_MSG = "Failed to delete storage group";
 

backend/src/main/java/org/apache/iotdb/admin/controller/FileController.java

@@ -115,6 +115,17 @@ public ResponseEntity<Resource> downloadTemplateFile() throws BaseException {
     return getResponseEntity(resource);
   }
 
+  @ApiOperation("Download the query log file")
+  @GetMapping("/downloadQueryLogFile")
+  public ResponseEntity<Resource> downloadQueryLogFile(
+      @RequestParam String SQLStatement, @RequestParam Long timeStamp) throws BaseException {
+    Resource resource = new ClassPathResource("file/[Fake]QueryLog.txt");
+    if (!resource.exists()) {
+      throw new BaseException(ErrorCode.FILE_NOT_FOUND, ErrorCode.FILE_NOT_FOUND_MSG);
+    }
+    return getResponseEntity(resource);
+  }
+
   private ResponseEntity<Resource> getResponseEntity(Resource resource) {
     String contentType = "application/octet-stream";
 

backend/src/main/java/org/apache/iotdb/admin/controller/IotDBController.java

@@ -85,10 +85,13 @@ public BaseVO<DataCountVO> getDataCount(
   @GetMapping("/dataModel")
   @ApiOperation("Get IoTDB data model")
   public BaseVO<DataModelVO> getDataModel(
-      @PathVariable("serverId") Integer serverId, HttpServletRequest request) throws BaseException {
+      @PathVariable("serverId") Integer serverId,
+      @RequestParam(value = "path", required = false, defaultValue = "root") String path,
+      HttpServletRequest request)
+      throws BaseException {
     check(request, serverId);
     Connection connection = connectionService.getById(serverId);
-    DataModelVO dataModelVO = iotDBService.getDataModel(connection);
+    DataModelVO dataModelVO = iotDBService.getDataModel(connection, path);
     return BaseVO.success("Get IoTDB data model successfully", dataModelVO);
   }
 
@@ -164,7 +167,6 @@ public BaseVO saveStorageGroup(
     checkTtl(ttl, ttlUnit);
     Integer groupId = groupDTO.getGroupId();
     groupDTO.setGroupName(groupName);
-
     List<String> groupNames = iotDBService.getAllStorageGroups(connection);
     if (groupId == null) {
       if (!groupNames.contains(groupDTO.getGroupName())) {
@@ -1121,9 +1123,7 @@ private void check(HttpServletRequest request, Integer serverId) throws BaseExce
 
   private void checkParameter(String groupName) throws BaseException {
     String checkName = StringUtils.removeStart(groupName, "root").toLowerCase();
-    if (!groupName.matches("^root\\.[^ ]+$")
-        || checkName.contains(".root.")
-        || checkName.matches("^[^ ]*\\.root$")) {
+    if (groupName.contains(".root.") || groupName.contains(".root")) {
       throw new BaseException(ErrorCode.NO_SUP_CONTAIN_ROOT, ErrorCode.NO_SUP_CONTAIN_ROOT_MSG);
     }
     if (checkName.contains(".as.")
@@ -1229,6 +1229,9 @@ private String getTTL(Long time) {
   }
 
   private void checkTtl(Long ttl, String unit) throws BaseException {
+    if (ttl == null || unit == null) {
+      return;
+    }
     if (Long.MAX_VALUE / switchTime(unit) < ttl) {
       throw new BaseException(ErrorCode.TTL_OVER, ErrorCode.TTL_OVER_MSG);
     }

backend/src/main/java/org/apache/iotdb/admin/model/dto/AuthorityPrivilegeDTO.java

@@ -26,6 +26,7 @@
 
 @Data
 public class AuthorityPrivilegeDTO implements Serializable {
+
   private List<String> privileges;
 
   private List<String> cancelPrivileges;

backend/src/main/java/org/apache/iotdb/admin/model/vo/DataCountVO.java

@@ -25,8 +25,9 @@
 
 @Data
 public class DataCountVO implements Serializable {
-  private Integer groupCount;
+  private Integer storageGroupCount;
   private Integer deviceCount;
-  private Integer measurementCount;
+  private Integer monitorCount;
   private Integer dataCount;
+  private String version;
 }

backend/src/main/java/org/apache/iotdb/admin/service/IotDBService.java

@@ -30,7 +30,7 @@
 public interface IotDBService {
   DataCountVO getDataCount(Connection connection) throws BaseException;
 
-  DataModelVO getDataModel(Connection connection) throws BaseException;
+  DataModelVO getDataModel(Connection connection, String path) throws BaseException;
 
   List<String> getAllStorageGroups(Connection connection) throws BaseException;
 
@@ -162,4 +162,22 @@ List<SqlResultVO> queryAll(Connection connection, List<String> sqls, Long timest
   void updatePwd(Connection connection, IotDBUser iotDBUser) throws BaseException;
 
   void stopQuery(Integer serverId, Long timestamp) throws BaseException;
+
+  QueryInfoDTO getQueryInfoListByQueryClassificationId(
+      Connection connection,
+      Integer queryClassificationId,
+      Integer pageSize,
+      Integer pageNum,
+      String filterString,
+      Long startTime,
+      Long endTime,
+      Integer executionResult)
+      throws BaseException;
+
+  MetricsDataForDiagramVO getMetricDataByMetricId(Connection connection, Integer metricId)
+      throws BaseException;
+
+  List<QueryMetricsVO> getTopQueryMetricsData();
+
+  List<QueryMetricsVO> getSlowQueryMetricsData();
 }