private void createMeasurement()

in backend/src/main/java/org/apache/iotdb/admin/service/impl/IotDBServiceImpl.java [1599:1630]

32 lines of code
8 McCabe index (conditional complexity)


  private void createMeasurement(SessionPool sessionPool, DeviceDTO deviceDTO)
      throws BaseException {
    String measurement = deviceDTO.getTimeseries();
    try {
      TSDataType type = handleTypeStr(deviceDTO.getDataType());
      TSEncoding encoding = handleEncodingStr(deviceDTO.getEncoding());
      CompressionType compressionType = handleCompressionStr(deviceDTO.getCompression());
      String alias = deviceDTO.getAlias();
      if (alias == null || "null".equals(alias) || StringUtils.isBlank(alias)) {
        alias = null;
      }
      Map<String, String> tags = handleTagsList(deviceDTO.getTags());
      Map<String, String> attributes = handleTagsList(deviceDTO.getAttributes());
      sessionPool.createTimeseries(
          measurement, type, encoding, compressionType, null, tags, attributes, alias);
    } catch (IoTDBConnectionException e) {
      logger.error(e.getMessage());
      throw new BaseException(ErrorCode.GET_SESSION_FAIL, ErrorCode.GET_SESSION_FAIL_MSG);
    } catch (StatementExecutionException e) {
      logger.error(e.getMessage());
      if (e.getMessage().contains("No permissions")) {
        throw new BaseException(
            ErrorCode.NO_PRI_CREATE_TIMESERIES, ErrorCode.NO_PRI_CREATE_TIMESERIES_MSG);
      }
      if (e.getMessage().contains("already exist")) {
        throw new BaseException(
            ErrorCode.MEASUREMENT_ALREADY_EXIST,
            measurement + ErrorCode.MEASUREMENT_ALREADY_EXIST_MSG);
      }
      throw new BaseException(ErrorCode.INSERT_TS_FAIL, measurement + ErrorCode.INSERT_TS_FAIL_MSG);
    }
  }