[TD-14487]<test>:add test case
This commit is contained in:
parent
e14570f66f
commit
19f0780829
|
@ -19,13 +19,13 @@ class TDTestCase:
|
||||||
def run(self): # sourcery skip: extract-duplicate-method
|
def run(self): # sourcery skip: extract-duplicate-method
|
||||||
tdSql.prepare()
|
tdSql.prepare()
|
||||||
|
|
||||||
tdLog.printNoPrefix("==========step1:create normal table")
|
tdLog.printNoPrefix("==========step1:create normal table==========")
|
||||||
tdSql.execute(
|
tdSql.execute(
|
||||||
'''create table if not exists normaltb
|
'''create table if not exists normaltb
|
||||||
(ts timestamp, c1 int, c2 float,c3 double)
|
(ts timestamp, c1 int, c2 float,c3 double)
|
||||||
'''
|
'''
|
||||||
)
|
)
|
||||||
tdLog.printNoPrefix("==========step2:insert data")
|
tdLog.printNoPrefix("==========step2:insert data==========")
|
||||||
tdSql.execute("insert into normaltb values(now,1,1.55,100.555555)")
|
tdSql.execute("insert into normaltb values(now,1,1.55,100.555555)")
|
||||||
tdSql.query("select timezone() from normaltb")
|
tdSql.query("select timezone() from normaltb")
|
||||||
tdSql.checkRows(1)
|
tdSql.checkRows(1)
|
||||||
|
@ -34,25 +34,39 @@ class TDTestCase:
|
||||||
tdSql.query("select timezone() from normaltb")
|
tdSql.query("select timezone() from normaltb")
|
||||||
tdSql.checkRows(2)
|
tdSql.checkRows(2)
|
||||||
|
|
||||||
tdSql.checkData(0,0,"Asia/Shanghai (CST, +0800)")
|
# tdSql.checkData(0,0,"Asia/Shanghai (CST, +0800)")
|
||||||
tdSql.checkData(1,0,"Asia/Shanghai (CST, +0800)")
|
# tdSql.checkData(1,0,"Asia/Shanghai (CST, +0800)")
|
||||||
|
|
||||||
tdSql.execute("insert into normaltb values(today(),3,3.333,333.333333)")
|
tdSql.execute("insert into normaltb values(today(),3,3.333,333.333333)")
|
||||||
tdSql.query("select * from normaltb where ts=today()")
|
tdSql.query("select * from normaltb where ts=today()")
|
||||||
tdSql.checkRows(1)
|
tdSql.checkRows(1)
|
||||||
tdSql.checkData(0,1,3)
|
tdSql.checkData(0,1,3)
|
||||||
for i in range(0,50):
|
# for i in range(0,50):
|
||||||
tdSql.query("select timezone() from db.normaltb")
|
# tdSql.query("select timezone() from db.normaltb")
|
||||||
tdSql.checkData(0,0,"Asia/Shanghai (CST, +0800)")
|
# tdSql.checkData(0,0,"Asia/Shanghai (CST, +0800)")
|
||||||
i+=1
|
# i+=1
|
||||||
sleep(0.5)
|
# sleep(0.5)
|
||||||
|
|
||||||
|
tdSql.query("select today() from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select today() from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
tdSql.query("select now() from db.normaltb")
|
tdSql.query("select now() from db.normaltb")
|
||||||
tdSql.checkRows(3)
|
tdSql.checkRows(3)
|
||||||
tdSql.query("select now() from normaltb")
|
tdSql.query("select now() from normaltb")
|
||||||
tdSql.checkRows(3)
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() +1w from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() +1w from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() +1d from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() +1d from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
tdSql.query("select now() +1h from db.normaltb")
|
tdSql.query("select now() +1h from db.normaltb")
|
||||||
tdSql.checkRows(3)
|
tdSql.checkRows(3)
|
||||||
tdSql.query("select now() +1h from normaltb")
|
tdSql.query("select now() +1h from normaltb")
|
||||||
|
@ -83,14 +97,155 @@ class TDTestCase:
|
||||||
tdSql.query("select now() +1b from normaltb")
|
tdSql.query("select now() +1b from normaltb")
|
||||||
tdSql.checkRows(3)
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
tdSql.execute("create table stb (ts timestamp,c0 int) tags(t0 int)")
|
tdSql.query("select now() -1w from db.normaltb")
|
||||||
tdSql.execute("create table stb_1 using stb tags(1)")
|
tdSql.checkRows(3)
|
||||||
tdSql.execute("insert into stb_1 values(now(),1000)")
|
tdSql.query("select now() -1w from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() -1d from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() -1d from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() -1h from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() -1h from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() -1m from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() -1m from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() -1s from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() -1s from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() -1a from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() -1a from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() -1u from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() -1u from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
tdSql.query("select now() -1b from db.normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.query("select now() -1b from normaltb")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
# tdLog.printNoPrefix("==========step3:create super table==========")
|
||||||
|
# tdSql.execute("create table stb (ts timestamp,c0 int) tags(t0 int)")
|
||||||
|
# tdSql.execute("create table stb_1 using stb tags(1)")
|
||||||
|
# tdSql.execute("create table stb_2 using stb tags(2)")
|
||||||
|
|
||||||
|
# tdLog.printNoPrefix("==========step4:insert data==========")
|
||||||
|
# tdSql.execute("insert into stb_1 values(now(),1000)")
|
||||||
# tdSql.query("select timezone() from stb")
|
# tdSql.query("select timezone() from stb")
|
||||||
# tdSql.checkRows(1)
|
# tdSql.checkRows(1)
|
||||||
# tdSql.checkData(0,0,"Asia/Shanghai (CST, +0800)")
|
# tdSql.checkData(0,0,"Asia/Shanghai (CST, +0800)")
|
||||||
|
|
||||||
|
# tdSql.execute("insert into stb_1 values(now(),1000)")
|
||||||
|
# tdSql.query("select timezone() from stb")
|
||||||
|
# tdSql.checkRows(1)
|
||||||
|
# tdSql.checkData(0,0,"Asia/Shanghai (CST, +0800)")
|
||||||
|
|
||||||
|
# tdSql.execute("insert into stb_2 values(now,1000)")
|
||||||
|
# tdSql.query("select timezone() from stb")
|
||||||
|
# tdSql.checkRows(2)
|
||||||
|
|
||||||
|
# tdSql.query("select now() from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() +1w from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() +1w from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() +1d from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() +1d from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() +1h from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() +1h from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() +1m from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() +1m from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() +1s from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() +1s from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() +1a from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() +1a from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() +1u from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() +1u from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() +1b from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() +1b from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() -1w from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() -1w from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() -1d from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() -1d from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() -1h from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() -1h from sltb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() -1m from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() -1m from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() -1s from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() -1s from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() -1a from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() -1a from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() -1u from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() -1u from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.query("select now() -1b from db.stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
# tdSql.query("select now() -1b from stb")
|
||||||
|
# tdSql.checkRows(3)
|
||||||
|
|
||||||
|
# tdSql.execute("insert into stb_1 values(today(),100)")
|
||||||
|
# tdSql.query("select * from stb_1 where ts=today()")
|
||||||
|
# tdSql.checkRows(1)
|
||||||
|
# tdSql.checkData(0,0,100)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue