add stat CachedPreparedStatementMissCount

This commit is contained in:
wenshao
2011-12-29 09:45:11 +08:00
parent cf7d2906ea
commit 4938016f86
3 changed files with 18 additions and 4 deletions
@@ -187,7 +187,8 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements
protected final AtomicLong preparedStatementCount = new AtomicLong();
protected final AtomicLong closedPreparedStatementCount = new AtomicLong();
protected final AtomicLong cachedPreparedStatementCount = new AtomicLong();
protected final AtomicLong cachedPreparedStatementDeleteCount = new AtomicLong();
protected final AtomicLong cachedPreparedStatementDeleteCount = new AtomicLong();
protected final AtomicLong cachedPreparedStatementMissCount = new AtomicLong();
protected final Histogram transactionHistogram = new Histogram(
10,
@@ -255,11 +256,19 @@ public abstract class DruidAbstractDataSource extends WrapperAdapter implements
public void decrementCachedPreparedStatementCount() {
cachedPreparedStatementCount.decrementAndGet();
}
public void incrementCachedPreparedStatementDeleteCount() {
cachedPreparedStatementDeleteCount.incrementAndGet();
}
public void incrementCachedPreparedStatementMissCount() {
cachedPreparedStatementMissCount.incrementAndGet();
}
public long getCachedPreparedStatementMissCount() {
return cachedPreparedStatementMissCount.get();
}
public long getCachedPreparedStatementDeleteCount() {
return cachedPreparedStatementDeleteCount.get();
}
@@ -49,6 +49,8 @@ public class PreparedStatementPool {
if (holder != null) {
holder.incrementReusedCount();
} else {
dataSource.incrementCachedPreparedStatementMissCount();
}
return holder;
@@ -90,6 +92,7 @@ public class PreparedStatementPool {
if (remove) {
dataSource.closePreapredStatement(eldest.getValue());
dataSource.decrementCachedPreparedStatementCount();
dataSource.incrementCachedPreparedStatementDeleteCount();
}
return remove;
@@ -201,6 +201,8 @@ public class DruidDataSourceStatManager implements DruidDataSourceStatManagerMBe
map.put("LastError", JMXUtils.getErrorCompositeData(dataSource.getLastError()));
map.put("LastCreateError", JMXUtils.getErrorCompositeData(dataSource.getCreateError()));
map.put("PreparedStatementCacheDeleteCount", dataSource.getCachedPreparedStatementDeleteCount());
map.put("PreparedStatementCacheMissCount", dataSource.getCachedPreparedStatementMissCount());
map.put("Version", dataSource.getVersion());
return new CompositeDataSupport(rowType, map);
@@ -223,7 +225,7 @@ public class DruidDataSourceStatManager implements DruidDataSourceStatManagerMBe
SimpleType.STRING, SimpleType.INTEGER, SimpleType.STRING, SimpleType.STRING, SimpleType.LONG, //
SimpleType.LONG, SimpleType.LONG, SimpleType.LONG, SimpleType.LONG, SimpleType.LONG//
, SimpleType.LONG, SimpleType.LONG, JMXUtils.getThrowableCompositeType(), JMXUtils.getThrowableCompositeType(), SimpleType.LONG //
, SimpleType.STRING
, SimpleType.LONG, SimpleType.STRING
//
};
@@ -242,7 +244,7 @@ public class DruidDataSourceStatManager implements DruidDataSourceStatManagerMBe
"NotEmptyWaitCount", "NotEmptyWaitNanos", "ErrorCount", "ReusePreparedStatementCount",
"StartTransactionCount", //
"CommitCount", "RollbackCount", "LastError", "LastCreateError", "PreparedStatementCacheDeleteCount" //
, "Version"
, "CachedPreparedStatementMissCount", "Version"
//
};