xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

test: Update TDTestCase in tmq_taosx.py to include additional data checks

This commit is contained in:
bitcapybara 2024-06-26 07:12:17 +00:00
parent 6e6a9acc43
commit 6517f59a85
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
tests/system-test/7-tmq/tmq_taosx.py
View File

@ -553,15 +553,25 @@ class TDTestCase:
tdSql.query(f'show subscriptions') tdSql.query(f'show subscriptions')
tdSql.checkRows(2) tdSql.checkRows(2)
tdSql.checkData(0, 0, "t2")
tdSql.checkData(0, 1, 'g1')
tdSql.checkData(1, 0, 't1')
tdSql.checkData(1, 1, 'g1')
tdSql.query(f'show consumers') tdSql.query(f'show consumers')
tdSql.checkRows(1) tdSql.checkRows(1)
tdSql.checkData(0, 1, 'g1')
tdSql.checkData(0, 4, 't2')
tdSql.execute(f'drop consumer group g1 on t1') tdSql.execute(f'drop consumer group g1 on t1')
tdSql.query(f'show consumers') tdSql.query(f'show consumers')
tdSql.checkRows(1) tdSql.checkRows(1)
tdSql.checkData(0, 1, 'g1')
tdSql.checkData(0, 4, 't2')
tdSql.query(f'show subscriptions') tdSql.query(f'show subscriptions')
tdSql.checkRows(1) tdSql.checkRows(1)
tdSql.checkData(0, 0, "t2")
tdSql.checkData(0, 1, 'g1')
index = 0 index = 0
try: try:
@ -593,6 +603,8 @@ class TDTestCase:
tdSql.query(f'show consumers') tdSql.query(f'show consumers')
tdSql.checkRows(1) tdSql.checkRows(1)
tdSql.checkData(0, 1, 'g1')
tdSql.checkData(0, 4, 't2')
tdSql.execute(f'insert into t4 using st tags(3) values(now, 1)') tdSql.execute(f'insert into t4 using st tags(3) values(now, 1)')
try: try:
@ -607,6 +619,8 @@ class TDTestCase:
tdSql.query(f'show subscriptions') tdSql.query(f'show subscriptions')
tdSql.checkRows(1) tdSql.checkRows(1)
tdSql.checkData(0, 0, "t2")
tdSql.checkData(0, 1, 'g1')
tdSql.execute(f'drop topic t1') tdSql.execute(f'drop topic t1')
tdSql.execute(f'drop topic t2') tdSql.execute(f'drop topic t2')