update case

tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica1_insertdatas_querys.py

@@ -30,7 +30,7 @@ class TDTestCase:
         self.vgroups = 1
         self.tb_nums = 10 
         self.row_nums = 1000
-        self.query_times = 1000
+        self.query_times = 500
 
     def getBuildPath(self):
         selfPath = os.path.dirname(os.path.realpath(__file__))

tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_follower.py

@@ -29,9 +29,10 @@ class TDTestCase:
         self.replica = 3 
         self.vgroups = 10
         self.tb_nums = 10 
-        self.row_nums = 1000
+        self.row_nums = 100
         self.max_restart_time = 20
-        self.restart_server_times = 10 
+        self.restart_server_times = 5
+        self.query_times = 100 
 
     def getBuildPath(self):
         selfPath = os.path.dirname(os.path.realpath(__file__))
@@ -300,7 +301,7 @@ class TDTestCase:
         restart_servers = threading.Thread(target = self.loop_restart_follower_constantly, args = (self.restart_server_times ,self.db_name))
         restart_servers.start()
 
-        reading = threading.Thread(target = self.loop_query_constantly, args=(1000,self.db_name , self.tb_nums , self.row_nums))
+        reading = threading.Thread(target = self.loop_query_constantly, args=(self.query_times,self.db_name , self.tb_nums , self.row_nums))
         reading.start()
         
         writing.join()

tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_leader.py

@@ -29,9 +29,10 @@ class TDTestCase:
         self.replica = 3 
         self.vgroups = 10
         self.tb_nums = 10 
-        self.row_nums = 1000
+        self.row_nums = 100
         self.max_restart_time = 20
         self.restart_server_times = 10 
+        self.query_times = 100
 
     def getBuildPath(self):
         selfPath = os.path.dirname(os.path.realpath(__file__))
@@ -353,7 +354,7 @@ class TDTestCase:
         restart_servers = threading.Thread(target = self.loop_restart_follower_constantly, args = (self.restart_server_times ,self.db_name))
         restart_servers.start()
 
-        reading = threading.Thread(target = self.loop_query_constantly, args=(1000,self.db_name , self.tb_nums , self.row_nums))
+        reading = threading.Thread(target = self.loop_query_constantly, args=(self.query_times,self.db_name , self.tb_nums , self.row_nums))
         reading.start()
         
         writing.join()

tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_leader_forece_stop.py

@@ -33,10 +33,10 @@ class TDTestCase:
         self.tb_nums = 10 
         self.row_nums = 100
         self.stop_dnode_id = None
-        self.loop_restart_times = 10
+        self.loop_restart_times = 5
         self.current_thread = None
         self.max_restart_time = 5
-
+        self.try_check_times = 10
     def getBuildPath(self):
         selfPath = os.path.dirname(os.path.realpath(__file__))
         if ("community" in selfPath):

tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_mnode3_insertdatas_querys.py

@@ -29,7 +29,7 @@ class TDTestCase:
         self.replica = 3 
         self.vgroups = 1
         self.tb_nums = 10 
-        self.row_nums = 2000
+        self.row_nums = 1000
         self.query_times = 100
 
     def getBuildPath(self):
@@ -170,10 +170,10 @@ class TDTestCase:
         # tdSql.checkRows(tb_nums)
 
     def loop_query_constantly(self, times ,  db_name, tb_nums ,row_nums):
-
+        newTdSql=tdCom.newTdSql()
         for loop_time in range(times):
             tdLog.debug(" === query is going ,this is {}_th query === ".format(loop_time))
-            self.check_insert_status( db_name, tb_nums , row_nums)
+            self.check_insert_status( newTdSql ,db_name, tb_nums , row_nums)
 
     def loop_create_databases(self, times , tb_nums , row_nums):
         newTdSql=tdCom.newTdSql()
@@ -203,7 +203,7 @@ class TDTestCase:
         reading = threading.Thread(target = self.loop_query_constantly, args=(self.query_times,self.db_name , self.tb_nums , self.row_nums))
         reading.start()
 
-        create_db = threading.Thread(target = self.loop_create_databases, args=(10, 10 , 10))
+        create_db = threading.Thread(target = self.loop_create_databases, args=(5, 10 , 10))
         create_db.start()
         
         writing.join()

tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_follower.py

@@ -392,7 +392,7 @@ class TDTestCase:
         self.create_stable_insert_datas(dbname = self.db_name , stablename = "stb1" , tb_nums= self.tb_nums ,row_nums= self.row_nums)
 
         # let query task start 
-        self.thread_list = self.multi_thread_query_task(10 ,self.db_name ,'stb1' )
+        self.thread_list = self.multi_thread_query_task(5 ,self.db_name ,'stb1' )
 
         # force stop follower
         for loop in range(self.loop_restart_times):

tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_leader.py

@@ -425,7 +425,7 @@ class TDTestCase:
         self.create_stable_insert_datas(dbname = self.db_name , stablename = "stb1" , tb_nums= self.tb_nums ,row_nums= self.row_nums)
 
         # let query task start 
-        self.thread_list = self.multi_thread_query_task(10 ,self.db_name ,'stb1' )
+        self.thread_list = self.multi_thread_query_task(2 ,self.db_name ,'stb1' )
 
         newTdSql=tdCom.newTdSql()
         # force stop follower
@@ -435,7 +435,7 @@ class TDTestCase:
             # get leader info before stop 
             before_leader_infos = self.get_leader_infos(newTdSql , self.db_name)
 
-            self.stop_dnode_id = self._get_stop_dnode_id(self.db_name)
+            self.stop_dnode_id = self._get_stop_dnode_id(self.db_name,"leader")
             tdDnodes[self.stop_dnode_id-1].stoptaosd()
 
             start = time.time()

tests/system-test/6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_leader_force_stop.py

@@ -426,7 +426,7 @@ class TDTestCase:
         self.create_stable_insert_datas(dbname = self.db_name , stablename = "stb1" , tb_nums= self.tb_nums ,row_nums= self.row_nums)
 
         # let query task start 
-        self.thread_list = self.multi_thread_query_task(10 ,self.db_name ,'stb1' )
+        self.thread_list = self.multi_thread_query_task(5 ,self.db_name ,'stb1' )
 
         # force stop follower
         for loop in range(self.loop_restart_times):

tests/system-test/fulltest.sh

@@ -193,6 +193,30 @@ python3 ./test.py -f 6-cluster/5dnode3mnodeRecreateMnode.py  -N 5 -M 3
 python3 ./test.py -f 6-cluster/5dnode3mnodeStopFollowerLeader.py  -N 5 -M 3 
 python3 ./test.py -f 6-cluster/5dnode3mnodeStop2Follower.py  -N 5 -M 3 
 
+# vnode case 
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_createDb_replica1.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica1_insertdatas.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica1_insertdatas_querys.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_force_stop_all_dnodes.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_all_vnode.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_follower.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys_loop_restart_leader.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_querys.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_all_dnodes.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_sync.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_unsync_force_stop.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_follower_unsync.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_leader_forece_stop.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_leader.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_mnode3_insertdatas_querys.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_follower_force_stop.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_follower.py -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_leader_force_stop.py -N 4 -M 1 
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_querydatas_stop_leader.py -N 4 -M 1 
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups.py  -N 4 -M 1
+python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups_stopOne.py -N 4 -M 1
+
 
 python3 ./test.py -f 7-tmq/dropDbR3ConflictTransaction.py -N 3
 python3 ./test.py -f 7-tmq/basic5.py