private Void write(
      AtomicLong writtenPointCounter,
      ExecutorService allThreads,
      int fileNumMax,
      int pointPerFile,
      int deviceNum,
      int testNum,
      boolean roundRobinDevice)
      throws SQLException {

    try (Connection connection = EnvFactory.getEnv().getConnection(BaseEnv.TABLE_SQL_DIALECT);
        Statement statement = connection.createStatement()) {

      statement.execute("create database if not exists test");
      statement.execute("use test");

      statement.execute(
          "create table if not exists table"
              + testNum
              + "(city TAG, deviceId STRING TAG, s0 INT32 field)");

      for (int i = 1; i <= fileNumMax; i++) {
        for (int j = 0; j < pointPerFile; j++) {
          long time = writtenPointCounter.get() + 1;
          if (roundRobinDevice) {
            statement.execute(
                String.format(
                    "INSERT INTO test.table"
                        + testNum
                        + "(time, city, deviceId, s0) VALUES(%d, 'bj', 'd"
                        + (time % deviceNum)
                        + "',%d)",
                    time,
                    time));
          } else {
            for (int d = 0; d < deviceNum; d++) {
              statement.execute(
                  String.format(
                      "INSERT INTO test.table"
                          + testNum
                          + "(time, city, deviceId, s0) VALUES(%d, 'bj', 'd"
                          + d
                          + "',%d)",
                      time,
                      time));
            }
          }

          writtenPointCounter.incrementAndGet();
          if (Thread.interrupted()) {
            return null;
          }
        }
        statement.execute("FLUSH");
        if (i % 100 == 0) {
          LOGGER.info("{} files written", i);
        }
      }
    } catch (SQLException e) {
      if (e.getMessage().contains("Fail to reconnect")) {
        // restart triggered, ignore
        return null;
      } else {
        allThreads.shutdownNow();
        throw e;
      }
    } catch (Throwable e) {
      allThreads.shutdownNow();
      throw e;
    }
    return null;
  }
Should delete this case after the deletion value filter feature be implemented
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBDeletionTableIT.java