rollback septer error commit

2023-03-04 19:17:16 +00:00 · 2012-08-12 12:40:45 +08:00
parent 734704676d
commit f1cfe2e305
6 changed files with 142 additions and 476 deletions
@@ -16,8 +16,10 @@
 package com.alibaba.druid.stat;

 import java.lang.management.ManagementFactory;
-import java.util.HashMap;
+import java.lang.reflect.Method;
+import java.util.IdentityHashMap;
 import java.util.Map;
+import java.util.Properties;
 import java.util.Set;
 import java.util.concurrent.atomic.AtomicLong;

@@ -35,124 +37,179 @@ import javax.management.openmbean.TabularType;
 import com.alibaba.druid.pool.DruidDataSource;
 import com.alibaba.druid.support.logging.Log;
 import com.alibaba.druid.support.logging.LogFactory;
-import com.alibaba.druid.util.ConcurrentIdentityHashMap;
+import com.alibaba.druid.util.DruidDataSourceUtils;
 import com.alibaba.druid.util.JMXUtils;

+@SuppressWarnings("rawtypes")
 public class DruidDataSourceStatManager implements DruidDataSourceStatManagerMBean {

-    private final static Log                                                    LOG         = LogFactory.getLog(DruidDataSourceStatManager.class);
+    public final static String                      SYS_PROP_INSTANCES = "druid.dataSources";

-    private final static DruidDataSourceStatManager                             instance    = new DruidDataSourceStatManager();
+    private final static Log                        LOG                = LogFactory.getLog(DruidDataSourceStatManager.class);

-    private final AtomicLong                                                    resetCount  = new AtomicLong();
+    private final static DruidDataSourceStatManager instance           = new DruidDataSourceStatManager();
+
+    private final AtomicLong                        resetCount         = new AtomicLong();

    // global instances
-    private static final ConcurrentIdentityHashMap<DruidDataSource, ObjectName> dataSources = new ConcurrentIdentityHashMap<DruidDataSource, ObjectName>();
+    private static IdentityHashMap                  dataSources;

-    private final static String                                                 MBEAN_NAME  = "com.alibaba.druid:type=DruidDataSourceStat";
+    private final static String                     MBEAN_NAME         = "com.alibaba.druid:type=DruidDataSourceStat";

    public static DruidDataSourceStatManager getInstance() {
        return instance;
    }
-    
+
    public static void cear() {
-        MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
-        for (Map.Entry<DruidDataSource, ObjectName> entry : dataSources.entrySet()) {
-            ObjectName objectName = entry.getValue();
-            if (objectName == null) {
-                continue;
-            }
-            try {
-                mbeanServer.unregisterMBean(objectName);
-            } catch (JMException e) {
-                LOG.error(e.getMessage(), e);
-            }
-        }
-        dataSources.clear();
-    }
+        IdentityHashMap<Object, ObjectName> dataSources = getInstances();

-    public synchronized static ObjectName add(DruidDataSource dataSource, String name) {
-        MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
-        if (dataSources.size() == 0) {
-            try {
+        synchronized (dataSources) {
+            MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
+            for (Object item : dataSources.entrySet()) {
+                Map.Entry entry = (Map.Entry) item;
+                ObjectName objectName = (ObjectName) entry.getValue();

-                ObjectName objectName = new ObjectName(MBEAN_NAME);
-                if (!mbeanServer.isRegistered(objectName)) {
-                    mbeanServer.registerMBean(instance, objectName);
+                if (objectName == null) {
+                    continue;
                }
-            } catch (JMException ex) {
-                LOG.error("register mbean error", ex);
-            }
-        }

-        ObjectName objectName = null;
-        if (name != null) {
-            try {
-                objectName = new ObjectName("com.alibaba.druid:type=DruidDataSource,id=" + name);
-                mbeanServer.registerMBean(dataSource, objectName);
-            } catch (JMException ex) {
-                LOG.error("register mbean error", ex);
-                objectName = null;
+                try {
+                    mbeanServer.unregisterMBean(objectName);
+                } catch (JMException e) {
+                    LOG.error(e.getMessage(), e);
+                }
            }
+            dataSources.clear();
        }
-
-        if (objectName == null) {
-            try {
-                int id = System.identityHashCode(dataSource);
-                objectName = new ObjectName("com.alibaba.druid:type=DruidDataSource,id=" + id);
-                mbeanServer.registerMBean(dataSource, objectName);
-            } catch (JMException ex) {
-                LOG.error("register mbean error", ex);
-                objectName = null;
-            }
-        }
-
-        dataSources.put(dataSource, objectName);
-        return objectName;
    }

-    public synchronized static void remove(DruidDataSource dataSource) {
-        ObjectName objectName = dataSources.remove(dataSource);
-
-        if (objectName == null) {
-            objectName = dataSource.getObjectName();
+    @SuppressWarnings("unchecked")
+    public static IdentityHashMap<Object, ObjectName> getInstances() {
+        if (dataSources == null) {
+            dataSources = getInstances0();
        }

-        if (objectName == null) {
-            LOG.error("unregister mbean failed. url " + dataSource.getUrl());
-            return;
-        }
+        return dataSources;
+    }

-        MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
+    @SuppressWarnings("unchecked")
+    static IdentityHashMap<Object, ObjectName> getInstances0() {
+        Properties properties = System.getProperties();
+        IdentityHashMap<Object, ObjectName> instances = (IdentityHashMap<Object, ObjectName>) properties.get(SYS_PROP_INSTANCES);

-        if (objectName != null) {
-            try {
-                mbeanServer.unregisterMBean(objectName);
-            } catch (JMException ex) {
-                LOG.error("unregister mbean error", ex);
+        if (instances == null) {
+            synchronized (properties) {
+                instances = (IdentityHashMap<Object, ObjectName>) properties.get(SYS_PROP_INSTANCES);
+
+                if (instances == null) {
+                    instances = new IdentityHashMap<Object, ObjectName>();
+                    properties.put(SYS_PROP_INSTANCES, instances);
+                }
            }
        }

-        if (dataSources.size() == 0) {
-            try {
-                mbeanServer.unregisterMBean(new ObjectName(MBEAN_NAME));
-            } catch (JMException ex) {
-                LOG.error("unregister mbean error", ex);
+        return instances;
+    }
+
+    public synchronized static ObjectName addDataSource(Object dataSource, String name) {
+        final IdentityHashMap<Object, ObjectName> instances = getInstances();
+
+        synchronized (instances) {
+            MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
+            if (instances.size() == 0) {
+                try {
+
+                    ObjectName objectName = new ObjectName(MBEAN_NAME);
+                    if (!mbeanServer.isRegistered(objectName)) {
+                        mbeanServer.registerMBean(instance, objectName);
+                    }
+                } catch (JMException ex) {
+                    LOG.error("register mbean error", ex);
+                }
+            }
+
+            ObjectName objectName = null;
+            if (name != null) {
+                try {
+                    objectName = new ObjectName("com.alibaba.druid:type=DruidDataSource,id=" + name);
+                    mbeanServer.registerMBean(dataSource, objectName);
+                } catch (JMException ex) {
+                    LOG.error("register mbean error", ex);
+                    objectName = null;
+                }
+            }
+
+            if (objectName == null) {
+                try {
+                    int id = System.identityHashCode(dataSource);
+                    objectName = new ObjectName("com.alibaba.druid:type=DruidDataSource,id=" + id);
+                    mbeanServer.registerMBean(dataSource, objectName);
+                } catch (JMException ex) {
+                    LOG.error("register mbean error", ex);
+                    objectName = null;
+                }
+            }
+
+            instances.put(dataSource, objectName);
+            return objectName;
+        }
+    }
+
+    public synchronized static void removeDataSource(Object dataSource) {
+        IdentityHashMap<Object, ObjectName> instances = getInstances();
+
+        synchronized (instances) {
+            ObjectName objectName = (ObjectName) instances.remove(dataSource);
+
+            if (objectName == null) {
+                objectName = DruidDataSourceUtils.getObjectName(dataSource);
+            }
+
+            if (objectName == null) {
+                LOG.error("unregister mbean failed. url " + DruidDataSourceUtils.getUrl(dataSource));
+                return;
+            }
+
+            MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
+
+            if (objectName != null) {
+                try {
+                    mbeanServer.unregisterMBean(objectName);
+                } catch (JMException ex) {
+                    LOG.error("unregister mbean error", ex);
+                }
+            }
+
+            if (instances.size() == 0) {
+                try {
+                    mbeanServer.unregisterMBean(new ObjectName(MBEAN_NAME));
+                } catch (JMException ex) {
+                    LOG.error("unregister mbean error", ex);
+                }
            }
        }
    }

+    @SuppressWarnings("unchecked")
    public static Set<DruidDataSource> getDruidDataSourceInstances() {
        return dataSources.keySet();
    }

    public void reset() {
-        final Set<DruidDataSource> dataSources = getDruidDataSourceInstances();
-        for (DruidDataSource dataSource : dataSources) {
-            dataSource.resetStat();
-        }
+        IdentityHashMap<Object, ObjectName> dataSources = getInstances();

-        resetCount.incrementAndGet();
+        synchronized (dataSources) {
+            for (Object item : dataSources.keySet()) {
+                try {
+                    Method method = item.getClass().getMethod("resetStat");
+                    method.invoke(item);
+                } catch (Exception e) {
+                    LOG.error("resetStat error", e);
+                }
+            }
+
+            resetCount.incrementAndGet();
+        }
    }

    public long getResetCount() {
@@ -166,80 +223,18 @@ public class DruidDataSourceStatManager implements DruidDataSourceStatManagerMBe
        TabularType tabularType = new TabularType("DruidDataSourceStat", "DruidDataSourceStat", rowType, indexNames);
        TabularData data = new TabularDataSupport(tabularType);

-        final Set<DruidDataSource> dataSources = getDruidDataSourceInstances();
-        for (DruidDataSource dataSource : dataSources) {
+        final Set<Object> dataSources = getInstances().keySet();
+        for (Object dataSource : dataSources) {
            data.put(getCompositeData(dataSource));
        }

        return data;
    }

-    public CompositeDataSupport getCompositeData(DruidDataSource dataSource) throws JMException {
+    public CompositeDataSupport getCompositeData(Object dataSource) throws JMException {
        CompositeType rowType = getDruidDataSourceCompositeType();

-        Map<String, Object> map = new HashMap<String, Object>();
-
-        // 0 - 4
-        map.put("Name", dataSource.getName());
-        map.put("URL", dataSource.getUrl());
-        map.put("CreateCount", dataSource.getCreateCount());
-        map.put("DestroyCount", dataSource.getDestroyCount());
-        map.put("ConnectCount", dataSource.getConnectCount());
-
-        // 5 - 9
-        map.put("CloseCount", dataSource.getCloseCount());
-        map.put("ActiveCount", dataSource.getActivePeak());
-        map.put("PoolingCount", dataSource.getPoolingCount());
-        map.put("LockQueueLength", dataSource.getLockQueueLength());
-        map.put("WaitThreadCount", dataSource.getNotEmptyWaitThreadPeak());
-
-        // 10 - 14
-        map.put("InitialSize", dataSource.getInitialSize());
-        map.put("MaxActive", dataSource.getMaxActive());
-        map.put("MinIdle", dataSource.getMinIdle());
-        map.put("PoolPreparedStatements", dataSource.isPoolPreparedStatements());
-        map.put("TestOnBorrow", dataSource.isTestOnBorrow());
-
-        // 15 - 19
-        map.put("TestOnReturn", dataSource.isTestOnReturn());
-        map.put("MinEvictableIdleTimeMillis", dataSource.getMinEvictableIdleTimeMillis());
-        map.put("ConnectErrorCount", dataSource.getConnectErrorCount());
-        map.put("CreateTimespanMillis", dataSource.getCreateTimespanMillis());
-        map.put("DbType", dataSource.getDbType());
-
-        // 20 - 24
-        map.put("ValidationQuery", dataSource.getValidationQuery());
-        map.put("ValidationQueryTimeout", dataSource.getValidationQueryTimeout());
-        map.put("DriverClassName", dataSource.getDriverClassName());
-        map.put("Username", dataSource.getUsername());
-        map.put("RemoveAbandonedCount", dataSource.getRemoveAbandonedCount());
-
-        // 25 - 29
-        map.put("NotEmptyWaitCount", dataSource.getNotEmptyWaitCount());
-        map.put("NotEmptyWaitNanos", dataSource.getNotEmptyWaitNanos());
-        map.put("ErrorCount", dataSource.getErrorCount());
-        map.put("ReusePreparedStatementCount", dataSource.getCachedPreparedStatementHitCount());
-        map.put("StartTransactionCount", dataSource.getStartTransactionCount());
-
-        // 30 - 34
-        map.put("CommitCount", dataSource.getCommitCount());
-        map.put("RollbackCount", dataSource.getRollbackCount());
-        map.put("LastError", JMXUtils.getErrorCompositeData(dataSource.getLastError()));
-        map.put("LastCreateError", JMXUtils.getErrorCompositeData(dataSource.getLastCreateError()));
-        map.put("PreparedStatementCacheDeleteCount", dataSource.getCachedPreparedStatementDeleteCount());
-
-        // 35 - 39
-        map.put("PreparedStatementCacheAccessCount", dataSource.getCachedPreparedStatementAccessCount());
-        map.put("PreparedStatementCacheMissCount", dataSource.getCachedPreparedStatementMissCount());
-        map.put("PreparedStatementCacheHitCount", dataSource.getCachedPreparedStatementHitCount());
-        map.put("PreparedStatementCacheCurrentCount", dataSource.getCachedPreparedStatementCount());
-        map.put("Version", dataSource.getVersion());
-
-        // 40 -
-        map.put("LastErrorTime", dataSource.getLastErrorTime());
-        map.put("LastCreateErrorTime", dataSource.getLastCreateErrorTime());
-        map.put("CreateErrorCount", dataSource.getCreateErrorCount());
-        map.put("DiscardCount", dataSource.getDiscardCount());
+        Map<String, Object> map = DruidDataSourceUtils.getStatData(dataSource);

        return new CompositeDataSupport(rowType, map);
    }
@@ -1,75 +0,0 @@
-package com.alibaba.druid.stat;
-
-import java.util.List;
-import java.util.Map;
-
-/**
- * 监控相关的对外数据暴露
- * 
- * <pre>
- * 1. 为了支持jndi数据源本类内部调用druid相关对象均需要反射调用,返回值也应该是Object,List<Object>,Map<String,Object>等无关于druid的类型
- * 2. 对外暴露的public方法都应该先调用init()，应该有更好的方式，暂时没想到
- * </pre>
- * 
- * @author sandzhang<sandzhangtoo@gmail.com>
- */
-public class DruidStatManagerFacade {
-
-    private final static DruidStatManagerFacade       instance = new DruidStatManagerFacade();
-
-    private static DruidDataSourceStatStrategyContext ctx      = null;
-
-    private static DruidDataSourceStatStrategy        strategy = null;
-
-    static {
-        strategy = new DruidDataSourceStatJNDIStatStrategy();
-        ctx = new DruidDataSourceStatStrategyContext(strategy);
-    }
-
-    private DruidStatManagerFacade(){
-    }
-
-    public static DruidStatManagerFacade getInstance() {
-        return instance;
-    }
-
-    public Map<String, Object> getSqlStatData(Integer id) {
-        return ctx.getSqlStatData(id);
-    }
-
-    public List<Map<String, Object>> getSqlStatDataList() {
-        return ctx.getSqlStatDataList();
-    }
-
-    public List<String> getActiveConnectionStackTraceByDataSourceId(Integer id) {
-        return ctx.getActiveConnectionStackTraceByDataSourceId(id);
-    }
-
-    public Map<String, Object> returnJSONBasicStat() {
-        return ctx.returnJSONBasicStat();
-    }
-
-    public List<Object> getDataSourceStatList() {
-        return ctx.getDataSourceStatList();
-    }
-
-    public Map<String, Object> getDataSourceStatData(Integer id) {
-        return ctx.getDataSourceStatData(id);
-    }
-
-    public List<Map<String, Object>> getPoolingConnectionInfoByDataSourceId(Integer id) {
-        return ctx.getPoolingConnectionInfoByDataSourceId(id);
-    }
-
-    public void resetAll() {
-        ctx.resetAll();
-    }
-
-    public Object getDruidDataSourceById(Integer id) {
-        return ctx.getDruidDataSourceById(id);
-    }
-
-    public Object getSqlStatById(Integer id) {
-        return ctx.getSqlStatById(id);
-    }
-}
@@ -1,75 +0,0 @@
-package com.alibaba.druid.stat;
-
-import java.util.List;
-import java.util.Map;
-
-/**
- * 监控相关的对外数据暴露
- * 
- * <pre>
- * 1. 为了支持jndi数据源本类内部调用druid相关对象均需要反射调用,返回值也应该是Object,List<Object>,Map<String,Object>等无关于druid的类型
- * 2. 对外暴露的public方法都应该先调用init()，应该有更好的方式，暂时没想到
- * </pre>
- * 
- * @author sandzhang<sandzhangtoo@gmail.com>
- */
-public class DruidStatManagerFacade {
-
-    private final static DruidStatManagerFacade       instance = new DruidStatManagerFacade();
-
-    private static DruidDataSourceStatStrategyContext ctx      = null;
-
-    private static DruidDataSourceStatStrategy        strategy = null;
-
-    static {
-        strategy = new DruidDataSourceStatReflectStatStrategy();
-        ctx = new DruidDataSourceStatStrategyContext(strategy);
-    }
-
-    private DruidStatManagerFacade(){
-    }
-
-    public static DruidStatManagerFacade getInstance() {
-        return instance;
-    }
-
-    public Map<String, Object> getSqlStatData(Integer id) {
-        return ctx.getSqlStatData(id);
-    }
-
-    public List<Map<String, Object>> getSqlStatDataList() {
-        return ctx.getSqlStatDataList();
-    }
-
-    public List<String> getActiveConnectionStackTraceByDataSourceId(Integer id) {
-        return ctx.getActiveConnectionStackTraceByDataSourceId(id);
-    }
-
-    public Map<String, Object> returnJSONBasicStat() {
-        return ctx.returnJSONBasicStat();
-    }
-
-    public List<Object> getDataSourceStatList() {
-        return ctx.getDataSourceStatList();
-    }
-
-    public Map<String, Object> getDataSourceStatData(Integer id) {
-        return ctx.getDataSourceStatData(id);
-    }
-
-    public List<Map<String, Object>> getPoolingConnectionInfoByDataSourceId(Integer id) {
-        return ctx.getPoolingConnectionInfoByDataSourceId(id);
-    }
-
-    public void resetAll() {
-        ctx.resetAll();
-    }
-
-    public Object getDruidDataSourceById(Integer id) {
-        return ctx.getDruidDataSourceById(id);
-    }
-
-    public Object getSqlStatById(Integer id) {
-        return ctx.getSqlStatById(id);
-    }
-}
@@ -1,168 +0,0 @@
-package com.alibaba.druid.stat;
-
-import java.sql.Driver;
-import java.sql.DriverManager;
-import java.util.ArrayList;
-import java.util.Enumeration;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import com.alibaba.druid.VERSION;
-import com.alibaba.druid.util.DruidDataSourceUtils;
-import com.alibaba.druid.util.JdbcSqlStatUtils;
-
-/**
- * 监控相关的对外数据暴露
- * 
- * <pre>
- * 1. 为了支持jndi数据源本类内部调用druid相关对象均需要反射调用,返回值也应该是Object,List<Object>,Map<String,Object>等无关于druid的类型
- * 2. 对外暴露的public方法都应该先调用init()，应该有更好的方式，暂时没想到
- * </pre>
- * 
- * @author sandzhang<sandzhangtoo@gmail.com>
- */
-public class DruidStatManagerFacade {
-
-    private final static DruidStatManagerFacade instance = new DruidStatManagerFacade();
-
-    private DruidStatManagerFacade(){
-    }
-
-    public static DruidStatManagerFacade getInstance() {
-        return instance;
-    }
-
-    private Set<Object> getDruidDataSourceInstances() {
-        return DruidDataSourceStatManager.getInstances().keySet();
-    }
-
-    public void resetDataSourceStat() {
-        DruidDataSourceStatManager.getInstance().reset();
-    }
-
-    public void resetSqlStat() {
-        JdbcStatManager.getInstance().reset();
-    }
-
-    public void resetAll() {
-        resetSqlStat();
-        resetDataSourceStat();
-    }
-
-    public Object getSqlStatById(Integer id) {
-        for (Object ds : getDruidDataSourceInstances()) {
-            Object sqlStat = DruidDataSourceUtils.getSqlStat(ds, id);
-            if (sqlStat != null) {
-                return sqlStat;
-            }
-        }
-        return null;
-    }
-
-    public Map<String, Object> getDataSourceStatData(Integer id) {
-        if (id == null) {
-            return null;
-        }
-
-        Object datasource = getDruidDataSourceById(id);
-        return datasource == null ? null : dataSourceToMapData(datasource);
-    }
-
-    public Object getDruidDataSourceById(Integer identity) {
-        if (identity == null) {
-            return null;
-        }
-
-        for (Object datasource : getDruidDataSourceInstances()) {
-            if (System.identityHashCode(datasource) == identity) {
-                return datasource;
-            }
-        }
-        return null;
-    }
-
-    public List<Map<String, Object>> getSqlStatDataList() {
-        List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
-        for (Object datasource : getDruidDataSourceInstances()) {
-            for (Object sqlStat : DruidDataSourceUtils.getSqlStatMap(datasource).values()) {
-
-                Map<String, Object> data = JdbcSqlStatUtils.getData(sqlStat);
-
-                long executeCount = (Long) data.get("ExecuteCount");
-                long runningCount = (Long) data.get("RunningCount");
-
-                if (executeCount == 0 && runningCount == 0) {
-                    continue;
-                }
-
-                result.add(data);
-            }
-        }
-        return result;
-    }
-
-    public Map<String, Object> getSqlStatData(Integer id) {
-        if (id == null) {
-            return null;
-        }
-
-        Object sqlStat = getSqlStatById(id);
-
-        if (sqlStat == null) {
-            return null;
-        }
-
-        return JdbcSqlStatUtils.getData(sqlStat);
-    }
-
-    public List<Object> getDataSourceStatList() {
-        List<Object> datasourceList = new ArrayList<Object>();
-        for (Object dataSource : getDruidDataSourceInstances()) {
-            datasourceList.add(dataSourceToMapData(dataSource));
-        }
-        return datasourceList;
-    }
-
-    public Map<String, Object> returnJSONBasicStat() {
-        Map<String, Object> dataMap = new LinkedHashMap<String, Object>();
-        dataMap.put("Version", VERSION.getVersionNumber());
-        dataMap.put("Drivers", getDriversData());
-        return dataMap;
-    }
-
-    private List<String> getDriversData() {
-        List<String> drivers = new ArrayList<String>();
-        for (Enumeration<Driver> e = DriverManager.getDrivers(); e.hasMoreElements();) {
-            Driver driver = e.nextElement();
-            drivers.add(driver.getClass().getName());
-        }
-        return drivers;
-    }
-
-    public List<Map<String, Object>> getPoolingConnectionInfoByDataSourceId(Integer id) {
-        Object datasource = getDruidDataSourceById(id);
-
-        if (datasource == null) {
-            return null;
-        }
-
-        return DruidDataSourceUtils.getPoolingConnectionInfo(datasource);
-    }
-
-    public List<String> getActiveConnectionStackTraceByDataSourceId(Integer id) {
-        Object datasource = getDruidDataSourceById(id);
-
-        if (datasource == null || DruidDataSourceUtils.isRemoveAbandoned(datasource)) {
-            return null;
-        }
-
-        return DruidDataSourceUtils.getActiveConnectionStackTrace(datasource);
-    }
-
-    private Map<String, Object> dataSourceToMapData(Object dataSource) {
-
-        return DruidDataSourceUtils.getStatData(dataSource);
-    }
-}
@@ -1,11 +0,0 @@
-package com.alibaba.druid.stat;
-
-import java.lang.reflect.Method;
-import java.util.HashMap;
-
-public abstract class ReflectStatStrategy {
-
-    public final static HashMap<Object, HashMap<String, Method>> methodHM = new HashMap<Object, HashMap<String, Method>>();
-
-    public abstract Object invoke(Object obj, String methodName, Integer id);
-}
@@ -81,7 +81,7 @@ public class DruidDataSourceUtils {
        }
    }

-    @SuppressWarnings("unchecked")
+    @SuppressWarnings({ "rawtypes" })
    public static Map getSqlStatMap(Object druidDatasource) {
        try {
            Method method = druidDatasource.getClass().getMethod("getSqlStatMap");