提交 b17c9a57 编写于 作者: A Alex Duan

case check modify code

上级 c6bf4d9a
......@@ -577,8 +577,11 @@ static void tscProcessStreamRetrieveResult(void *param, TAOS_RES *res, int numOf
if (!pStream->isProject) {
pStream->stime = taosTimeAdd(pStream->stime, pStream->interval.sliding, pStream->interval.slidingUnit, pStream->precision);
}
int32_t code = TSDB_CODE_SUCCESS;
if(pQueryInfo && pQueryInfo->pQInfo)
code = pQueryInfo->pQInfo->code;
// actually only one row is returned. this following is not necessary
if(pQueryInfo->pQInfo->code == TSDB_CODE_SUCCESS) {
if(code == TSDB_CODE_SUCCESS) {
taos_fetch_rows_a(res, tscProcessStreamRetrieveResult, pStream);
}
} else { // numOfRows == 0, all data has been retrieved
......
......@@ -27,13 +27,14 @@ class TDTestCase:
def run(self):
rowNum = 200
tdSql.prepare()
start = 1633017600
tdLog.info("=============== step1")
tdSql.execute("create table mt(ts timestamp, tbcol int, tbcol2 float) TAGS(tgcol int)")
for i in range(5):
tdSql.execute("create table tb%d using mt tags(%d)" % (i, i))
for j in range(rowNum):
tdSql.execute("insert into tb%d values(now + %ds, %d, %d)" % (i, j, j, j))
tdSql.execute("insert into tb%d values(%d + %ds, %d, %d)" % (start, i, j, j, j))
time.sleep(0.1)
tdLog.info("=============== step2")
......@@ -52,7 +53,7 @@ class TDTestCase:
for i in range(5, 10):
tdSql.execute("create table tb%d using mt tags(%d)" % (i, i))
for j in range(rowNum):
tdSql.execute("insert into tb%d values(now + %ds, %d, %d)" % (i, j, j, j))
tdSql.execute("insert into tb%d values(%d + %ds, %d, %d)" % (start, i, j, j, j))
tdLog.info("=============== step5")
maxValue = 0
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册