Method unload

src/main/java/com/oltpbenchmark/api/Loader.java:98–111

Method that can be overriden to specifically unload the tables of the database. In the default implementation it checks for tables from the catalog to delete them using SQL. Any subclass can inject custom behavior here. @param catalog The catalog containing all loaded tables @throws SQLException

(Connection conn, AbstractCatalog catalog)

   * @throws SQLException
   */
  public void unload(Connection conn, AbstractCatalog catalog) throws SQLException {

    boolean shouldEscapeNames = this.getDatabaseType().shouldEscapeNames();

    try (Statement st = conn.createStatement()) {
      for (Table catalog_tbl : catalog.getTables()) {
        String tableName = shouldEscapeNames ? catalog_tbl.getEscapedName() : catalog_tbl.getName();
        LOG.debug(String.format("Deleting data from table [%s]", tableName));

        String sql = "DELETE FROM " + tableName;
        st.execute(sql);
      }
    }
  }

  protected void updateAutoIncrement(Connection conn, Column catalog_col, int value)
      throws SQLException {