From b796febc6d0a7dc6e2db3c755ee1353c85d834ee Mon Sep 17 00:00:00 2001 From: "wenzhouwww@live.cn" Date: Mon, 6 Jun 2022 17:08:38 +0800 Subject: [PATCH] update case about udf for 2.4 branch --- tests/pytest/query/udf.py | 26 ++++++++++++++++++++++++++ 1 file changed, 26 insertions(+) diff --git a/tests/pytest/query/udf.py b/tests/pytest/query/udf.py index e9fc42c72e..2cf0fbc330 100644 --- a/tests/pytest/query/udf.py +++ b/tests/pytest/query/udf.py @@ -32,6 +32,7 @@ class TDTestCase: os.system("gcc -g -O0 -fPIC -shared ../script/sh/abs_max.c -o /tmp/abs_max.so") os.system("gcc -g -O0 -fPIC -shared ../script/sh/add_one.c -o /tmp/add_one.so") os.system("gcc -g -O0 -fPIC -shared ../script/sh/sum_double.c -o /tmp/sum_double.so") + os.system("gcc -g -O0 -fPIC -shared ../script/sh/demo.c -o /tmp/demo.so") tdSql.execute("create table stb(ts timestamp ,c1 int, c2 bigint) tags(t1 int)") for i in range(50): for j in range(200): @@ -80,6 +81,8 @@ class TDTestCase: tdSql.execute("create function add_one as '/tmp/add_one.so' outputtype int") tdSql.execute("create aggregate function abs_max as '/tmp/abs_max.so' outputtype bigint;") tdSql.execute("create aggregate function sum_double as '/tmp/sum_double.so' outputtype bigint;") + tdSql.execute("create aggregate function demo as '/tmp/demo.so' outputtype float bufsize 128;") + tdSql.execute("create aggregate function sumdemo as '/tmp/sumdemo.so' outputtype float bufsize 128;") # tdSql.error("create aggregate function max as '/tmp/abs_max.so' outputtype bigint ;") # tdSql.error("create aggregate function avg as '/tmp/abs_max.so' outputtype bigint ;") @@ -537,6 +540,29 @@ class TDTestCase: tdSql.query("select sum(sumdb) from (select sum_double(id) sumdb from tb1)") tdSql.checkData(0,0,20) + # add test case for demo function of UDF examples + tdSql.query("select demo(number) from st") + tdSql.checkRows(1) + tdSql.query("select demo(number) from tb1") + tdSql.checkRows(1) + tdSql.query("select demo(number) from st where ts > 1604298064000 and ts < 1604298064020") + tdSql.checkRows(1) + tdSql.query("select demo(number) from tb1 where ts > 1604298064000 and id in (2,3)") + tdSql.checkRows(1) + tdSql.query("select demo(number) from tb1 where ts > 1604298064000 and id in (2,3)") + tdSql.checkRows(1) + tdSql.query("select demo(number) from st where ts < now and ind =1 interval(3s) sliding (1s) limit 2 ") + tdSql.checkRows(2) + tdSql.query("select demo(number) from tb1 union all select demo(number) from tb2") + tdSql.checkRows(2) + tdSql.query("select demo(number) from st group by ind") + tdSql.checkRows(2) + tdSql.query("select demo(tb1.number),demo(bound.number) from tb1,bound where tb1.ts=bound.ts") + tdSql.checkRows(1) + tdSql.query("select demo(number) from (select number from st)") + tdSql.checkRows(1) + tdSql.query("select max(number) from (select demo(number) number from st)") + tdSql.checkRows(1) tdLog.info(" =====================test illegal creation method =====================") -- GitLab