improve LogFilter

This commit is contained in:
wenshao
2012-11-27 14:44:32 +08:00
parent b66ecca5d7
commit ba1d978f9e
3 changed files with 45 additions and 4 deletions
@@ -386,7 +386,7 @@ public abstract class LogFilter extends FilterEventAdapter implements LogFilterM
double millis = nanos / (1000 * 1000);
statementLog("{conn-" + statement.getConnectionProxy().getId() + ", " + stmtId(statement) + "} executed. "
+ sql + " (" + millis + " milliseconds)");
+ millis + " millis. " + sql);
}
}
@@ -410,7 +410,7 @@ public abstract class LogFilter extends FilterEventAdapter implements LogFilterM
}
statementLog("{conn-" + statement.getConnectionProxy().getId() + ", " + stmtId(statement)
+ "} batch executed. " + sql + " (" + millis + " milliseconds)");
+ "} batch executed. " + millis + " millis. " + sql);
}
}
@@ -430,7 +430,7 @@ public abstract class LogFilter extends FilterEventAdapter implements LogFilterM
double millis = nanos / (1000 * 1000);
statementLog("{conn-" + statement.getConnectionProxy().getId() + ", " + stmtId(statement) + ", rs-"
+ resultSet.getId() + "} query executed. " + sql + " (" + millis + " milliseconds)");
+ resultSet.getId() + "} query executed. " + millis + " millis. " + sql);
}
}
@@ -450,7 +450,7 @@ public abstract class LogFilter extends FilterEventAdapter implements LogFilterM
double millis = nanos / (1000 * 1000);
statementLog("{conn-" + statement.getConnectionProxy().getId() + ", " + stmtId(statement)
+ "} update executed. effort " + updateCount + ". " + sql + " (" + millis + " milliseconds)");
+ "} update executed. effort " + updateCount + ". " + millis + " millis. " + sql);
}
}
@@ -0,0 +1,40 @@
package com.alibaba.druid.bvt.filter.log;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import junit.framework.TestCase;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.util.JdbcUtils;
public class LogFilterTest2 extends TestCase {
private DruidDataSource dataSource;
protected void setUp() throws Exception {
dataSource = new DruidDataSource();
dataSource.setUrl("jdbc:derby:classpath:petstore-db");
dataSource.setFilters("log4j");
}
public void test_select() throws Exception {
Connection conn = dataSource.getConnection();
PreparedStatement stmt = conn.prepareStatement("SELECT * FROM ITEM WHERE LISTPRICE > 10");
for (int i = 0; i < 10; ++i) {
ResultSet rs = stmt.executeQuery();
rs.close();
}
stmt.close();
conn.close();
}
protected void tearDown() throws Exception {
JdbcUtils.close(dataSource);
}
}
@@ -34,6 +34,7 @@ public class HibernateCRUDTest extends TestCase {
dataSource.setUsername("sa");
dataSource.setPassword("");
dataSource.setDefaultAutoCommit(false);
dataSource.setFilters("log4j");
/*init sessionFactory*/
LocalSessionFactoryBean factoryBean = new LocalSessionFactoryBean();