Merge pull request #15972 from taosdata/fix/TD-18115
test: add interp test cases
This commit is contained in:
Ganlin Zhao
GitHub
commit
5570e9645a
|
|
@ -0,0 +1,559 @@
|
||||||
|
import taos
|
||||||
|
import sys
|
||||||
|
|
||||||
|
from util.log import *
|
||||||
|
from util.sql import *
|
||||||
|
from util.cases import *
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
class TDTestCase:
|
||||||
|
|
||||||
|
def init(self, conn, logSql):
|
||||||
|
tdLog.debug(f"start to excute {__file__}")
|
||||||
|
tdSql.init(conn.cursor())
|
||||||
|
|
||||||
|
def run(self):
|
||||||
|
dbname = "db"
|
||||||
|
tbname = "tb"
|
||||||
|
|
||||||
|
tdSql.prepare()
|
||||||
|
|
||||||
|
tdLog.printNoPrefix("==========step1:create table")
|
||||||
|
|
||||||
|
tdSql.execute(
|
||||||
|
f'''create table if not exists {dbname}.{tbname}
|
||||||
|
(ts timestamp, c0 tinyint, c1 smallint, c2 int, c3 bigint, c4 double, c5 float, c6 bool, c7 varchar(10), c8 nchar(10))
|
||||||
|
'''
|
||||||
|
)
|
||||||
|
|
||||||
|
tdLog.printNoPrefix("==========step2:insert data")
|
||||||
|
|
||||||
|
tdSql.execute(f"insert into {dbname}.{tbname} values ('2020-02-01 00:00:05', 5, 5, 5, 5, 5.0, 5.0, true, 'varchar', 'nchar')")
|
||||||
|
tdSql.execute(f"insert into {dbname}.{tbname} values ('2020-02-01 00:00:10', 10, 10, 10, 10, 10.0, 10.0, true, 'varchar', 'nchar')")
|
||||||
|
tdSql.execute(f"insert into {dbname}.{tbname} values ('2020-02-01 00:00:15', 15, 15, 15, 15, 15.0, 15.0, true, 'varchar', 'nchar')")
|
||||||
|
|
||||||
|
tdLog.printNoPrefix("==========step3:fill null")
|
||||||
|
|
||||||
|
## {. . .}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:04', '2020-02-01 00:00:16') every(1s) fill(null)")
|
||||||
|
tdSql.checkRows(13)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, None)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
tdSql.checkData(4, 0, None)
|
||||||
|
tdSql.checkData(5, 0, None)
|
||||||
|
tdSql.checkData(6, 0, 10)
|
||||||
|
tdSql.checkData(7, 0, None)
|
||||||
|
tdSql.checkData(8, 0, None)
|
||||||
|
tdSql.checkData(9, 0, None)
|
||||||
|
tdSql.checkData(10, 0, None)
|
||||||
|
tdSql.checkData(11, 0, 15)
|
||||||
|
tdSql.checkData(12, 0, None)
|
||||||
|
|
||||||
|
## {} ...
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:01', '2020-02-01 00:00:04') every(1s) fill(null)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, None)
|
||||||
|
tdSql.checkData(2, 0, None)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
|
||||||
|
## {.}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:03', '2020-02-01 00:00:07') every(1s) fill(null)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, None)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
tdSql.checkData(4, 0, None)
|
||||||
|
|
||||||
|
## .{}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:06', '2020-02-01 00:00:09') every(1s) fill(null)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, None)
|
||||||
|
tdSql.checkData(2, 0, None)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
|
||||||
|
## .{.}.
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:08', '2020-02-01 00:00:12') every(1s) fill(null)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, None)
|
||||||
|
tdSql.checkData(2, 0, 10)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
tdSql.checkData(4, 0, None)
|
||||||
|
|
||||||
|
## ..{.}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:13', '2020-02-01 00:00:17') every(1s) fill(null)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, None)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
tdSql.checkData(4, 0, None)
|
||||||
|
|
||||||
|
## ... {}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(null)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, None)
|
||||||
|
tdSql.checkData(2, 0, None)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
|
||||||
|
tdLog.printNoPrefix("==========step4:fill value")
|
||||||
|
|
||||||
|
## {. . .}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:04', '2020-02-01 00:00:16') every(1s) fill(value, 1)")
|
||||||
|
tdSql.checkRows(13)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 1)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
tdSql.checkData(4, 0, 1)
|
||||||
|
tdSql.checkData(5, 0, 1)
|
||||||
|
tdSql.checkData(6, 0, 10)
|
||||||
|
tdSql.checkData(7, 0, 1)
|
||||||
|
tdSql.checkData(8, 0, 1)
|
||||||
|
tdSql.checkData(9, 0, 1)
|
||||||
|
tdSql.checkData(10, 0, 1)
|
||||||
|
tdSql.checkData(11, 0, 15)
|
||||||
|
tdSql.checkData(12, 0, 1)
|
||||||
|
|
||||||
|
## {} ...
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:01', '2020-02-01 00:00:04') every(1s) fill(value, 1)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 1)
|
||||||
|
tdSql.checkData(2, 0, 1)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
|
||||||
|
## {.}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:03', '2020-02-01 00:00:07') every(1s) fill(value, 1)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 1)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
tdSql.checkData(4, 0, 1)
|
||||||
|
|
||||||
|
## .{}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:06', '2020-02-01 00:00:09') every(1s) fill(value, 1)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 1)
|
||||||
|
tdSql.checkData(2, 0, 1)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
|
||||||
|
## .{.}.
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:08', '2020-02-01 00:00:12') every(1s) fill(value, 1)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 1)
|
||||||
|
tdSql.checkData(2, 0, 10)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
tdSql.checkData(4, 0, 1)
|
||||||
|
|
||||||
|
## ..{.}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:13', '2020-02-01 00:00:17') every(1s) fill(value, 1)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 1)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
tdSql.checkData(4, 0, 1)
|
||||||
|
|
||||||
|
## ... {}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(value, 1)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 1)
|
||||||
|
tdSql.checkData(2, 0, 1)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
|
||||||
|
tdLog.printNoPrefix("==========step5:fill prev")
|
||||||
|
|
||||||
|
## {. . .}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:04', '2020-02-01 00:00:16') every(1s) fill(prev)")
|
||||||
|
tdSql.checkRows(12)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, 5)
|
||||||
|
tdSql.checkData(4, 0, 5)
|
||||||
|
tdSql.checkData(5, 0, 10)
|
||||||
|
tdSql.checkData(6, 0, 10)
|
||||||
|
tdSql.checkData(7, 0, 10)
|
||||||
|
tdSql.checkData(8, 0, 10)
|
||||||
|
tdSql.checkData(9, 0, 10)
|
||||||
|
tdSql.checkData(10, 0, 15)
|
||||||
|
tdSql.checkData(11, 0, 15)
|
||||||
|
|
||||||
|
## {} ...
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:01', '2020-02-01 00:00:04') every(1s) fill(prev)")
|
||||||
|
tdSql.checkRows(0)
|
||||||
|
|
||||||
|
## {.}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:03', '2020-02-01 00:00:07') every(1s) fill(prev)")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
|
||||||
|
## .{}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:06', '2020-02-01 00:00:09') every(1s) fill(prev)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, 5)
|
||||||
|
|
||||||
|
## .{.}.
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:08', '2020-02-01 00:00:12') every(1s) fill(prev)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 10)
|
||||||
|
tdSql.checkData(3, 0, 10)
|
||||||
|
tdSql.checkData(4, 0, 10)
|
||||||
|
|
||||||
|
## ..{.}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:13', '2020-02-01 00:00:17') every(1s) fill(prev)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 10)
|
||||||
|
tdSql.checkData(1, 0, 10)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
tdSql.checkData(3, 0, 15)
|
||||||
|
tdSql.checkData(4, 0, 15)
|
||||||
|
|
||||||
|
## ... {}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(prev)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, 15)
|
||||||
|
tdSql.checkData(1, 0, 15)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
tdSql.checkData(3, 0, 15)
|
||||||
|
|
||||||
|
tdLog.printNoPrefix("==========step6:fill next")
|
||||||
|
|
||||||
|
## {. . .}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:04', '2020-02-01 00:00:16') every(1s) fill(next)")
|
||||||
|
tdSql.checkRows(12)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 10)
|
||||||
|
tdSql.checkData(3, 0, 10)
|
||||||
|
tdSql.checkData(4, 0, 10)
|
||||||
|
tdSql.checkData(5, 0, 10)
|
||||||
|
tdSql.checkData(6, 0, 10)
|
||||||
|
tdSql.checkData(7, 0, 15)
|
||||||
|
tdSql.checkData(8, 0, 15)
|
||||||
|
tdSql.checkData(9, 0, 15)
|
||||||
|
tdSql.checkData(10, 0, 15)
|
||||||
|
tdSql.checkData(11, 0, 15)
|
||||||
|
|
||||||
|
## {} ...
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:01', '2020-02-01 00:00:04') every(1s) fill(next)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, 5)
|
||||||
|
|
||||||
|
## {.}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:03', '2020-02-01 00:00:07') every(1s) fill(next)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, 10)
|
||||||
|
tdSql.checkData(4, 0, 10)
|
||||||
|
|
||||||
|
## .{}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:06', '2020-02-01 00:00:09') every(1s) fill(next)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, 10)
|
||||||
|
tdSql.checkData(1, 0, 10)
|
||||||
|
tdSql.checkData(2, 0, 10)
|
||||||
|
tdSql.checkData(3, 0, 10)
|
||||||
|
|
||||||
|
## .{.}.
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:08', '2020-02-01 00:00:12') every(1s) fill(next)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 10)
|
||||||
|
tdSql.checkData(1, 0, 10)
|
||||||
|
tdSql.checkData(2, 0, 10)
|
||||||
|
tdSql.checkData(3, 0, 15)
|
||||||
|
tdSql.checkData(4, 0, 15)
|
||||||
|
|
||||||
|
## ..{.}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:13', '2020-02-01 00:00:17') every(1s) fill(next)")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.checkData(0, 0, 15)
|
||||||
|
tdSql.checkData(1, 0, 15)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
|
||||||
|
## ... {}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(next)")
|
||||||
|
tdSql.checkRows(0)
|
||||||
|
|
||||||
|
|
||||||
|
tdLog.printNoPrefix("==========step7:fill linear")
|
||||||
|
|
||||||
|
## {. . .}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:04', '2020-02-01 00:00:16') every(1s) fill(linear)")
|
||||||
|
tdSql.checkRows(11)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 6)
|
||||||
|
tdSql.checkData(2, 0, 7)
|
||||||
|
tdSql.checkData(3, 0, 8)
|
||||||
|
tdSql.checkData(4, 0, 9)
|
||||||
|
tdSql.checkData(5, 0, 10)
|
||||||
|
tdSql.checkData(6, 0, 11)
|
||||||
|
tdSql.checkData(7, 0, 12)
|
||||||
|
tdSql.checkData(8, 0, 13)
|
||||||
|
tdSql.checkData(9, 0, 14)
|
||||||
|
tdSql.checkData(10, 0, 15)
|
||||||
|
|
||||||
|
## {} ...
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:01', '2020-02-01 00:00:04') every(1s) fill(linear)")
|
||||||
|
tdSql.checkRows(0)
|
||||||
|
|
||||||
|
## {.}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:03', '2020-02-01 00:00:07') every(1s) fill(linear)")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 6)
|
||||||
|
tdSql.checkData(2, 0, 7)
|
||||||
|
|
||||||
|
## .{}..
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:06', '2020-02-01 00:00:09') every(1s) fill(linear)")
|
||||||
|
tdSql.checkRows(4)
|
||||||
|
tdSql.checkData(0, 0, 6)
|
||||||
|
tdSql.checkData(1, 0, 7)
|
||||||
|
tdSql.checkData(2, 0, 8)
|
||||||
|
tdSql.checkData(3, 0, 9)
|
||||||
|
|
||||||
|
## .{.}.
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:08', '2020-02-01 00:00:12') every(1s) fill(linear)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 8)
|
||||||
|
tdSql.checkData(1, 0, 9)
|
||||||
|
tdSql.checkData(2, 0, 10)
|
||||||
|
tdSql.checkData(3, 0, 11)
|
||||||
|
tdSql.checkData(4, 0, 12)
|
||||||
|
|
||||||
|
## ..{.}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:13', '2020-02-01 00:00:17') every(1s) fill(linear)")
|
||||||
|
tdSql.checkRows(3)
|
||||||
|
tdSql.checkData(0, 0, 13)
|
||||||
|
tdSql.checkData(1, 0, 14)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
|
||||||
|
## ... {}
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:16', '2020-02-01 00:00:19') every(1s) fill(linear)")
|
||||||
|
tdSql.checkRows(0)
|
||||||
|
|
||||||
|
|
||||||
|
tdLog.printNoPrefix("==========step8:test intra block interpolation")
|
||||||
|
tdSql.execute(f"drop database {dbname}");
|
||||||
|
|
||||||
|
tdSql.prepare()
|
||||||
|
|
||||||
|
tdSql.execute(f"create table if not exists {dbname}.{tbname} (ts timestamp, c0 tinyint, c1 smallint, c2 int, c3 bigint, c4 double, c5 float, c6 bool, c7 varchar(10), c8 nchar(10))")
|
||||||
|
|
||||||
|
# set two data point has 10 days interval will be stored in different datablocks
|
||||||
|
tdSql.execute(f"insert into {dbname}.{tbname} values ('2020-02-01 00:00:05', 5, 5, 5, 5, 5.0, 5.0, true, 'varchar', 'nchar')")
|
||||||
|
tdSql.execute(f"insert into {dbname}.{tbname} values ('2020-02-11 00:00:05', 15, 15, 15, 15, 15.0, 15.0, true, 'varchar', 'nchar')")
|
||||||
|
|
||||||
|
tdSql.execute(f"flush database {dbname}");
|
||||||
|
|
||||||
|
# test fill null
|
||||||
|
|
||||||
|
## | {. | | .} |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:05', '2020-02-11 00:00:05') every(1d) fill(null)")
|
||||||
|
tdSql.checkRows(11)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, None)
|
||||||
|
tdSql.checkData(2, 0, None)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
tdSql.checkData(4, 0, None)
|
||||||
|
tdSql.checkData(5, 0, None)
|
||||||
|
tdSql.checkData(6, 0, None)
|
||||||
|
tdSql.checkData(7, 0, None)
|
||||||
|
tdSql.checkData(8, 0, None)
|
||||||
|
tdSql.checkData(9, 0, None)
|
||||||
|
tdSql.checkData(10, 0, 15)
|
||||||
|
|
||||||
|
## | . | {} | . |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-03 00:00:05', '2020-02-07 00:00:05') every(1d) fill(null)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, None)
|
||||||
|
tdSql.checkData(2, 0, None)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
tdSql.checkData(4, 0, None)
|
||||||
|
|
||||||
|
## | {. | } | . |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-01-31 00:00:05', '2020-02-05 00:00:05') every(1d) fill(null)")
|
||||||
|
tdSql.checkRows(6)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, None)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
tdSql.checkData(4, 0, None)
|
||||||
|
tdSql.checkData(5, 0, None)
|
||||||
|
|
||||||
|
## | . | { | .} |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-10 00:00:05', '2020-02-15 00:00:05') every(1d) fill(null)")
|
||||||
|
tdSql.checkRows(6)
|
||||||
|
tdSql.checkData(0, 0, None)
|
||||||
|
tdSql.checkData(1, 0, 15)
|
||||||
|
tdSql.checkData(2, 0, None)
|
||||||
|
tdSql.checkData(3, 0, None)
|
||||||
|
tdSql.checkData(4, 0, None)
|
||||||
|
tdSql.checkData(5, 0, None)
|
||||||
|
|
||||||
|
|
||||||
|
# test fill value
|
||||||
|
|
||||||
|
## | {. | | .} |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:05', '2020-02-11 00:00:05') every(1d) fill(value, 1)")
|
||||||
|
tdSql.checkRows(11)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 1)
|
||||||
|
tdSql.checkData(2, 0, 1)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
tdSql.checkData(4, 0, 1)
|
||||||
|
tdSql.checkData(5, 0, 1)
|
||||||
|
tdSql.checkData(6, 0, 1)
|
||||||
|
tdSql.checkData(7, 0, 1)
|
||||||
|
tdSql.checkData(8, 0, 1)
|
||||||
|
tdSql.checkData(9, 0, 1)
|
||||||
|
tdSql.checkData(10, 0, 15)
|
||||||
|
|
||||||
|
## | . | {} | . |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-03 00:00:05', '2020-02-07 00:00:05') every(1d) fill(value, 1)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 1)
|
||||||
|
tdSql.checkData(2, 0, 1)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
tdSql.checkData(4, 0, 1)
|
||||||
|
|
||||||
|
## | {. | } | . |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-01-31 00:00:05', '2020-02-05 00:00:05') every(1d) fill(value, 1)")
|
||||||
|
tdSql.checkRows(6)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 1)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
tdSql.checkData(4, 0, 1)
|
||||||
|
tdSql.checkData(5, 0, 1)
|
||||||
|
|
||||||
|
## | . | { | .} |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-10 00:00:05', '2020-02-15 00:00:05') every(1d) fill(value, 1)")
|
||||||
|
tdSql.checkRows(6)
|
||||||
|
tdSql.checkData(0, 0, 1)
|
||||||
|
tdSql.checkData(1, 0, 15)
|
||||||
|
tdSql.checkData(2, 0, 1)
|
||||||
|
tdSql.checkData(3, 0, 1)
|
||||||
|
tdSql.checkData(4, 0, 1)
|
||||||
|
tdSql.checkData(5, 0, 1)
|
||||||
|
|
||||||
|
|
||||||
|
# test fill prev
|
||||||
|
|
||||||
|
## | {. | | .} |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:05', '2020-02-11 00:00:05') every(1d) fill(prev)")
|
||||||
|
tdSql.checkRows(11)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, 5)
|
||||||
|
tdSql.checkData(4, 0, 5)
|
||||||
|
tdSql.checkData(5, 0, 5)
|
||||||
|
tdSql.checkData(6, 0, 5)
|
||||||
|
tdSql.checkData(7, 0, 5)
|
||||||
|
tdSql.checkData(8, 0, 5)
|
||||||
|
tdSql.checkData(9, 0, 5)
|
||||||
|
tdSql.checkData(10, 0, 15)
|
||||||
|
|
||||||
|
## | . | {} | . |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-03 00:00:05', '2020-02-07 00:00:05') every(1d) fill(prev)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, 5)
|
||||||
|
tdSql.checkData(4, 0, 5)
|
||||||
|
|
||||||
|
## | {. | } | . |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-01-31 00:00:05', '2020-02-05 00:00:05') every(1d) fill(prev)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 5)
|
||||||
|
tdSql.checkData(3, 0, 5)
|
||||||
|
tdSql.checkData(4, 0, 5)
|
||||||
|
|
||||||
|
## | . | { | .} |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-10 00:00:05', '2020-02-15 00:00:05') every(1d) fill(prev)")
|
||||||
|
tdSql.checkRows(6)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 15)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
tdSql.checkData(3, 0, 15)
|
||||||
|
tdSql.checkData(4, 0, 15)
|
||||||
|
tdSql.checkData(5, 0, 15)
|
||||||
|
|
||||||
|
# test fill next
|
||||||
|
|
||||||
|
## | {. | | .} |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-01 00:00:05', '2020-02-11 00:00:05') every(1d) fill(next)")
|
||||||
|
tdSql.checkRows(11)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 15)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
tdSql.checkData(3, 0, 15)
|
||||||
|
tdSql.checkData(4, 0, 15)
|
||||||
|
tdSql.checkData(5, 0, 15)
|
||||||
|
tdSql.checkData(6, 0, 15)
|
||||||
|
tdSql.checkData(7, 0, 15)
|
||||||
|
tdSql.checkData(8, 0, 15)
|
||||||
|
tdSql.checkData(9, 0, 15)
|
||||||
|
tdSql.checkData(10, 0, 15)
|
||||||
|
|
||||||
|
## | . | {} | . |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-03 00:00:05', '2020-02-07 00:00:05') every(1d) fill(next)")
|
||||||
|
tdSql.checkRows(5)
|
||||||
|
tdSql.checkData(0, 0, 15)
|
||||||
|
tdSql.checkData(1, 0, 15)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
tdSql.checkData(3, 0, 15)
|
||||||
|
tdSql.checkData(4, 0, 15)
|
||||||
|
|
||||||
|
## | {. | } | . |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-01-31 00:00:05', '2020-02-05 00:00:05') every(1d) fill(next)")
|
||||||
|
tdSql.checkRows(6)
|
||||||
|
tdSql.checkData(0, 0, 5)
|
||||||
|
tdSql.checkData(1, 0, 5)
|
||||||
|
tdSql.checkData(2, 0, 15)
|
||||||
|
tdSql.checkData(3, 0, 15)
|
||||||
|
tdSql.checkData(4, 0, 15)
|
||||||
|
tdSql.checkData(5, 0, 15)
|
||||||
|
|
||||||
|
## | . | { | .} |
|
||||||
|
tdSql.query(f"select interp(c0) from {dbname}.{tbname} range('2020-02-10 00:00:05', '2020-02-15 00:00:05') every(1d) fill(next)")
|
||||||
|
tdSql.checkRows(2)
|
||||||
|
tdSql.checkData(0, 0, 15)
|
||||||
|
tdSql.checkData(1, 0, 15)
|
||||||
|
|
||||||
|
def stop(self):
|
||||||
|
tdSql.close()
|
||||||
|
tdLog.success(f"{__file__} successfully executed")
|
||||||
|
|
||||||
|
tdCases.addLinux(__file__, TDTestCase())
|
||||||
|
tdCases.addWindows(__file__, TDTestCase())
|
||||||
|
|
@ -335,7 +335,7 @@ class TDTestCase:
|
||||||
# case11 = {"alias": ", st1"}
|
# case11 = {"alias": ", st1"}
|
||||||
# self.checksample(**case11)
|
# self.checksample(**case11)
|
||||||
tdSql.query("select sample( c1 , 1 ) , st1 from t1")
|
tdSql.query("select sample( c1 , 1 ) , st1 from t1")
|
||||||
|
|
||||||
# case12 = {"alias": ", c1"}
|
# case12 = {"alias": ", c1"}
|
||||||
# self.checksample(**case12)
|
# self.checksample(**case12)
|
||||||
|
|
||||||
|
|
@ -497,7 +497,7 @@ class TDTestCase:
|
||||||
# tdSql.query(" select sample(c1 , 1) + 2 from t1 ")
|
# tdSql.query(" select sample(c1 , 1) + 2 from t1 ")
|
||||||
err41 = {"alias": "+ avg(c1)"}
|
err41 = {"alias": "+ avg(c1)"}
|
||||||
# self.checksample(**err41) # mix with arithmetic 2
|
# self.checksample(**err41) # mix with arithmetic 2
|
||||||
|
|
||||||
# err42 = {"alias": ", c1"}
|
# err42 = {"alias": ", c1"}
|
||||||
# self.checksample(**err42)
|
# self.checksample(**err42)
|
||||||
tdSql.query("select sample( c1 , 1 ) , c1 from t1")
|
tdSql.query("select sample( c1 , 1 ) , c1 from t1")
|
||||||
|
|
@ -605,14 +605,14 @@ class TDTestCase:
|
||||||
tdSql.execute(f"create table tt{i} using stb2 tags({i})")
|
tdSql.execute(f"create table tt{i} using stb2 tags({i})")
|
||||||
|
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
|
||||||
def check_sample(self , sample_query , origin_query ):
|
def check_sample(self , sample_query , origin_query ):
|
||||||
|
|
||||||
tdSql.query(origin_query)
|
tdSql.query(origin_query)
|
||||||
|
|
||||||
origin_datas = tdSql.queryResult
|
origin_datas = tdSql.queryResult
|
||||||
|
|
||||||
tdSql.query(sample_query)
|
tdSql.query(sample_query)
|
||||||
|
|
||||||
sample_datas = tdSql.queryResult
|
sample_datas = tdSql.queryResult
|
||||||
|
|
@ -620,7 +620,7 @@ class TDTestCase:
|
||||||
for ind , sample_data in enumerate(sample_datas):
|
for ind , sample_data in enumerate(sample_datas):
|
||||||
if sample_data not in origin_datas:
|
if sample_data not in origin_datas:
|
||||||
status = False
|
status = False
|
||||||
|
|
||||||
if status:
|
if status:
|
||||||
tdLog.info(" sample data is in datas groups ,successed sql is : %s" % sample_query )
|
tdLog.info(" sample data is in datas groups ,successed sql is : %s" % sample_query )
|
||||||
else:
|
else:
|
||||||
|
|
@ -637,7 +637,7 @@ class TDTestCase:
|
||||||
tags (t1 int)
|
tags (t1 int)
|
||||||
'''
|
'''
|
||||||
)
|
)
|
||||||
|
|
||||||
tdSql.execute(
|
tdSql.execute(
|
||||||
'''
|
'''
|
||||||
create table t1
|
create table t1
|
||||||
|
|
@ -689,7 +689,7 @@ class TDTestCase:
|
||||||
tdSql.error(" select sample(c1,ts) from t1 ")
|
tdSql.error(" select sample(c1,ts) from t1 ")
|
||||||
tdSql.error(" select sample(c1,false) from t1 ")
|
tdSql.error(" select sample(c1,false) from t1 ")
|
||||||
tdSql.query(" select sample(123,1) from t1 ")
|
tdSql.query(" select sample(123,1) from t1 ")
|
||||||
|
|
||||||
tdSql.query(" select sample(c1,2) from t1 ")
|
tdSql.query(" select sample(c1,2) from t1 ")
|
||||||
tdSql.checkRows(2)
|
tdSql.checkRows(2)
|
||||||
tdSql.query(" select sample(c1,10) from t1 ")
|
tdSql.query(" select sample(c1,10) from t1 ")
|
||||||
|
|
@ -704,10 +704,10 @@ class TDTestCase:
|
||||||
tdSql.checkRows(9)
|
tdSql.checkRows(9)
|
||||||
tdSql.error(" select sample(c1,-1) from t1 ")
|
tdSql.error(" select sample(c1,-1) from t1 ")
|
||||||
|
|
||||||
# bug need fix
|
# bug need fix
|
||||||
# tdSql.query("select sample(c1 ,2) , 123 from stb1;")
|
# tdSql.query("select sample(c1 ,2) , 123 from stb1;")
|
||||||
|
|
||||||
# all type support
|
# all type support
|
||||||
tdSql.query(" select sample(c1 , 20 ) from ct4 ")
|
tdSql.query(" select sample(c1 , 20 ) from ct4 ")
|
||||||
tdSql.checkRows(9)
|
tdSql.checkRows(9)
|
||||||
|
|
||||||
|
|
@ -761,7 +761,7 @@ class TDTestCase:
|
||||||
|
|
||||||
self.check_sample("select sample( c1 ,3 ) from t1 where c1 between 1 and 10" ,"select c1 from t1 where c1 between 1 and 10")
|
self.check_sample("select sample( c1 ,3 ) from t1 where c1 between 1 and 10" ,"select c1 from t1 where c1 between 1 and 10")
|
||||||
|
|
||||||
# join
|
# join
|
||||||
|
|
||||||
tdSql.query("select sample( ct4.c1 , 1 ) from ct1, ct4 where ct4.ts=ct1.ts")
|
tdSql.query("select sample( ct4.c1 , 1 ) from ct1, ct4 where ct4.ts=ct1.ts")
|
||||||
|
|
||||||
|
|
@ -772,22 +772,22 @@ class TDTestCase:
|
||||||
|
|
||||||
self.check_sample("select sample(c1,2) from stb1 partition by tbname" , "select c1 from stb1 partition by tbname")
|
self.check_sample("select sample(c1,2) from stb1 partition by tbname" , "select c1 from stb1 partition by tbname")
|
||||||
|
|
||||||
# nest query
|
# nest query
|
||||||
# tdSql.query("select sample(c1,2) from (select c1 from t1); ")
|
# tdSql.query("select sample(c1,2) from (select c1 from t1); ")
|
||||||
# tdSql.checkRows(2)
|
# tdSql.checkRows(2)
|
||||||
|
|
||||||
# union all
|
# union all
|
||||||
tdSql.query("select sample(c1,2) from t1 union all select sample(c1,3) from t1")
|
tdSql.query("select sample(c1,2) from t1 union all select sample(c1,3) from t1")
|
||||||
tdSql.checkRows(5)
|
tdSql.checkRows(5)
|
||||||
|
|
||||||
# fill interval
|
# fill interval
|
||||||
|
|
||||||
# not support mix with other function
|
# not support mix with other function
|
||||||
tdSql.error("select top(c1,2) , sample(c1,2) from ct1")
|
tdSql.error("select top(c1,2) , sample(c1,2) from ct1")
|
||||||
tdSql.error("select max(c1) , sample(c1,2) from ct1")
|
tdSql.error("select max(c1) , sample(c1,2) from ct1")
|
||||||
tdSql.query("select c1 , sample(c1,2) from ct1")
|
tdSql.query("select c1 , sample(c1,2) from ct1")
|
||||||
|
|
||||||
# bug for mix with scalar
|
# bug for mix with scalar
|
||||||
tdSql.query("select 123 , sample(c1,100) from ct1")
|
tdSql.query("select 123 , sample(c1,100) from ct1")
|
||||||
tdSql.query("select sample(c1,100)+2 from ct1")
|
tdSql.query("select sample(c1,100)+2 from ct1")
|
||||||
tdSql.query("select abs(sample(c1,100)) from ct1")
|
tdSql.query("select abs(sample(c1,100)) from ct1")
|
||||||
|
|
@ -864,13 +864,13 @@ class TDTestCase:
|
||||||
for i in range(2000):
|
for i in range(2000):
|
||||||
ts = self.ts+i*10
|
ts = self.ts+i*10
|
||||||
tdSql.execute(f"insert into sub_tb values({ts} ,{i})")
|
tdSql.execute(f"insert into sub_tb values({ts} ,{i})")
|
||||||
|
|
||||||
tdSql.query("select count(*) from st")
|
tdSql.query("select count(*) from st")
|
||||||
tdSql.checkData(0,0,2000)
|
tdSql.checkData(0,0,2000)
|
||||||
tdSql.query("select sample(c1 ,1000) from st")
|
tdSql.query("select sample(c1 ,1000) from st")
|
||||||
tdSql.checkRows(1000)
|
tdSql.checkRows(1000)
|
||||||
|
|
||||||
# bug need fix
|
# bug need fix
|
||||||
tdSql.query("select c1 ,t1, sample(c1,2) from db.stb1 partition by c1 ")
|
tdSql.query("select c1 ,t1, sample(c1,2) from db.stb1 partition by c1 ")
|
||||||
tdSql.query("select sample(c1,2) from db.stb1 partition by c1 ")
|
tdSql.query("select sample(c1,2) from db.stb1 partition by c1 ")
|
||||||
# tdSql.query("select c1 ,ind, sample(c1,2) from sample_db.st partition by c1 ")
|
# tdSql.query("select c1 ,ind, sample(c1,2) from sample_db.st partition by c1 ")
|
||||||
|
|
|
||||||
|
|
@ -96,6 +96,8 @@ python3 ./test.py -f 2-query/distribute_agg_stddev.py
|
||||||
python3 ./test.py -f 2-query/distribute_agg_stddev.py -R
|
python3 ./test.py -f 2-query/distribute_agg_stddev.py -R
|
||||||
python3 ./test.py -f 2-query/distribute_agg_sum.py
|
python3 ./test.py -f 2-query/distribute_agg_sum.py
|
||||||
python3 ./test.py -f 2-query/distribute_agg_sum.py -R
|
python3 ./test.py -f 2-query/distribute_agg_sum.py -R
|
||||||
|
python3 ./test.py -f 2-query/interp.py
|
||||||
|
python3 ./test.py -f 2-query/interp.py -R
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -338,6 +340,7 @@ python3 ./test.py -f 2-query/arcsin.py -Q 2
|
||||||
python3 ./test.py -f 2-query/arccos.py -Q 2
|
python3 ./test.py -f 2-query/arccos.py -Q 2
|
||||||
python3 ./test.py -f 2-query/arctan.py -Q 2
|
python3 ./test.py -f 2-query/arctan.py -Q 2
|
||||||
python3 ./test.py -f 2-query/query_cols_tags_and_or.py -Q 2
|
python3 ./test.py -f 2-query/query_cols_tags_and_or.py -Q 2
|
||||||
|
python3 ./test.py -f 2-query/interp.py -Q 2
|
||||||
|
|
||||||
# python3 ./test.py -f 2-query/nestedQuery.py -Q 2
|
# python3 ./test.py -f 2-query/nestedQuery.py -Q 2
|
||||||
# python3 ./test.py -f 2-query/nestedQuery_str.py -Q 2
|
# python3 ./test.py -f 2-query/nestedQuery_str.py -Q 2
|
||||||
|
|
@ -457,3 +460,4 @@ python3 ./test.py -f 2-query/max_partition.py -Q 3
|
||||||
python3 ./test.py -f 2-query/last_row.py -Q 3
|
python3 ./test.py -f 2-query/last_row.py -Q 3
|
||||||
python3 ./test.py -f 2-query/tsbsQuery.py -Q 3
|
python3 ./test.py -f 2-query/tsbsQuery.py -Q 3
|
||||||
python3 ./test.py -f 2-query/sml.py -Q 3
|
python3 ./test.py -f 2-query/sml.py -Q 3
|
||||||
|
python3 ./test.py -f 2-query/interp.py -Q 3
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue