From d10e85c0f45adae26ce22118f44e593a3e018f95 Mon Sep 17 00:00:00 2001 From: wenshao Date: Sun, 25 Aug 2013 10:58:59 +0800 Subject: [PATCH] bug fixed for com.alibaba.druid.proxy.jdbc.StatementProxyImpl.getMoreResults --- .../com/alibaba/druid/proxy/jdbc/StatementProxyImpl.java | 4 +--- .../alibaba/druid/bvt/pool/SpringMybatisFilterTest.java | 8 ++++++++ 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/alibaba/druid/proxy/jdbc/StatementProxyImpl.java b/src/main/java/com/alibaba/druid/proxy/jdbc/StatementProxyImpl.java index c8aa5d33b8..f1c7c240a6 100644 --- a/src/main/java/com/alibaba/druid/proxy/jdbc/StatementProxyImpl.java +++ b/src/main/java/com/alibaba/druid/proxy/jdbc/StatementProxyImpl.java @@ -321,9 +321,7 @@ public class StatementProxyImpl extends WrapperProxyImpl implements StatementPro public boolean getMoreResults() throws SQLException { FilterChainImpl chain = createChain(); boolean value = chain.statement_getMoreResults(this); - if (value) { - updateCount = null; - } + updateCount = null; recycleFilterChain(chain); return value; } diff --git a/src/test/java/com/alibaba/druid/bvt/pool/SpringMybatisFilterTest.java b/src/test/java/com/alibaba/druid/bvt/pool/SpringMybatisFilterTest.java index 300d5fb031..93e980d95d 100644 --- a/src/test/java/com/alibaba/druid/bvt/pool/SpringMybatisFilterTest.java +++ b/src/test/java/com/alibaba/druid/bvt/pool/SpringMybatisFilterTest.java @@ -24,6 +24,7 @@ import junit.framework.TestCase; import org.apache.ibatis.annotations.Insert; import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; import org.junit.Assert; import org.springframework.context.support.ClassPathXmlApplicationContext; @@ -81,6 +82,10 @@ public class SpringMybatisFilterTest extends TestCase { userMapper.addUser(user); } + { + userMapper.errorSelect(1); + } + { Connection conn = dataSource.getConnection(); Statement stmt = conn.createStatement(); @@ -105,5 +110,8 @@ public class SpringMybatisFilterTest extends TestCase { @Insert(value = "insert into t_User (id, name) values (#{user.id}, #{user.name})") void addUser(@Param("user") User user); + + @Select(value = "delete from t_User where id = #{id}") + void errorSelect(@Param("id") long id); } }