From a97c2e0e165b32ddc02392041ee843aff76172c3 Mon Sep 17 00:00:00 2001
From: charles <flyingangel_2008@163.com>
Date: Wed, 27 Dec 2023 13:27:38 +0800
Subject: [PATCH] add test case for jira TS-4382

---
 tests/parallel_test/cases.task           |  1 +
 tests/system-test/2-query/test_ts4382.py | 75 ++++++++++++++++++++++++
 2 files changed, 76 insertions(+)
 create mode 100644 tests/system-test/2-query/test_ts4382.py

diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task
index e35bc60e20..e7c26b9833 100644
--- a/tests/parallel_test/cases.task
+++ b/tests/parallel_test/cases.task
@@ -518,6 +518,7 @@ e
 ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/json_tag.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/nestedQueryInterval.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/systable_func.py
+,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/test_ts4382.py
 
 ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/stablity.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/stablity_1.py
diff --git a/tests/system-test/2-query/test_ts4382.py b/tests/system-test/2-query/test_ts4382.py
new file mode 100644
index 0000000000..50ec67ed23
--- /dev/null
+++ b/tests/system-test/2-query/test_ts4382.py
@@ -0,0 +1,75 @@
+import random
+import string
+from util.log import *
+from util.cases import *
+from util.sql import *
+from util.sqlset import *
+from util import constant
+from util.common import *
+
+
+class TDTestCase:
+    """Verify the jira TS-4382
+    """
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
+        tdLog.debug("start to execute %s" % __file__)
+        tdSql.init(conn.cursor())
+        self.dbname = 'db'
+        self.stbname = 'st'
+        self.ctbname_list = ["ct1", "ct2"]
+        self.tag_value_list = ['{"instance":"100"}', '{"instance":"200"}']
+
+    def prepareData(self):
+        # db
+        tdSql.execute("create database {};".format(self.dbname))
+        tdSql.execute("use {};".format(self.dbname))
+        tdLog.debug("Create database %s" % self.dbname)
+
+        # super table
+        tdSql.execute("create table {} (ts timestamp, col1 int) tags (t1 json);".format(self.stbname))
+        tdLog.debug("Create super table %s" % self.stbname)
+
+        # child table
+        for i in range(len(self.ctbname_list)):
+            tdSql.execute("create table {} using {} tags('{}');".format(self.ctbname_list[i], self.stbname, self.tag_value_list[i]))
+        tdLog.debug("Create child table %s" % self.ctbname_list)
+
+        # insert data
+        tdSql.execute("insert into {} values(now, 1)(now+1s, 2)".format(self.ctbname_list[0]))
+        tdSql.execute("insert into {} values(now, null)(now+1s, null)".format(self.ctbname_list[1]))
+
+    def run(self):
+        self.prepareData()
+        sql_list = [
+            # super table query with correct tag name of json type
+            {
+                "sql": "select to_char(ts, 'yyyy-mm-dd hh24:mi:ss') as time, irate(col1) from st group by to_char(ts, 'yyyy-mm-dd hh24:mi:ss'), t1->'instance' order by time;",
+                "result_check": "0.0"
+            },
+            # child table query with incorrect tag name of json type
+            {
+                "sql": "select to_char(ts, 'yyyy-mm-dd hh24:mi:ss') as time, irate(col1) from ct1 group by to_char(ts, 'yyyy-mm-dd hh24:mi:ss'), t1->'name' order by time;",
+                "result_check": "None"
+            },
+            # child table query with null value
+            {
+                "sql": "select ts, avg(col1) from ct2 group by ts, t1->'name' order by ts;",
+                "result_check": "None"
+            }
+        ]
+        for sql_dic in sql_list:
+            tdSql.query(sql_dic["sql"])
+            tdLog.debug("execute sql: %s" % sql_dic["sql"])
+            for item in [row[1] for row in tdSql.queryResult]:
+                if sql_dic["result_check"] in str(item):
+                    tdLog.debug("Check query result of '{}' successfully".format(sql_dic["sql"]))
+                    break
+
+    def stop(self):
+        tdSql.close()
+        tdLog.success("%s successfully executed" % __file__)
+
+tdCases.addWindows(__file__, TDTestCase())
+tdCases.addLinux(__file__, TDTestCase())
+