From aaae42307c1420b14b21d0cd243784f949dd864a Mon Sep 17 00:00:00 2001 From: Ping Xiao Date: Thu, 14 Jul 2022 18:42:12 +0800 Subject: [PATCH] test: add test cases for max_row/min_row function --- tests/parallel_test/cases.task | 2 + tests/pytest/functions/function_max_row.py | 84 ++++++++++++++++++++++ tests/pytest/functions/function_min_row.py | 84 ++++++++++++++++++++++ 3 files changed, 170 insertions(+) create mode 100644 tests/pytest/functions/function_max_row.py create mode 100644 tests/pytest/functions/function_min_row.py diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task index 365823d227..36c57cdf95 100644 --- a/tests/parallel_test/cases.task +++ b/tests/parallel_test/cases.task @@ -814,6 +814,8 @@ 3,,pytest,python3 test.py -f table/columnNameValidation.py 3,,pytest,python3 test.py -f table/tagNameCaseSensitive.py 3,,pytest,python3 test.py -f table/tbNameCaseSensitive.py +3,,pytest,python3 test.py -f functions/function_max_row.py +3,,pytest,python3 test.py -f functions/function_min_row.py 3,,develop-test,python3 ./test.py -f 2-query/ts_hidden_column.py 3,,develop-test,python3 ./test.py -f 2-query/ts_shortcut.py 3,,develop-test,python3 ./test.py -f 2-query/nchar_funcs.py diff --git a/tests/pytest/functions/function_max_row.py b/tests/pytest/functions/function_max_row.py new file mode 100644 index 0000000000..7ffa9858b9 --- /dev/null +++ b/tests/pytest/functions/function_max_row.py @@ -0,0 +1,84 @@ +################################################################### +# 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 * +import numpy as np + + +class TDTestCase: + def init(self, conn, logSql): + tdLog.debug("start to execute %s" % __file__) + tdSql.init(conn.cursor()) + + self.rowNum = 10 + self.tables = 10 + self.ts = 1537146000000 + + def run(self): + tdSql.prepare() + + intData = [] + floatData = [] + + tdSql.execute("create table stb (ts timestamp, c1 int, c2 double, c3 float) tags(t1 int)") + for i in range(self.tables): + tdSql.execute("create table tb%d using stb tags(%d)" % (i, i)) + sql = "insert into tb%d values" % i + for j in range(self.rowNum): + sql += "(%d, %d, %f, %f)" % (self.ts + j * 3000, j, j + 0.1, j + 0.1) + intData.append(j) + floatData.append(j + 0.1) + tdSql.execute(sql) + + tdSql.error("select max_row(ts) from stb") + tdSql.error("select max_row(t1) from stb") + + tdSql.query("select max_row(c1) from stb") + tdSql.checkData(0, 0, np.max(intData)) + + tdSql.query("select max_row(c1), * from stb") + tdSql.checkData(0, 0, np.max(intData)) + tdSql.checkData(0, 2, np.max(intData)) + tdSql.checkData(0, 3, np.max(floatData)) + tdSql.checkData(0, 4, np.max(floatData)) + + tdSql.query("select max_row(c1), * from stb group by tbname") + for i in range(self.tables): + tdSql.checkData(i, 0, np.max(intData)) + tdSql.checkData(i, 2, np.max(intData)) + tdSql.checkData(i, 3, np.max(floatData)) + tdSql.checkData(i, 4, np.max(floatData)) + + tdSql.query("select max_row(c1), * from stb interval(6s)") + tdSql.checkRows(5) + + tdSql.query("select max_row(c1), * from tb1 interval(6s)") + tdSql.checkRows(5) + + tdSql.query("select max_row(c1), * from stb interval(6s) group by tbname") + tdSql.checkRows(50) + + tdSql.query("select max_row(c1), * from (select min_row(c1) c1, * from stb group by tbname)") + tdSql.checkData(0, 0, np.min(intData)) + tdSql.checkRows(1) + + def stop(self): + tdSql.close() + tdLog.success("%s successfully executed" % __file__) + +tdCases.addWindows(__file__, TDTestCase()) +tdCases.addLinux(__file__, TDTestCase()) \ No newline at end of file diff --git a/tests/pytest/functions/function_min_row.py b/tests/pytest/functions/function_min_row.py new file mode 100644 index 0000000000..9acc0eee5b --- /dev/null +++ b/tests/pytest/functions/function_min_row.py @@ -0,0 +1,84 @@ +################################################################### +# 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 * +import numpy as np + + +class TDTestCase: + def init(self, conn, logSql): + tdLog.debug("start to execute %s" % __file__) + tdSql.init(conn.cursor()) + + self.rowNum = 10 + self.tables = 10 + self.ts = 1537146000000 + + def run(self): + tdSql.prepare() + + intData = [] + floatData = [] + + tdSql.execute("create table stb (ts timestamp, c1 int, c2 double, c3 float) tags(t1 int)") + for i in range(self.tables): + tdSql.execute("create table tb%d using stb tags(%d)" % (i, i)) + sql = "insert into tb%d values" % i + for j in range(self.rowNum): + sql += "(%d, %d, %f, %f)" % (self.ts + j * 3000, j, j + 0.1, j + 0.1) + intData.append(j) + floatData.append(j + 0.1) + tdSql.execute(sql) + + tdSql.error("select min_row(ts) from stb") + tdSql.error("select min_row(t1) from stb") + + tdSql.query("select min_row(c1) from stb") + tdSql.checkData(0, 0, np.min(intData)) + + tdSql.query("select min_row(c1), * from stb") + tdSql.checkData(0, 0, np.min(intData)) + tdSql.checkData(0, 2, np.min(intData)) + tdSql.checkData(0, 3, np.min(floatData)) + tdSql.checkData(0, 4, np.min(floatData)) + + tdSql.query("select min_row(c1), * from stb group by tbname") + for i in range(self.tables): + tdSql.checkData(i, 0, np.min(intData)) + tdSql.checkData(i, 2, np.min(intData)) + tdSql.checkData(i, 3, np.min(floatData)) + tdSql.checkData(i, 4, np.min(floatData)) + + tdSql.query("select min_row(c1), * from stb interval(6s)") + tdSql.checkRows(5) + + tdSql.query("select min_row(c1), * from tb1 interval(6s)") + tdSql.checkRows(5) + + tdSql.query("select min_row(c1), * from stb interval(6s) group by tbname") + tdSql.checkRows(50) + + tdSql.query("select min_row(c1), * from (select max_row(c1) c1, * from stb group by tbname)") + tdSql.checkData(0, 0, np.max(intData)) + tdSql.checkRows(1) + + def stop(self): + tdSql.close() + tdLog.success("%s successfully executed" % __file__) + +tdCases.addWindows(__file__, TDTestCase()) +tdCases.addLinux(__file__, TDTestCase()) \ No newline at end of file -- GitLab