private void cleanup() throws SQLException {
    try {
      DataSource dataSource = repairRequestsDb.getDataSource();
      try (Connection connection = dataSource.getConnection()) {
        Statement statement = connection.createStatement();
        statement.executeUpdate("DELETE FROM " + MysqlRepairRequestsDb.REPAIR_REQUESTS_TABLE + ";");
      }
    } catch (SQLException e) {
      throw e;
    }
  }
Empty the table
@throws SQLException throw any SQL related exception
ambry-mysql/src/integration-test/java/com/github/ambry/repair/MysqlRepairRequestsDbTest.java