From c761650c789bb3d4e3b0964559e76e6f5cd6d39b Mon Sep 17 00:00:00 2001
From: wenshao <szujobs@hotmail.com>
Date: Thu, 15 Aug 2013 20:38:45 +0800
Subject: [PATCH] bug fixed

---
 .../monitor/dao/MonitorDaoJdbcImpl.java       | 43 ++++++++++++++++++-
 .../monitor/MonitorDaoJdbcImplTest.java       |  4 +-
 2 files changed, 43 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/alibaba/druid/support/monitor/dao/MonitorDaoJdbcImpl.java b/src/main/java/com/alibaba/druid/support/monitor/dao/MonitorDaoJdbcImpl.java
index f2a4159cc6..148cb93bed 100644
--- a/src/main/java/com/alibaba/druid/support/monitor/dao/MonitorDaoJdbcImpl.java
+++ b/src/main/java/com/alibaba/druid/support/monitor/dao/MonitorDaoJdbcImpl.java
@@ -373,8 +373,13 @@ private void loadHashValue(FieldInfo hashField, List<?> list, Map<String, Object
 
         for (Object statValue : list) {
             try {
-                String sql = "select hash, value from druid_const where domain = ? AND app = ? and type = ? and value = ?";
                 Long hash = (Long) hashField.field.get(statValue);
+                String value = hashField.getCacheValue(hash);
+
+                if (value == null) {
+                    value = getConstValueFromDb(domain, app, hashField.getHashForType(), hash);
+                }
+                hashField.getHashFor().set(statValue, value);
             } catch (IllegalArgumentException e) {
                 throw new DruidRuntimeException("set field error" + hashField.getField(), e);
             } catch (IllegalAccessException e) {
@@ -383,6 +388,36 @@ private void loadHashValue(FieldInfo hashField, List<?> list, Map<String, Object
         }
     }
 
+    protected String getConstValueFromDb(String domain, String app, String type, Long hash) {
+        String sql = "select value from druid_const where domain = ? AND app = ? and type = ? and hash = ?";
+
+        Connection conn = null;
+        PreparedStatement stmt = null;
+        ResultSet rs = null;
+        try {
+            conn = dataSource.getConnection();
+            stmt = conn.prepareStatement(sql);
+
+            stmt.setString(1, domain);
+            stmt.setString(2, app);
+            stmt.setString(3, type);
+            stmt.setLong(4, hash);
+
+            rs = stmt.executeQuery();
+            if (rs.next()) {
+                return rs.getString(1);
+            }
+        } catch (SQLException ex) {
+            LOG.error("save const error error", ex);
+        } finally {
+            JdbcUtils.close(rs);
+            JdbcUtils.close(stmt);
+            JdbcUtils.close(conn);
+        }
+
+        return null;
+    }
+
     private void saveHash(FieldInfo hashField, MonitorContext ctx, List<?> list) {
         final String hashType = hashField.getHashForType();
 
@@ -703,13 +738,17 @@ public void hashCacheAdd(long hash, String value) {
             if (hashCache.size() > 1000) {
                 return;
             }
-            
+
             hashCache.put(hash, value);
         }
 
         public boolean hashCacheContains(long hash) {
             return hashCache.containsKey(hash);
         }
+
+        public String getCacheValue(long hash) {
+            return hashCache.get(hash);
+        }
     }
 
     @Override
diff --git a/src/test/java/com/alibaba/druid/bvt/support/monitor/MonitorDaoJdbcImplTest.java b/src/test/java/com/alibaba/druid/bvt/support/monitor/MonitorDaoJdbcImplTest.java
index 8ebd0436b9..ac98f2c1a0 100644
--- a/src/test/java/com/alibaba/druid/bvt/support/monitor/MonitorDaoJdbcImplTest.java
+++ b/src/test/java/com/alibaba/druid/bvt/support/monitor/MonitorDaoJdbcImplTest.java
@@ -24,8 +24,8 @@ public class MonitorDaoJdbcImplTest extends TestCase {
     protected void setUp() throws Exception {
         dataSource = new DruidDataSource();
         dataSource.setUrl("jdbc:h2:mem:test");
-        dataSource.setInitialSize(2);
-        dataSource.setMinIdle(2);
+        dataSource.setInitialSize(1);
+        dataSource.setMinIdle(1);
         dataSource.setFilters("wall,stat,log4j");
         dataSource.init();
     }