Merge pull request #5113 from taosdata/xiaoping/add_test_case
[TD-2850][TD-2671]<test>: add test case
This commit is contained in:
commit
91a3148aac
|
@ -111,6 +111,18 @@ class TDTestCase:
|
|||
tdSql.query("select * from tb where c5 = 'true' ")
|
||||
tdSql.checkRows(5)
|
||||
|
||||
# For jira: https://jira.taosdata.com:18080/browse/TD-2850
|
||||
tdSql.execute("create database 'Test' ")
|
||||
tdSql.execute("use 'Test' ")
|
||||
tdSql.execute("create table 'TB'(ts timestamp, 'Col1' int) tags('Tag1' int)")
|
||||
tdSql.execute("insert into 'Tb0' using tb tags(1) values(now, 1)")
|
||||
tdSql.query("select * from tb")
|
||||
tdSql.checkRows(1)
|
||||
|
||||
tdSql.query("select * from tb0")
|
||||
tdSql.checkRows(1)
|
||||
|
||||
|
||||
def stop(self):
|
||||
tdSql.close()
|
||||
tdLog.success("%s successfully executed" % __file__)
|
||||
|
|
|
@ -47,6 +47,40 @@ class TDTestCase:
|
|||
tdSql.query("select * from db.st where dev='dev_02'")
|
||||
tdSql.checkRows(1)
|
||||
|
||||
#For: https://jira.taosdata.com:18080/browse/TD-2671
|
||||
print("==============step3")
|
||||
tdSql.execute(
|
||||
"create stable if not exists stb (ts timestamp, tagtype int) tags(dev nchar(50))")
|
||||
tdSql.execute(
|
||||
'CREATE TABLE if not exists dev_01 using stb tags("dev_01")')
|
||||
tdSql.execute(
|
||||
'CREATE TABLE if not exists dev_02 using stb tags("dev_02")')
|
||||
|
||||
print("==============step4")
|
||||
|
||||
tdSql.execute(
|
||||
"""INSERT INTO dev_01(ts, tagtype) VALUES('2020-05-13 10:00:00.000', 1),
|
||||
('2020-05-13 10:00:00.001', 1)
|
||||
dev_02 VALUES('2020-05-13 10:00:00.001', 1)""")
|
||||
|
||||
tdSql.query("select * from db.stb where dev='dev_01'")
|
||||
tdSql.checkRows(2)
|
||||
|
||||
tdSql.query("select * from db.stb where dev='dev_02'")
|
||||
tdSql.checkRows(1)
|
||||
|
||||
tdSql.query("describe db.stb")
|
||||
tdSql.checkRows(3)
|
||||
|
||||
tdSql.execute("alter stable db.stb add tag t1 int")
|
||||
tdSql.query("describe db.stb")
|
||||
tdSql.checkRows(4)
|
||||
|
||||
tdSql.execute("drop stable db.stb")
|
||||
tdSql.query("show stables")
|
||||
tdSql.checkRows(1)
|
||||
|
||||
|
||||
def stop(self):
|
||||
tdSql.close()
|
||||
tdLog.success("%s successfully executed" % __file__)
|
||||
|
|
|
@ -31,10 +31,18 @@ class TDTestCase:
|
|||
|
||||
def insertDataAndAlterTable(self, threadID):
|
||||
if(threadID == 0):
|
||||
os.system("yes | taosdemo -t %d -n %d" % (self.numberOfTables, self.numberOfRecords))
|
||||
os.system("yes | taosdemo -t %d -n %d -x" % (self.numberOfTables, self.numberOfRecords))
|
||||
if(threadID == 1):
|
||||
print("use test")
|
||||
tdSql.execute("use test")
|
||||
while True:
|
||||
print("query started")
|
||||
tdSql.query("select * from test.t9")
|
||||
rows = tdSql.queryRows
|
||||
print("rows %d" % rows)
|
||||
if(rows > 0):
|
||||
break
|
||||
time.sleep(1)
|
||||
print("alter table test.meters add column f4 int")
|
||||
tdSql.execute("alter table test.meters add column f4 int")
|
||||
print("insert into test.t0 values (now, 1, 2, 3, 4)")
|
||||
|
@ -46,8 +54,8 @@ class TDTestCase:
|
|||
t1 = threading.Thread(target=self.insertDataAndAlterTable, args=(0, ))
|
||||
t2 = threading.Thread(target=self.insertDataAndAlterTable, args=(1, ))
|
||||
|
||||
t1.start()
|
||||
time.sleep(2)
|
||||
t1.start()
|
||||
time.sleep(2)
|
||||
t2.start()
|
||||
t1.join()
|
||||
t2.join()
|
||||
|
|
Loading…
Reference in New Issue