From 7752a7e4fd067a7452b977bf09f4bb94e7304a7b Mon Sep 17 00:00:00 2001
From: jiacy-jcy <cyjia@taosdata.com>
Date: Sat, 25 Jun 2022 14:14:01 +0800
Subject: [PATCH] add test case for param ttl

---
 tests/system-test/1-insert/table_param_ttl.py | 61 +++++++++++++++++++
 1 file changed, 61 insertions(+)
 create mode 100644 tests/system-test/1-insert/table_param_ttl.py

diff --git a/tests/system-test/1-insert/table_param_ttl.py b/tests/system-test/1-insert/table_param_ttl.py
new file mode 100644
index 0000000000..f93ebb98cb
--- /dev/null
+++ b/tests/system-test/1-insert/table_param_ttl.py
@@ -0,0 +1,61 @@
+###################################################################
+#           Copyright (c) 2016 by TAOS Technologies, Inc.
+#                     All rights reserved.
+#
+#  This file is proprietary and confidential to TAOS Technologies.
+#  No part of this file may be reproduced, stored, transmitted,
+#  disclosed or used in any form or by any means other than as
+#  expressly provided by the written permission from Jianhui Tao
+#
+###################################################################
+
+# -*- coding: utf-8 -*-
+
+from util.log import *
+from util.cases import *
+from util.sql import *
+from util.common import *
+
+class TDTestCase:
+    updatecfgDict = {'ttlUnit':10,'ttlPushInterval':5}
+    def init(self, conn, logSql):
+        tdLog.debug("start to execute %s" % __file__)
+        tdSql.init(conn.cursor())      
+        self.ntbname = 'ntb'
+        self.stbname = 'stb'
+        self.tbnum = 10
+        self.ttl_param = 1
+    def ttl_check(self):
+        tdSql.prepare()
+        for i in range(self.tbnum):
+            tdSql.execute(f'create table {self.ntbname}_{i} (ts timestamp,c0 int) ttl {self.ttl_param}')
+        tdSql.query(f'show tables')
+        tdSql.checkRows(self.tbnum)
+        tdSql.execute('reset query cache')
+        sleep(self.updatecfgDict['ttlUnit']*self.ttl_param+5)
+        tdSql.query(f'show tables')
+        tdSql.checkRows(0)
+
+        tdSql.execute(f'create table {self.stbname} (ts timestamp,c0 int) tags(t0 int)')
+        for i in range(self.tbnum):
+            tdSql.execute(f'create table {self.stbname}_{i} using {self.stbname} tags({i}) ttl {self.ttl_param}')
+        tdSql.query(f'show tables')
+        tdSql.checkRows(self.tbnum)
+        sleep(self.updatecfgDict['ttlUnit']*self.ttl_param+5)
+        tdSql.query(f'show tables')
+        tdSql.checkRows(0)
+
+    def run(self):
+    
+        self.ttl_check()
+        
+        
+
+        
+
+    def stop(self):
+        tdSql.close()
+        tdLog.success("%s successfully executed" % __file__)
+
+tdCases.addWindows(__file__, TDTestCase())
+tdCases.addLinux(__file__, TDTestCase())
-- 
GitLab