chore: add test case generated by claude

Author: kailixu

test/cases/uncatalog/system-test/0-others/test_grant.py

@@ -309,6 +309,140 @@ def s4_ts6191_check_dual_replica(self):
             self.clearEnv()
             raise Exception(repr(e))
 
+    def s5_check_timeseries_exclude_systable(self):
+        """
+        测试计算测点时排除系统表的功能
+        
+        排除的系统表为超级表：
+        1. log 库中的超级表 (tkLogStb)
+        2. audit 库中的超级表 (tkAuditStb)，audit 库的判断条件：
+           - 数据库名为 audit
+           - 或者建库语句中指明 is_audit 1
+        """
+        # log 库的系统表超级表列表
+        tkLogStb = [
+            "cluster_info", "data_dir", "dnodes_info", "d_info", "grants_info",
+            "keeper_monitor", "logs", "log_dir", "log_summary", "m_info",
+            "taosadapter_restful_http_request_fail", "taosadapter_restful_http_request_in_flight",
+            "taosadapter_restful_http_request_summary_milliseconds", "taosadapter_restful_http_request_total",
+            "taosadapter_system_cpu_percent", "taosadapter_system_mem_percent", "temp_dir", "vgroups_info",
+            "vnodes_role", "taosd_dnodes_status", "adapter_conn_pool", "taosd_vnodes_info", "taosd_dnodes_metrics",
+            "taosd_vgroups_info", "taos_sql_req", "taosd_mnodes_info", "adapter_c_interface", "taosd_cluster_info",
+            "taosd_sql_req", "taosd_dnodes_info", "adapter_requests", "taosd_write_metrics", "adapter_status",
+            "taos_slow_sql", "taos_slow_sql_detail", "taosd_cluster_basic", "taosd_dnodes_data_dirs",
+            "taosd_dnodes_log_dirs", "xnode_agent_activities", "xnode_task_activities", "xnode_task_metrics",
+            "taosx_task_csv", "taosx_task_progress", "taosx_task_kinghist", "taosx_task_tdengine2",
+            "taosx_task_tdengine3", "taosx_task_opc_da", "taosx_task_opc_ua", "taosx_task_kafka",
+            "taosx_task_influxdb", "taosx_task_mqtt", "taosx_task_avevahistorian", "taosx_task_opentsdb",
+            "taosx_task_mysql", "taosx_task_postgres", "taosx_task_oracle", "taosx_task_mssql",
+            "taosx_task_mongodb", "taosx_task_sparkplugb", "taosx_task_orc", "taosx_task_pulsar", "taosx_task_pspace"
+        ]
+        
+        # audit 库的系统表超级表列表
+        tkAuditStb = ["operations"]
+
+        tdLog.printNoPrefix("======== test timeseries exclude systable: ")
+        try:
+            # 获取当前的 timeseries 数量作为基准
+            tss_grant_base = self.getShowGrantsTimeSeries()
+            tdLog.info(f"Base timeseries count: {tss_grant_base}")
+
+            # ========== 测试1: 验证 audit 库中的 operations 表不计入 timeseries ==========
+            tdLog.printNoPrefix("======== test1: audit db operations table should be excluded")
+            # audit 库已在 s0_five_dnode_one_mnode 中创建，包含 operations 超级表
+            # 验证 audit 库中的 operations 子表不计入 timeseries
+            tdSql.execute("use audit")
+            tdSql.execute("insert into t_operations_abc values(now, 1, 100, 10, 1.0, 2.0)")
+            tdSql.execute("create table t_operations_def using operations tags(2)")
+            tdSql.execute("insert into t_operations_def values(now, 2, 200, 20, 2.0, 3.0)")
+            
+            # 验证 timeseries 数量不变（audit 库的 operations 表应被排除）
+            self.checkGrantsTimeSeries("audit db operations should be excluded", tss_grant_base)
+            tdLog.info("test1 passed: audit db operations table excluded from timeseries count")
+
+            # ========== 测试2: 验证 is_audit 标记的库中的 operations 表不计入 timeseries ==========
+            tdLog.printNoPrefix("======== test2: is_audit db operations table should be excluded")
+            tdSql.execute("drop database if exists audit_test")
+            tdSql.execute("create database audit_test is_audit 1 keep 36500d")
+            tdSql.execute("use audit_test")
+            # 在 is_audit 库中创建 operations 超级表和子表
+            tdSql.execute("create table operations(ts timestamp, c0 int primary key, c1 bigint, c2 int, c3 float, c4 double) tags(t0 bigint unsigned)")
+            tdSql.execute("create table t_ops_1 using operations tags(1)")
+            tdSql.execute("insert into t_ops_1 values(now, 1, 100, 10, 1.0, 2.0)")
+            tdSql.execute("create table t_ops_2 using operations tags(2)")
+            tdSql.execute("insert into t_ops_2 values(now, 2, 200, 20, 2.0, 3.0)")
+            
+            # 验证 timeseries 数量不变（is_audit 库的 operations 表应被排除）
+            self.checkGrantsTimeSeries("is_audit db operations should be excluded", tss_grant_base)
+            tdLog.info("test2 passed: is_audit db operations table excluded from timeseries count")
+
+            # ========== 测试3: 验证 is_audit 库中的非 operations 表正常计入 timeseries ==========
+            tdLog.printNoPrefix("======== test3: is_audit db non-operations table should be counted")
+            tdSql.execute("use audit_test")
+            # 在 is_audit 库中创建非 operations 的普通表
+            tdSql.execute("create table normal_stb(ts timestamp, c0 int, c1 bigint, c2 int) tags(t0 int)")
+            tdSql.execute("create table t_normal_1 using normal_stb tags(1)")
+            tdSql.execute("insert into t_normal_1 values(now, 1, 100, 10)")
+            tss_grant_expected = tss_grant_base + 3  # 3 columns (excluding ts)
+            self.checkGrantsTimeSeries("is_audit db non-operations table should be counted", tss_grant_expected)
+            tdLog.info("test3 passed: is_audit db non-operations table counted in timeseries")
+
+            # ========== 测试4: 验证普通库中的 operations 表正常计入 timeseries ==========
+            tdLog.printNoPrefix("======== test4: normal db operations table should be counted")
+            tdSql.execute("drop database if exists normal_test")
+            tdSql.execute("create database normal_test keep 36500d")
+            tdSql.execute("use normal_test")
+            # 在普通库中创建同名的 operations 超级表和子表
+            tdSql.execute("create table operations(ts timestamp, c0 int primary key, c1 bigint, c2 int, c3 float, c4 double) tags(t0 bigint unsigned)")
+            tdSql.execute("create table t_ops_normal_1 using operations tags(1)")
+            tdSql.execute("insert into t_ops_normal_1 values(now, 1, 100, 10, 1.0, 2.0)")
+            tss_grant_expected += 5  # 5 columns (excluding ts)
+            self.checkGrantsTimeSeries("normal db operations table should be counted", tss_grant_expected)
+            tdLog.info("test4 passed: normal db operations table counted in timeseries")
+
+            # ========== 测试5: 验证 log 库中的系统表不计入 timeseries ==========
+            tdLog.printNoPrefix("======== test5: log db system tables should be excluded")
+            tdSql.execute("drop database if exists log")
+            tdSql.execute("create database log keep 36500d")
+            tdSql.execute("use log")
+            # 在 log 库中创建部分系统表超级表和子表
+            test_log_stbs = ["cluster_info", "dnodes_info", "grants_info", "logs"]
+            for stb_name in test_log_stbs:
+                tdSql.execute(f"create table {stb_name}(ts timestamp, c0 int, c1 bigint, c2 int, c3 float, c4 double) tags(t0 bigint unsigned)")
+                tdSql.execute(f"create table t_{stb_name}_1 using {stb_name} tags(1)")
+                tdSql.execute(f"insert into t_{stb_name}_1 values(now, 1, 100, 10, 1.0, 2.0)")
+            
+            # 验证 timeseries 数量不变（log 库的系统表应被排除）
+            self.checkGrantsTimeSeries("log db system tables should be excluded", tss_grant_expected)
+            tdLog.info("test5 passed: log db system tables excluded from timeseries count")
+
+            # ========== 测试6: 验证 log 库中的非系统表正常计入 timeseries ==========
+            tdLog.printNoPrefix("======== test6: log db non-system table should be counted")
+            tdSql.execute("use log")
+            # 在 log 库中创建非系统表的普通表
+            tdSql.execute("create table user_defined_stb(ts timestamp, c0 int, c1 bigint, c2 int) tags(t0 int)")
+            tdSql.execute("create table t_user_1 using user_defined_stb tags(1)")
+            tdSql.execute("insert into t_user_1 values(now, 1, 100, 10)")
+            tss_grant_expected += 3  # 3 columns (excluding ts)
+            self.checkGrantsTimeSeries("log db non-system table should be counted", tss_grant_expected)
+            tdLog.info("test6 passed: log db non-system table counted in timeseries")
+
+            # ========== 清理测试数据 ==========
+            tdLog.printNoPrefix("======== cleanup test databases")
+            tdSql.execute("drop database if exists audit_test")
+            tdSql.execute("drop database if exists normal_test")
+            tdSql.execute("drop database if exists log")
+            
+            # 验证清理后 timeseries 恢复到基准值
+            self.checkGrantsTimeSeries("cleanup and verify base timeseries", tss_grant_base)
+            tdLog.info("cleanup completed, timeseries restored to base count")
+
+            tdLog.printNoPrefix("======== all s5_check_timeseries_exclude_systable tests passed!")
+
+        except Exception as e:
+            self.clearEnv()
+            raise Exception(repr(e))
+
     def test_grant(self):
         """summary: xxx
 
@@ -343,6 +477,7 @@ def test_grant(self):
         self.s2_check_show_grants_ungranted()
         self.s3_check_show_grants_granted()
         self.s4_ts6191_check_dual_replica()
+        self.s5_check_timeseries_exclude_systable()
 
         self.clearEnv()