Skip to content

Commit e7dee10

Browse files
guanshengliangguanshengliang
authored
test: migrate cases (#30976)
1 parent 94d57f7 commit e7dee10

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

43 files changed

+15022
-45
lines changed

‎test/cases/02-Databases/05-Sync/test_balance1.py‎

Lines changed: 215 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,215 @@
1+
import time
2+
from new_test_framework.utils import tdLog, tdSql, sc, clusterComCheck, clusterComCheck
3+
4+
5+
class TestBalance1:
6+
7+
def setup_class(cls):
8+
tdLog.debug(f"start to execute {__file__}")
9+
10+
def test_balance_1(self):
11+
"""balance 1
12+
13+
1. -
14+
15+
Catalog:
16+
- Database:Sync
17+
18+
Since: v3.0.0.0
19+
20+
Labels: common,ci
21+
22+
Jira: None
23+
24+
History:
25+
- 2025-5-6 Simon Guan Migrated to new test framework, from tsim/dnode/balance1.sim
26+
27+
"""
28+
29+
clusterComCheck.checkDnodes(1)
30+
tdSql.execute(f"alter dnode 1 'supportVnodes' '4'")
31+
clusterComCheck.checkDnodeSupportVnodes(1, 4)
32+
33+
tdLog.info(f"========== step1")
34+
tdSql.execute(f"create database d1 vgroups 1")
35+
tdSql.execute(f"create table d1.t1 (t timestamp, i int)")
36+
tdSql.execute(f"insert into d1.t1 values(now+1s, 15)")
37+
tdSql.execute(f"insert into d1.t1 values(now+2s, 14)")
38+
tdSql.execute(f"insert into d1.t1 values(now+3s, 13)")
39+
tdSql.execute(f"insert into d1.t1 values(now+4s, 12)")
40+
tdSql.execute(f"insert into d1.t1 values(now+5s, 11)")
41+
42+
tdSql.query(f"select * from information_schema.ins_dnodes")
43+
tdSql.checkKeyData(1, 2, 1)
44+
45+
tdLog.info(f"========== step2")
46+
tdSql.execute(f"create dnode localhost port 6130")
47+
clusterComCheck.checkDnodes(2)
48+
tdSql.execute(f"alter dnode 2 'supportVnodes' '4'")
49+
clusterComCheck.checkDnodeSupportVnodes(2, 4)
50+
51+
tdSql.query(f"select * from information_schema.ins_dnodes")
52+
tdSql.checkRows(2)
53+
tdSql.checkKeyData(1, 4, "ready")
54+
tdSql.checkKeyData(2, 4, "ready")
55+
56+
tdSql.execute(f"balance vgroup")
57+
tdSql.query(f"select * from information_schema.ins_dnodes")
58+
tdSql.checkKeyData(1, 2, 0)
59+
tdSql.checkKeyData(2, 2, 1)
60+
61+
tdLog.info(f"========== step3")
62+
tdSql.execute(f"create database d2 vgroups 1")
63+
tdSql.execute(f"create table d2.t2 (t timestamp, i int)")
64+
tdSql.execute(f"insert into d2.t2 values(now+1s, 25)")
65+
tdSql.execute(f"insert into d2.t2 values(now+2s, 24)")
66+
tdSql.execute(f"insert into d2.t2 values(now+3s, 23)")
67+
tdSql.execute(f"insert into d2.t2 values(now+4s, 22)")
68+
tdSql.execute(f"insert into d2.t2 values(now+5s, 21)")
69+
70+
tdSql.query(f"select * from information_schema.ins_dnodes")
71+
tdSql.checkKeyData(1, 2, 1)
72+
tdSql.checkKeyData(2, 2, 1)
73+
74+
tdSql.query(f"select * from d1.t1 order by t desc")
75+
tdSql.checkData(0, 1, 11)
76+
tdSql.checkData(1, 1, 12)
77+
tdSql.checkData(2, 1, 13)
78+
tdSql.checkData(3, 1, 14)
79+
tdSql.checkData(4, 1, 15)
80+
81+
tdSql.query(f"select * from d2.t2 order by t desc")
82+
tdSql.checkData(0, 1, 21)
83+
tdSql.checkData(1, 1, 22)
84+
tdSql.checkData(2, 1, 23)
85+
tdSql.checkData(3, 1, 24)
86+
tdSql.checkData(4, 1, 25)
87+
88+
tdLog.info(f"========== step4")
89+
tdSql.execute(f"drop dnode 2")
90+
tdSql.query(f"select * from information_schema.ins_dnodes")
91+
tdSql.checkKeyData(1, 2, 2)
92+
93+
tdSql.query(f"select * from d1.t1 order by t desc")
94+
tdSql.checkData(0, 1, 11)
95+
tdSql.checkData(1, 1, 12)
96+
tdSql.checkData(2, 1, 13)
97+
tdSql.checkData(3, 1, 14)
98+
tdSql.checkData(4, 1, 15)
99+
100+
tdSql.query(f"select * from d2.t2 order by t desc")
101+
tdSql.checkData(0, 1, 21)
102+
tdSql.checkData(1, 1, 22)
103+
tdSql.checkData(2, 1, 23)
104+
tdSql.checkData(3, 1, 24)
105+
tdSql.checkData(4, 1, 25)
106+
107+
sc.dnodeStop(2)
108+
109+
tdLog.info(f"========== step5")
110+
tdSql.execute(f"create dnode localhost port 6230")
111+
clusterComCheck.checkDnodes(2)
112+
tdSql.execute(f"alter dnode 3 'supportVnodes' '4'")
113+
clusterComCheck.checkDnodeSupportVnodes(3, 4)
114+
115+
tdSql.query(f"select * from information_schema.ins_dnodes")
116+
tdSql.checkRows(2)
117+
tdSql.checkKeyData(1, 4, "ready")
118+
tdSql.checkKeyData(3, 4, "ready")
119+
120+
tdSql.execute(f"balance vgroup")
121+
tdSql.query(f"select * from information_schema.ins_dnodes")
122+
tdSql.checkKeyData(1, 2, 1)
123+
tdSql.checkKeyData(3, 2, 1)
124+
125+
tdSql.query(f"select * from d1.t1 order by t desc")
126+
tdSql.checkData(0, 1, 11)
127+
tdSql.checkData(1, 1, 12)
128+
tdSql.checkData(2, 1, 13)
129+
tdSql.checkData(3, 1, 14)
130+
tdSql.checkData(4, 1, 15)
131+
132+
tdSql.query(f"select * from d2.t2 order by t desc")
133+
tdSql.checkData(0, 1, 21)
134+
tdSql.checkData(1, 1, 22)
135+
tdSql.checkData(2, 1, 23)
136+
tdSql.checkData(3, 1, 24)
137+
tdSql.checkData(4, 1, 25)
138+
139+
tdLog.info(f"========== step6")
140+
tdSql.execute(f"create database d3 vgroups 1")
141+
tdSql.execute(f"create table d3.t3 (t timestamp, i int)")
142+
tdSql.execute(f"insert into d3.t3 values(now+1s, 35)")
143+
tdSql.execute(f"insert into d3.t3 values(now+2s, 34)")
144+
tdSql.execute(f"insert into d3.t3 values(now+3s, 33)")
145+
tdSql.execute(f"insert into d3.t3 values(now+4s, 32)")
146+
tdSql.execute(f"insert into d3.t3 values(now+5s, 31)")
147+
148+
tdSql.query(f"select * from information_schema.ins_dnodes")
149+
tdSql.checkKeyData(1, 2, 1)
150+
tdSql.checkKeyData(3, 2, 2)
151+
152+
tdLog.info(f"========== step7")
153+
tdSql.execute(f"create dnode localhost port 6330")
154+
clusterComCheck.checkDnodes(3)
155+
tdSql.execute(f"alter dnode 4 'supportVnodes' '4'")
156+
clusterComCheck.checkDnodeSupportVnodes(4, 4)
157+
158+
tdSql.query(f"select * from information_schema.ins_dnodes")
159+
tdSql.checkRows(3)
160+
tdSql.checkKeyData(1, 4, "ready")
161+
tdSql.checkKeyData(3, 4, "ready")
162+
tdSql.checkKeyData(4, 4, "ready")
163+
164+
tdLog.info(f"========== step8")
165+
tdSql.execute(f"create database d4 vgroups 1")
166+
tdSql.execute(f"create table d4.t4 (t timestamp, i int)")
167+
tdSql.execute(f"insert into d4.t4 values(now+1s, 45)")
168+
tdSql.execute(f"insert into d4.t4 values(now+2s, 44)")
169+
tdSql.execute(f"insert into d4.t4 values(now+3s, 43)")
170+
tdSql.execute(f"insert into d4.t4 values(now+4s, 42)")
171+
tdSql.execute(f"insert into d4.t4 values(now+5s, 41)")
172+
173+
tdSql.query(f"select * from information_schema.ins_dnodes")
174+
tdSql.checkKeyData(1, 2, 1)
175+
tdSql.checkKeyData(3, 2, 2)
176+
tdSql.checkKeyData(4, 2, 1)
177+
178+
tdLog.info(f"========== step9")
179+
tdSql.execute(f"drop dnode 3")
180+
tdSql.query(f"select * from information_schema.ins_dnodes")
181+
tdSql.checkKeyData(1, 2, 2)
182+
tdSql.checkKeyData(4, 2, 2)
183+
184+
sc.dnodeStop(3)
185+
tdSql.execute(f"reset query cache")
186+
187+
tdLog.info(f"========== step10")
188+
tdSql.query(f"select * from d1.t1 order by t desc")
189+
tdSql.checkData(0, 1, 11)
190+
tdSql.checkData(1, 1, 12)
191+
tdSql.checkData(2, 1, 13)
192+
tdSql.checkData(3, 1, 14)
193+
tdSql.checkData(4, 1, 15)
194+
195+
tdSql.query(f"select * from d2.t2 order by t desc")
196+
tdSql.checkData(0, 1, 21)
197+
tdSql.checkData(1, 1, 22)
198+
tdSql.checkData(2, 1, 23)
199+
tdSql.checkData(3, 1, 24)
200+
tdSql.checkData(4, 1, 25)
201+
202+
tdSql.query(f"select * from d3.t3 order by t desc")
203+
tdSql.checkData(0, 1, 31)
204+
tdSql.checkData(1, 1, 32)
205+
tdSql.checkData(2, 1, 33)
206+
tdSql.checkData(3, 1, 34)
207+
tdSql.checkData(4, 1, 35)
208+
209+
tdSql.query(f"select * from d4.t4 order by t desc")
210+
211+
tdSql.checkData(0, 1, 41)
212+
tdSql.checkData(1, 1, 42)
213+
tdSql.checkData(2, 1, 43)
214+
tdSql.checkData(3, 1, 44)
215+
tdSql.checkData(4, 1, 45)

‎test/cases/02-Databases/05-Sync/test_balance2.py‎

Lines changed: 159 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,159 @@
1+
import time
2+
from new_test_framework.utils import tdLog, tdSql, sc, clusterComCheck, clusterComCheck
3+
4+
5+
class TestBalance2:
6+
7+
def setup_class(cls):
8+
tdLog.debug(f"start to execute {__file__}")
9+
10+
def test_balance_2(self):
11+
"""balance 2
12+
13+
1. -
14+
15+
Catalog:
16+
- Database:Sync
17+
18+
Since: v3.0.0.0
19+
20+
Labels: common,ci
21+
22+
Jira: None
23+
24+
History:
25+
- 2025-5-6 Simon Guan Migrated to new test framework, from tsim/dnode/balance2.sim
26+
27+
"""
28+
29+
clusterComCheck.checkDnodes(3)
30+
tdSql.execute(f"alter dnode 1 'supportVnodes' '5'")
31+
tdSql.execute(f"alter dnode 2 'supportVnodes' '5'")
32+
tdSql.execute(f"alter dnode 3 'supportVnodes' '5'")
33+
clusterComCheck.checkDnodeSupportVnodes(1, 5)
34+
clusterComCheck.checkDnodeSupportVnodes(2, 5)
35+
clusterComCheck.checkDnodeSupportVnodes(3, 5)
36+
37+
tdLog.info(f"========== step1")
38+
39+
tdSql.query(f"select * from information_schema.ins_dnodes")
40+
tdSql.checkRows(3)
41+
tdSql.checkKeyData(1, 4, "ready")
42+
tdSql.checkKeyData(2, 4, "ready")
43+
tdSql.checkKeyData(3, 4, "ready")
44+
45+
tdLog.info(f"========== step2")
46+
tdSql.execute(f"create database d1 replica 3 vgroups 1")
47+
tdSql.execute(f"create table d1.t1 (t timestamp, i int)")
48+
tdSql.execute(f"insert into d1.t1 values(now+1s, 15)")
49+
tdSql.execute(f"insert into d1.t1 values(now+2s, 14)")
50+
tdSql.execute(f"insert into d1.t1 values(now+3s, 13)")
51+
tdSql.execute(f"insert into d1.t1 values(now+4s, 12)")
52+
tdSql.execute(f"insert into d1.t1 values(now+5s, 11)")
53+
54+
tdSql.execute(f"create database d2 replica 3 vgroups 1")
55+
tdSql.execute(f"create table d2.t2 (t timestamp, i int)")
56+
tdSql.execute(f"insert into d2.t2 values(now+1s, 25)")
57+
tdSql.execute(f"insert into d2.t2 values(now+2s, 24)")
58+
tdSql.execute(f"insert into d2.t2 values(now+3s, 23)")
59+
tdSql.execute(f"insert into d2.t2 values(now+4s, 22)")
60+
tdSql.execute(f"insert into d2.t2 values(now+5s, 21)")
61+
62+
tdSql.execute(f"create database d3 replica 3 vgroups 1")
63+
tdSql.execute(f"create table d3.t3 (t timestamp, i int)")
64+
tdSql.execute(f"insert into d3.t3 values(now+1s, 35)")
65+
tdSql.execute(f"insert into d3.t3 values(now+2s, 34)")
66+
tdSql.execute(f"insert into d3.t3 values(now+3s, 33)")
67+
tdSql.execute(f"insert into d3.t3 values(now+4s, 32)")
68+
tdSql.execute(f"insert into d3.t3 values(now+5s, 31)")
69+
70+
tdSql.execute(f"create database d4 replica 3 vgroups 1")
71+
tdSql.execute(f"create table d4.t4 (t timestamp, i int)")
72+
tdSql.execute(f"insert into d4.t4 values(now+1s, 45)")
73+
tdSql.execute(f"insert into d4.t4 values(now+2s, 44)")
74+
tdSql.execute(f"insert into d4.t4 values(now+3s, 43)")
75+
tdSql.execute(f"insert into d4.t4 values(now+4s, 42)")
76+
tdSql.execute(f"insert into d4.t4 values(now+5s, 41)")
77+
78+
tdLog.info(f"========== step2.1")
79+
tdSql.query(f"select * from information_schema.ins_dnodes")
80+
tdSql.checkKeyData(1, 2, 4)
81+
tdSql.checkKeyData(2, 2, 4)
82+
tdSql.checkKeyData(3, 2, 4)
83+
84+
tdLog.info(f"========== step3")
85+
tdSql.execute(f"create dnode localhost port 6330")
86+
tdSql.execute(f"create dnode localhost port 6430")
87+
clusterComCheck.checkDnodes(5)
88+
tdSql.execute(f"alter dnode 4 'supportVnodes' '5'")
89+
tdSql.execute(f"alter dnode 5 'supportVnodes' '5'")
90+
clusterComCheck.checkDnodeSupportVnodes(4, 5)
91+
clusterComCheck.checkDnodeSupportVnodes(5, 5)
92+
93+
tdSql.query(f"select * from information_schema.ins_dnodes")
94+
tdSql.checkRows(5)
95+
tdSql.checkKeyData(1, 4, "ready")
96+
tdSql.checkKeyData(2, 4, "ready")
97+
tdSql.checkKeyData(3, 4, "ready")
98+
tdSql.checkKeyData(4, 4, "ready")
99+
tdSql.checkKeyData(5, 4, "ready")
100+
101+
tdSql.execute(f"balance vgroup")
102+
tdSql.query(f"select * from information_schema.ins_dnodes")
103+
tdSql.checkKeyData(1, 2, 2)
104+
tdSql.checkKeyData(2, 2, 3)
105+
tdSql.checkKeyData(3, 2, 3)
106+
tdSql.checkKeyData(4, 2, 2)
107+
tdSql.checkKeyData(5, 2, 2)
108+
109+
tdLog.info(f"========== step4")
110+
tdSql.execute(f"drop dnode 2")
111+
tdSql.query(f"select * from information_schema.ins_dnodes")
112+
tdSql.checkKeyData(1, 2, 3)
113+
tdSql.checkKeyData(3, 2, 3)
114+
tdSql.checkKeyData(4, 2, 3)
115+
tdSql.checkKeyData(5, 2, 3)
116+
117+
sc.dnodeStop(2)
118+
clusterComCheck.checkDnodes(4)
119+
120+
tdLog.info(f"========== step5")
121+
tdSql.execute(f"drop dnode 3")
122+
tdSql.query(f"select * from information_schema.ins_dnodes")
123+
tdSql.checkKeyData(1, 2, 4)
124+
tdSql.checkKeyData(4, 2, 4)
125+
tdSql.checkKeyData(5, 2, 4)
126+
127+
tdSql.execute(f"reset query cache")
128+
129+
sc.dnodeStop(3)
130+
clusterComCheck.checkDnodes(3)
131+
132+
tdLog.info(f"========== step6")
133+
tdSql.query(f"select * from d1.t1 order by t desc")
134+
tdSql.checkData(0, 1, 11)
135+
tdSql.checkData(1, 1, 12)
136+
tdSql.checkData(2, 1, 13)
137+
tdSql.checkData(3, 1, 14)
138+
tdSql.checkData(4, 1, 15)
139+
140+
tdSql.query(f"select * from d2.t2 order by t desc")
141+
tdSql.checkData(0, 1, 21)
142+
tdSql.checkData(1, 1, 22)
143+
tdSql.checkData(2, 1, 23)
144+
tdSql.checkData(3, 1, 24)
145+
tdSql.checkData(4, 1, 25)
146+
147+
tdSql.query(f"select * from d3.t3 order by t desc")
148+
tdSql.checkData(0, 1, 31)
149+
tdSql.checkData(1, 1, 32)
150+
tdSql.checkData(2, 1, 33)
151+
tdSql.checkData(3, 1, 34)
152+
tdSql.checkData(4, 1, 35)
153+
154+
tdSql.query(f"select * from d4.t4 order by t desc")
155+
tdSql.checkData(0, 1, 41)
156+
tdSql.checkData(1, 1, 42)
157+
tdSql.checkData(2, 1, 43)
158+
tdSql.checkData(3, 1, 44)
159+
tdSql.checkData(4, 1, 45)

0 commit comments

Comments
 (0)