[td-225]fix bug found by crash_gen
This commit is contained in:
parent
a06a1fb370
commit
b671d723b0
|
@ -667,7 +667,6 @@ static int32_t tscLaunchRealSubqueries(SSqlObj* pSql) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
// tscDoQuery(pSql->pSubs[i]);
|
|
||||||
SQueryInfo* pQueryInfo = tscGetQueryInfo(&pSql->pSubs[i]->cmd, 0);
|
SQueryInfo* pQueryInfo = tscGetQueryInfo(&pSql->pSubs[i]->cmd, 0);
|
||||||
executeQuery(pSql->pSubs[i], pQueryInfo);
|
executeQuery(pSql->pSubs[i], pQueryInfo);
|
||||||
}
|
}
|
||||||
|
|
|
@ -2783,6 +2783,11 @@ void doExecuteQuery(SSqlObj* pSql, SQueryInfo* pQueryInfo) {
|
||||||
|
|
||||||
// do execute the query according to the query execution plan
|
// do execute the query according to the query execution plan
|
||||||
void executeQuery(SSqlObj* pSql, SQueryInfo* pQueryInfo) {
|
void executeQuery(SSqlObj* pSql, SQueryInfo* pQueryInfo) {
|
||||||
|
if (pSql->cmd.command == TSDB_SQL_RETRIEVE_EMPTY_RESULT) {
|
||||||
|
(*pSql->fp)(pSql->param, pSql, 0);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
if (taosArrayGetSize(pQueryInfo->pUpstream) > 0) { // nest query. do execute it firstly
|
if (taosArrayGetSize(pQueryInfo->pUpstream) > 0) { // nest query. do execute it firstly
|
||||||
SQueryInfo* pq = taosArrayGetP(pQueryInfo->pUpstream, 0);
|
SQueryInfo* pq = taosArrayGetP(pQueryInfo->pUpstream, 0);
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue