From 77f942a12665f0822e9c79884ecef9b68d219737 Mon Sep 17 00:00:00 2001
From: liuyq-617 <yqliu@taosdata.com>
Date: Sat, 28 Aug 2021 15:24:01 +0800
Subject: [PATCH] [TD-6387]<test> fetch over 100000 from super table

---
 tests/pytest/fulltest.sh    |  1 +
 tests/pytest/query/query.py | 22 ++++++++++++++++++++--
 2 files changed, 21 insertions(+), 2 deletions(-)

diff --git a/tests/pytest/fulltest.sh b/tests/pytest/fulltest.sh
index f2312821b5..617b505f53 100755
--- a/tests/pytest/fulltest.sh
+++ b/tests/pytest/fulltest.sh
@@ -298,6 +298,7 @@ python3 testMinTablesPerVnode.py
 python3 queryCount.py
 python3 ./test.py -f query/queryGroupbyWithInterval.py
 python3 client/twoClients.py
+python3 query/query.py
 python3 test.py -f query/queryInterval.py
 python3 test.py -f query/queryFillTest.py
 
diff --git a/tests/pytest/query/query.py b/tests/pytest/query/query.py
index eaec42721a..b076fe05eb 100644
--- a/tests/pytest/query/query.py
+++ b/tests/pytest/query/query.py
@@ -26,6 +26,18 @@ class TDTestCase:
 
         self.ts = 1538548685000
 
+    def bug_6387(self):
+        tdSql.execute("create database bug6387 ")
+        tdSql.execute("use bug6387 ")
+        tdSql.execute("create table test(ts timestamp, c1 int) tags(t1 int)")
+        for i in range(5000):
+            sql = "insert into t%d using test tags(1) values " % i
+            for j in range(21):
+                sql = sql + "(now+%ds,%d)" % (j ,j )
+            tdSql.execute(sql)
+        tdSql.query("select count(*) from test interval(1s) group by tbname")
+        tdSql.checkData(0,1,1)
+
     def run(self):
         tdSql.prepare()
 
@@ -120,15 +132,21 @@ class TDTestCase:
         tdSql.execute("insert into 'Tb0' using tb tags(1) values(now, 1)")
         tdSql.query("select * from tb")
         tdSql.checkRows(1)
+        tdSql.query("select * from tb0")
+        tdSql.checkRows(1)
 
         # For jira:https://jira.taosdata.com:18080/browse/TD-6314
         tdSql.execute("use db")
         tdSql.execute("create stable stb_001(ts timestamp,v int) tags(c0 int)")
+        tdSql.execute("insert into stb1 using stb_001 tags(1) values(now,1)")
         tdSql.query("select _block_dist() from stb_001")
         tdSql.checkRows(1)
 
-        tdSql.query("select * from tb0")
-        tdSql.checkRows(1)
+        
+
+        #For jira: https://jira.taosdata.com:18080/browse/TD-6387
+        tdLog.info("case for bug_6387")
+        self.bug_6387()
 
     def stop(self):
         tdSql.close()
-- 
GitLab