提交 303936b8 编写于 作者: P Ping Xiao

[TD-2601][TD-2609][TD-2624]<test> add test case

上级 632c3b50
###################################################################
# Copyright (c) 2016 by TAOS Technologies, Inc.
# All rights reserved.
#
# This file is proprietary and confidential to TAOS Technologies.
# No part of this file may be reproduced, stored, transmitted,
# disclosed or used in any form or by any means other than as
# expressly provided by the written permission from Jianhui Tao
#
###################################################################
# -*- coding: utf-8 -*-
import sys
import taos
from util.log import *
from util.cases import *
from util.sql import *
class TDTestCase:
def init(self, conn, logSql):
tdLog.debug("start to execute %s" % __file__)
tdSql.init(conn.cursor())
self.rowNum = 10
self.ts = 1537146000000
def run(self):
tdSql.prepare()
tdSql.execute("create table st(ts timestamp, c1 int, c2 int)")
for i in range(self.rowNum):
tdSql.execute("insert into st values(%d, null, null)" % (self.ts + i))
tdSql.query("select avg(c1) from st")
tdSql.checkRows(0)
tdSql.query("select max(c1) from st")
tdSql.checkRows(0)
tdSql.query("select min(c1) from st")
tdSql.checkRows(0)
tdSql.query("select bottom(c1, 1) from st")
tdSql.checkRows(0)
tdSql.query("select top(c1, 1) from st")
tdSql.checkRows(0)
tdSql.query("select diff(c1) from st")
tdSql.checkRows(0)
tdSql.query("select first(c1) from st")
tdSql.checkRows(0)
tdSql.query("select last(c1) from st")
tdSql.checkRows(0)
tdSql.query("select last_row(c1) from st")
tdSql.checkRows(1)
tdSql.checkData(0, 0, None)
tdSql.query("select count(c1) from st")
tdSql.checkRows(0)
tdSql.query("select leastsquares(c1, 1, 1) from st")
tdSql.checkRows(0)
tdSql.query("select c1 + c2 from st")
tdSql.checkRows(10)
tdSql.query("select spread(c1) from st")
tdSql.checkRows(0)
# tdSql.query("select stddev(c1) from st")
# tdSql.checkRows(0)
tdSql.query("select sum(c1) from st")
tdSql.checkRows(0)
tdSql.query("select twa(c1) from st")
tdSql.checkRows(0)
def stop(self):
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())
...@@ -143,6 +143,14 @@ class TDTestCase: ...@@ -143,6 +143,14 @@ class TDTestCase:
tdSql.query("select apercentile(voltage, 20) from meters") tdSql.query("select apercentile(voltage, 20) from meters")
print("apercentile result: %s" % tdSql.getData(0, 0)) print("apercentile result: %s" % tdSql.getData(0, 0))
# Test case for: https://jira.taosdata.com:18080/browse/TD-2609
tdSql.execute("create table st(ts timestamp, k int)")
tdSql.execute("insert into st values(now, -100)")
tdSql.query("select apercentile(k, 20) from st")
tdSql.checkData(0, 0, -100.00)
def stop(self): def stop(self):
tdSql.close() tdSql.close()
tdLog.success("%s successfully executed" % __file__) tdLog.success("%s successfully executed" % __file__)
......
...@@ -132,6 +132,22 @@ class TDTestCase: ...@@ -132,6 +132,22 @@ class TDTestCase:
tdSql.query('select twa(c) from t4 interval(10s)') tdSql.query('select twa(c) from t4 interval(10s)')
tdSql.checkData(0,1,10.999) tdSql.checkData(0,1,10.999)
# Test case: https://jira.taosdata.com:18080/browse/TD-2624
tdSql.execute("create database test keep 7300")
tdSql.execute("use test")
tdSql.execute("create table st(ts timestamp, k int)")
tdSql.execute("insert into st values('2011-01-02 18:42:45.326', -1)")
tdSql.execute("insert into st values('2020-07-30 17:44:06.283', 0)")
tdSql.execute("insert into st values('2020-07-30 17:44:19.578', 9999999)")
tdSql.execute("insert into st values('2020-07-30 17:46:06.417', NULL)")
tdSql.execute("insert into st values('2020-11-09 18:42:25.538', 0)")
tdSql.execute("insert into st values('2020-12-29 17:43:11.641', 0)")
tdSql.execute("insert into st values('2020-12-29 18:43:17.129', 0)")
tdSql.execute("insert into st values('2020-12-29 18:46:19.109', NULL)")
tdSql.execute("insert into st values('2021-01-03 18:40:40.065', 0)")
tdSql.query("select twa(k),first(ts) as taos1 from st where k <50 interval(17s)")
tdSql.checkRows(6)
def stop(self): def stop(self):
tdSql.close() tdSql.close()
......
...@@ -85,6 +85,22 @@ class TDTestCase: ...@@ -85,6 +85,22 @@ class TDTestCase:
tdSql.query("select last(*) from t interval(1s)") tdSql.query("select last(*) from t interval(1s)")
tdSql.checkRows(10000) tdSql.checkRows(10000)
# test case for https://jira.taosdata.com:18080/browse/TD-2601
newTs = 1601481600000
tdSql.execute("create database test2")
tdSql.execute("use test2")
tdSql.execute("create table t (ts timestamp, voltage int)")
for i in range(100):
tdSql.execute("insert into t values(%d, %d)" % (newTs + i * 10000000, i))
tdSql.query("select sum(voltage) from t where ts >='2020-10-01 00:00:00' and ts <='2020-12-01 00:00:00' interval(1n) fill(NULL)")
tdSql.checkRows(3)
tdSql.checkData(0, 1, 4950)
tdSql.checkData(1, 1, None)
tdSql.checkData(2, 1, None)
def stop(self): def stop(self):
tdSql.close() tdSql.close()
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册