From 2ebed9c0526a68d616e071ea88324e1d3552d9d4 Mon Sep 17 00:00:00 2001 From: wenshao Date: Tue, 7 Aug 2012 07:19:30 +0800 Subject: [PATCH] bug fixed pooledStatementStat --- .../java/com/alibaba/druid/filter/stat/StatFilter.java | 4 ++-- .../druid/proxy/jdbc/PreparedStatementProxyImpl.java | 9 --------- 2 files changed, 2 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/alibaba/druid/filter/stat/StatFilter.java b/src/main/java/com/alibaba/druid/filter/stat/StatFilter.java index c475aa61a1..3241a5a6d9 100644 --- a/src/main/java/com/alibaba/druid/filter/stat/StatFilter.java +++ b/src/main/java/com/alibaba/druid/filter/stat/StatFilter.java @@ -341,7 +341,7 @@ public class StatFilter extends FilterEventAdapter implements StatFilterMBean { final int batchSize = statement.getBatchSqlList().size(); JdbcSqlStat sqlStat = statement.getSqlStat(); - if (sqlStat == null) { + if (sqlStat == null || sqlStat.isRemoved()) { sqlStat = createSqlStat(statement, sql); statement.setSqlStat(sqlStat); } @@ -380,7 +380,7 @@ public class StatFilter extends FilterEventAdapter implements StatFilterMBean { // //////////SQL JdbcSqlStat sqlStat = statement.getSqlStat(); - if (sqlStat == null) { + if (sqlStat == null || sqlStat.isRemoved()) { sqlStat = createSqlStat(statement, sql); statement.setSqlStat(sqlStat); } diff --git a/src/main/java/com/alibaba/druid/proxy/jdbc/PreparedStatementProxyImpl.java b/src/main/java/com/alibaba/druid/proxy/jdbc/PreparedStatementProxyImpl.java index 37b373e975..4888ee452d 100644 --- a/src/main/java/com/alibaba/druid/proxy/jdbc/PreparedStatementProxyImpl.java +++ b/src/main/java/com/alibaba/druid/proxy/jdbc/PreparedStatementProxyImpl.java @@ -466,13 +466,4 @@ public class PreparedStatementProxyImpl extends StatementProxyImpl implements Pr return super.unwrap(iface); } - - public JdbcSqlStat getSqlStat() { - if (sqlStat != null && sqlStat.isRemoved()) { - JdbcSqlStat sqlStat = this.getConnectionProxy().getDirectDataSource().getDataSourceStat().createSqlStat(sql); - sqlStat.setDbType(this.sqlStat.getDbType()); - this.sqlStat = sqlStat; - } - return sqlStat; - } }