AJ-691:fix broken case

Author: weisun123

test/com/xxdb/Prepare.java

@@ -40,6 +40,35 @@ public static void clear_env() throws IOException {
                     "clearShare()");
             conn.run("try{dropStreamEngine(\"serInput\");\n}catch(ex){\n}\n");
     }
+    public static void clear_env_1() throws IOException {
+        for (int i = 0; i < port_list.length; i++) {
+            DBConnection conn = new DBConnection();
+            conn.connect(HOST, port_list[i], "admin", "123456");
+            conn.run("a = getStreamingStat().pubTables\n" +
+                    "for(i in a){\n" +
+                    "\ttry{stopPublishTable(i.subscriber.split(\":\")[0],int(i.subscriber.split(\":\")[1]),i.tableName,i.actions)}catch(ex){}\n" +
+                    "}");
+            conn.run("def getAllShare(){\n" +
+                    "\treturn select name from objs(true) where shared=1\n" +
+                    "\t}\n" +
+                    "\n" +
+                    "def clearShare(){\n" +
+                    "\tlogin(`admin,`123456)\n" +
+                    "\tallShare=exec name from pnodeRun(getAllShare)\n" +
+                    "\tfor(i in allShare){\n" +
+                    "\t\ttry{\n" +
+                    "\t\t\trpc((exec node from pnodeRun(getAllShare) where name =i)[0],clearTablePersistence,objByName(i))\n" +
+                    "\t\t\t}catch(ex1){}\n" +
+                    "\t\trpc((exec node from pnodeRun(getAllShare) where name =i)[0],undef,i,SHARED)\n" +
+                    "\t}\n" +
+                    "\ttry{\n" +
+                    "\t\tPST_DIR=rpc(getControllerAlias(),getDataNodeConfig{getNodeAlias()})['persistenceDir']\n" +
+                    "\t}catch(ex1){}\n" +
+                    "}\n" +
+                    "clearShare()");
+            conn.run("try{dropStreamEngine(\"serInput\");\n}catch(ex){\n}\n");
+        }
+    }
 
     public static void Preparedata(long count) throws IOException {
         String script = "login(`admin, `123456); \n" +

test/com/xxdb/streaming/reverse/PollingClientReverseTest.java

@@ -49,8 +49,12 @@ public class PollingClientReverseTest {
     public static PollingClient client;
     private StreamDeserializer deserializer_;
 
+    @BeforeClass
+    public static void setUp() throws IOException {
+        try {clear_env_1();}catch (Exception e){}
+    }
     @Before
-    public void setUp() throws IOException {
+    public void clear() throws IOException {
         conn = new DBConnection();
         conn.connect(HOST, PORT, "admin", "123456");
         try {
@@ -92,12 +96,17 @@ public  void after() throws IOException, InterruptedException {
         } catch (Exception e) {
         }
         try{conn.run("dropStreamTable(`Trades1)");}catch (Exception e){}
-       // clear_env();
+        try {clear_env();}catch (Exception e){}
         //client.close();
         conn.close();
         Thread.sleep(2000);
     }
 
+    @AfterClass
+    public static void clear_conn() {
+        try {clear_env_1();}catch (Exception e){}
+    }
+
     public void wait_data(String table_name,int data_row) throws IOException, InterruptedException {
         BasicInt row_num;
         while(true){

test/com/xxdb/streaming/reverse/ThreadPooledClientReverseTest.java

@@ -30,7 +30,7 @@ public class ThreadPooledClientReverseTest {
 
     @BeforeClass
     public static void setUp() throws IOException {
-
+        try {clear_env_1();}catch (Exception e){}
     }
     @Before
     public void clear() throws IOException {
@@ -50,7 +50,7 @@ public void clear() throws IOException {
         try{client.unsubscribe(HOST, PORT, "outTables", "mutiSchema");}catch (Exception ex){}
         try{client.unsubscribe(HOST, PORT, "outTables", "javaStreamingApi");}catch (Exception ex){}
         try{client.unsubscribe(HOST, PORT, "Trades1", "javaStreamingApi");}catch (Exception ex){}
-        clear_env();
+        try {clear_env();}catch (Exception e){}
     }
 
     @After
@@ -83,6 +83,7 @@ public void after() throws IOException, InterruptedException {
 
     @AfterClass
     public static void clear_conn() {
+        try {clear_env_1();}catch (Exception e){}
     }
 
 public static void PrepareStreamTable() throws IOException {

test/com/xxdb/streaming/reverse/ThreadedClientsubscribeReverseTest.java

@@ -35,7 +35,7 @@ public class ThreadedClientsubscribeReverseTest {
 
     @BeforeClass
     public static void setUp() throws IOException {
-
+        try {clear_env_1();}catch (Exception e){}
     }
     @Before
     public void clear() throws IOException {
@@ -54,7 +54,7 @@ public void clear() throws IOException {
         try{client.unsubscribe(HOST, PORT, "Trades", "subTrades");}catch (Exception ex){}
         try{client.unsubscribe(HOST, PORT, "outTables", "mutiSchema");}catch (Exception ex){}
         try{client.unsubscribe(HOST, PORT, "outTables", "javaStreamingApi");}catch (Exception ex){}
-        clear_env();
+        try {clear_env();}catch (Exception e){}
     }
 
     @After
@@ -65,7 +65,7 @@ public void after() throws IOException, InterruptedException {
         try{client.unsubscribe(HOST, PORT, "Trades", "subTrades");}catch (Exception ex){}
         try{client.unsubscribe(HOST, PORT, "outTables", "mutiSchema");}catch (Exception ex){}
         try{client.unsubscribe(HOST, PORT, "outTables", "javaStreamingApi");}catch (Exception ex){}
-        clear_env();
+        try {clear_env();}catch (Exception e){}
         Thread.sleep(2000);
         client.close();
         conn.close();
@@ -74,6 +74,7 @@ public void after() throws IOException, InterruptedException {
 
     @AfterClass
     public static void clear_conn() {
+        try {clear_env_1();}catch (Exception e){}
     }
     public static MessageHandler MessageHandler_handler = new MessageHandler() {
         @Override