From c7e9863c1312503ef64d9376a7e713700caaafa0 Mon Sep 17 00:00:00 2001
From: wenshao <szujobs@hotmail.com>
Date: Tue, 20 Sep 2011 12:39:45 +0000
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85HADataSource=E7=9A=84?=
 =?UTF-8?q?=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

git-svn-id: http://code.alibabatech.com/svn/druid/trunk@892 b9813039-fb51-4c41-a8b9-e21c2acb5095
---
 .../druid/bvt/pool/ha/HADataSourceTest.java   | 50 ++++++++++++++++++-
 1 file changed, 49 insertions(+), 1 deletion(-)

diff --git a/src/test/java/com/alibaba/druid/bvt/pool/ha/HADataSourceTest.java b/src/test/java/com/alibaba/druid/bvt/pool/ha/HADataSourceTest.java
index 50c001b916..df47b9598e 100644
--- a/src/test/java/com/alibaba/druid/bvt/pool/ha/HADataSourceTest.java
+++ b/src/test/java/com/alibaba/druid/bvt/pool/ha/HADataSourceTest.java
@@ -22,9 +22,11 @@ public class HADataSourceTest extends TestCase {
     protected void setUp() throws Exception {
         dataSourceA = new DruidDataSource();
         dataSourceA.setUrl("jdbc:mock:x1");
+        dataSourceA.setFilters("trace");
 
         dataSourceB = new DruidDataSource();
         dataSourceB.setUrl("jdbc:mock:x1");
+        dataSourceB.setFilters("stat");
 
         dataSourceHA = new HADataSource();
         dataSourceHA.addDataSource(dataSourceA);
@@ -71,7 +73,7 @@ public class HADataSourceTest extends TestCase {
         Assert.assertEquals("cName", mockStmt.getCursorName());
         Assert.assertEquals(ResultSet.FETCH_REVERSE, mockStmt.getFetchDirection());
         Assert.assertEquals(202, mockStmt.getFetchSize());
-        
+
         {
             MultiDataSourceStatement dsStmt = stmt.unwrap(MultiDataSourceStatement.class);
             Assert.assertTrue(dsStmt.getId() > 0);
@@ -149,4 +151,50 @@ public class HADataSourceTest extends TestCase {
 
         conn.close();
     }
+
+    public void test_createStatement_4() throws Exception {
+        Connection conn = dataSourceHA.getConnection();
+
+        Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE,
+                                              ResultSet.CLOSE_CURSORS_AT_COMMIT);
+        stmt.executeUpdate("SET @user = 'xxx'");
+
+        MockStatement mockStmt = stmt.unwrap(MockStatement.class);
+        Assert.assertEquals(ResultSet.TYPE_SCROLL_INSENSITIVE, mockStmt.getResultSetType());
+        Assert.assertEquals(ResultSet.CONCUR_UPDATABLE, mockStmt.getResultSetConcurrency());
+        Assert.assertEquals(ResultSet.CLOSE_CURSORS_AT_COMMIT, mockStmt.getResultSetHoldability());
+        Assert.assertEquals(ResultSet.TYPE_SCROLL_INSENSITIVE, stmt.getResultSetType());
+        Assert.assertEquals(ResultSet.CONCUR_UPDATABLE, stmt.getResultSetConcurrency());
+        Assert.assertEquals(ResultSet.CLOSE_CURSORS_AT_COMMIT, stmt.getResultSetHoldability());
+
+        stmt.close();
+
+        conn.close();
+    }
+
+    public void test_close() throws Exception {
+        Connection conn = dataSourceHA.getConnection();
+
+        Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE,
+                                              ResultSet.CLOSE_CURSORS_AT_COMMIT);
+
+        stmt.getMaxFieldSize();
+        stmt.getMaxRows();
+        stmt.cancel();
+        stmt.getWarnings();
+        stmt.clearWarnings();
+        stmt.getResultSet();
+        stmt.getUpdateCount();
+        stmt.getMoreResults();
+        stmt.getMoreResults(1);
+        stmt.getResultSetConcurrency();
+        stmt.getResultSetHoldability();
+        stmt.getResultSetType();
+        stmt.getConnection();
+        stmt.getGeneratedKeys();
+        stmt.isClosed();
+        stmt.close();
+
+        conn.close();
+    }
 }