AJ-532:fix broken case

Author: weisun123

test/com/xxdb/ConnectionPoolTest.java

@@ -1668,7 +1668,7 @@ public void test_PartitionedTableAppender_ArrayVector_decimal128_compress_true()
         pool.shutdown();
     }
 
-    @Test(timeout = 200000)
+    @Test(timeout = 300000)
     public void test_PartitionedTableAppender_ArrayVector_BigData() throws Exception {
         String script = "if(existsDatabase(\"dfs://testArrayVector\")){\n" +
                 "    dropDatabase(\"dfs://testArrayVector\")\n" +

test/com/xxdb/DBConnectionTest.java

@@ -829,7 +829,6 @@ public void testDurationVector() throws Exception {
         dataStream.close();
         fos.close();
     }
-
     @Test
     public void testSymbolVector() throws IOException {
         BasicStringVector vector = (BasicStringVector) conn.run("rand(`IBM`MSFT`GOOG`BIDU,10)");

test/com/xxdb/LoadBalanceTest.java

@@ -376,6 +376,7 @@ public void Test_getConnection_enableHighAvailability_false_enableLoadBalance_fa
         }
         DBConnection connection1 = new DBConnection();
         connection1.connect(HOST, PORT, "admin", "123456",false);
+        connection1.run("sleep(1000)");
         BasicIntVector re = (BasicIntVector)connection1.run("EXEC connectionNum from rpc(getControllerAlias(),getClusterPerf) where port="+PORT);
         System.out.println(re.getInt(0));
         assertEquals(true,re.getInt(0)>100);
@@ -421,6 +422,7 @@ public void Test_getConnection_enableHighAvailability_true_enableLoadBalance_fal
             list.add(connection);
         }
         controller_conn.run("try{startDataNode('"+HOST+":"+PORT+"')}catch(ex){}");
+        controller_conn.run("sleep(2000);");
         DBConnection connection1 = new DBConnection();
         connection1.connect(HOST, PORT, "admin", "123456",false);
         int port1 = port_list[1];

test/com/xxdb/data/BasicDurationTest.java

@@ -30,7 +30,38 @@ public void test_BasicDuration(){
         assertFalse(bd.equals(null));
         assertEquals("",new BasicDuration(Entity.DURATION.US,Integer.MIN_VALUE).getString());
     }
-
+    @Test
+    public void test_BasicDuration_unit_string() throws IOException {
+        BasicDuration bd1 = new BasicDuration("ns",3);
+        assertEquals("3ns",bd1.getJsonString());
+        BasicDuration bd2 = new BasicDuration("us",3);
+        assertEquals("3us",bd2.getJsonString());
+        BasicDuration bd3 = new BasicDuration("ms",3);
+        assertEquals("3ms",bd3.getJsonString());
+        BasicDuration bd4 = new BasicDuration("s",3);
+        assertEquals("3s",bd4.getJsonString());
+        BasicDuration bd5 = new BasicDuration("m",3);
+        assertEquals("3m",bd5.getJsonString());
+        BasicDuration bd6 = new BasicDuration("H",3);
+        assertEquals("3H",bd6.getJsonString());
+        BasicDuration bd7 = new BasicDuration("d",3);
+        assertEquals("3d",bd7.getJsonString());
+        BasicDuration bd8 = new BasicDuration("w",3);
+        assertEquals("3w",bd8.getJsonString());
+        BasicDuration bd9 = new BasicDuration("M",3);
+        assertEquals("3M",bd9.getJsonString());
+        BasicDuration bd10 = new BasicDuration("y",3);
+        assertEquals("3y",bd10.getJsonString());
+        BasicDuration bd11 = new BasicDuration("B",3);
+        assertEquals("3B",bd11.getJsonString());
+        String re = null;
+        try{
+            BasicDuration bd12 = new BasicDuration("b",3);
+        }catch(Exception e){
+            re = e.getMessage();
+        }
+        assertEquals("error unit: b",re);
+    }
     @Test
     public void test_BasicDuration_write() throws IOException {
         BasicDuration bd = new BasicDuration(Entity.DURATION.MONTH,3);
@@ -481,6 +512,7 @@ public void test_BasicDuration_1() throws IOException {
         BasicDuration bd3 = (BasicDuration)conn.run("duration(-9999999XNYS)");
         assertEquals(-9999999,bd3.getDuration());
         assertEquals("-9999999XNYS",bd3.getString());
+        conn.close();
     }
     @Test
     public void test_BasicDuration_2() throws IOException {
@@ -536,6 +568,7 @@ public void test_BasicDurationVector_1() throws Exception {
         assertEquals("(3XNYS,3XNYS)",bdv.getString());
         System.out.println(((BasicDuration)bdv.get(0)).getDuration());
         assertEquals(3,((BasicDuration)bdv.get(0)).getDuration());
+        conn.close();
     }
     @Test
     public void test_BasicDurationVector_2() throws Exception {
@@ -546,4 +579,14 @@ public void test_BasicDurationVector_2() throws Exception {
         assertEquals("[3XNYS,0XNYS,-999999999XNYS]",bdv.getString());
         assertEquals("3XNYS",bdv.get(0).getString());
     }
+    @Test
+    public void test_BasicDurationVector_3() throws Exception {
+        DBConnection conn = new DBConnection();
+        conn.connect(HOST,PORT,"admin","123456");
+        BasicDurationVector Vector1 = (BasicDurationVector) conn.run("-5AAAA:0AAAA");
+        BasicDurationVector Vector2 = (BasicDurationVector) conn.run("pair(-5AAAA,0AAAA)");
+        assertEquals("[-5AAAA,0AAAA]",Vector1.getString());
+        assertEquals("[-5AAAA,0AAAA]",Vector2.getString());
+        conn.close();
+    }
 }