From 7e96e3b21dd93e12dd89d00af0a5a9d98b5e393d Mon Sep 17 00:00:00 2001 From: Alex Duan <417921451@qq.com> Date: Wed, 17 Apr 2024 11:40:43 +0800 Subject: [PATCH] fix: show.py can not passed --- tests/army/community/query/show.py | 2 +- tests/army/community/storage/compressBasic.py | 34 ++++++++++++++++--- 2 files changed, 31 insertions(+), 5 deletions(-) diff --git a/tests/army/community/query/show.py b/tests/army/community/query/show.py index 8b6844820e..9192aee06e 100644 --- a/tests/army/community/query/show.py +++ b/tests/army/community/query/show.py @@ -38,7 +38,7 @@ class TDTestCase(TBase): self.childtable_count = 10 self.insert_rows = 10000 - self.autoGen = AutoGen(startTs = 1600000000000*1000*1000, batch=500, fillOne=True) + self.autoGen = AutoGen(startTs = 1600000000000*1000*1000, batch=500, genDataMode = "fillone") self.autoGen.create_db(self.db, 2, 3, "precision 'ns'") self.autoGen.create_stable(stbname = self.stb, tag_cnt = 5, column_cnt = 20, binary_len = 10, nchar_len = 5) self.autoGen.create_child(self.stb, "child", self.childtable_count) diff --git a/tests/army/community/storage/compressBasic.py b/tests/army/community/storage/compressBasic.py index 666e6da637..d1943516ca 100644 --- a/tests/army/community/storage/compressBasic.py +++ b/tests/army/community/storage/compressBasic.py @@ -195,6 +195,16 @@ class TDTestCase(TBase): sql = f"alter table {tbname} modify column {col} LEVEL '{level}';" tdSql.execute(sql) self.writeData(1000) + + # alter error + sqls = { + "alter table nodb.nostb modify column ts LEVEL 'high';", + "alter table db.stb modify column ts encode 'simple8b';", + "alter table db.stb modify column c1 compress 'errorcompress';", + "alter table db.stb modify column c2 level 'errlevel';", + "alter table db.errstb modify column c3 compress 'xz';" + } + tdSql.errors(sqls) def validCreate(self): @@ -216,6 +226,24 @@ class TDTestCase(TBase): # check alter and write self.checkAlter() + def checkCorrect(self): + # check data correct + tbname = f"{self.db}.{self.stb}" + # count + sql = f"select count(*) from {tbname}" + count = tdSql.getFirstValue(sql) + step = 100000 + offset = 0 + + while offset < count: + sql = f"select * from {tbname} limit {step} offset {offset}" + tdSql.query(sql) + self.autoGen.dataCorrect(tdSql.res, tdSql.getRows(), step) + offset += step + tdLog.info(f"check data correct rows={offset}") + + tdLog.info(F"check {tbname} rows {count} data correct successfully.") + # run def run(self): @@ -239,10 +267,8 @@ class TDTestCase(TBase): self.flushDb() self.writeData(1000) - # check data correct - sql = f"select * from {self.db}.{self.stb}" - tdSql.query(sql) - self.autoGen.dataCorrect(tdSql.res, tdSql.getRows(), 10000) + # check corrent + self.checkCorrect() tdLog.success(f"{__file__} successfully executed")