From b0dfe54d239c911291e50fb4bd3f7ea0ceebaed7 Mon Sep 17 00:00:00 2001 From: qevolg <2227465945@qq.com> Date: Thu, 10 Oct 2024 13:57:15 +0800 Subject: [PATCH] test(func): modify func test cases --- tests/army/query/function/test_function.py | 436 ++++++++++----------- 1 file changed, 218 insertions(+), 218 deletions(-) diff --git a/tests/army/query/function/test_function.py b/tests/army/query/function/test_function.py index cd0f39d436..d77539ab7e 100644 --- a/tests/army/query/function/test_function.py +++ b/tests/army/query/function/test_function.py @@ -96,21 +96,21 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 0 - tdSql.query('select pi() * voltage from meters limit 1;') + tdSql.query('select pi() * voltage from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 694.2919764 - tdSql.query('select 2 * pi() * phase from meters limit 1;') + tdSql.query('select 2 * pi() * phase from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 3.1975006 - tdSql.query('select current, sqrt(current / pi()) from meters limit 1;') + tdSql.query('select current, sqrt(current / pi()) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert round(res0, 7) == 10.6499996 assert round(res1, 7) == 1.8411953 - tdSql.query('select id, case when voltage > 100 then pi() else pi() / 2 end from meters limit 1;') + tdSql.query('select id, case when voltage > 100 then pi() else pi() / 2 end from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 0 @@ -120,7 +120,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == None - tdSql.query('select pi() * name from meters limit 1;') + tdSql.query('select pi() * name from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 0 @@ -128,7 +128,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert round(res, 7) == -3.1415927 - tdSql.query('select voltage / pi() from meters limit 1;') + tdSql.query('select voltage / pi() from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 70.3464848 @@ -136,19 +136,19 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == None - tdSql.query('select round(pi() * phase, 2) from meters limit 1;') + tdSql.query('select round(pi() * phase, 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1.6 - tdSql.query('select abs(pi() * phase) from meters limit 1;') + tdSql.query('select abs(pi() * phase) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 1.5987503 - tdSql.query('select sqrt(pi() * voltage) from meters limit 1;') + tdSql.query('select sqrt(pi() * voltage) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 26.3494208 - tdSql.query('select log(pi() * voltage) from meters limit 1;') + tdSql.query('select log(pi() * voltage) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 6.5428926 @@ -183,23 +183,23 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 0 - tdSql.query('select round(voltage, 0) from meters limit 1;') + tdSql.query('select round(voltage, 0) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 221 - tdSql.query('select round(current, 1) from meters limit 1;') + tdSql.query('select round(current, 1) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 10.6999998 - tdSql.query('select round(phase, 3) from meters limit 1;') + tdSql.query('select round(phase, 3) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 3) == 0.509 - tdSql.query('select round(voltage, -1) from meters limit 1;') + tdSql.query('select round(voltage, -1) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 220 - tdSql.query('select round(current * voltage, 2) from meters limit 1;') + tdSql.query('select round(current * voltage, 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 2) == 2353.65 @@ -215,23 +215,23 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == None - tdSql.query('select round(abs(voltage), 2) from meters limit 1;') + tdSql.query('select round(abs(voltage), 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 221 - tdSql.query('select round(pi() * phase, 3) from meters limit 1;') + tdSql.query('select round(pi() * phase, 3) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1.599 - tdSql.query('select round(sqrt(voltage), 2) from meters limit 1;') + tdSql.query('select round(sqrt(voltage), 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 14.8700000 - tdSql.query('select round(log(current), 2) from meters limit 1;') + tdSql.query('select round(log(current), 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 2.37 - tdSql.error('select round(name, 2) from meters limit 1;') + tdSql.error('select round(name, 2) from ts_4893.meters limit 1;') def test_exp(self): self.test_normal_query('exp') @@ -260,19 +260,19 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert round(res, 7) == 1.0001000 - tdSql.query('select exp(voltage) from meters limit 1;') + tdSql.query('select exp(voltage) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 9.529727902367202e+95 - tdSql.query('select exp(current) from meters limit 1;') + tdSql.query('select exp(current) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 42192.5784536 - tdSql.query('select exp(phase) from meters limit 1;') + tdSql.query('select exp(phase) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 1.6634571 - tdSql.query('select exp(voltage + current) from meters limit 1;') + tdSql.query('select exp(voltage + current) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 4.0208379216243076e+100 @@ -292,15 +292,15 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 0 - tdSql.query('select round(exp(voltage), 2) from meters limit 1;') + tdSql.query('select round(exp(voltage), 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 9.529727902367202e+95 - tdSql.query('select exp(abs(current)) from meters limit 1;') + tdSql.query('select exp(abs(current)) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 42192.5784536 - tdSql.query('select exp(log(voltage)) from meters limit 1;') + tdSql.query('select exp(log(voltage)) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 221.0000000 @@ -331,19 +331,19 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 2.7182 - tdSql.query('select truncate(voltage, 2) from meters limit 1;') + tdSql.query('select truncate(voltage, 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 221 - tdSql.query('select truncate(current, 1) from meters limit 1;') + tdSql.query('select truncate(current, 1) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 1) == 10.6 - tdSql.query('select truncate(phase, 3) from meters limit 1;') + tdSql.query('select truncate(phase, 3) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 3) == 0.508 - tdSql.query('select truncate(voltage + current, 2) from meters limit 1;') + tdSql.query('select truncate(voltage + current, 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 231.6400000 @@ -359,30 +359,30 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 1.000000000000000e+14 - tdSql.query('select truncate(voltage, -1) from meters limit 1;') + tdSql.query('select truncate(voltage, -1) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 220 - tdSql.query('select round(truncate(voltage, 1), 2) from meters limit 1;') + tdSql.query('select round(truncate(voltage, 1), 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 221 - tdSql.query('select truncate(abs(current), 1) from meters limit 1;') + tdSql.query('select truncate(abs(current), 1) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 10.600000381469727 - tdSql.query('select truncate(exp(phase), 2) from meters limit 1;') + tdSql.query('select truncate(exp(phase), 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1.66 - tdSql.query('select truncate(log(current), 1) from meters limit 1;') + tdSql.query('select truncate(log(current), 1) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 2.3 tdSql.error('select truncate(0.999);') tdSql.error('select truncate(-1.999);') tdSql.error('select truncate(null);') - tdSql.error('select truncate(name, 1) from meters limit 1;') + tdSql.error('select truncate(name, 1) from ts_4893.meters limit 1;') def test_ln(self): self.test_normal_query('ln') @@ -411,15 +411,15 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert round(res, 7) == 2.3025851 - tdSql.query('select ln(voltage) from meters where voltage > 0 limit 1;') + tdSql.query('select ln(voltage) from ts_4893.meters where voltage > 0 limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 5.3981627 - tdSql.query('select ln(current) from meters where current > 0 limit 1;') + tdSql.query('select ln(current) from ts_4893.meters where current > 0 limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 2.3655599 - tdSql.query('select ln(phase) from meters where phase > 0 limit 1;') + tdSql.query('select ln(phase) from ts_4893.meters where phase > 0 limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == -0.6755076 @@ -447,23 +447,23 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert round(res, 7) == 32.2361913 - tdSql.query('select ln(exp(voltage)) from meters where voltage > 0 limit 1;') + tdSql.query('select ln(exp(voltage)) from ts_4893.meters where voltage > 0 limit 1;') res = tdSql.getData(0, 0) assert res == 221 - tdSql.query('select ln(abs(current)) from meters where current != 0 limit 1;') + tdSql.query('select ln(abs(current)) from ts_4893.meters where current != 0 limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 2.3655599 - tdSql.query('select ln(sqrt(phase)) from meters where phase >= 0 limit 1;') + tdSql.query('select ln(sqrt(phase)) from ts_4893.meters where phase >= 0 limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == -0.3377538 - tdSql.query('select ln(log(current)) from meters where current > 1 limit 1;') + tdSql.query('select ln(log(current)) from ts_4893.meters where current > 1 limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 0.8610147 - tdSql.error('select ln(name) from meters limit 1;') + tdSql.error('select ln(name) from ts_4893.meters limit 1;') def test_mod(self): self.test_normal_query('mod') @@ -500,15 +500,15 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 2 - tdSql.query('select mod(voltage, 2) from meters limit 1;') + tdSql.query('select mod(voltage, 2) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select mod(current, 10) from meters limit 1;') + tdSql.query('select mod(current, 10) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 0.6499996 - tdSql.query('select mod(phase, 4) from meters limit 1;') + tdSql.query('select mod(phase, 4) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 0.5088980 @@ -532,23 +532,23 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == None - tdSql.query('select mod(abs(voltage), 3) from meters limit 1;') + tdSql.query('select mod(abs(voltage), 3) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 2 - tdSql.query('select mod(phase, sqrt(16)) from meters limit 1;') + tdSql.query('select mod(phase, sqrt(16)) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 0.5088980 - tdSql.query('select mod(round(voltage), 5) from meters limit 1;') + tdSql.query('select mod(round(voltage), 5) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select mod(current, log(100)) from meters limit 1;') + tdSql.query('select mod(current, log(100)) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 7) == 1.4396592 - tdSql.error('select mod(name, 2) from meters limit 1;') + tdSql.error('select mod(name, 2) from ts_4893.meters limit 1;') def test_sign(self): self.test_normal_query('sign') @@ -577,15 +577,15 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == -1 - tdSql.query('select sign(current) from meters limit 1;') + tdSql.query('select sign(current) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select sign(voltage) from meters limit 1;') + tdSql.query('select sign(voltage) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select sign(phase) from meters limit 1;') + tdSql.query('select sign(phase) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 @@ -597,19 +597,19 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == -1 - tdSql.query('select sign(abs(voltage)) from meters limit 1;') + tdSql.query('select sign(abs(voltage)) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select sign(round(current)) from meters limit 1;') + tdSql.query('select sign(round(current)) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select sign(sqrt(voltage)) from meters limit 1;') + tdSql.query('select sign(sqrt(voltage)) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select sign(log(current + 1)) from meters limit 1;') + tdSql.query('select sign(log(current + 1)) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 1 @@ -645,11 +645,11 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 360 - tdSql.query('select degrees(current) from meters limit 1;') + tdSql.query('select degrees(current) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 2) == 610.20 - tdSql.query('select degrees(voltage) from meters limit 1;') + tdSql.query('select degrees(voltage) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 2) == 12662.37 @@ -657,7 +657,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert round(res, 2) == 57.30 - tdSql.query('select degrees(phase) from meters limit 1;') + tdSql.query('select degrees(phase) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 2) == 29.16 @@ -724,15 +724,15 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert round(res, 2) == 6.28 - tdSql.query('select radians(current) from meters limit 1;') + tdSql.query('select radians(current) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 2) == 0.19 - tdSql.query('select radians(voltage) from meters limit 1;') + tdSql.query('select radians(voltage) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 2) == 3.86 - tdSql.query('select radians(phase) from meters limit 1;') + tdSql.query('select radians(phase) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert round(res, 2) == 0.01 @@ -783,11 +783,11 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == None - tdSql.query('select min(char_length(name)) from meters;') + tdSql.query('select min(char_length(name)) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select max(char_length(name)) from meters;') + tdSql.query('select max(char_length(name)) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 4 @@ -799,49 +799,49 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 5 - tdSql.query('select name, char_length(name) from meters limit 1;') + tdSql.query('select name, char_length(name) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 4 - tdSql.query('select nch1, char_length(nch1) from meters limit 1;') + tdSql.query('select nch1, char_length(nch1) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' assert res1 == 5 - tdSql.query('select groupid, max(char_length(name)) from meters group by groupid;') + tdSql.query('select groupid, max(char_length(name)) from ts_4893.meters group by groupid;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 assert res1 == 4 - tdSql.query('select location, avg(char_length(name)) from meters group by location;') + tdSql.query('select location, avg(char_length(name)) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert res1 == 3.2446 - tdSql.query('select upper(name), char_length(upper(name)) from meters limit 1;') + tdSql.query('select upper(name), char_length(upper(name)) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'LILI' assert res1 == 4 - tdSql.query("select concat(name, ' - ', location), char_length(concat(name, ' - ', location)) from meters limit 1;") + tdSql.query("select concat(name, ' - ', location), char_length(concat(name, ' - ', location)) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili - beijing' assert res1 == 14 - tdSql.query('select substring(name, 1, 5), char_length(substring(name, 1, 5)) from meters limit 1;') + tdSql.query('select substring(name, 1, 5), char_length(substring(name, 1, 5)) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 4 - tdSql.query('select trim(name), char_length(trim(name)) from meters limit 1;') + tdSql.query('select trim(name), char_length(trim(name)) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' @@ -850,7 +850,7 @@ class TDTestCase(TBase): tdSql.error('select char_length(12345);') tdSql.error('select char_length(true);') tdSql.error("select char_length(repeat('a', 1000000));") - tdSql.error('select char_length(id) from meters;') + tdSql.error('select char_length(id) from ts_4893.meters;') def test_char(self): self.test_normal_query('char') @@ -864,11 +864,11 @@ class TDTestCase(TBase): assert res == chr(0) res = [[chr(0)], [chr(1)], [chr(2)], [chr(3)], [chr(4)], [chr(5)], [chr(6)], [chr(7)], [chr(8)], [chr(9)]] - tdSql.checkDataMem("select char(id) from meters limit 10;", res) + tdSql.checkDataMem("select char(id) from ts_4893.meters limit 10;", res) res = [[chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)], [chr(0)]] - tdSql.checkDataMem("select char(nch1) from meters limit 10;", res) - tdSql.checkDataMem("select char(var1) from meters limit 10;", res) + tdSql.checkDataMem("select char(nch1) from ts_4893.meters limit 10;", res) + tdSql.checkDataMem("select char(var1) from ts_4893.meters limit 10;", res) tdSql.query('select char(65.99);') res = tdSql.getData(0, 0) @@ -905,19 +905,19 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 72 - tdSql.query('select name, ascii(name) from meters limit 1;') + tdSql.query('select name, ascii(name) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 108 - tdSql.query('select nch1, ascii(nch1) from meters limit 1;') + tdSql.query('select nch1, ascii(nch1) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' assert res1 == 110 - tdSql.query('select var1, ascii(var1) from meters limit 1;') + tdSql.query('select var1, ascii(var1) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -947,7 +947,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 65 - tdSql.query('select name, ascii(substring(name, 1, 1)) from meters limit 1;') + tdSql.query('select name, ascii(substring(name, 1, 1)) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' @@ -1002,19 +1002,19 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 3 - tdSql.query("select name, position('e' in name) from meters limit 1;") + tdSql.query("select name, position('e' in name) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 0 - tdSql.query("select nch1, position('n' in nch1) from meters limit 1;") + tdSql.query("select nch1, position('n' in nch1) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' assert res1 == 1 - tdSql.query("select var1, position('1' in var1) from meters limit 1;") + tdSql.query("select var1, position('1' in var1) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1048,7 +1048,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 2 - tdSql.query("select name, position('a' in substring(name, 2, 5)) from meters limit 1;") + tdSql.query("select name, position('a' in substring(name, 2, 5)) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' @@ -1101,19 +1101,19 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 'Hello MySQL' - tdSql.query("select name, replace(name, 'a', 'o') from meters limit 1;") + tdSql.query("select name, replace(name, 'a', 'o') from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 'lili' - tdSql.query("select nch1, replace(nch1, 'n', 'm') from meters limit 1;") + tdSql.query("select nch1, replace(nch1, 'n', 'm') from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' assert res1 == 'movel' - tdSql.query("select var1, replace(var1, '1', 'one') from meters limit 1;") + tdSql.query("select var1, replace(var1, '1', 'one') from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1147,7 +1147,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 'AZC' - tdSql.query("select name, replace(substring(name, 1, 5), 'e', 'o') from meters limit 1;") + tdSql.query("select name, replace(substring(name, 1, 5), 'e', 'o') from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' @@ -1204,13 +1204,13 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 'HelloHello' - tdSql.query("select name, repeat(name, 3) from meters limit 1;") + tdSql.query("select name, repeat(name, 3) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 'lililililili' - tdSql.query("select nch1, repeat(nch1, 4) from meters limit 1;") + tdSql.query("select nch1, repeat(nch1, 4) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1220,7 +1220,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == '123123123123123' - tdSql.query("select var1, repeat(var1, 2) from meters limit 1;") + tdSql.query("select var1, repeat(var1, 2) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1250,7 +1250,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 'ABCABCABC' - tdSql.query("select name, repeat(substring(name, 1, 5), 2) from meters limit 1;") + tdSql.query("select name, repeat(substring(name, 1, 5), 2) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' @@ -1323,13 +1323,13 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 'elloW' - tdSql.query('select name, substr(name, 1, 3) from meters limit 1;') + tdSql.query('select name, substr(name, 1, 3) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 'lil' - tdSql.query('select nch1, substr(nch1, 2, 4) from meters limit 1;') + tdSql.query('select nch1, substr(nch1, 2, 4) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1339,7 +1339,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == '67890' - tdSql.query('select var1, substr(var1, 1, 6) from meters limit 1;') + tdSql.query('select var1, substr(var1, 1, 6) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1424,13 +1424,13 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 'apple.orange' - tdSql.query("select name, substring_index(name, ' ', 1) from meters limit 1;") + tdSql.query("select name, substring_index(name, ' ', 1) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 'lili' - tdSql.query("select var1, substring_index(var1, '-', -1) from meters limit 1;") + tdSql.query("select var1, substring_index(var1, '-', -1) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1440,7 +1440,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == '192.168.1' - tdSql.query("select nch1, substring_index(nch1, ',', 3) from meters limit 1;") + tdSql.query("select nch1, substring_index(nch1, ',', 3) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1525,19 +1525,19 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == '' - tdSql.query("select name, trim(name) from meters limit 1;") + tdSql.query("select name, trim(name) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'lili' assert res1 == 'lili' - tdSql.query("select var1, trim(trailing '!' from var1) from meters limit 1;") + tdSql.query("select var1, trim(trailing '!' from var1) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' assert res1 == 'novel' - tdSql.query("select nch1, trim(leading '-' from nch1) from meters limit 1;") + tdSql.query("select nch1, trim(leading '-' from nch1) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'novel' @@ -1547,7 +1547,7 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 'apple banana' - tdSql.query("select var2, trim('*' from var2) from meters limit 1;") + tdSql.query("select var2, trim('*' from var2) from ts_4893.meters limit 1;") res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'e' @@ -1624,43 +1624,43 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == None - tdSql.query('select timediff(ts, ts) from meters limit 1;') + tdSql.query('select timediff(ts, ts) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 0 - tdSql.query('select timediff(ts, ts - 1d) from meters limit 1;') + tdSql.query('select timediff(ts, ts - 1d) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 86400000 - tdSql.query("select timediff(ts, '00:00:00') from meters limit 1;") + tdSql.query("select timediff(ts, '00:00:00') from ts_4893.meters limit 1;") res = tdSql.getData(0, 0) assert res == None - tdSql.query('select timediff(ts, null) from meters limit 1;') + tdSql.query('select timediff(ts, null) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == None - tdSql.query("select timediff('25:61:61', ts) from meters limit 1;") + tdSql.query("select timediff('25:61:61', ts) from ts_4893.meters limit 1;") res = tdSql.getData(0, 0) assert res == None - tdSql.query("select timediff('invalid_format', ts) from meters limit 1;") + tdSql.query("select timediff('invalid_format', ts) from ts_4893.meters limit 1;") res = tdSql.getData(0, 0) assert res == None - tdSql.query('select timediff(name, ts) from meters limit 2;') + tdSql.query('select timediff(name, ts) from ts_4893.meters limit 2;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(1, 0) assert res0 == None assert res1 == None - tdSql.query("select timediff('string_value', 'another_string') from meters limit 1;") + tdSql.query("select timediff('string_value', 'another_string') from ts_4893.meters limit 1;") res = tdSql.getData(0, 0) assert res == None - tdSql.error("select timediff(min(ts), '2023-01-01 00:00:00') from meters limit 1;") - tdSql.error("select timediff(max(ts), '2023-12-31 23:59:59') from meters limit 1;") - tdSql.error('select (select timediff(ts, (select max(ts) from meters)) from meters where id = m.id) from meters m;') + tdSql.error("select timediff(min(ts), '2023-01-01 00:00:00') from ts_4893.meters limit 1;") + tdSql.error("select timediff(max(ts), '2023-12-31 23:59:59') from ts_4893.meters limit 1;") + tdSql.error('select (select timediff(ts, (select max(ts) from ts_4893.meters)) from ts_4893.meters where id = m.id) from ts_4893.meters m;') def test_week(self): self.test_normal_query('week') @@ -1713,17 +1713,17 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 39 - tdSql.query('select week(ts) from meters limit 1;') + tdSql.query('select week(ts) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 28 - tdSql.query('select id, week(ts) from meters where id = 1 limit 1;') + tdSql.query('select id, week(ts) from ts_4893.meters where id = 1 limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 assert res1 == 28 - tdSql.query('select week(name) from meters limit 1;') + tdSql.query('select week(name) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == None @@ -1731,17 +1731,17 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 52 - tdSql.query('select week(ts), dayofweek(ts) from meters limit 1;') + tdSql.query('select week(ts), dayofweek(ts) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 28 assert res1 == 6 - tdSql.query("select week(timediff(ts, '2024-10-10 09:36:50.172')) from meters limit 1;") + tdSql.query("select week(timediff(ts, '2024-10-10 09:36:50.172')) from ts_4893.meters limit 1;") res = tdSql.getData(0, 0) assert res == 39 - tdSql.query('select groupid, sum(week(ts)) from meters group by groupid;') + tdSql.query('select groupid, sum(week(ts)) from ts_4893.meters group by groupid;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 @@ -1798,13 +1798,13 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 0 - tdSql.query('select id, weekday(ts) from meters where id = 1 limit 1;') + tdSql.query('select id, weekday(ts) from ts_4893.meters where id = 1 limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 assert res1 == 4 - tdSql.query('select weekday(name) from meters limit 1;') + tdSql.query('select weekday(name) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == None @@ -1812,25 +1812,25 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 4 - tdSql.query('select weekday(ts), dayofweek(ts) from meters limit 1;') + tdSql.query('select weekday(ts), dayofweek(ts) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 4 assert res1 == 6 - tdSql.query("select weekday(timediff(ts, '2024-10-10 09:36:50.172')) from meters limit 1;") + tdSql.query("select weekday(timediff(ts, '2024-10-10 09:36:50.172')) from ts_4893.meters limit 1;") res = tdSql.getData(0, 0) assert res == 4 - tdSql.query('select groupid, sum(weekday(ts)) from meters group by groupid;') + tdSql.query('select groupid, sum(weekday(ts)) from ts_4893.meters group by groupid;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select weekday(ts) from meters limit 1;') + tdSql.query('select weekday(ts) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 4 - tdSql.error('select weekday(hello) from meters limit 1;') + tdSql.error('select weekday(hello) from ts_4893.meters limit 1;') def test_weekofyear(self): self.test_normal_query('weekofyear') @@ -1883,17 +1883,17 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select weekofyear(ts) from meters limit 1;') + tdSql.query('select weekofyear(ts) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 28 - tdSql.query('select id, weekofyear(ts) from meters where id = 1 limit 1;') + tdSql.query('select id, weekofyear(ts) from ts_4893.meters where id = 1 limit 1;') res0 = tdSql.getData(0, 0) res2 = tdSql.getData(0, 1) assert res0 == 1 assert res2 == 28 - tdSql.query('select weekofyear(name) from meters limit 1;') + tdSql.query('select weekofyear(name) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == None @@ -1901,17 +1901,17 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 52 - tdSql.query('select weekofyear(ts), dayofweek(ts) from meters limit 1;') + tdSql.query('select weekofyear(ts), dayofweek(ts) from ts_4893.meters limit 1;') res0 = tdSql.getData(0, 0) res2 = tdSql.getData(0, 1) assert res0 == 28 assert res2 == 6 - tdSql.query("select weekofyear(timediff(ts, '2024-10-10 09:36:50.172')) from meters limit 1;") + tdSql.query("select weekofyear(timediff(ts, '2024-10-10 09:36:50.172')) from ts_4893.meters limit 1;") res = tdSql.getData(0, 0) assert res == 40 - tdSql.query('select groupid, sum(weekofyear(ts)) from meters group by groupid;') + tdSql.query('select groupid, sum(weekofyear(ts)) from ts_4893.meters group by groupid;') res0 = tdSql.getData(0, 0) res2 = tdSql.getData(0, 1) assert res0 == 1 @@ -1968,15 +1968,15 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 3 - tdSql.query('select dayofweek(ts) from meters limit 1;') + tdSql.query('select dayofweek(ts) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == 6 - tdSql.query('select id, dayofweek(ts) from meters where id = 1 limit 1;') + tdSql.query('select id, dayofweek(ts) from ts_4893.meters where id = 1 limit 1;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select dayofweek(name) from meters limit 1;') + tdSql.query('select dayofweek(name) from ts_4893.meters limit 1;') res = tdSql.getData(0, 0) assert res == None @@ -1984,11 +1984,11 @@ class TDTestCase(TBase): res = tdSql.getData(0, 0) assert res == 6 - tdSql.query("select dayofweek(timediff(ts, '2024-10-10 09:36:50.172')) from meters limit 1;") + tdSql.query("select dayofweek(timediff(ts, '2024-10-10 09:36:50.172')) from ts_4893.meters limit 1;") res = tdSql.getData(0, 0) assert res == 6 - tdSql.query('select groupid, sum(dayofweek(ts)) from meters group by groupid;') + tdSql.query('select groupid, sum(dayofweek(ts)) from ts_4893.meters group by groupid;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 @@ -1997,146 +1997,146 @@ class TDTestCase(TBase): def test_stddev_pop(self): self.test_normal_query('stddev') - tdSql.query('select stddev_pop(null) from meters;') + tdSql.query('select stddev_pop(null) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == None - tdSql.query('select stddev_pop(current) from meters;') + tdSql.query('select stddev_pop(current) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 1.1543397 - tdSql.query('select stddev_pop(voltage) from meters;') + tdSql.query('select stddev_pop(voltage) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 2.8764597 - tdSql.query("select stddev_pop(phase) from meters where ts between '2023-01-01 00:00:00' and '2023-12-31 23:59:59';") + tdSql.query("select stddev_pop(phase) from ts_4893.meters where ts between '2023-01-01 00:00:00' and '2023-12-31 23:59:59';") res = tdSql.getData(0, 0) assert round(res, 7) == 0.2880754 - tdSql.query('select stddev_pop(id) from meters;') + tdSql.query('select stddev_pop(id) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 2886.7513315 - tdSql.query('select groupid, stddev_pop(voltage) from meters group by groupid;') + tdSql.query('select groupid, stddev_pop(voltage) from ts_4893.meters group by groupid;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 assert round(res1, 7) == 2.8764597 - tdSql.query('select location, stddev_pop(current) from meters group by location;') + tdSql.query('select location, stddev_pop(current) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert round(res1, 7) == 1.1543397 - tdSql.query('select stddev_pop(phase) from meters;') + tdSql.query('select stddev_pop(phase) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 0.2885955 - tdSql.query('select location, stddev_pop(voltage) from meters group by location;') + tdSql.query('select location, stddev_pop(voltage) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert round(res1, 7) == 2.8764597 - tdSql.query('select stddev_pop(voltage) from meters where voltage is not null;') + tdSql.query('select stddev_pop(voltage) from ts_4893.meters where voltage is not null;') res = tdSql.getData(0, 0) assert round(res, 7) == 2.8764597 - tdSql.query('select stddev_pop(voltage) from meters where voltage is not null;') + tdSql.query('select stddev_pop(voltage) from ts_4893.meters where voltage is not null;') res = tdSql.getData(0, 0) assert round(res, 7) == 2.8764597 - tdSql.query('select round(stddev_pop(current), 2) from meters;') + tdSql.query('select round(stddev_pop(current), 2) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 1.15 - tdSql.query('select pow(stddev_pop(current), 2) from meters;') + tdSql.query('select pow(stddev_pop(current), 2) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 1.3325001 - tdSql.query('select log(stddev_pop(voltage) + 1) from meters;') + tdSql.query('select log(stddev_pop(voltage) + 1) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 1.3549223 - tdSql.query('select stddev_pop(total_voltage) from (select sum(voltage) as total_voltage from meters group by location);') + tdSql.query('select stddev_pop(total_voltage) from (select sum(voltage) as total_voltage from ts_4893.meters group by location);') res = tdSql.getData(0, 0) assert res == 0 - tdSql.error('select stddev_pop(var1) from meters;') - tdSql.error('select stddev_pop(current) from empty_meters;') - tdSql.error('select stddev_pop(name) from meters;') - tdSql.error('select stddev_pop(nonexistent_column) from meters;') + tdSql.error('select stddev_pop(var1) from ts_4893.meters;') + tdSql.error('select stddev_pop(current) from empty_ts_4893.meters;') + tdSql.error('select stddev_pop(name) from ts_4893.meters;') + tdSql.error('select stddev_pop(nonexistent_column) from ts_4893.meters;') def test_var_pop(self): self.test_normal_query('varpop') - tdSql.query('select var_pop(null) from meters;') + tdSql.query('select var_pop(null) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == None - tdSql.query('select var_pop(current) from meters;') + tdSql.query('select var_pop(current) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 1.3325001 - tdSql.query('select var_pop(voltage) from meters;') + tdSql.query('select var_pop(voltage) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 8.2740204 - tdSql.query("select var_pop(phase) from meters where ts between '2023-01-01 00:00:00' and '2023-12-31 23:59:59';") + tdSql.query("select var_pop(phase) from ts_4893.meters where ts between '2023-01-01 00:00:00' and '2023-12-31 23:59:59';") res = tdSql.getData(0, 0) assert round(res, 7) == 0.0829874 - tdSql.query('select var_pop(id) from meters;') + tdSql.query('select var_pop(id) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 8333333.25 - tdSql.query('select groupid, var_pop(voltage) from meters group by groupid;') + tdSql.query('select groupid, var_pop(voltage) from ts_4893.meters group by groupid;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 assert round(res1, 7) == 8.2740204 - tdSql.query('select location, var_pop(current) from meters group by location;') + tdSql.query('select location, var_pop(current) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert round(res1, 7) == 1.3325001 - tdSql.query('select var_pop(phase) from meters;') + tdSql.query('select var_pop(phase) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 0.0832873 - tdSql.query('select location, var_pop(voltage) from meters group by location;') + tdSql.query('select location, var_pop(voltage) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert round(res1, 7) == 8.2740204 - tdSql.query('select var_pop(voltage) from meters where voltage is not null;') + tdSql.query('select var_pop(voltage) from ts_4893.meters where voltage is not null;') res = tdSql.getData(0, 0) assert round(res, 7) == 8.2740204 - tdSql.query('select round(var_pop(current), 2) from meters;') + tdSql.query('select round(var_pop(current), 2) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 1.33 - tdSql.query('select pow(var_pop(current), 2) from meters;') + tdSql.query('select pow(var_pop(current), 2) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 1.7755564 - tdSql.query('select log(var_pop(voltage) + 1) from meters;') + tdSql.query('select log(var_pop(voltage) + 1) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 2.2272170 - tdSql.query('select var_pop(total_voltage) from (select sum(voltage) as total_voltage from meters group by location);') + tdSql.query('select var_pop(total_voltage) from (select sum(voltage) as total_voltage from ts_4893.meters group by location);') res = tdSql.getData(0, 0) assert res == 0 - tdSql.error('select var_pop(var1) from meters;') - tdSql.error('select var_pop(current) from empty_meters;') - tdSql.error('select var_pop(name) from meters;') - tdSql.error('select var_pop(nonexistent_column) from meters;') + tdSql.error('select var_pop(var1) from ts_4893.meters;') + tdSql.error('select var_pop(current) from empty_ts_4893.meters;') + tdSql.error('select var_pop(name) from ts_4893.meters;') + tdSql.error('select var_pop(nonexistent_column) from ts_4893.meters;') def test_rand(self): self.test_normal_query('rand') @@ -2215,7 +2215,7 @@ class TDTestCase(TBase): assert res >= 0 assert res < 1 - tdSql.query('select rand(id) from meters limit 100;') + tdSql.query('select rand(id) from ts_4893.meters limit 100;') for i in range(len(tdSql.res)): res = tdSql.getData(i, 0) assert res >= 0 @@ -2229,171 +2229,171 @@ class TDTestCase(TBase): def test_max(self): self.test_normal_query('max') - tdSql.query('select max(null) from meters;') + tdSql.query('select max(null) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == None - tdSql.query('select max(name) from meters;') + tdSql.query('select max(name) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 'x' - tdSql.query('select max(current) from meters;') + tdSql.query('select max(current) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 11.9989996 - tdSql.query('select max(voltage) from meters;') + tdSql.query('select max(voltage) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 224 - tdSql.query('select max(nch1) from meters;') + tdSql.query('select max(nch1) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == '一二三四五六七八九十' - tdSql.query('select max(var1) from meters;') + tdSql.query('select max(var1) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == '一二三四五六七八九十' - tdSql.query('select max(id) from meters;') + tdSql.query('select max(id) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 9999 - tdSql.query('select max(id) from meters where id > 0;') + tdSql.query('select max(id) from ts_4893.meters where id > 0;') res = tdSql.getData(0, 0) assert res == 9999 - tdSql.query('select max(id) from meters where id <= 0;') + tdSql.query('select max(id) from ts_4893.meters where id <= 0;') res = tdSql.getData(0, 0) assert res == 0 - tdSql.query("select max(phase) from meters where ts between '2023-01-01 00:00:00' and '2023-12-31 23:59:59';") + tdSql.query("select max(phase) from ts_4893.meters where ts between '2023-01-01 00:00:00' and '2023-12-31 23:59:59';") res = tdSql.getData(0, 0) assert round(res, 7) == 0.9999660 - tdSql.query('select groupid, max(voltage) from meters group by groupid;') + tdSql.query('select groupid, max(voltage) from ts_4893.meters group by groupid;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 assert res1 == 224 - tdSql.query('select location, max(current) from meters group by location;') + tdSql.query('select location, max(current) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert round(res1, 7) == 11.9989996 - tdSql.query('select location, max(id) from meters group by location;') + tdSql.query('select location, max(id) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert res1 == 9999 - tdSql.query('select max(voltage) from meters where voltage is not null;') + tdSql.query('select max(voltage) from ts_4893.meters where voltage is not null;') res = tdSql.getData(0, 0) assert res == 224 - tdSql.query('select round(max(current), 2) from meters;') + tdSql.query('select round(max(current), 2) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 12 - tdSql.query('select pow(max(current), 2) from meters;') + tdSql.query('select pow(max(current), 2) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 143.9759913 - tdSql.query('select log(max(voltage) + 1) from meters;') + tdSql.query('select log(max(voltage) + 1) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 5.4161004 - tdSql.query('select max(total_voltage) from (select sum(voltage) as total_voltage from meters group by location);') + tdSql.query('select max(total_voltage) from (select sum(voltage) as total_voltage from ts_4893.meters group by location);') res = tdSql.getData(0, 0) assert res == 21948660 - tdSql.error('select max(nonexistent_column) from meters;') + tdSql.error('select max(nonexistent_column) from ts_4893.meters;') def test_min(self): self.test_normal_query('min') - tdSql.query('select min(null) from meters;') + tdSql.query('select min(null) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == None - tdSql.query('select min(name) from meters;') + tdSql.query('select min(name) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 'haha' - tdSql.query('select min(current) from meters;') + tdSql.query('select min(current) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 8 - tdSql.query('select min(voltage) from meters;') + tdSql.query('select min(voltage) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 215 - tdSql.query('select min(nch1) from meters;') + tdSql.query('select min(nch1) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 'abc一二三abc一二三abc' - tdSql.query('select min(var1) from meters;') + tdSql.query('select min(var1) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 'abc一二三abc一二三abc' - tdSql.query('select min(id) from meters;') + tdSql.query('select min(id) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 0 - tdSql.query('select min(id) from meters where id > 0;') + tdSql.query('select min(id) from ts_4893.meters where id > 0;') res = tdSql.getData(0, 0) assert res == 1 - tdSql.query('select min(id) from meters where id <= 0;') + tdSql.query('select min(id) from ts_4893.meters where id <= 0;') res = tdSql.getData(0, 0) assert res == 0 - tdSql.query("select min(phase) from meters where ts between '2023-01-01 00:00:00' and '2023-12-31 23:59:59';") + tdSql.query("select min(phase) from ts_4893.meters where ts between '2023-01-01 00:00:00' and '2023-12-31 23:59:59';") res = tdSql.getData(0, 0) assert round(res, 7) == 0.0001700 - tdSql.query('select groupid, min(voltage) from meters group by groupid;') + tdSql.query('select groupid, min(voltage) from ts_4893.meters group by groupid;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 1 assert res1 == 215 - tdSql.query('select location, min(current) from meters group by location;') + tdSql.query('select location, min(current) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert res1 == 8 - tdSql.query('select location, min(id) from meters group by location;') + tdSql.query('select location, min(id) from ts_4893.meters group by location;') res0 = tdSql.getData(0, 0) res1 = tdSql.getData(0, 1) assert res0 == 'beijing' assert res1 == 0 - tdSql.query('select min(voltage) from meters where voltage is not null;') + tdSql.query('select min(voltage) from ts_4893.meters where voltage is not null;') res = tdSql.getData(0, 0) assert res == 215 - tdSql.query('select round(min(current), 2) from meters;') + tdSql.query('select round(min(current), 2) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 8.0000000e+00 - tdSql.query('select pow(min(current), 2) from meters;') + tdSql.query('select pow(min(current), 2) from ts_4893.meters;') res = tdSql.getData(0, 0) assert res == 64 - tdSql.query('select log(min(voltage) + 1) from meters;') + tdSql.query('select log(min(voltage) + 1) from ts_4893.meters;') res = tdSql.getData(0, 0) assert round(res, 7) == 5.3752784 - tdSql.query('select min(total_voltage) from (select sum(voltage) as total_voltage from meters group by location);') + tdSql.query('select min(total_voltage) from (select sum(voltage) as total_voltage from ts_4893.meters group by location);') res = tdSql.getData(0, 0) assert res == 21948660 - tdSql.error('select min(nonexistent_column) from meters;') + tdSql.error('select min(nonexistent_column) from ts_4893.meters;') def test_error(self): - tdSql.error('select * from (select to_iso8601(ts, timezone()), timezone() from meters \ + tdSql.error('select * from (select to_iso8601(ts, timezone()), timezone() from ts_4893.meters \ order by ts desc) limit 1000;', expectErrInfo="Not supported timzone format") # TS-5340 def run(self):