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

Fix taosdemotest2.py failure

This commit is contained in:
Ping Xiao 2021-02-04 10:58:11 +08:00
parent 01e47002ea
commit 86c2c8f871
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
tests/pytest/tools/taosdemoTest2.py
View File

@ -33,18 +33,23 @@ class TDTestCase:
if(threadID == 0): if(threadID == 0):
os.system("yes | taosdemo -t %d -n %d -x" % (self.numberOfTables, self.numberOfRecords)) os.system("yes | taosdemo -t %d -n %d -x" % (self.numberOfTables, self.numberOfRecords))
if(threadID == 1): if(threadID == 1):
time.sleep(2)
print("use test") print("use test")
tdSql.execute("use test") tdSql.execute("use test")
# check if all the tables have heen created
while True: while True:
tdSql.query("show tables") tdSql.query("show tables")
rows = tdSql.queryRows rows = tdSql.queryRows
if(rows == 10): print("number of tables: %d" % rows)
break if(rows == self.numberOfTables):
break
time.sleep(1)
# check if there are any records in the last created table
while True: while True:
print("query started") print("query started")
tdSql.query("select * from test.t9") tdSql.query("select * from test.t9")
rows = tdSql.queryRows rows = tdSql.queryRows
print("rows %d" % rows) print("number of records: %d" % rows)
if(rows > 0): if(rows > 0):
break break
time.sleep(1) time.sleep(1)