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; - } }