From 6c20dfa1717362173e6d1d72a353bd8a473e0d3a Mon Sep 17 00:00:00 2001
From: Alex Duan <417921451@qq.com>
Date: Tue, 4 Jul 2023 14:35:58 +0800
Subject: [PATCH] add check data correct case for compact database

---
 tests/system-test/0-others/splitVGroup.py | 31 +++++++++++++++++------
 1 file changed, 23 insertions(+), 8 deletions(-)

diff --git a/tests/system-test/0-others/splitVGroup.py b/tests/system-test/0-others/splitVGroup.py
index 4509961066..9fd00892e4 100644
--- a/tests/system-test/0-others/splitVGroup.py
+++ b/tests/system-test/0-others/splitVGroup.py
@@ -283,14 +283,14 @@ class TDTestCase:
 
         # normal table
 
-        # all rows
-        sql = "select * from @db_name.ta"
-        self.queryDouble(sql)
-
         # count
         sql = "select count(*) from @db_name.ta"
         self.queryDouble(sql)
 
+        # all rows
+        sql = "select * from @db_name.ta"
+        self.queryDouble(sql)
+
         # sum
         sql = "select sum(c1) from @db_name.ta"
         self.queryDouble(sql)
@@ -316,7 +316,8 @@ class TDTestCase:
         tdSql.execute(sql)
 
         # wait end
-        for i in range(100):
+        seconds = 300
+        for i in range(seconds):
             sql ="show transactions;"
             rows = tdSql.query(sql)
             if rows == 0:
@@ -325,7 +326,7 @@ class TDTestCase:
             #tdLog.info(f"i={i} wait split vgroup ...")
             time.sleep(1)
 
-        tdLog.exit("split vgroup transaction is not finished after executing 50s")
+        tdLog.exit(f"split vgroup transaction is not finished after executing {seconds}s")
         return False
 
     # split error 
@@ -382,6 +383,14 @@ class TDTestCase:
         self.expectSplitError("topicdb")
         tdSql.execute("drop topic toa;")
         self.expectSplitOk("topicdb")
+   
+    # compact and check db2
+    def compactAndCheck(self):
+        tdLog.info("compact db2 and check result ...")
+        # compact
+        tdSql.execute(f"compact database {self.db2};")
+        # check result
+        self.checkResult()
 
     # run
     def run(self):
@@ -390,12 +399,15 @@ class TDTestCase:
 
         for i in range(5):
             # split vgroup on db2
+            start = time.time()
             self.splitVGroup(self.db2)
+            end = time.time()
             self.vgroups2 += 1
-
+            
             # check two db query result same
             self.checkResult()
-            tdLog.info(f"split vgroup i={i} passed.")
+            spend = "%.3f"%(end-start)
+            tdLog.info(f"split vgroup i={i} passed. spend = {spend}s")
 
         # split empty db
         self.splitEmptyDB()
@@ -403,6 +415,9 @@ class TDTestCase:
         # check topic and stream forib
         self.checkForbid()
 
+        # compact database
+        self.compactAndCheck()
+
     # stop
     def stop(self):
         tdSql.close()