Elgato_dark/TDengine
1
0
Fork 0
mirror of https://github.com/taosdata/TDengine synced 2026-05-24 10:09:01 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4
TDengine/tests/system-test/2-query/diff.py

277 lines
11 KiB
Python
Raw Normal View History

update
2022-05-09 08:50:59 +00:00
from wsgiref.headers import tspecials
add case for diff
2022-05-07 07:15:36 +00:00
from util.log import *
from util.cases import *
from util.sql import *
import numpy as np
class TDTestCase:
test:add replica 3 for all testcases and frameworks
2022-10-31 06:41:59 +00:00
def init(self, conn, logSql, replicaVar=1):
test:add replica parameters for all testcase
2022-11-02 09:33:44 +00:00
self.replicaVar = int(replicaVar)
add case for diff
2022-05-07 07:15:36 +00:00
tdLog.debug("start to execute %s" % __file__)
tdSql.init(conn.cursor())
self.rowNum = 10
self.ts = 1537146000000
self.perfix = 'dev'
self.tables = 10
def run(self):
tdSql.prepare()
fix case
2022-07-21 09:05:31 +00:00
dbname = "db"
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.execute(
fix case
2022-07-21 09:05:31 +00:00
f"create table {dbname}.ntb(ts timestamp,c1 int,c2 double,c3 float)")
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.execute(
add test case
2023-07-04 03:31:49 +00:00
f"insert into {dbname}.ntb values('2023-01-01 00:00:01',1,1.0,10.5)('2023-01-01 00:00:02',10,-100.0,5.1)('2023-01-01 00:00:03',-1,15.1,5.0)")
update
2022-05-09 08:50:59 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(c1,0) from {dbname}.ntb")
update
2022-05-09 08:50:59 +00:00
tdSql.checkRows(2)
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.checkData(0, 0, 9)
tdSql.checkData(1, 0, -11)
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(c1,1) from {dbname}.ntb")
update
2022-05-09 08:50:59 +00:00
tdSql.checkRows(2)
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.checkData(0, 0, 9)
tdSql.checkData(1, 0, None)
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(c2,0) from {dbname}.ntb")
update
2022-05-09 08:50:59 +00:00
tdSql.checkRows(2)
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.checkData(0, 0, -101)
tdSql.checkData(1, 0, 115.1)
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(c2,1) from {dbname}.ntb")
update
2022-05-09 08:50:59 +00:00
tdSql.checkRows(2)
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.checkData(0, 0, None)
tdSql.checkData(1, 0, 115.1)
update
2022-05-09 08:50:59 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(c3,0) from {dbname}.ntb")
update
2022-05-09 08:50:59 +00:00
tdSql.checkRows(2)
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.checkData(0, 0, -5.4)
tdSql.checkData(1, 0, -0.1)
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(c3,1) from {dbname}.ntb")
update
2022-05-09 08:50:59 +00:00
tdSql.checkRows(2)
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.checkData(0, 0, None)
tdSql.checkData(1, 0, None)
add case for diff
2022-05-07 07:15:36 +00:00
add test cases
2023-05-31 05:42:02 +00:00
# handle null values
tdSql.execute(
f"create table {dbname}.ntb_null(ts timestamp,c1 int,c2 double,c3 float,c4 bool)")
tdSql.execute(f"insert into {dbname}.ntb_null values(now, 1, 1.0, NULL, NULL)")
tdSql.execute(f"insert into {dbname}.ntb_null values(now, NULL, 2.0, 2.0, NULL)")
tdSql.execute(f"insert into {dbname}.ntb_null values(now, 2, NULL, NULL, false)")
tdSql.execute(f"insert into {dbname}.ntb_null values(now, NULL, 1.0, 1.0, NULL)")
tdSql.execute(f"insert into {dbname}.ntb_null values(now, NULL, 3.0, NULL, true)")
tdSql.execute(f"insert into {dbname}.ntb_null values(now, 3, NULL, 3.0, NULL)")
tdSql.execute(f"insert into {dbname}.ntb_null values(now, 1, NULL, NULL, true)")
tdSql.query(f"select diff(c1) from {dbname}.ntb_null")
tdSql.checkRows(6)
tdSql.checkData(0, 0, None)
tdSql.checkData(1, 0, 1)
tdSql.checkData(2, 0, None)
tdSql.checkData(3, 0, None)
tdSql.checkData(4, 0, 1)
tdSql.checkData(5, 0, -2)
tdSql.query(f"select diff(c2) from {dbname}.ntb_null")
tdSql.checkRows(6)
tdSql.checkData(0, 0, 1)
tdSql.checkData(1, 0, None)
tdSql.checkData(2, 0, -1)
tdSql.checkData(3, 0, 2)
tdSql.checkData(4, 0, None)
tdSql.checkData(5, 0, None)
tdSql.query(f"select diff(c3) from {dbname}.ntb_null")
tdSql.checkRows(6)
tdSql.checkData(0, 0, None)
tdSql.checkData(1, 0, None)
tdSql.checkData(2, 0, -1)
tdSql.checkData(3, 0, None)
tdSql.checkData(4, 0, 2)
tdSql.checkData(5, 0, None)
tdSql.query(f"select diff(c4) from {dbname}.ntb_null")
tdSql.checkRows(6)
tdSql.checkData(0, 0, None)
tdSql.checkData(1, 0, None)
tdSql.checkData(2, 0, None)
tdSql.checkData(3, 0, 1)
tdSql.checkData(4, 0, None)
tdSql.checkData(5, 0, 0)
tdSql.query(f"select diff(c1),diff(c2),diff(c3),diff(c4) from {dbname}.ntb_null")
tdSql.checkRows(6)
tdSql.checkData(0, 0, None)
tdSql.checkData(1, 0, 1)
tdSql.checkData(2, 0, None)
tdSql.checkData(3, 0, None)
tdSql.checkData(4, 0, 1)
tdSql.checkData(5, 0, -2)
tdSql.checkData(0, 1, 1)
tdSql.checkData(1, 1, None)
tdSql.checkData(2, 1, -1)
tdSql.checkData(3, 1, 2)
tdSql.checkData(4, 1, None)
tdSql.checkData(5, 1, None)
tdSql.checkData(0, 2, None)
tdSql.checkData(1, 2, None)
tdSql.checkData(2, 2, -1)
tdSql.checkData(3, 2, None)
tdSql.checkData(4, 2, 2)
tdSql.checkData(5, 2, None)
tdSql.checkData(0, 3, None)
tdSql.checkData(1, 3, None)
tdSql.checkData(2, 3, None)
tdSql.checkData(3, 3, 1)
tdSql.checkData(4, 3, None)
tdSql.checkData(5, 3, 0)
tdSql.query(f"select diff(c1),diff(c2),diff(c3),diff(c4) from {dbname}.ntb_null where c1 is not null")
tdSql.checkRows(3)
tdSql.checkData(0, 0, 1)
tdSql.checkData(1, 0, 1)
tdSql.checkData(2, 0, -2)
tdSql.checkData(0, 1, None)
tdSql.checkData(1, 1, None)
tdSql.checkData(2, 1, None)
tdSql.checkData(0, 2, None)
tdSql.checkData(1, 2, None)
tdSql.checkData(2, 2, None)
tdSql.checkData(0, 3, None)
tdSql.checkData(1, 3, None)
tdSql.checkData(2, 3, 1)
fix case
2022-07-21 09:05:31 +00:00
tdSql.execute(f'''create table {dbname}.stb(ts timestamp, col1 tinyint, col2 smallint, col3 int, col4 bigint, col5 float, col6 double,
add case for diff
2022-05-07 07:15:36 +00:00
col7 bool, col8 binary(20), col9 nchar(20), col11 tinyint unsigned, col12 smallint unsigned, col13 int unsigned, col14 bigint unsigned) tags(loc nchar(20))''')
fix case
2022-07-21 09:05:31 +00:00
tdSql.execute(f"create table {dbname}.stb_1 using {dbname}.stb tags('beijing')")
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.execute(
fix case
2022-07-21 09:05:31 +00:00
f"insert into {dbname}.stb_1 values(%d, 0, 0, 0, 0, 0.0, 0.0, False, ' ', ' ', 0, 0, 0, 0)" % (self.ts - 1))
update diff.py
2022-05-26 03:30:38 +00:00
# diff verifacation
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col1) from {dbname}.stb_1")
update
2022-05-07 08:22:11 +00:00
tdSql.checkRows(0)
update diff.py
2022-05-26 03:30:38 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col2) from {dbname}.stb_1")
update
2022-05-07 08:22:11 +00:00
tdSql.checkRows(0)
add case for diff
2022-05-07 07:15:36 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col3) from {dbname}.stb_1")
update
2022-05-07 08:22:11 +00:00
tdSql.checkRows(0)
add case for diff
2022-05-07 07:15:36 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col4) from {dbname}.stb_1")
update
2022-05-07 08:22:11 +00:00
tdSql.checkRows(0)
add case for diff
2022-05-07 07:15:36 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col5) from {dbname}.stb_1")
update
2022-05-07 08:22:11 +00:00
tdSql.checkRows(0)
add case for diff
2022-05-07 07:15:36 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col6) from {dbname}.stb_1")
update
2022-05-07 08:22:11 +00:00
tdSql.checkRows(0)
add case for diff
2022-05-07 07:15:36 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col7) from {dbname}.stb_1")
update test case
2022-05-10 02:15:16 +00:00
tdSql.checkRows(0)
add case for diff
2022-05-07 07:15:36 +00:00
for i in range(self.rowNum):
fix case
2022-07-21 09:05:31 +00:00
tdSql.execute(f"insert into {dbname}.stb_1 values(%d, %d, %d, %d, %d, %f, %f, %d, 'taosdata%d', '涛思数据%d', %d, %d, %d, %d)"
update diff.py
2022-05-26 03:30:38 +00:00
% (self.ts + i, i + 1, i + 1, i + 1, i + 1, i + 0.1, i + 0.1, i % 2, i + 1, i + 1, i + 1, i + 1, i + 1, i + 1))
fix case
2022-07-21 09:05:31 +00:00
# tdSql.error(f"select diff(col7) from {dbname}.stb")
update diff.py
2022-05-26 03:30:38 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.error(f"select diff(col8) from {dbname}.stb")
tdSql.error(f"select diff(col8) from {dbname}.stb_1")
tdSql.error(f"select diff(col9) from {dbname}.stb")
tdSql.error(f"select diff(col9) from {dbname}.stb_1")
tdSql.error(f"select diff(col11) from {dbname}.stb_1")
tdSql.error(f"select diff(col12) from {dbname}.stb_1")
tdSql.error(f"select diff(col13) from {dbname}.stb_1")
tdSql.error(f"select diff(col14) from {dbname}.stb_1")
test:supplement muti-branch for query fuction testcase
2022-10-28 08:35:13 +00:00
tdSql.error(f"select diff(col14) from {dbname}.stb_1")
tdSql.error(f"select diff(col1,col1,col1) from {dbname}.stb_1")
tdSql.error(f"select diff(col1,1,col1) from {dbname}.stb_1")
tdSql.error(f"select diff(col1,col1,col) from {dbname}.stb_1")
tdSql.error(f"select diff(col1,col1) from {dbname}.stb_1")
tdSql.error(f"select diff(col1,'123') from {dbname}.stb_1")
tdSql.error(f"select diff(col1,1.23) from {dbname}.stb_1")
tdSql.error(f"select diff(col1,-1) from {dbname}.stb_1")
fix case
2022-07-27 06:38:34 +00:00
tdSql.query(f"select ts,diff(col1),ts from {dbname}.stb_1")
add test cases
2023-05-31 05:45:02 +00:00
tdSql.error(f"select diff(col1, 1),diff(col2) from {dbname}.stb_1")
tdSql.error(f"select diff(col1, 1),diff(col2, 0) from {dbname}.stb_1")
tdSql.error(f"select diff(col1, 1),diff(col2, 1) from {dbname}.stb_1")
update
2022-05-09 01:38:05 +00:00
test:supplement muti-branch for query fuction testcase
2022-10-28 08:35:13 +00:00
tdSql.query(f"select diff(ts) from {dbname}.stb_1")
tdSql.checkRows(10)
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col1) from {dbname}.stb_1")
update diff.py
2022-05-09 07:01:06 +00:00
tdSql.checkRows(10)
update
2022-05-09 01:38:05 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col2) from {dbname}.stb_1")
update diff.py
2022-05-09 07:01:06 +00:00
tdSql.checkRows(10)
update
2022-05-09 01:38:05 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col3) from {dbname}.stb_1")
update diff.py
2022-05-09 07:01:06 +00:00
tdSql.checkRows(10)
update
2022-05-09 01:38:05 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col4) from {dbname}.stb_1")
update diff.py
2022-05-09 07:01:06 +00:00
tdSql.checkRows(10)
update
2022-05-09 01:38:05 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col5) from {dbname}.stb_1")
update diff.py
2022-05-09 07:01:06 +00:00
tdSql.checkRows(10)
update
2022-05-09 01:38:05 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col6) from {dbname}.stb_1")
update diff.py
2022-05-09 07:01:06 +00:00
tdSql.checkRows(10)
update diff.py
2022-05-26 03:30:38 +00:00
fix case
2022-07-21 09:05:31 +00:00
tdSql.execute(f'''create table {dbname}.stb1(ts timestamp, col1 tinyint, col2 smallint, col3 int, col4 bigint, col5 float, col6 double,
update diff.py
2022-05-26 03:30:38 +00:00
col7 bool, col8 binary(20), col9 nchar(20), col11 tinyint unsigned, col12 smallint unsigned, col13 int unsigned, col14 bigint unsigned) tags(loc nchar(20))''')
fix case
2022-07-21 09:05:31 +00:00
tdSql.execute(f"create table {dbname}.stb1_1 using {dbname}.stb tags('shanghai')")
update diff.py
2022-05-26 03:30:38 +00:00
for i in range(self.rowNum):
fix case
2022-07-21 09:05:31 +00:00
tdSql.execute(f"insert into {dbname}.stb1_1 values(%d, %d, %d, %d, %d, %f, %f, %d, 'taosdata%d', '涛思数据%d', %d, %d, %d, %d)"
update diff.py
2022-05-26 03:30:38 +00:00
% (self.ts + i, i + 1, i + 1, i + 1, i + 1, i + 0.1, i + 0.1, i % 2, i + 1, i + 1, i + 1, i + 1, i + 1, i + 1))
for i in range(self.rowNum):
fix case
2022-07-21 09:05:31 +00:00
tdSql.execute(f"insert into {dbname}.stb1_1 values(%d, %d, %d, %d, %d, %f, %f, %d, 'taosdata%d', '涛思数据%d', %d, %d, %d, %d)"
update diff.py
2022-05-26 03:30:38 +00:00
% (self.ts - i-1, i-1, i-1, i-1, i-1, -i - 0.1, -i - 0.1, -i % 2, i - 1, i - 1, i + 1, i + 1, i + 1, i + 1))
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col1,0) from {dbname}.stb1_1")
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.checkRows(19)
fix case
2022-07-21 09:05:31 +00:00
tdSql.query(f"select diff(col1,1) from {dbname}.stb1_1")
update diff.py
2022-05-26 03:30:38 +00:00
tdSql.checkRows(19)
tdSql.checkData(0,0,None)
add test case
2023-07-04 03:31:49 +00:00
# TD-25098
tdSql.query(f"select ts, diff(c1) from {dbname}.ntb order by ts")
tdSql.checkRows(2)
tdSql.checkData(0, 0, '2023-01-01 00:00:02.000')
tdSql.checkData(1, 0, '2023-01-01 00:00:03.000')
tdSql.checkData(0, 1, 9)
tdSql.checkData(1, 1, -11)
tdSql.query(f"select ts, diff(c1) from {dbname}.ntb order by ts desc")
tdSql.checkRows(2)
tdSql.checkData(0, 0, '2023-01-01 00:00:03.000')
tdSql.checkData(1, 0, '2023-01-01 00:00:02.000')
tdSql.checkData(0, 1, -11)
tdSql.checkData(1, 1, 9)
tdSql.query(f"select ts, diff(c1) from (select * from {dbname}.ntb order by ts)")
tdSql.checkRows(2)
tdSql.checkData(0, 0, '2023-01-01 00:00:02.000')
tdSql.checkData(1, 0, '2023-01-01 00:00:03.000')
tdSql.checkData(0, 1, 9)
tdSql.checkData(1, 1, -11)
tdSql.query(f"select ts, diff(c1) from (select * from {dbname}.ntb order by ts desc)")
tdSql.checkRows(2)
tdSql.checkData(0, 0, '2023-01-01 00:00:02.000')
tdSql.checkData(1, 0, '2023-01-01 00:00:01.000')
tdSql.checkData(0, 1, 11)
tdSql.checkData(1, 1, -9)
add case for diff
2022-05-07 07:15:36 +00:00
def stop(self):
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
update diff.py
2022-05-26 03:30:38 +00:00
add case for diff
2022-05-07 07:15:36 +00:00
tdCases.addWindows(__file__, TDTestCase())
update diff.py
2022-05-26 03:30:38 +00:00
tdCases.addLinux(__file__, TDTestCase())
Reference in a new issue Copy permalink