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

test case

This commit is contained in:
factosea 2025-02-06 09:39:39 +08:00
parent b461ec002a
commit 6ba3edfd0b
2 changed files with 49 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
source/libs/parser/src/parTranslater.c
View File

@ -7375,9 +7375,8 @@ static EDealRes pushDownBindSelectFunc(SNode** pNode, void* pContext) {
((SExprNode*)*pNode)->bindTupleFuncIdx = pCxt->bindTupleFuncIdx;
int32_t len = strlen(((SExprNode*)*pNode)->aliasName);
if (len + TSDB_COL_NAME_EXLEN >= TSDB_COL_NAME_LEN) {
parserWarn("%s The alias name is too long, the extra part will be truncated", __func__);
tsnprintf(((SExprNode*)*pNode)->aliasName + TSDB_COL_NAME_EXLEN - TSDB_COL_NAME_EXLEN, TSDB_COL_NAME_EXLEN, ".%d",
pCxt->bindTupleFuncIdx);
parserError("%s The alias name is too long, the extra part will be truncated", __func__);
return DEAL_RES_ERROR;
} else {
tsnprintf(((SExprNode*)*pNode)->aliasName + len, TSDB_COL_NAME_EXLEN, ".%d", pCxt->bindTupleFuncIdx);
}

46
tests/system-test/2-query/cols_function.py
View File

@ -891,6 +891,51 @@ class TDTestCase:
def window_test(self):
tdSql.query(f'select tbname, _wstart,_wend, max(c0), max(c1), cols( max(c0), c1) from test.meters partition \
by tbname count_window(2) order by tbname')
tdSql.checkRows(4)
tdSql.checkCols(6)
tdSql.checkData(0, 0, 'd0')
tdSql.checkData(3, 0, 'd1')
tdSql.checkData(3, 5, 1)
tdSql.query(f'select _wstart,_wend, max(c0), max(c1), cols( max(c0), c1) from test.d1 count_window(2);')
tdSql.checkRows(1)
tdSql.checkCols(5)
tdSql.checkData(0, 4, 1)
tdSql.query(f'select _wstart,_wend, max(c0), max(c1), cols( max(c0), c1) from test.normal_table count_window(2);')
tdSql.checkRows(3)
tdSql.checkCols(5)
tdSql.checkData(0, 4, 2)
def join_test(self):
tdSql.query(f'select cols(last(a.ts), a.c0) from test.d0 a join test.d1 b on a.ts = b.ts;')
tdSql.checkRows(1)
tdSql.checkCols(1)
tdSql.checkData(0, 0, 1)
tdSql.query(f'select cols(last(a.ts), a.c0) from test.d0 a join test.d1 b on a.ts = b.ts and a.c0 = b.c0;')
tdSql.checkRows(1)
tdSql.checkCols(1)
tdSql.checkData(0, 0, 1)
tdSql.query(f'select cols(last(a.ts), a.c0) from test.d0 a join test.d1 b on a.ts = b.ts and a.c0 > b.c0;')
tdSql.checkRows(0)
tdSql.query(f'select tbname, ts, c0 from (select cols(last(a.ts), a.tbname, a.ts, a.c0) from test.d0 a join test.d1 b on a.ts = b.ts and a.c0=b.c0)')
tdSql.checkRows(1)
tdSql.checkCols(3)
tdSql.checkData(0, 0, 'd0')
tdSql.checkData(0, 1, 1734574929000)
tdSql.checkData(0, 2, 1)
tdSql.query(f'select tbname, ts, c0 from (select cols(first(a.ts), a.tbname, a.ts, a.c0) from test.d0 a join test.d1 b on a.ts = b.ts and a.c0=b.c0)')
tdSql.checkRows(1)
tdSql.checkCols(3)
tdSql.checkData(0, 0, 'd0')
tdSql.checkData(0, 1, 1734574929000)
tdSql.checkData(0, 2, 1)
tdSql.error(f'select tbname, ts, c0 from (select cols(first(a.ts), a.tbname, a.ts, a.c0), cols(last(a.ts), b.tbname, b.ts, b.c0) from test.d0 a join test.d1 b on a.ts = b.ts and a.c0=b.c0)')
tdSql.query(f'select tbname, ts, c0 from (select cols(first(a.ts), a.tbname, a.ts, a.c0), cols(last(a.ts), b.tbname tbname1, b.ts ts2, b.c0 c02) from test.d0 a join test.d1 b on a.ts = b.ts and a.c0=b.c0)')
tdSql.checkRows(1)
tdSql.checkCols(3)
tdSql.checkData(0, 0, 'd0')
tdSql.checkData(0, 1, 1734574929000)
tdSql.checkData(0, 2, 1)
def run(self):
self.funcNestTest()
@ -901,6 +946,7 @@ class TDTestCase:
self.multi_cols_output_test()
self.subquery_test()
self.window_test()
self.join_test()
def stop(self):
tdSql.close()