From 9c23429d70a2110da3a0e6e45c1e2a5347ee4afa Mon Sep 17 00:00:00 2001 From: melin Date: Sat, 6 Apr 2013 15:40:28 +0800 Subject: [PATCH] =?UTF-8?q?Revert=20"wall.html=E5=A2=9E=E5=8A=A0=E6=8E=92?= =?UTF-8?q?=E5=BA=8F"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit eb78871f0bb47c5dadd4975877806a19bc881048. --- .../alibaba/druid/stat/DruidStatService.java | 764 +++++++++--------- .../support/http/resources/wall.html | 131 ++- 2 files changed, 443 insertions(+), 452 deletions(-) diff --git a/src/main/java/com/alibaba/druid/stat/DruidStatService.java b/src/main/java/com/alibaba/druid/stat/DruidStatService.java index e8ac57e4fd..28d40a91e1 100644 --- a/src/main/java/com/alibaba/druid/stat/DruidStatService.java +++ b/src/main/java/com/alibaba/druid/stat/DruidStatService.java @@ -1,385 +1,379 @@ -/* - * Copyright 1999-2011 Alibaba Group Holding Ltd. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.alibaba.druid.stat; - -import java.lang.management.ManagementFactory; -import java.text.DateFormat; -import java.text.SimpleDateFormat; -import java.util.Collections; -import java.util.Date; -import java.util.LinkedHashMap; -import java.util.List; -import java.util.Map; - -import javax.management.JMException; -import javax.management.MBeanServer; -import javax.management.ObjectName; - -import com.alibaba.druid.sql.SQLUtils; -import com.alibaba.druid.sql.ast.SQLStatement; -import com.alibaba.druid.sql.visitor.SchemaStatVisitor; -import com.alibaba.druid.support.http.stat.WebAppStatManager; -import com.alibaba.druid.support.json.JSONUtils; -import com.alibaba.druid.support.logging.Log; -import com.alibaba.druid.support.logging.LogFactory; -import com.alibaba.druid.support.spring.stat.SpringStatManager; -import com.alibaba.druid.util.MapComparator; -import com.alibaba.druid.util.StringUtils; - -/** - * 注意：避免直接调用Druid相关对象例如DruidDataSource等，相关调用要到DruidStatManagerFacade里用反射实现 - * - * @author sandzhang - */ -public final class DruidStatService implements DruidStatServiceMBean { - - private final static Log LOG = LogFactory.getLog(DruidStatService.class); - - public final static String MBEAN_NAME = "com.alibaba.druid:type=DruidStatService"; - - private final static DruidStatService instance = new DruidStatService(); - - private static DruidStatManagerFacade statManagerFacade = DruidStatManagerFacade.getInstance(); - - public final static int RESULT_CODE_SUCCESS = 1; - public final static int RESULT_CODE_ERROR = -1; - - private final static int DEFAULT_PAGE = 1; - private final static int DEFAULT_PER_PAGE_COUNT = Integer.MAX_VALUE; - private static final String DEFAULT_ORDER_TYPE = "asc"; - private static final String DEFAULT_ORDERBY = "SQL"; - - private DruidStatService(){ - } - - public static DruidStatService getInstance() { - return instance; - } - - public boolean isResetEnable() { - return statManagerFacade.isResetEnable(); - } - - public void setResetEnable(boolean value) { - statManagerFacade.setResetEnable(value); - } - - public String service(String url) { - - Map parameters = getParameters(url); - - if (url.equals("/basic.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, statManagerFacade.returnJSONBasicStat()); - } - - if (url.equals("/reset-all.json")) { - statManagerFacade.resetAll(); - - return returnJSONResult(RESULT_CODE_SUCCESS, null); - } - - if (url.equals("/datasource.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, statManagerFacade.getDataSourceStatDataList()); - } - - if (url.equals("/activeConnectionStackTrace.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, statManagerFacade.getActiveConnStackTraceList()); - } - - if (url.startsWith("/datasource-")) { - Integer id = StringUtils.subStringToInteger(url, "datasource-", "."); - Object result = statManagerFacade.getDataSourceStatData(id); - return returnJSONResult(result == null ? RESULT_CODE_ERROR : RESULT_CODE_SUCCESS, result); - } - - if (url.startsWith("/connectionInfo-") && url.endsWith(".json")) { - Integer id = StringUtils.subStringToInteger(url, "connectionInfo-", "."); - List connectionInfoList = statManagerFacade.getPoolingConnectionInfoByDataSourceId(id); - return returnJSONResult(connectionInfoList == null ? RESULT_CODE_ERROR : RESULT_CODE_SUCCESS, - connectionInfoList); - } - - if (url.startsWith("/activeConnectionStackTrace-") && url.endsWith(".json")) { - Integer id = StringUtils.subStringToInteger(url, "activeConnectionStackTrace-", "."); - return returnJSONActiveConnectionStackTrace(id); - } - - if (url.startsWith("/sql.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, getSqlStatDataList(parameters)); - } - - if (url.startsWith("/wall.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, getWallStatMap(parameters)); - } - - if (url.startsWith("/wall-") && url.indexOf(".json") > 0) { - Integer dataSourceId = StringUtils.subStringToInteger(url, "wall-", ".json"); - Object result = statManagerFacade.getWallStatMap(dataSourceId); - return returnJSONResult(result == null ? RESULT_CODE_ERROR : RESULT_CODE_SUCCESS, result); - } - - if (url.startsWith("/sql-") && url.indexOf(".json") > 0) { - Integer id = StringUtils.subStringToInteger(url, "sql-", ".json"); - return getSqlStat(id); - } - - if (url.startsWith("/weburi.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, getWebURIStatDataList(parameters)); - } - - if (url.startsWith("/weburi-") && url.indexOf(".json") > 0) { - String uri = StringUtils.subString(url, "weburi-", ".json"); - return returnJSONResult(RESULT_CODE_SUCCESS, getWebURIStatData(uri)); - } - - if (url.startsWith("/webapp.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, getWebAppStatDataList(parameters)); - } - - if (url.startsWith("/websession.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, getWebSessionStatDataList(parameters)); - } - - if (url.startsWith("/websession-") && url.indexOf(".json") > 0) { - String id = StringUtils.subString(url, "websession-", ".json"); - return returnJSONResult(RESULT_CODE_SUCCESS, getWebSessionStatData(id)); - } - - if (url.startsWith("/spring.json")) { - return returnJSONResult(RESULT_CODE_SUCCESS, getSpringStatDataList(parameters)); - } - - if (url.startsWith("/spring-detail.json")) { - String clazz = parameters.get("class"); - String method = parameters.get("method"); - return returnJSONResult(RESULT_CODE_SUCCESS, getSpringMethodStatData(clazz, method)); - } - - return returnJSONResult(RESULT_CODE_ERROR, "Do not support this request, please contact with administrator."); - } - - private List> getSpringStatDataList(Map parameters) { - List> array = SpringStatManager.getInstance().getMethodStatData(); - return comparatorOrderBy(array, parameters); - } - - private List> getWebURIStatDataList(Map parameters) { - List> array = WebAppStatManager.getInstance().getURIStatData(); - return comparatorOrderBy(array, parameters); - } - - private Map getWebURIStatData(String uri) { - return WebAppStatManager.getInstance().getURIStatData(uri); - } - - private Map getWebSessionStatData(String sessionId) { - return WebAppStatManager.getInstance().getSessionStat(sessionId); - } - - private Map getSpringMethodStatData(String clazz, String method) { - return SpringStatManager.getInstance().getMethodStatData(clazz, method); - } - - private List> getWebSessionStatDataList(Map parameters) { - List> array = WebAppStatManager.getInstance().getSessionStatData(); - return comparatorOrderBy(array, parameters); - } - - private List> getWebAppStatDataList(Map parameters) { - List> array = WebAppStatManager.getInstance().getWebAppStatData(); - return comparatorOrderBy(array, parameters); - } - - private List> comparatorOrderBy(List> array, Map parameters) { - // when open the stat page before executing some sql - if (array == null || array.isEmpty()) { - return null; - } - - // when parameters is null - String orderBy, orderType = null; - Integer page = DEFAULT_PAGE; - Integer perPageCount = DEFAULT_PER_PAGE_COUNT; - if (parameters == null) { - orderBy = DEFAULT_ORDER_TYPE; - orderType = DEFAULT_ORDER_TYPE; - page = DEFAULT_PAGE; - perPageCount = DEFAULT_PER_PAGE_COUNT; - } else { - orderBy = parameters.get("orderBy"); - orderType = parameters.get("orderType"); - String pageParam = parameters.get("page"); - if (pageParam != null && pageParam.length() != 0) { - page = Integer.parseInt(pageParam); - } - String pageCountParam = parameters.get("perPageCount"); - if (pageCountParam != null && pageCountParam.length() > 0) { - perPageCount = Integer.parseInt(pageCountParam); - } - } - - // others,such as order - orderBy = orderBy == null ? DEFAULT_ORDERBY : orderBy; - orderType = orderType == null ? DEFAULT_ORDER_TYPE : orderType; - - if (!"desc".equals(orderType)) { - orderType = DEFAULT_ORDER_TYPE; - } - - // orderby the statData array - if (orderBy != null && orderBy.trim().length() != 0) { - Collections.sort(array, new MapComparator(orderBy, DEFAULT_ORDER_TYPE.equals(orderType))); - } - - // page - int fromIndex = (page - 1) * perPageCount; - int toIndex = page * perPageCount; - if (toIndex > array.size()) { - toIndex = array.size(); - } - - return array.subList(fromIndex, toIndex); - } - - private List> getSqlStatDataList(Map parameters) { - Integer dataSourceId = null; - - String dataSourceIdParam = parameters.get("dataSourceId"); - if (dataSourceIdParam != null && dataSourceIdParam.length() > 0) { - dataSourceId = Integer.parseInt(dataSourceIdParam); - } - - List> array = statManagerFacade.getSqlStatDataList(dataSourceId); - List> sortedArray = comparatorOrderBy(array, parameters); - return sortedArray; - } - - public Map getWallStatMap(Map parameters) { - Integer dataSourceId = null; - - String dataSourceIdParam = parameters.get("dataSourceId"); - if (dataSourceIdParam != null && dataSourceIdParam.length() > 0) { - dataSourceId = Integer.parseInt(dataSourceIdParam); - } - - Map result = statManagerFacade.getWallStatMap(dataSourceId); - List> sortedArray = comparatorOrderBy((List>)result.get("tables"), parameters); - result.put("tables", sortedArray); - - sortedArray = comparatorOrderBy((List>)result.get("functions"), parameters); - result.put("functions", sortedArray); - - return result; - } - - private String getSqlStat(Integer id) { - Map map = statManagerFacade.getSqlStatData(id); - - if (map == null) { - return returnJSONResult(RESULT_CODE_ERROR, null); - } - - String dbType = (String) map.get("DbType"); - String sql = (String) map.get("SQL"); - - map.put("formattedSql", SQLUtils.format(sql, dbType)); - List statementList = SQLUtils.parseStatements(sql, dbType); - - if (!statementList.isEmpty()) { - SQLStatement statemen = statementList.get(0); - SchemaStatVisitor visitor = SQLUtils.createSchemaStatVisitor(statementList, dbType); - statemen.accept(visitor); - map.put("parsedTable", visitor.getTables().toString()); - map.put("parsedFields", visitor.getColumns().toString()); - map.put("parsedConditions", visitor.getConditions().toString()); - map.put("parsedRelationships", visitor.getRelationships().toString()); - map.put("parsedOrderbycolumns", visitor.getOrderByColumns().toString()); - } - - DateFormat format = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss:SSS"); - Date maxTimespanOccurTime = (Date) map.get("MaxTimespanOccurTime"); - if (maxTimespanOccurTime != null) { - map.put("MaxTimespanOccurTime", format.format(maxTimespanOccurTime)); - } - - return returnJSONResult(map == null ? RESULT_CODE_ERROR : RESULT_CODE_SUCCESS, map); - } - - private String returnJSONActiveConnectionStackTrace(Integer id) { - List result = statManagerFacade.getActiveConnectionStackTraceByDataSourceId(id); - - if (result == null) { - return returnJSONResult(RESULT_CODE_ERROR, "require set removeAbandoned=true"); - } - return returnJSONResult(RESULT_CODE_SUCCESS, result); - } - - public static String returnJSONResult(int resultCode, Object content) { - Map dataMap = new LinkedHashMap(); - dataMap.put("ResultCode", resultCode); - dataMap.put("Content", content); - return JSONUtils.toJSONString(dataMap); - } - - public static void registerMBean() { - MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer(); - try { - - ObjectName objectName = new ObjectName(MBEAN_NAME); - if (!mbeanServer.isRegistered(objectName)) { - mbeanServer.registerMBean(instance, objectName); - } - } catch (JMException ex) { - LOG.error("register mbean error", ex); - } - } - - public static void unregisterMBean() { - MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer(); - - try { - mbeanServer.unregisterMBean(new ObjectName(MBEAN_NAME)); - } catch (JMException ex) { - LOG.error("unregister mbean error", ex); - } - } - - public static Map getParameters(String url) { - if (url == null || (url = url.trim()).length() == 0) { - return Collections. emptyMap(); - } - - String parametersStr = StringUtils.subString(url, "?", null); - if (parametersStr == null || parametersStr.length() == 0) { - return Collections. emptyMap(); - } - - String[] parametersArray = parametersStr.split("&"); - Map parameters = new LinkedHashMap(); - - for (String parameterStr : parametersArray) { - int index = parameterStr.indexOf("="); - if (index <= 0) { - continue; - } - - String name = parameterStr.substring(0, index); - String value = parameterStr.substring(index + 1); - parameters.put(name, value); - } - return parameters; - } -} +/* + * Copyright 1999-2011 Alibaba Group Holding Ltd. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package com.alibaba.druid.stat; + +import java.lang.management.ManagementFactory; +import java.text.DateFormat; +import java.text.SimpleDateFormat; +import java.util.Collections; +import java.util.Date; +import java.util.LinkedHashMap; +import java.util.List; +import java.util.Map; + +import javax.management.JMException; +import javax.management.MBeanServer; +import javax.management.ObjectName; + +import com.alibaba.druid.sql.SQLUtils; +import com.alibaba.druid.sql.ast.SQLStatement; +import com.alibaba.druid.sql.visitor.SchemaStatVisitor; +import com.alibaba.druid.support.http.stat.WebAppStatManager; +import com.alibaba.druid.support.json.JSONUtils; +import com.alibaba.druid.support.logging.Log; +import com.alibaba.druid.support.logging.LogFactory; +import com.alibaba.druid.support.spring.stat.SpringStatManager; +import com.alibaba.druid.util.MapComparator; +import com.alibaba.druid.util.StringUtils; + +/** + * 注意：避免直接调用Druid相关对象例如DruidDataSource等，相关调用要到DruidStatManagerFacade里用反射实现 + * + * @author sandzhang + */ +public final class DruidStatService implements DruidStatServiceMBean { + + private final static Log LOG = LogFactory.getLog(DruidStatService.class); + + public final static String MBEAN_NAME = "com.alibaba.druid:type=DruidStatService"; + + private final static DruidStatService instance = new DruidStatService(); + + private static DruidStatManagerFacade statManagerFacade = DruidStatManagerFacade.getInstance(); + + public final static int RESULT_CODE_SUCCESS = 1; + public final static int RESULT_CODE_ERROR = -1; + + private final static int DEFAULT_PAGE = 1; + private final static int DEFAULT_PER_PAGE_COUNT = Integer.MAX_VALUE; + private static final String DEFAULT_ORDER_TYPE = "asc"; + private static final String DEFAULT_ORDERBY = "SQL"; + + private DruidStatService(){ + } + + public static DruidStatService getInstance() { + return instance; + } + + public boolean isResetEnable() { + return statManagerFacade.isResetEnable(); + } + + public void setResetEnable(boolean value) { + statManagerFacade.setResetEnable(value); + } + + public String service(String url) { + + Map parameters = getParameters(url); + + if (url.equals("/basic.json")) { + return returnJSONResult(RESULT_CODE_SUCCESS, statManagerFacade.returnJSONBasicStat()); + } + + if (url.equals("/reset-all.json")) { + statManagerFacade.resetAll(); + + return returnJSONResult(RESULT_CODE_SUCCESS, null); + } + + if (url.equals("/datasource.json")) { + return returnJSONResult(RESULT_CODE_SUCCESS, statManagerFacade.getDataSourceStatDataList()); + } + + if (url.equals("/activeConnectionStackTrace.json")) { + return returnJSONResult(RESULT_CODE_SUCCESS, statManagerFacade.getActiveConnStackTraceList()); + } + + if (url.startsWith("/datasource-")) { + Integer id = StringUtils.subStringToInteger(url, "datasource-", "."); + Object result = statManagerFacade.getDataSourceStatData(id); + return returnJSONResult(result == null ? RESULT_CODE_ERROR : RESULT_CODE_SUCCESS, result); + } + + if (url.startsWith("/connectionInfo-") && url.endsWith(".json")) { + Integer id = StringUtils.subStringToInteger(url, "connectionInfo-", "."); + List connectionInfoList = statManagerFacade.getPoolingConnectionInfoByDataSourceId(id); + return returnJSONResult(connectionInfoList == null ? RESULT_CODE_ERROR : RESULT_CODE_SUCCESS, + connectionInfoList); + } + + if (url.startsWith("/activeConnectionStackTrace-") && url.endsWith(".json")) { + Integer id = StringUtils.subStringToInteger(url, "activeConnectionStackTrace-", "."); + return returnJSONActiveConnectionStackTrace(id); + } + + if (url.startsWith("/sql.json")) { + return returnJSONResult(RESULT_CODE_SUCCESS, getSqlStatDataList(parameters)); + } + + if (url.startsWith("/wall.json")) { + Object result = statManagerFacade.getWallStatMap(null); + return returnJSONResult(RESULT_CODE_SUCCESS, result); + } + + if (url.startsWith("/wall-") && url.indexOf(".json") > 0) { + Integer dataSourceId = StringUtils.subStringToInteger(url, "wall-", ".json"); + Object result = statManagerFacade.getWallStatMap(dataSourceId); + return returnJSONResult(result == null ? RESULT_CODE_ERROR : RESULT_CODE_SUCCESS, result); + } + + if (url.startsWith("/sql-") && url.indexOf(".json") > 0) { + Integer id = StringUtils.subStringToInteger(url, "sql-", ".json"); + return getSqlStat(id); + } + + if (url.startsWith("/weburi.json")) { + return returnJSONResult(RESULT_CODE_SUCCESS, getWebURIStatDataList(parameters)); + } + + if (url.startsWith("/weburi-") && url.indexOf(".json") > 0) { + String uri = StringUtils.subString(url, "weburi-", ".json"); + return returnJSONResult(RESULT_CODE_SUCCESS, getWebURIStatData(uri)); + } + + if (url.startsWith("/webapp.json")) { + return returnJSONResult(RESULT_CODE_SUCCESS, getWebAppStatDataList(parameters)); + } + + if (url.startsWith("/websession.json")) { + return returnJSONResult(RESULT_CODE_SUCCESS, getWebSessionStatDataList(parameters)); + } + + if (url.startsWith("/websession-") && url.indexOf(".json") > 0) { + String id = StringUtils.subString(url, "websession-", ".json"); + return returnJSONResult(RESULT_CODE_SUCCESS, getWebSessionStatData(id)); + } + + if (url.startsWith("/spring.json")) { + return returnJSONResult(RESULT_CODE_SUCCESS, getSpringStatDataList(parameters)); + } + + if (url.startsWith("/spring-detail.json")) { + String clazz = parameters.get("class"); + String method = parameters.get("method"); + return returnJSONResult(RESULT_CODE_SUCCESS, getSpringMethodStatData(clazz, method)); + } + + return returnJSONResult(RESULT_CODE_ERROR, "Do not support this request, please contact with administrator."); + } + + private List> getSpringStatDataList(Map parameters) { + List> array = SpringStatManager.getInstance().getMethodStatData(); + return comparatorOrderBy(array, parameters); + } + + private List> getWebURIStatDataList(Map parameters) { + List> array = WebAppStatManager.getInstance().getURIStatData(); + return comparatorOrderBy(array, parameters); + } + + private Map getWebURIStatData(String uri) { + return WebAppStatManager.getInstance().getURIStatData(uri); + } + + private Map getWebSessionStatData(String sessionId) { + return WebAppStatManager.getInstance().getSessionStat(sessionId); + } + + private Map getSpringMethodStatData(String clazz, String method) { + return SpringStatManager.getInstance().getMethodStatData(clazz, method); + } + + private List> getWebSessionStatDataList(Map parameters) { + List> array = WebAppStatManager.getInstance().getSessionStatData(); + return comparatorOrderBy(array, parameters); + } + + private List> getWebAppStatDataList(Map parameters) { + List> array = WebAppStatManager.getInstance().getWebAppStatData(); + return comparatorOrderBy(array, parameters); + } + + private List> comparatorOrderBy(List> array, Map parameters) { + // when open the stat page before executing some sql + if (array == null || array.isEmpty()) { + return null; + } + + // when parameters is null + String orderBy, orderType = null; + Integer page = DEFAULT_PAGE; + Integer perPageCount = DEFAULT_PER_PAGE_COUNT; + if (parameters == null) { + orderBy = DEFAULT_ORDER_TYPE; + orderType = DEFAULT_ORDER_TYPE; + page = DEFAULT_PAGE; + perPageCount = DEFAULT_PER_PAGE_COUNT; + } else { + orderBy = parameters.get("orderBy"); + orderType = parameters.get("orderType"); + String pageParam = parameters.get("page"); + if (pageParam != null && pageParam.length() != 0) { + page = Integer.parseInt(pageParam); + } + String pageCountParam = parameters.get("perPageCount"); + if (pageCountParam != null && pageCountParam.length() > 0) { + perPageCount = Integer.parseInt(pageCountParam); + } + } + + // others,such as order + orderBy = orderBy == null ? DEFAULT_ORDERBY : orderBy; + orderType = orderType == null ? DEFAULT_ORDER_TYPE : orderType; + + if (!"desc".equals(orderType)) { + orderType = DEFAULT_ORDER_TYPE; + } + + // orderby the statData array + if (orderBy != null && orderBy.trim().length() != 0) { + Collections.sort(array, new MapComparator(orderBy, DEFAULT_ORDER_TYPE.equals(orderType))); + } + + // page + int fromIndex = (page - 1) * perPageCount; + int toIndex = page * perPageCount; + if (toIndex > array.size()) { + toIndex = array.size(); + } + + return array.subList(fromIndex, toIndex); + } + + private List> getSqlStatDataList(Map parameters) { + Integer dataSourceId = null; + + String dataSourceIdParam = parameters.get("dataSourceId"); + if (dataSourceIdParam != null && dataSourceIdParam.length() > 0) { + dataSourceId = Integer.parseInt(dataSourceIdParam); + } + + List> array = statManagerFacade.getSqlStatDataList(dataSourceId); + List> sortedArray = comparatorOrderBy(array, parameters); + return sortedArray; + } + + public Map getWallStatMap(Map parameters) { + Integer dataSourceId = null; + + String dataSourceIdParam = parameters.get("dataSourceId"); + if (dataSourceIdParam != null && dataSourceIdParam.length() > 0) { + dataSourceId = Integer.parseInt(dataSourceIdParam); + } + + return statManagerFacade.getWallStatMap(dataSourceId); + } + + private String getSqlStat(Integer id) { + Map map = statManagerFacade.getSqlStatData(id); + + if (map == null) { + return returnJSONResult(RESULT_CODE_ERROR, null); + } + + String dbType = (String) map.get("DbType"); + String sql = (String) map.get("SQL"); + + map.put("formattedSql", SQLUtils.format(sql, dbType)); + List statementList = SQLUtils.parseStatements(sql, dbType); + + if (!statementList.isEmpty()) { + SQLStatement statemen = statementList.get(0); + SchemaStatVisitor visitor = SQLUtils.createSchemaStatVisitor(statementList, dbType); + statemen.accept(visitor); + map.put("parsedTable", visitor.getTables().toString()); + map.put("parsedFields", visitor.getColumns().toString()); + map.put("parsedConditions", visitor.getConditions().toString()); + map.put("parsedRelationships", visitor.getRelationships().toString()); + map.put("parsedOrderbycolumns", visitor.getOrderByColumns().toString()); + } + + DateFormat format = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss:SSS"); + Date maxTimespanOccurTime = (Date) map.get("MaxTimespanOccurTime"); + if (maxTimespanOccurTime != null) { + map.put("MaxTimespanOccurTime", format.format(maxTimespanOccurTime)); + } + + return returnJSONResult(map == null ? RESULT_CODE_ERROR : RESULT_CODE_SUCCESS, map); + } + + private String returnJSONActiveConnectionStackTrace(Integer id) { + List result = statManagerFacade.getActiveConnectionStackTraceByDataSourceId(id); + + if (result == null) { + return returnJSONResult(RESULT_CODE_ERROR, "require set removeAbandoned=true"); + } + return returnJSONResult(RESULT_CODE_SUCCESS, result); + } + + public static String returnJSONResult(int resultCode, Object content) { + Map dataMap = new LinkedHashMap(); + dataMap.put("ResultCode", resultCode); + dataMap.put("Content", content); + return JSONUtils.toJSONString(dataMap); + } + + public static void registerMBean() { + MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer(); + try { + + ObjectName objectName = new ObjectName(MBEAN_NAME); + if (!mbeanServer.isRegistered(objectName)) { + mbeanServer.registerMBean(instance, objectName); + } + } catch (JMException ex) { + LOG.error("register mbean error", ex); + } + } + + public static void unregisterMBean() { + MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer(); + + try { + mbeanServer.unregisterMBean(new ObjectName(MBEAN_NAME)); + } catch (JMException ex) { + LOG.error("unregister mbean error", ex); + } + } + + public static Map getParameters(String url) { + if (url == null || (url = url.trim()).length() == 0) { + return Collections. emptyMap(); + } + + String parametersStr = StringUtils.subString(url, "?", null); + if (parametersStr == null || parametersStr.length() == 0) { + return Collections. emptyMap(); + } + + String[] parametersArray = parametersStr.split("&"); + Map parameters = new LinkedHashMap(); + + for (String parameterStr : parametersArray) { + int index = parameterStr.indexOf("="); + if (index <= 0) { + continue; + } + + String name = parameterStr.substring(0, index); + String value = parameterStr.substring(index + 1); + parameters.put(name, value); + } + return parameters; + } +} diff --git a/src/main/resources/support/http/resources/wall.html b/src/main/resources/support/http/resources/wall.html index e7d41f64a7..eac8bd835f 100644 --- a/src/main/resources/support/http/resources/wall.html +++ b/src/main/resources/support/http/resources/wall.html @@ -59,20 +59,20 @@ - +
- - - - - - - - - - - + + + + + + + + + + + @@ -80,8 +80,8 @@
Table NameSelectCountSelectIntoCountInsertCountUpdateCountDeleteCountTruncateCountCreateCountAlterCountDropCountReplaceCountTable NameSelectCountSelectIntoCountInsertCountUpdateCountDeleteCountTruncateCountCreateCountAlterCountDropCountReplaceCount
- - + + @@ -91,69 +91,66 @@
Function NameInvokeCountFunction NameInvokeCount