fixed test

This commit is contained in:
温少
2012-03-20 07:03:29 +08:00
parent 0e40c7a5f3
commit 70ae17c006
3 changed files with 7 additions and 15 deletions
@@ -261,7 +261,7 @@ public class StatFilter extends FilterEventAdapter implements StatFilterMBean {
final String sql = statement.getBatchSql();
final int batchSize = statement.getBatchSqlList().size();
JdbcSqlStat sqlStat = getSqlStat(statement);
JdbcSqlStat sqlStat = statement.getSqlStat();
if (sqlStat == null) {
sqlStat = createSqlStat(statement, sql);
statement.setSqlStat(sqlStat);
@@ -300,7 +300,7 @@ public class StatFilter extends FilterEventAdapter implements StatFilterMBean {
// //////////SQL
JdbcSqlStat sqlStat = getSqlStat(statement);
JdbcSqlStat sqlStat = statement.getSqlStat();
if (sqlStat == null) {
sqlStat = createSqlStat(statement, sql);
statement.setSqlStat(sqlStat);
@@ -337,7 +337,7 @@ public class StatFilter extends FilterEventAdapter implements StatFilterMBean {
if (attr == null) {
statement.getAttributes().put(ATTR_UPDATE_COUNT, updateCount);
final JdbcSqlStat sqlStat = getSqlStat(statement);
final JdbcSqlStat sqlStat = statement.getSqlStat();
if (sqlStat != null) {
sqlStat.addUpdateCount(updateCount);
}
@@ -357,7 +357,7 @@ public class StatFilter extends FilterEventAdapter implements StatFilterMBean {
dataSourceStat.getStatementStat().afterExecute(nanoSpan);
// // SQL
final JdbcSqlStat sqlStat = getSqlStat(statement);
final JdbcSqlStat sqlStat = statement.getSqlStat();
if (sqlStat != null) {
sqlStat.incrementExecuteSuccessCount();
@@ -456,7 +456,7 @@ public class StatFilter extends FilterEventAdapter implements StatFilterMBean {
connectionCounter.error(error);
// SQL
JdbcSqlStat sqlStat = getSqlStat(statement);
JdbcSqlStat sqlStat = statement.getSqlStat();
if (sqlStat != null) {
sqlStat.error(error);
@@ -647,14 +647,6 @@ public class StatFilter extends FilterEventAdapter implements StatFilterMBean {
return dataSourceStat.createSqlStat(sql);
}
public static JdbcSqlStat getSqlStat(StatementProxy statement) {
if (statement == null) {
return null;
}
return statement.getSqlStat();
}
public JdbcSqlStat getSqlCounter(String sql) {
return getSqlStat(sql);
}