Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

添加了显示sql语句详细信息的界面

Browse Source
This commit is contained in:
yunnysunny
2012-09-15 22:59:34 +08:00
parent 71ee73b098
commit a85d8faf4d
4 changed files with 406 additions and 76 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/support/jconsole/DruidPanel.java
+25 -73
View File
@@ -20,11 +20,8 @@ import java.awt.event.ComponentListener;
import java.util.ArrayList;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import javax.swing.BorderFactory;
import javax.swing.JLabel;
import javax.swing.JPanel;
@@ -32,9 +29,8 @@ import javax.swing.JScrollPane;
import javax.swing.JTable;
import javax.swing.border.TitledBorder;
import com.alibaba.druid.stat.DruidStatService;
import com.alibaba.druid.support.jconsole.model.DruidTableModel;
import com.alibaba.druid.support.json.JSONUtils;
import com.alibaba.druid.support.jconsole.util.TableDataProcessor;
import com.alibaba.druid.support.logging.Log;
import com.alibaba.druid.support.logging.LogFactory;
import com.sun.tools.jconsole.JConsoleContext;
@@ -46,34 +42,31 @@ import com.sun.tools.jconsole.JConsoleContext;
*/
public abstract class DruidPanel extends JPanel {
private static final long serialVersionUID = 1L;
/** 成功的返回码 */
protected static final int RESP_SUCCESS_RESULT = 1;
/** 返回码在json中的键名 */
protected static final String RESP_JSON_RESULT_KEY = "ResultCode";
/** 内容在json中的键名 */
protected static final String RESP_JSON_CONTENT_KEY = "Content";
private static final long serialVersionUID = 1L;
/** 默认面板刷新的间隔时间 */
protected static final long DEFAULT_ACTIVE_TIME = 5 * 60 * 1000;
protected static final long DEFAULT_ACTIVE_TIME = 5 * 60 * 1000;
/** 版权信息字符串 */
private static final String COPYRIGHT_STRING = "<html>powered by <a href=\"http://blog.csdn.net/yunnysunny\">yunnysunny</a></html>";
private static final String COPYRIGHT_STRING = "<html>powered by <a href=\"http://blog.csdn.net/yunnysunny\">yunnysunny</a></html>";
/** 滚动条面板 */
protected JScrollPane scrollPane;
protected JScrollPane scrollPane;
/** 表格模板 */
protected DruidTableModel tableModel;
protected DruidTableModel tableModel;
/** 表格 */
protected JTable table;
protected JTable table;
/** 版权面板 */
protected JPanel copyrightPanel;
protected JPanel copyrightPanel;
/** json请求的地址 */
protected String url;
protected String url;
/** 界面刷新的间隔时间，单位为毫秒. */
protected long activeTime;
protected long activeTime;
/** 上次刷新的时间 */
protected long lastRefreshTime;
private final static Log LOG = LogFactory.getLog(DruidPanel.class);
protected long lastRefreshTime;
/** 与界面管理的MBeanServerConnection对象 */
protected MBeanServerConnection conn;
private final static Log LOG = LogFactory.getLog(DruidPanel.class);
/**
* 根据传入的刷新时间间隔来初始化.
@@ -91,53 +84,7 @@ public abstract class DruidPanel extends JPanel {
activeTime = DEFAULT_ACTIVE_TIME;
}
/**
* 解析调用service后得到JSON数据
*
* @param respData 获取到的json对象
* @return 返回解析后的数据
*/
@SuppressWarnings("unchecked")
protected ArrayList<LinkedHashMap<String, Object>> parseData(Object respData) {
ArrayList<LinkedHashMap<String, Object>> data = null;
if (respData instanceof Map) {
LinkedHashMap<String, Object> map = (LinkedHashMap<String, Object>) respData;
int rv = (Integer) map.get(RESP_JSON_RESULT_KEY);
if (rv == RESP_SUCCESS_RESULT) {
Object content = map.get(RESP_JSON_CONTENT_KEY);
if (content instanceof List) {
data = (ArrayList<LinkedHashMap<String, Object>>) content;
} else if (content instanceof Map) {
LinkedHashMap<String, Object> contentEle = (LinkedHashMap<String, Object>) content;
data = new ArrayList<LinkedHashMap<String, Object>>();
data.add(contentEle);
}
}
}
return data;
}
/**
* 调用service，返回数据
*
* @param url service的地址
* @param conn MBeanServerConnection对象
* @return 调用service后返回的数据
* @throws Exception
*/
protected Object getData(String url, MBeanServerConnection conn) throws Exception {
Object o = null;
ObjectName name = new ObjectName(DruidStatService.MBEAN_NAME);
String result = (String) conn.invoke(name, "service", new String[] { url },
new String[] { String.class.getName() });
o = JSONUtils.parse(result);
if (LOG.isDebugEnabled()) {
LOG.debug(o.toString());
}
return o;
}
/**
* 调用完service之后，各个子类对于解析后的数据的具体处理
@@ -154,7 +101,7 @@ public abstract class DruidPanel extends JPanel {
* @param conn MBeanServerConnection对象
* @throws Exception
*/
protected void addOrRefreshTable(String url, MBeanServerConnection conn) throws Exception {
protected void addOrRefreshTable(String url) throws Exception {
if (url != null) {
boolean needRefresh = false;
long timeNow = new Date().getTime();
@@ -211,7 +158,8 @@ public abstract class DruidPanel extends JPanel {
}
if (needRefresh) {
LOG.debug("refresh" + timeNow);
ArrayList<LinkedHashMap<String, Object>> data = parseData(getData(url, conn));
ArrayList<LinkedHashMap<String, Object>> data = TableDataProcessor.parseData(TableDataProcessor.getData(url,
conn));
if (data != null) {
tableDataProcess(data);
}
@@ -230,9 +178,13 @@ public abstract class DruidPanel extends JPanel {
}
protected void doInBackground(MBeanServerConnection conn) {
if (conn == null) {
LOG.warn("MBeanServerConnection is null");
return;
}
try {
addOrRefreshTable(url, conn);
this.conn = conn;
addOrRefreshTable(url);
} catch (Exception e) {
LOG.warn("", e);
}
src/main/java/com/alibaba/druid/support/jconsole/DruidSQLPanel.java
+1 -1
View File
@@ -299,7 +299,7 @@ public class DruidSQLPanel extends DruidPanel {
if (e.getClickCount() == 2) {// 点击几次，这里是双击事件
int row = table.getSelectedRow();
String id = ids.get(row);
System.out.println(id);
new DruidSqlDetailFrame(id,conn);
}
}
});
src/main/java/com/alibaba/druid/support/jconsole/DruidSqlDetailFrame.java
+313
View File
@@ -0,0 +1,313 @@
package com.alibaba.druid.support.jconsole;
import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.GridLayout;
import java.awt.Toolkit;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.Map.Entry;
import javax.management.MBeanServerConnection;
import javax.swing.BorderFactory;
import javax.swing.JFrame;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTable;
import javax.swing.JTextArea;
import javax.swing.border.TitledBorder;
import javax.swing.table.JTableHeader;
import javax.swing.table.TableColumn;
import com.alibaba.druid.support.jconsole.model.DruidTableCellRenderer;
import com.alibaba.druid.support.jconsole.model.DruidTableModel;
import com.alibaba.druid.support.jconsole.util.TableDataProcessor;
import com.alibaba.druid.support.jconsole.util.TableDataProcessor.ColumnData;
import com.alibaba.druid.support.logging.Log;
import com.alibaba.druid.support.logging.LogFactory;
/**
* sql语句的详细信息
*
* 调用服务地址：/sql-{id}.json
* 返回信息：
* <pre>
* {
"ResultCode": 1,
"Content": {
"ExecuteCount": 15,
"ReadStringLength": 0,
"LastSlowParameters": null,
"BlobOpenCount": 0,
"InputStreamOpenCount": 0,
"DbType": "mysql",
"DataSource": null,
"RunningCount": 0,
"parsedRelationships": "[]",
"ConcurrentMax": 1,
"LastErrorClass": null,
"MaxTimespan": 125,
"InTransactionCount": 0,
"ID": 3,
"parsedFields": "[]",
"EffectedRowCount": 0,
"BatchSizeTotal": 0,
"URL": null,
"ExecuteAndResultSetHoldTime": 0,
"LastErrorMessage": null,
"FetchRowCountHistogram": [
0,
0,
0,
0,
0,
0
],
"FetchRowCountMax": 0,
"Histogram": [
0,
0,
13,
2,
0,
0,
0,
0
],
"parsedOrderbycolumns": "[]",
"ErrorCount": 0,
"SQL": "DROP TABLE t_big",
"ClobOpenCount": 0,
"LastTime": "2012-09-14 21:35:10",
"File": null,
"LastErrorStackTrace": null,
"LastError": null,
"EffectedRowCountHistogram": [
15,
0,
0,
0,
0,
0
],
"TotalTime": 742,
"formattedSql": "DROP TABLE t_big",
"Name": null,
"MaxTimespanOccurTime": "2012/09/14 09:35:00:758",
"parsedTable": "{t_big=Drop}",
"BatchSizeMax": 0,
"ReadBytesLength": 0,
"EffectedRowCountMax": 0,
"FetchRowCount": 0,
"parsedConditions": "[]",
"ResultSetHoldTime": 0,
"ReaderOpenCount": 0,
"ExecuteAndResultHoldTimeHistogram": [
0,
0,
13,
2,
0,
0,
0,
0
],
"LastErrorTime": null
}
}
* </pre>
* */
public class DruidSqlDetailFrame extends JFrame {
private static final long serialVersionUID = 1L;
private static final String BASE_URL = "/sql";
private String id;
private MBeanServerConnection conn;
private static final ArrayList<String> PARESE_TITLE_LIST = new ArrayList<String>(){
private static final long serialVersionUID = 1L;
{
add("parsedTable");
add("parsedFields");
add("parsedConditions");
add("parsedRelationships");
add("parsedOrderbycolumns");
}
};
private static final ArrayList<String> LAST_SLOW_TITLE_LIST= new ArrayList<String>(){
private static final long serialVersionUID = 1L;
{
add("MaxTimespan");
add("MaxTimespanOccurTime");
add("LastSlowParameters");
}
};
private static final ArrayList<String> LAST_ERROR_TITLE_LIST= new ArrayList<String>(){
private static final long serialVersionUID = 1L;
{
add("LastErrorMessage");
add("LastErrorClass");
add("LastErrorTime");
add("LastErrorStackTrace");
}
};
private static final ArrayList<String> OTHER_ERROR_TITLE_LIST= new ArrayList<String>(){
private static final long serialVersionUID = 1L;
{
add("BatchSizeMax");
add("BatchSizeTotal");
add("BlobOpenCount");
add("ClobOpenCount");
add("ReaderOpenCount");
add("InputStreamOpenCount");
add("ReadStringLength");
add("ReadBytesLength");
}
};
private ArrayList<LinkedHashMap<String, Object>> parseData;
private ArrayList<LinkedHashMap<String, Object>> lastSlowData;
private ArrayList<LinkedHashMap<String, Object>> lastErrorData;
private ArrayList<LinkedHashMap<String, Object>> otherData;
private int maxListLen;
private String formatSql;
private String sql;
private static final int WIDTH = 620;
private static final int HEIGHT = 520;
private final static Log LOG = LogFactory.getLog(DruidSqlDetailFrame.class);
public DruidSqlDetailFrame(String id, MBeanServerConnection conn) {
this.id = id;
this.conn = conn;
getMaxListLen();
init();
start();
}
private void getMaxListLen() {
maxListLen = PARESE_TITLE_LIST.size();
int slowLen = LAST_SLOW_TITLE_LIST.size();
int errLen = LAST_ERROR_TITLE_LIST.size();
int otherLen = OTHER_ERROR_TITLE_LIST.size();
if (maxListLen < slowLen) {
maxListLen = slowLen;
}
if (maxListLen < errLen) {
maxListLen = errLen;
}
if (maxListLen < otherLen) {
maxListLen = otherLen;
}
}
private void init() {
String url = BASE_URL + "-" + id + ".json";
try {
ArrayList<LinkedHashMap<String, Object>> data = TableDataProcessor.parseData(TableDataProcessor.getData(url,conn));
if (data != null) {
LinkedHashMap<String, Object> contentEle = data.get(0);
formatSql = (String)contentEle.remove("formattedSql");
int parseLen = PARESE_TITLE_LIST.size();
int slowLen = LAST_SLOW_TITLE_LIST.size();
int errLen = LAST_ERROR_TITLE_LIST.size();
int otherLen = OTHER_ERROR_TITLE_LIST.size();
LinkedHashMap<String, Object> parseDataEle = new LinkedHashMap<String, Object>();
LinkedHashMap<String, Object> slowDataEle = new LinkedHashMap<String, Object>();
LinkedHashMap<String, Object> errDataEle = new LinkedHashMap<String, Object>();
LinkedHashMap<String, Object> otherDataEle = new LinkedHashMap<String, Object>();
parseData = new ArrayList<LinkedHashMap<String, Object>>(1);
lastSlowData = new ArrayList<LinkedHashMap<String, Object>>(1);
lastErrorData = new ArrayList<LinkedHashMap<String, Object>>(1);
otherData = new ArrayList<LinkedHashMap<String, Object>>(1);
for (Iterator<Entry<String, Object>> it = contentEle.entrySet().iterator(); it.hasNext();) {
Entry<String, Object> entry = it.next();
String key = entry.getKey();
Object value = entry.getValue();
for(int i=0;i<maxListLen;i++) {
if (i < parseLen && key.equals(PARESE_TITLE_LIST.get(i))) {
parseDataEle.put(key, value);
} else if (i < slowLen && key.equals(LAST_SLOW_TITLE_LIST.get(i))) {
slowDataEle.put(key, value);
} else if (i < errLen && key.equals(LAST_ERROR_TITLE_LIST.get(i))) {
errDataEle.put(key, value);
} else if (i < otherLen && key.equals(OTHER_ERROR_TITLE_LIST.get(i))) {
otherDataEle.put(key, value);
}
}
}
parseData.add(parseDataEle);
lastSlowData.add(slowDataEle);
lastErrorData.add(errDataEle);
otherData.add(otherDataEle);
} else {
LOG.warn("错误的json格式");
}
} catch (Exception e) {
LOG.warn("获取数据时异常",e);
}
}
private void addTable(JPanel contentPanel,String title,ArrayList<LinkedHashMap<String, Object>> data) {
final JPanel content1 = new JPanel();
content1.setLayout(new BorderLayout());
content1.setBorder((TitledBorder)BorderFactory.createTitledBorder(title));
contentPanel.add(content1);
ColumnData colData = TableDataProcessor.row2col(data);
JTable table = new JTable();
DruidTableModel tableModel = new DruidTableModel(colData.getDatas());
table.setModel(tableModel);
TableColumn col = table.getColumnModel().getColumn(0);
col.setCellRenderer(new DruidTableCellRenderer());
final JTableHeader header1 = table.getTableHeader();
content1.add(header1,BorderLayout.NORTH);
content1.add(table);
}
private void addComponentsToPane(Container pane) {
JScrollPane scrollPane = new JScrollPane();
JPanel contentPanel = new JPanel();
contentPanel.setLayout(new GridLayout(0,1));
final JTextArea sqlField = new JTextArea(formatSql,15,20);
final JScrollPane content1 = new JScrollPane (sqlField);
content1.setBorder((TitledBorder)BorderFactory.createTitledBorder("SQL语句"));
contentPanel.add(content1);
addTable(contentPanel,"解析信息",parseData);
addTable(contentPanel,"上次慢查询信息",lastSlowData);
addTable(contentPanel,"上次错误查询信息",lastErrorData);
addTable(contentPanel,"其他信息",otherData);
scrollPane.setViewportView(contentPanel);
pane.add(scrollPane,BorderLayout.CENTER);
}
private void start() {
addComponentsToPane(getContentPane());
pack();
setSize(WIDTH, HEIGHT);
double width = Toolkit.getDefaultToolkit().getScreenSize().getWidth();
double height = Toolkit.getDefaultToolkit().getScreenSize().getHeight();
setLocation( (int) (width - getWidth()) / 2,
(int) (height - getHeight()) / 2);
setVisible(true);
}
}
src/main/java/com/alibaba/druid/support/jconsole/util/TableDataProcessor.java
+67 -2
View File
@@ -17,8 +17,17 @@ package com.alibaba.druid.support.jconsole.util;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import javax.management.MBeanServerConnection;
import javax.management.ObjectName;
import com.alibaba.druid.stat.DruidStatService;
import com.alibaba.druid.support.json.JSONUtils;
import com.alibaba.druid.support.logging.Log;
import com.alibaba.druid.support.logging.LogFactory;
/**
* 表格数据处理类
*
@@ -27,10 +36,18 @@ import java.util.Map;
public final class TableDataProcessor {
/** 名称列的列名. */
private static final String COLUMN_KEY_NAME = "名称";
private static final String COLUMN_KEY_NAME = "名称";
/** 内容列的列名. */
private static final String COLUMN_VALUE_NAME = "值";
private static final String COLUMN_VALUE_NAME = "值";
/** 返回码在json中的键名 */
private static final String RESP_JSON_RESULT_KEY = "ResultCode";
/** 内容在json中的键名 */
private static final String RESP_JSON_CONTENT_KEY = "Content";
/** 成功的返回码 */
protected static final int RESP_SUCCESS_RESULT = 1;
private final static Log LOG = LogFactory.getLog(TableDataProcessor.class);
/**
* TableDataProcessor的构造函数
@@ -124,6 +141,54 @@ public final class TableDataProcessor {
public static ColumnData row2col(ArrayList<LinkedHashMap<String, Object>> rowDatas) {
return row2col(rowDatas, null);
}
/**
* 解析调用service后得到JSON数据
*
* @param respData 获取到的json对象
* @return 返回解析后的数据
*/
@SuppressWarnings("unchecked")
public static ArrayList<LinkedHashMap<String, Object>> parseData(Object respData) {
ArrayList<LinkedHashMap<String, Object>> data = null;
if (respData instanceof Map) {
LinkedHashMap<String, Object> map = (LinkedHashMap<String, Object>) respData;
int rv = (Integer) map.get(RESP_JSON_RESULT_KEY);
if (rv == RESP_SUCCESS_RESULT) {
Object content = map.get(RESP_JSON_CONTENT_KEY);
if (content instanceof List) {
data = (ArrayList<LinkedHashMap<String, Object>>) content;
} else if (content instanceof Map) {
LinkedHashMap<String, Object> contentEle = (LinkedHashMap<String, Object>) content;
data = new ArrayList<LinkedHashMap<String, Object>>();
data.add(contentEle);
}
}
}
return data;
}
/**
* 调用service，返回数据
*
* @param url service的地址
* @param conn MBeanServerConnection对象
* @return 调用service后返回的数据
* @throws Exception
*/
public static Object getData(String url, MBeanServerConnection conn) throws Exception {
Object o = null;
ObjectName name = new ObjectName(DruidStatService.MBEAN_NAME);
String result = (String) conn.invoke(name, "service", new String[] { url },
new String[] { String.class.getName() });
o = JSONUtils.parse(result);
if (LOG.isDebugEnabled()) {
LOG.debug(o.toString());
}
return o;
}
/**
* The Class ColumnData.