opt case

Author: GroundWu

src/test/java/com/alipay/oceanbase/rpc/ObTableFullTextIndexTest.java

@@ -40,7 +40,6 @@ public class ObTableFullTextIndexTest {
     String truncateNoPartTableSQL = "truncate table tbl1;";
     String truncatePartTableSQL = "truncate table part_tbl1;";
     String truncateTTLTableSQL = "truncate table ttl_tbl1;";
-    String dropTableSQL = "drop table tbl1";
     String idCol = "id";
     String c2Col = "c2";
     String txtCol = "txt";
@@ -57,7 +56,9 @@ public void setup() throws Exception {
 
     @After
     public void teardown() throws Exception {
-//        executeSQL(dropTableSQL);
+        executeSQL("drop table " + noPartTableName);
+        executeSQL("drop table " + partTableName);
+        executeSQL("drop table " + ttlTableName);
     }
 
     @Test
@@ -71,6 +72,9 @@ public void testInsert() throws Exception {
             Assert.assertEquals(1, res.getAffectedRows());
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
+        } finally {
+            executeSQL(truncatePartTableSQL);
         }
     }
 
@@ -92,6 +96,9 @@ public void testGet() throws Exception {
             Assert.assertEquals(txt, res.get(txtCol));
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
+        } finally {
+            executeSQL(truncatePartTableSQL);
         }
     }
 
@@ -119,6 +126,9 @@ public void testDel() throws Exception {
             Assert.assertTrue(res.isEmpty());
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
+        } finally {
+            executeSQL(truncatePartTableSQL);
         }
     }
 
@@ -178,6 +188,9 @@ public void testUpd() throws Exception {
             Assert.assertEquals(txt, res.get(txtCol));
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
+        } finally {
+            executeSQL(truncatePartTableSQL);
         }
     }
 
@@ -239,6 +252,7 @@ public void testInsOrUpd() throws Exception {
 
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
         } finally {
             executeSQL(truncatePartTableSQL);
         }
@@ -302,6 +316,7 @@ public void testReplace() throws Exception {
 
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
         } finally {
             executeSQL(truncatePartTableSQL);
         }
@@ -370,8 +385,9 @@ public void testTTLInsert() throws Exception {
             Assert.assertEquals(txt4, res.get(txtCol));
         } catch(Exception e) {
             e.printStackTrace();
+            Assert.fail();
         } finally {
-           // executeSQL(truncateTTLTableSQL);
+            executeSQL(truncateTTLTableSQL);
         }
     }
 
@@ -404,8 +420,9 @@ public void testIncrment() throws Exception {
             Assert.assertEquals(null, getRes.get(txtCol));
         } catch(Exception e) {
             e.printStackTrace();
+            Assert.fail();
         } finally {
-            // executeSQL(truncateTTLTableSQL);
+            executeSQL(truncatePartTableSQL);
         }
     }
 
@@ -439,8 +456,9 @@ public void testAppend() throws Exception {
             Assert.assertEquals(txt1+txt2, getRes.get(txtCol));
         } catch(Exception e) {
             e.printStackTrace();
+            Assert.fail();
         } finally {
-            // executeSQL(truncateTTLTableSQL);
+            executeSQL(truncatePartTableSQL);
         }
     }
 
@@ -500,6 +518,7 @@ public void testFTSQuery() throws Exception {
             Assert.assertTrue(2 == count);
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
         } finally {
             executeSQL(truncatePartTableSQL);
         }
@@ -571,6 +590,9 @@ public void testFTSQueryWithTTL() throws Exception {
             Assert.assertTrue(1 == count);
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
+        } finally {
+            executeSQL(truncateTTLTableSQL);
         }
     }
 
@@ -622,6 +644,7 @@ public void testQueryWithLimitOffset() throws Exception {
             Assert.assertTrue(1 == count);
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
         } finally {
             executeSQL(truncateNoPartTableSQL);
         }
@@ -730,6 +753,9 @@ public void testBatch() throws Exception {
             }
         } catch (Exception e) {
             e.printStackTrace();
+            Assert.fail();
+        } finally {
+            executeSQL(truncatePartTableSQL);
         }
     }
 }