Cluster: auto-commit was disabled after opening a connection.

h2/src/test/org/h2/test/db/TestCluster.java

@@ -35,10 +35,59 @@ public class TestCluster extends TestBase {
     }
 
     public void test() throws Exception {
+        testCase();
         testCreateClusterAtRuntime();
         testStartStopCluster();
     }
 
+    private void testCase() throws SQLException {
+        if (config.memory || config.networked || config.cipher != null) {
+            return;
+        }
+        int port1 = 9191, port2 = 9192;
+        String serverList = "localhost:" + port1 + ",localhost:" + port2;
+        deleteFiles();
+
+        org.h2.Driver.load();
+        String user = getUser(), password = getPassword();
+        Connection conn;
+        Statement stat;
+        String url1 = "jdbc:h2:tcp://localhost:" + port1 + "/test";
+        String url2 = "jdbc:h2:tcp://localhost:" + port2 + "/test";
+        String urlCluster = "jdbc:h2:tcp://" + serverList + "/test";
+
+        Server n1 = org.h2.tools.Server.createTcpServer("-tcpPort", "" + port1, "-baseDir", getBaseDir() + "/node1").start();
+        Server n2 = org.h2.tools.Server.createTcpServer("-tcpPort", "" + port2 , "-baseDir", getBaseDir() + "/node2").start();
+
+        CreateCluster.main("-urlSource", url1, "-urlTarget", url2, "-user", user, "-password", password, "-serverList",
+                serverList);
+
+        conn = DriverManager.getConnection(urlCluster, user, password);
+        stat = conn.createStatement();
+        assertTrue(conn.getAutoCommit());
+        stat.execute("create table test(name int)");
+        assertTrue(conn.getAutoCommit());
+        stat.execute("insert into test values(1)");
+        conn.setAutoCommit(false);
+        assertFalse(conn.getAutoCommit());
+        stat.execute("insert into test values(2)");
+        assertFalse(conn.getAutoCommit());
+        conn.rollback();
+        conn.close();
+
+        // stop server 2, and test if only one server is available
+        n2.stop();
+
+        conn = DriverManager.getConnection(urlCluster, user, password);
+        stat = conn.createStatement();
+        ResultSet rs = stat.executeQuery("select * from test");
+        assertTrue(rs.next());
+        assertEquals(1, rs.getInt(1));
+        conn.close();
+
+        n1.stop();
+        deleteFiles();
+    }
     private void testCreateClusterAtRuntime() throws SQLException {
         if (config.memory || config.networked || config.cipher != null) {
             return;