diff --git a/src/client/src/tscUtil.c b/src/client/src/tscUtil.c index 02f93c0a38217c43c12f9752bab6fbbdf9d4bdec..e6027d304fa6ecc570e6ff98d0d54b898b5e1f6f 100644 --- a/src/client/src/tscUtil.c +++ b/src/client/src/tscUtil.c @@ -4315,6 +4315,11 @@ void executeQuery(SSqlObj* pSql, SQueryInfo* pQueryInfo) { // create sub query to handle the sub query. SQueryInfo* pq = tscGetQueryInfo(&psub->cmd); + STableMetaInfo* pSubMeta = tscGetMetaInfo(pq, 0); + if (UTIL_TABLE_IS_SUPER_TABLE(pSubMeta) && + pq->command == TSDB_SQL_RETRIEVE_EMPTY_RESULT) { + psub->cmd.command = TSDB_SQL_RETRIEVE_EMPTY_RESULT; + } executeQuery(psub, pq); } diff --git a/tests/develop-test/2-query/ts_2016.py b/tests/develop-test/2-query/ts_2016.py new file mode 100644 index 0000000000000000000000000000000000000000..ecebf53ed3d4afa753ae6f563b63c62f1fd58b21 --- /dev/null +++ b/tests/develop-test/2-query/ts_2016.py @@ -0,0 +1,62 @@ +################################################################### +# Copyright (c) 2021 by TAOS Technologies, Inc. +# All rights reserved. +# +# This file is proprietary and confidential to TAOS Technologies. +# No part of this file may be reproduced, stored, transmitted, +# disclosed or used in any form or by any means other than as +# expressly provided by the written permission from Jianhui Tao +# +################################################################### + +# -*- coding: utf-8 -*- + +import sys +from util.log import * +from util.cases import * +from util.sql import * + + +class TDTestCase: + def caseDescription(self): + ''' + case1: [TS-2016]fix select * from (select * from empty_stable) + ''' + return + + def init(self, conn, logSql): + tdLog.debug("start to execute %s" % __file__) + tdSql.init(conn.cursor(), logSql) + self._conn = conn + + def run(self): + print("running {}".format(__file__)) + tdSql.execute("drop database if exists td12229") + tdSql.execute("create database if not exists td12229") + tdSql.execute('use td12229') + + tdSql.execute('create stable st(ts timestamp , value int ) tags (ind int)') + tdSql.execute('insert into tb1 using st tags(1) values(now ,1)') + tdSql.execute('insert into tb1 using st tags(1) values(now+1s ,2)') + tdSql.execute('insert into tb1 using st tags(1) values(now+2s ,3)') + tdSql.execute('create stable ste(ts timestamp , value int ) tags (ind int)') + tdSql.query('select * from st') + tdSql.checkRows(3) + tdSql.query('select * from (select * from ste)') + tdSql.checkRows(0) + tdSql.query('select * from st union all select * from ste') + tdSql.checkRows(3) + tdSql.query('select * from ste union all select * from st') + tdSql.checkRows(3) + tdSql.query('select elapsed(ts) from ste group by tbname union all select elapsed(ts) from st group by tbname;') + tdSql.checkRows(1) + tdSql.query('select elapsed(ts) from st group by tbname union all select elapsed(ts) from ste group by tbname;') + tdSql.checkRows(1) + tdSql.execute('drop database td12229') + def stop(self): + tdSql.close() + tdLog.success("%s successfully executed" % __file__) + + +tdCases.addWindows(__file__, TDTestCase()) +tdCases.addLinux(__file__, TDTestCase()) diff --git a/tests/develop-test/fulltest-query.sh b/tests/develop-test/fulltest-query.sh index b5147d20a399e6e19bcb7d84985a83a187429780..fe9fe8ee20340928a0cd5a3d8077a55a614ecb42 100755 --- a/tests/develop-test/fulltest-query.sh +++ b/tests/develop-test/fulltest-query.sh @@ -1,3 +1,4 @@ python3 ./test.py -f 2-query/ts_hidden_column.py python3 ./test.py -f 2-query/union-order.py python3 ./test.py -f 2-query/session_two_stage.py +python3 ./test.py -f 2-query/ts_2016.py diff --git a/tests/pytest/query/queryTbnameUpperLower.py b/tests/pytest/query/queryTbnameUpperLower.py index 147ec04793c3708258fc08bfadc8c12637a3df80..ec30f1089052ff8f1102aa0df03dcd57e4833697 100644 --- a/tests/pytest/query/queryTbnameUpperLower.py +++ b/tests/pytest/query/queryTbnameUpperLower.py @@ -26,6 +26,8 @@ class TDTestCase: ''' tdCom.cleanTb() table_name = tdCom.getLongName(8, "letters_mixed") + while table_name.islower(): + table_name = tdCom.getLongName(8, "letters_mixed") table_name_sub = f'{table_name}_sub' tb_name_lower = table_name_sub.lower() tb_name_upper = table_name_sub.upper()