From 3f1a80342695cad1b5732081f204f0d9a7db6dbf Mon Sep 17 00:00:00 2001 From: tomchon Date: Mon, 6 Jun 2022 22:25:57 +0800 Subject: [PATCH] test:add testcase of python connector using Statement API --- .../1-insert/test_stmt_set_tbname_tag.py | 25 +++++++++++++++---- 1 file changed, 20 insertions(+), 5 deletions(-) diff --git a/tests/system-test/1-insert/test_stmt_set_tbname_tag.py b/tests/system-test/1-insert/test_stmt_set_tbname_tag.py index 4e9d2c6e4d..fb9f455d4d 100644 --- a/tests/system-test/1-insert/test_stmt_set_tbname_tag.py +++ b/tests/system-test/1-insert/test_stmt_set_tbname_tag.py @@ -249,18 +249,33 @@ class TDTestCase: print("8",rows4) assert rows4[0][0] == 3, ' 8 case is failed' - #query: selector Functions + #query: selector Functions 9 - querystmt4=conn.statement(" select count(?) from log ") + querystmt4=conn.statement(" select bottom(bu,?) from log group by bu ; ") queryparam4=new_bind_params(1) print(type(queryparam4)) - queryparam4[0].int(123) + queryparam4[0].int(2) querystmt4.bind_param(queryparam4) querystmt4.execute() result4=querystmt4.use_result() rows4=result4.fetch_all() - print("8",rows4) - assert rows4[0][0] == 3, ' 8 case is failed' + print("9",rows4) + assert rows4[0][0] == 4, ' 9 case is failed' + assert rows4[1][0] == 3, ' 9 case is failed' + + # #query: time-series specific Functions 10 + + querystmt4=conn.statement(" select twa(?) from log; ") + queryparam4=new_bind_params(1) + print(type(queryparam4)) + queryparam4[0].int(15) + querystmt4.bind_param(queryparam4) + querystmt4.execute() + result4=querystmt4.use_result() + rows4=result4.fetch_all() + print("10",rows4) + assert rows4[0][0] == 15, ' 10 case is failed' + # conn.execute("drop database if exists %s" % dbname) conn.close()