Merge pull request #26486 from taosdata/ts5131
udpate test case for backquote modification
This commit is contained in:
commit
fdf9e69184
|
@ -97,13 +97,45 @@ class TDTestCase:
|
|||
tdSql.checkEqual(tdSql.queryResult[0][1], 123)
|
||||
tdSql.checkEqual(tdSql.queryResult[0][2], 4)
|
||||
|
||||
tdSql.execute(f'drop database {self.dbname}')
|
||||
# tdSql.execute(f'drop database {self.dbname}')
|
||||
|
||||
def view_name_check(self):
|
||||
"""Cover the view name with backquote"""
|
||||
tdSql.execute(f'create view `v1` as select * from (select `ts`, `c0` from ntb1) `t1`;')
|
||||
tdSql.query('select * from `v1`;')
|
||||
tdSql.checkRows(1)
|
||||
tdSql.execute(f'drop view `v1`;')
|
||||
|
||||
def query_check(self):
|
||||
"""Cover the table name, column name with backquote in query statement"""
|
||||
tdSql.query(f'select `t1`.`ts`, `t1`.`c0` + 2 as `c1` from `{self.ntbname1}` `t1` union select `t2`.`ts`, `t2`.`c0` from `{self.ntbname2}` `t2`')
|
||||
tdSql.checkRows(2)
|
||||
|
||||
tdSql.query(f'select `t1`.`ts`, `t1`.`c0` + `t2`.`c0` as `c0`, `t1`.`c1` * `t2`.`c1` as `c1` from `{self.ntbname1}` `t1` join `{self.ntbname2}` `t2` on timetruncate(`t1`.`ts`, 1s) = timetruncate(`t2`.`ts`, 1s);')
|
||||
tdSql.checkRows(1)
|
||||
tdSql.checkEqual(tdSql.queryResult[0][1], 3)
|
||||
|
||||
tdSql.query(f'select `t1`.`ts`, `t1`.`c1`, `t1`.`c2` from (select `ts`, `c0` + 1 as `c1`, `c1` + 2 as `c2` from `{self.ntbname1}`) `t1`;')
|
||||
tdSql.checkEqual(tdSql.queryResult[0][1], 2)
|
||||
tdSql.checkEqual(tdSql.queryResult[0][2], 3)
|
||||
|
||||
tdSql.query(f'select `t`.`ts`, cast(`t`.`v1` as int) + `t`.`c0` as `v` from (select `ts`, "12" as `v1`, `c0`, `c1` from `ntb1`) `t`;')
|
||||
tdSql.checkRows(1)
|
||||
tdSql.checkEqual(tdSql.queryResult[0][1], 13)
|
||||
|
||||
tdSql.query(f'select count(`t1`.`ts`) from (select `t`.`ts` from `{self.ntbname1}` `t`) `t1`;')
|
||||
tdSql.checkRows(1)
|
||||
|
||||
def run(self):
|
||||
self.topic_name_check()
|
||||
self.db_name_check()
|
||||
self.stream_name_check()
|
||||
self.table_name_check()
|
||||
self.view_name_check()
|
||||
self.query_check()
|
||||
|
||||
def stop(self):
|
||||
tdSql.execute(f'drop database {self.dbname}')
|
||||
tdSql.close()
|
||||
tdLog.success("%s successfully executed" % __file__)
|
||||
|
||||
|
|
Loading…
Reference in New Issue