Close
@@ -141,6 +165,12 @@
$("#BatchSizeMax").text(sqlInfo.BatchSizeMax)
$("#BatchSizeTotal").text(sqlInfo.BatchSizeTotal)
+ $("#BlobOpenCount").text(sqlInfo.BlobOpenCount)
+ $("#ClobOpenCount").text(sqlInfo.ClobOpenCount)
+ $("#InputStreamOpenCount").text(sqlInfo.InputStreamOpenCount)
+ $("#ReaderOpenCount").text(sqlInfo.ReaderOpenCount)
+ $("#ReadStringLength").text(sqlInfo.ReadStringLength)
+ $("#ReadBytesLength").text(sqlInfo.ReadBytesLength)
},
dataType: "json"
});
diff --git a/src/test/java/com/alibaba/druid/bvt/filter/StatFilterReadBytesLengthTest.java b/src/test/java/com/alibaba/druid/bvt/filter/StatFilterReadBytesLengthTest.java
new file mode 100644
index 0000000000..2322a13f99
--- /dev/null
+++ b/src/test/java/com/alibaba/druid/bvt/filter/StatFilterReadBytesLengthTest.java
@@ -0,0 +1,103 @@
+package com.alibaba.druid.bvt.filter;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+import junit.framework.Assert;
+import junit.framework.TestCase;
+
+import com.alibaba.druid.filter.FilterAdapter;
+import com.alibaba.druid.filter.FilterChain;
+import com.alibaba.druid.pool.DruidDataSource;
+import com.alibaba.druid.proxy.jdbc.ResultSetProxy;
+import com.alibaba.druid.stat.JdbcSqlStat;
+import com.alibaba.druid.util.JdbcUtils;
+
+public class StatFilterReadBytesLengthTest extends TestCase {
+
+ private DruidDataSource dataSource;
+
+ protected void setUp() throws Exception {
+ dataSource = new DruidDataSource();
+
+ dataSource.setUrl("jdbc:mock:xxx");
+ dataSource.setFilters("stat");
+ dataSource.setTestOnBorrow(false);
+ dataSource.getProxyFilters().add(new FilterAdapter() {
+
+ @Override
+ public byte[] resultSet_getBytes(FilterChain chain, ResultSetProxy result, int columnIndex)
+ throws SQLException {
+ return new byte[6];
+ }
+
+ @Override
+ public byte[] resultSet_getBytes(FilterChain chain, ResultSetProxy result, String columnIndex)
+ throws SQLException {
+ return new byte[7];
+ }
+ });
+
+ dataSource.init();
+ }
+
+ protected void tearDown() throws Exception {
+ JdbcUtils.close(dataSource);
+ }
+
+ public void test_stat() throws Exception {
+ Connection conn = dataSource.getConnection();
+
+ String sql = "select 'x'";
+ PreparedStatement stmt = conn.prepareStatement("select 'x'");
+
+ JdbcSqlStat sqlStat = dataSource.getDataSourceStat().getSqlStat(sql);
+
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+ Assert.assertEquals(0, sqlStat.getReadBytesLength());
+
+ ResultSet rs = stmt.executeQuery();
+ rs.next();
+ rs.getBytes(1);
+ rs.close();
+ stmt.close();
+
+ conn.close();
+
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+ Assert.assertEquals(6, sqlStat.getReadBytesLength());
+
+ sqlStat.reset();
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+ Assert.assertEquals(0, sqlStat.getReadBytesLength());
+ }
+
+ public void test_stat_1() throws Exception {
+ Connection conn = dataSource.getConnection();
+
+ String sql = "select 'x'";
+ PreparedStatement stmt = conn.prepareStatement("select 'x'");
+
+ JdbcSqlStat sqlStat = dataSource.getDataSourceStat().getSqlStat(sql);
+
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+ Assert.assertEquals(0, sqlStat.getReadBytesLength());
+
+ ResultSet rs = stmt.executeQuery();
+ rs.next();
+ rs.getBytes("1");
+ rs.close();
+ stmt.close();
+
+ conn.close();
+
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+ Assert.assertEquals(7, sqlStat.getReadBytesLength());
+
+ sqlStat.reset();
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+ Assert.assertEquals(0, sqlStat.getReadBytesLength());
+ }
+}
diff --git a/src/test/java/com/alibaba/druid/bvt/filter/StatFilterReadStringLengthTest.java b/src/test/java/com/alibaba/druid/bvt/filter/StatFilterReadStringLengthTest.java
new file mode 100644
index 0000000000..5ff79aab1c
--- /dev/null
+++ b/src/test/java/com/alibaba/druid/bvt/filter/StatFilterReadStringLengthTest.java
@@ -0,0 +1,97 @@
+package com.alibaba.druid.bvt.filter;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+import junit.framework.Assert;
+import junit.framework.TestCase;
+
+import com.alibaba.druid.filter.FilterAdapter;
+import com.alibaba.druid.filter.FilterChain;
+import com.alibaba.druid.pool.DruidDataSource;
+import com.alibaba.druid.proxy.jdbc.ResultSetProxy;
+import com.alibaba.druid.stat.JdbcSqlStat;
+import com.alibaba.druid.util.JdbcUtils;
+
+public class StatFilterReadStringLengthTest extends TestCase {
+
+ private DruidDataSource dataSource;
+
+ protected void setUp() throws Exception {
+ dataSource = new DruidDataSource();
+
+ dataSource.setUrl("jdbc:mock:xxx");
+ dataSource.setFilters("stat");
+ dataSource.setTestOnBorrow(false);
+ dataSource.getProxyFilters().add(new FilterAdapter() {
+
+ @Override
+ public String resultSet_getString(FilterChain chain, ResultSetProxy result, int columnIndex)
+ throws SQLException {
+ return "123456";
+ }
+
+ @Override
+ public String resultSet_getString(FilterChain chain, ResultSetProxy result, String columnIndex)
+ throws SQLException {
+ return "1234567";
+ }
+ });
+
+ dataSource.init();
+ }
+
+ protected void tearDown() throws Exception {
+ JdbcUtils.close(dataSource);
+ }
+
+ public void test_stat() throws Exception {
+ Connection conn = dataSource.getConnection();
+
+ String sql = "select 'x'";
+ PreparedStatement stmt = conn.prepareStatement("select 'x'");
+
+ JdbcSqlStat sqlStat = dataSource.getDataSourceStat().getSqlStat(sql);
+
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+
+ ResultSet rs = stmt.executeQuery();
+ rs.next();
+ rs.getString(1);
+ rs.close();
+ stmt.close();
+
+ conn.close();
+
+ Assert.assertEquals(6, sqlStat.getReadStringLength());
+
+ sqlStat.reset();
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+ }
+
+ public void test_stat_1() throws Exception {
+ Connection conn = dataSource.getConnection();
+
+ String sql = "select 'x'";
+ PreparedStatement stmt = conn.prepareStatement("select 'x'");
+
+ JdbcSqlStat sqlStat = dataSource.getDataSourceStat().getSqlStat(sql);
+
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+
+ ResultSet rs = stmt.executeQuery();
+ rs.next();
+ rs.getString("1");
+ rs.close();
+ stmt.close();
+
+ conn.close();
+
+ Assert.assertEquals(7, sqlStat.getReadStringLength());
+
+ sqlStat.reset();
+ Assert.assertEquals(0, sqlStat.getReadStringLength());
+ }
+}