@Test public void testDeleteTableData() throws Exception { executor.deleteTableData(table); assertEquals("Table " + table + " is expected to be empty.", 0, executor.getTableRowCount(table)); }
public void deleteTableData(String tableName) { LOG.info("Deleting all the rows from: " + tableName); executeUpdate("DELETE FROM " + tableName); }
GenericJdbcExecutor { public void deleteTableData(String tableName) { LOG.info("Deleting all the rows from: " + tableName); executeUpdate("DELETE FROM " + tableName); } }
GenericJdbcExecutor { public void deleteTableData(String tableName) { LOG.info("Deleting all the rows from: " + tableName); executeUpdate("DELETE FROM " + tableName); } GenericJdbcExecutor(LinkConfig linkConfig); }
GenericJdbcExecutor { public void deleteTableData(String tableName) { LOG.info("Deleting all the rows from: " + tableName); executeUpdate("DELETE FROM " + tableName); } GenericJdbcExecutor(LinkConfig linkConfig); ResultSet executeQuery(String sql); PreparedStatement createStatement(String sql); void setAutoCommit(boolean autoCommit); void deleteTableData(String tableName); void migrateData(String fromTable, String toTable); long getTableRowCount(String tableName); void executeUpdate(String sql); void beginBatch(String sql); void addBatch(Object[] array, Schema schema); void executeBatch(boolean commit); void endBatch(); String getPrimaryKey(String table); String[] getQueryColumns(String query); boolean existTable(String table); String qualify(String name, String qualifier); String[] dequalify(String name); String delimitIdentifier(String name); void close(); }
GenericJdbcExecutor { public void deleteTableData(String tableName) { LOG.info("Deleting all the rows from: " + tableName); executeUpdate("DELETE FROM " + tableName); } GenericJdbcExecutor(LinkConfig linkConfig); ResultSet executeQuery(String sql); PreparedStatement createStatement(String sql); void setAutoCommit(boolean autoCommit); void deleteTableData(String tableName); void migrateData(String fromTable, String toTable); long getTableRowCount(String tableName); void executeUpdate(String sql); void beginBatch(String sql); void addBatch(Object[] array, Schema schema); void executeBatch(boolean commit); void endBatch(); String getPrimaryKey(String table); String[] getQueryColumns(String query); boolean existTable(String table); String qualify(String name, String qualifier); String[] dequalify(String name); String delimitIdentifier(String name); void close(); static final String JDBC_PROPERTY_USERNAME; static final String JDBC_PROPERTY_PASSWORD; }