Проблема с отображением графического интерфейса AbstractTableModel

Поскольку доступ к базе данных по сути является асинхронным, вы обязательно захотите получить строки в фоновом режиме, чтобы избежать блокировки streamа отправки событий ; SwingWorker делает это относительно легко. Извлеките строки в вашей реализации doInBackground() , publish() промежуточных результатов и добавьте их в модель таблицы при реализации process() . Здесь показан полный пример, в котором излагаются вспомогательные преимущества. Пример выполняется через файл, но вы можете заменить свои операции ResultSet .

 while (rs.next()) { //collect row data publish(rowData); } 

tableData.add() на реализацию process() .

Сосредоточив внимание на взаимодействии между настраиваемой TableModel и содержащейся в нем SwingWorker , следующий полный пример создает тестовую базу данных, содержащую N строк, и отображает JTable показывающий результаты запроса этой таблицы. В частности,

• JDBCModel расширяет AbstractTableModel . Для простоты data модели хранятся в List , а ResultSetMetaData используется для имен столбцов. В качестве более абстрактной альтернативы см. Apache Commons DbUtils , который использует DbUtils литералы как токены типа Runtime и ResultSetMetaData для безопасного создания экземпляров данных строки.

• JDBCModel делегирует поиск строк частному JDBCWorker ; он вызывает publish() для каждой строки, полученной из ResultSet ; поскольку process() работает на EDT, рабочий может оптимизировать количество событий модели таблицы, которые он запускает от имени родительской модели, используя fireTableRowsInserted() .

• Аналогично, ваша реализация delete() должна находиться в JDBCModel , а не в графическом интерфейсе; он должен fireTableRowsDeleted() после того, как строка будет успешно удалена из базы данных и удалена из data .

• Добавьте Thread.sleep() в фоновый цикл работника, чтобы увидеть эффект искусственно увеличивающей латентности.

• Используйте setProgress() и PropertyChangeListener , показанные здесь , для отображения прогресса; JOptionPane когда done() может быть излишним.

• Переопределите getPreferredScrollableViewportSize() чтобы настроить размер охватывающей JScrollPane .

• Избегайте имен classов, например TableModel , которые сталкиваются с общими именами API.

• Здесь рассматривается вариант, который реализует фильтрацию в реальном времени в представлении.

 import java.awt.Dimension; import java.awt.EventQueue; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; import java.util.Random; import javax.swing.JFrame; import javax.swing.JScrollPane; import javax.swing.JTable; import javax.swing.SwingWorker; import javax.swing.table.AbstractTableModel; /** * @see https://stackoverflow.com/a/34742409/230513 * @see https://stackoverflow.com/a/24762078/230513 */ public class WorkerTest { private static final int N = 1_000; private static final String URL = "jdbc:h2:mem:test"; private static final Random r = new Random(); private void display() { JFrame f = new JFrame("WorkerTest"); f.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); createTestDatabase(N); JDBCModel model = new JDBCModel(getConnection(), "select * from city"); f.add(new JScrollPane(new JTable(model) { @Override public Dimension getPreferredScrollableViewportSize() { return new Dimension(320, 240); } })); f.pack(); f.setLocationRelativeTo(null); f.setVisible(true); } private static class Row { int ID; String name; } private static class JDBCModel extends AbstractTableModel { private final List data = new ArrayList<>(); private ResultSet rs = null; private ResultSetMetaData meta; public JDBCModel(Connection conn, String query) { try { Statement s = conn.createStatement(); rs = s.executeQuery(query); meta = rs.getMetaData(); JDBCWorker worker = new JDBCWorker(); worker.execute(); } catch (SQLException e) { e.printStackTrace(System.err); } } @Override public int getRowCount() { return data.size(); } @Override public int getColumnCount() { try { return meta.getColumnCount(); } catch (SQLException e) { e.printStackTrace(System.err); } return 0; } @Override public Object getValueAt(int rowIndex, int colIndex) { Row row = data.get(rowIndex); switch (colIndex) { case 0: return row.ID; case 1: return row.name; } return null; } @Override public String getColumnName(int colIndex) { try { return meta.getColumnName(colIndex + 1); } catch (SQLException e) { e.printStackTrace(System.err); } return null; } private class JDBCWorker extends SwingWorker, Row> { @Override protected List doInBackground() { try { while (rs.next()) { Row r = new Row(); r.ID = rs.getInt(1); r.name = rs.getString(2); publish(r); } } catch (SQLException e) { e.printStackTrace(System.err); } return data; } @Override protected void process(List chunks) { int n = getRowCount(); for (Row row : chunks) { data.add(row); } fireTableRowsInserted(n, n + chunks.size()); } } } private static void createTestDatabase(int n) { Connection conn = getConnection(); try { Statement st = conn.createStatement(); st.execute("create table city(id integer, name varchar2)"); PreparedStatement ps = conn.prepareStatement( "insert into city values (?, ?)"); for (int i = 0; i < n; i++) { ps.setInt(1, i); ps.setString(2, (char) ('A' + r.nextInt(26)) + String.valueOf(r.nextInt(1_000_000))); ps.execute(); } } catch (SQLException ex) { ex.printStackTrace(System.err); } } private static Connection getConnection() { try { return DriverManager.getConnection(URL, "", ""); } catch (SQLException e) { e.printStackTrace(System.err); } return null; } public static void main(String[] args) { EventQueue.invokeLater(new WorkerTest()::display); } }