xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: add child table query udf

This commit is contained in:
Alex Duan 2024-08-28 16:44:00 +08:00
parent e739a48735
commit 6498dc94a1
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
tests/system-test/0-others/udfpy_main.py
View File

@ -272,12 +272,24 @@ class TDTestCase:
if val is not None: if val is not None:
tdLog.exit(f" check {sql} not expect None.") tdLog.exit(f" check {sql} not expect None.")
# concat # concat - stable
sql = f'select sf_concat_var(col12, t12), concat(col12, t12) from {self.stbname} limit 1000' sql = f'select sf_concat_var(col12, t12), concat(col12, t12) from {self.stbname} limit 1000'
self.verify_same_value(sql) self.verify_same_value(sql)
sql = f'select sf_concat_nch(col13, t13), concat(col13, t13) from {self.stbname} limit 1000' sql = f'select sf_concat_nch(col13, t13), concat(col13, t13) from {self.stbname} limit 1000'
self.verify_same_value(sql) self.verify_same_value(sql)
# concat - child table
sql = f'select sf_concat_var(col12, t12), concat(col12, t12) from {self.tbname}0 limit 1000'
self.verify_same_value(sql)
sql = f'select sf_concat_nch(col13, t13), concat(col13, t13) from {self.tbname}0 limit 1000'
self.verify_same_value(sql)
# single child
sql = f'select sf_concat_nch(col13, t13) from {self.tbname}1'
tdSql.query(sql)
tdSql.checkRows(5000)
# create aggregate # create aggregate
def create_aggr_udfpy(self): def create_aggr_udfpy(self):
@ -349,6 +361,12 @@ class TDTestCase:
self.verify_same_value(sql) self.verify_same_value(sql)
sql = f'select count(col8), af_count_float(col8) from {self.stbname}' sql = f'select count(col8), af_count_float(col8) from {self.stbname}'
self.verify_same_value(sql) self.verify_same_value(sql)
# child
sql = f'select count(col8), af_count_float(col8) from {self.tbname}0'
self.verify_same_value(sql)
sql = f'select af_count_bigint(col7) from {self.tbname}1'
tdSql.query(sql)
tdSql.checkData(0, 0, 5000)
# nest # nest
sql = f'select a+1000,b+1000 from (select count(col8) as a, af_count_float(col8) as b from {self.stbname})' sql = f'select a+1000,b+1000 from (select count(col8) as a, af_count_float(col8) as b from {self.stbname})'