public static void main()

in backup-command/src/main/java/org/apache/iotdb/backup/command/ImportTool.java [59:91]

33 lines of code
6 McCabe index (conditional complexity)


  public static void main(String[] args) {
    init(args);
    int exitCode = CODE_OK;
    try {
      initSession();
      ImportStarter importStarter = new ImportStarter();
      ImportModel importModel = generateImportCsvFile();
      importModel.setSession(session);
      Disposable disposable = importStarter.start(importModel);
      while (!disposable.isDisposed()) {
        System.out.print("完成行数:" + importStarter.finishedRowNum() + "行\r");
        Thread.sleep(1000);
      }
      System.out.print("完成行数:" + importStarter.finishedRowNum() + "行\r");
    } catch (IoTDBConnectionException | StatementExecutionException e) {
      System.out.println("Connect failed because " + e.getMessage());
      exitCode = CODE_ERROR;
    } catch (Exception e) {
      System.out.println(e.getMessage());
      exitCode = CODE_ERROR;
    } finally {
      if (session != null) {
        try {
          session.close();
        } catch (IoTDBConnectionException e) {
          exitCode = CODE_ERROR;
          System.out.println(
              "Encounter an error when closing session, error is: " + e.getMessage());
        }
      }
    }
    System.exit(exitCode);
  }