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

TD-23722: add case for TMQ unsubscribe with taosAdapter

This commit is contained in:
Ping Xiao 2023-09-04 18:33:19 +08:00
parent 88e69036d8
commit b7b97e7a66
2 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
tests/parallel_test/cases.task
View File

@ -48,6 +48,7 @@
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqMaxGroupIds.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqMaxGroupIds.py
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsumeDiscontinuousData.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsumeDiscontinuousData.py
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqOffset.py ,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqOffset.py
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCommon.py -R
,,n,system-test,python3 ./test.py -f 7-tmq/tmqDropConsumer.py ,,n,system-test,python3 ./test.py -f 7-tmq/tmqDropConsumer.py

12
tests/system-test/7-tmq/tmqCommon.py
View File

@ -233,7 +233,7 @@ class TMQCom:
#tdLog.debug("doing insert data into stable:%s rows:%d ..."%(stbName, allRows)) #tdLog.debug("doing insert data into stable:%s rows:%d ..."%(stbName, allRows))
for i in range(ctbNum): for i in range(ctbNum):
rowsBatched = 0 rowsBatched = 0
sql += " %s%d values "%(stbName,i) sql += " %s.%s%d values "%(dbName, stbName, i)
for j in range(rowsPerTbl): for j in range(rowsPerTbl):
sql += "(%d, %d, 'tmqrow_%d') "%(startTs + j, j, j) sql += "(%d, %d, 'tmqrow_%d') "%(startTs + j, j, j)
rowsBatched += 1 rowsBatched += 1
@ -241,7 +241,7 @@ class TMQCom:
tsql.execute(sql) tsql.execute(sql)
rowsBatched = 0 rowsBatched = 0
if j < rowsPerTbl - 1: if j < rowsPerTbl - 1:
sql = "insert into %s%d values " %(stbName,i) sql = "insert into %s.%s%d values " %(dbName, stbName,i)
else: else:
sql = "insert into " sql = "insert into "
#end sql #end sql
@ -263,7 +263,7 @@ class TMQCom:
#tdLog.debug("doing insert data into stable:%s rows:%d ..."%(stbName, allRows)) #tdLog.debug("doing insert data into stable:%s rows:%d ..."%(stbName, allRows))
for i in range(ctbNum): for i in range(ctbNum):
rowsBatched = 0 rowsBatched = 0
sql += " %s%d values "%(ctbPrefix,i) sql += " %s.%s%d values "%(dbName, ctbPrefix,i)
for j in range(rowsPerTbl): for j in range(rowsPerTbl):
if (j % 2 == 0): if (j % 2 == 0):
sql += "(%d, %d, %d, 'tmqrow_%d') "%(startTs + j, j, j, j) sql += "(%d, %d, %d, 'tmqrow_%d') "%(startTs + j, j, j, j)
@ -274,7 +274,7 @@ class TMQCom:
tsql.execute(sql) tsql.execute(sql)
rowsBatched = 0 rowsBatched = 0
if j < rowsPerTbl - 1: if j < rowsPerTbl - 1:
sql = "insert into %s%d values " %(ctbPrefix,i) sql = "insert into %s.%s%d values " %(dbName, ctbPrefix, i)
else: else:
sql = "insert into " sql = "insert into "
#end sql #end sql
@ -296,7 +296,7 @@ class TMQCom:
#tdLog.debug("doing insert data into stable:%s rows:%d ..."%(stbName, allRows)) #tdLog.debug("doing insert data into stable:%s rows:%d ..."%(stbName, allRows))
for i in range(ctbNum): for i in range(ctbNum):
rowsBatched = 0 rowsBatched = 0
sql += " %s%d values "%(ctbPrefix,i+ctbStartIdx) sql += " %s.%s%d values "%(dbName, ctbPrefix, i+ctbStartIdx)
for j in range(rowsPerTbl): for j in range(rowsPerTbl):
if (j % 2 == 0): if (j % 2 == 0):
sql += "(%d, %d, %d, 'tmqrow_%d', now) "%(startTs + j, j, j, j) sql += "(%d, %d, %d, 'tmqrow_%d', now) "%(startTs + j, j, j, j)
@ -307,7 +307,7 @@ class TMQCom:
tsql.execute(sql) tsql.execute(sql)
rowsBatched = 0 rowsBatched = 0
if j < rowsPerTbl - 1: if j < rowsPerTbl - 1:
sql = "insert into %s%d values " %(ctbPrefix,i+ctbStartIdx) sql = "insert into %s.%s%d values " %(dbName, ctbPrefix, i+ctbStartIdx)
else: else:
sql = "insert into " sql = "insert into "
#end sql #end sql