From 6af204b0f45623fa65957ef1a0cb776bed4f0489 Mon Sep 17 00:00:00 2001
From: wenshao <szujobs@hotmail.com>
Date: Thu, 2 Jun 2011 10:18:42 +0000
Subject: [PATCH] git-svn-id: http://code.alibabatech.com/svn/druid/trunk@246
 b9813039-fb51-4c41-a8b9-e21c2acb5095

---
 .../com/alibaba/druid/jconsole/SQLPanel.java  | 62 ++++++++++++++++++-
 1 file changed, 60 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/alibaba/druid/jconsole/SQLPanel.java b/src/main/java/com/alibaba/druid/jconsole/SQLPanel.java
index e21a352a30..ea39df469e 100644
--- a/src/main/java/com/alibaba/druid/jconsole/SQLPanel.java
+++ b/src/main/java/com/alibaba/druid/jconsole/SQLPanel.java
@@ -32,13 +32,15 @@ public class SQLPanel extends JPanel {
     private DataSourceInfo        dataSourceInfo;
 
     private JTable                table;
+    private SQLTableModel tableModel;
 
     private String[]              columnNames      = { "ID", "File", "Name", "SQL", "ExecCount",
 
                                                    "ErrorCount", "TotalTime", "LastTime", "MaxTimespan", "LastError",
 
                                                    "EffectedRowCount", "FetchRowCount", "ConcurrentMax", "Running" };
-
+    
+    
     public SQLPanel(MBeanServerConnection connection, ObjectInstance objectInstance, DataSourceInfo dataSourceInfo){
         super();
         this.connection = connection;
@@ -85,7 +87,8 @@ public class SQLPanel extends JPanel {
             rowList.toArray(rows);
             TableColumnModel columnModel = new TableColumnModel();
 
-            table = new JTable(new SQLTableModel(rows), columnModel);
+            tableModel = new SQLTableModel(rows);
+            table = new JTable(tableModel, columnModel);
             table.setAutoResizeMode(JTable.AUTO_RESIZE_SUBSEQUENT_COLUMNS);
             table.addMouseListener(new MouseAdapter() {
 
@@ -105,6 +108,57 @@ public class SQLPanel extends JPanel {
         }
     }
 
+    void refresh() {
+        try {
+            TabularData connectionTabularData = (TabularData) connection.getAttribute(objectInstance.getObjectName(), "SqlList");
+
+            List<Object[]> rowList = new ArrayList<Object[]>();
+
+            for (Object item : connectionTabularData.values()) {
+                CompositeData rowData = (CompositeData) item;
+
+                String url = (String) rowData.get("DataSource");
+
+                if (!dataSourceInfo.getUrl().equals(url)) {
+                    continue;
+                }
+
+                Object[] row = new Object[columnNames.length];
+                int columnIndex = 0;
+                row[columnIndex++] = rowData;
+                row[columnIndex++] = rowData.get("File");
+                row[columnIndex++] = rowData.get("Name");
+                row[columnIndex++] = rowData.get("SQL");
+                row[columnIndex++] = rowData.get("ExecuteCount");
+
+                row[columnIndex++] = rowData.get("ErrorCount");
+                row[columnIndex++] = rowData.get("TotalTime");
+                row[columnIndex++] = rowData.get("LastTime");
+                row[columnIndex++] = rowData.get("MaxTimespan");
+                row[columnIndex++] = rowData.get("LastError");
+
+                row[columnIndex++] = rowData.get("EffectedRowCount");
+                row[columnIndex++] = rowData.get("FetchRowCount");
+                row[columnIndex++] = rowData.get("ConcurrentMax");
+                row[columnIndex++] = rowData.get("RunningCount");
+
+                rowList.add(row);
+            }
+
+            Object[][] rows = new Object[rowList.size()][];
+            rowList.toArray(rows);
+            
+            int rowCount = tableModel.getRowCount();
+            tableModel.setRowData(rows);
+            tableModel.fireTableRowsDeleted(0, rowCount - 1);
+            
+            tableModel.setRowData(rows);
+            tableModel.fireTableRowsInserted(0, rows.length);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
     public void tableMouseClicked(MouseEvent e) {
         if (e.getClickCount() < 2) {
             return;
@@ -176,6 +230,10 @@ public class SQLPanel extends JPanel {
             return true;
         }
 
+        public void setRowData(Object[][] rowData) {
+            this.rowData = rowData;
+        }
+
         public void setValueAt(Object value, int row, int col) {
             rowData[row][col] = value;
             fireTableCellUpdated(row, col);