From e5023259ffb53682fa3df26b19170258d58dd243 Mon Sep 17 00:00:00 2001
From: dapan1121 <wpan@taosdata.com>
Date: Tue, 21 Feb 2023 14:36:25 +0800
Subject: [PATCH] fix: add tag filter case

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

diff --git a/tests/parallel_test/cases.task b/tests/parallel_test/cases.task
index 16751423b1..50016dd963 100644
--- a/tests/parallel_test/cases.task
+++ b/tests/parallel_test/cases.task
@@ -646,6 +646,7 @@
 ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/elapsed.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/csum.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/function_diff.py
+,,y,system-test,./pytest.sh python3 ./test.py -f 2-query/tagFilter.py
 ,,n,system-test,python3 ./test.py -f 2-query/queryQnode.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode1mnode.py
 ,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode2mnode.py -N 5
diff --git a/tests/system-test/2-query/tagFilter.py b/tests/system-test/2-query/tagFilter.py
new file mode 100644
index 0000000000..b03776c31b
--- /dev/null
+++ b/tests/system-test/2-query/tagFilter.py
@@ -0,0 +1,67 @@
+from util.log import *
+from util.sql import *
+from util.cases import *
+from util.dnodes import *
+
+
+INT_COL     = "c1"
+BINT_COL    = "c2"
+SINT_COL    = "c3"
+TINT_COL    = "c4"
+FLOAT_COL   = "c5"
+DOUBLE_COL  = "c6"
+BOOL_COL    = "c7"
+
+BINARY_COL  = "c8"
+NCHAR_COL   = "c9"
+TS_COL      = "c10"
+
+NUM_COL = [INT_COL, BINT_COL, SINT_COL, TINT_COL, FLOAT_COL, DOUBLE_COL, ]
+UN_NUM_COL = [BOOL_COL, BINARY_COL, NCHAR_COL, ]
+TS_TYPE_COL = [TS_COL]
+
+DBNAME = "db"
+
+class TDTestCase:
+
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
+        tdLog.debug(f"start to excute {__file__}")
+        tdSql.init(conn.cursor())
+        tdSql.execute(f'drop database if exists db')
+        tdSql.execute(f'create database if not exists db vgroups 1')
+
+    def __create_tb(self, dbname="db"):
+        create_stb_sql  =  f'''create table {dbname}.stb1(
+                ts timestamp, f1 int
+            ) tags (tag1 binary(16300))
+            '''
+        tdSql.execute(create_stb_sql)
+
+        tag_value = 'a'
+        for i in range(1200):
+            tag_value = tag_value + 'a'
+
+        for i in range(8000):
+            tdSql.execute(f"create table {dbname}.ct{i+1} using {dbname}.stb1 tags ( '{tag_value}' )")
+
+    def __query_data(self, rows, dbname="db"):
+        tdSql.execute(
+            f'''select count(*) from {dbname}.stb1 where tag1 like '%a'
+            '''
+        )
+        tdSql.checkRows(0)
+
+    def run(self):
+        tdLog.printNoPrefix("==========step1:create table")
+        self.__create_tb()
+
+        tdLog.printNoPrefix("==========step2:query data")
+        self.__query_data(10)
+
+    def stop(self):
+        tdSql.close()
+        tdLog.success(f"{__file__} successfully executed")
+
+tdCases.addLinux(__file__, TDTestCase())
+tdCases.addWindows(__file__, TDTestCase())