update test case

tests/system-test/1-insert/alter_table.py

@@ -87,7 +87,6 @@ class TDTestCase:
 
         }
     def alter_check_ntb(self):      
-        
         tdSql.prepare()
         tdSql.execute(self.setsql.set_create_normaltable_sql(self.ntbname,self.column_dict))
         for i in self.values_list:
@@ -107,6 +106,7 @@ class TDTestCase:
                 v = f'binary({self.binary_length+1})'
                 v_error = f'binary({self.binary_length-1})'
                 tdSql.error(f'alter table {self.ntbname} modify column {key} {v_error}')
+                tdSql.error(f'alter table {self.ntbname} set tag {key} = "abcd1"')
                 tdSql.execute(f'alter table {self.ntbname} modify column {key} {v}')
                 tdSql.query(f'describe {self.ntbname}')
                 result = tdCom.getOneRow(1,'VARCHAR')
@@ -115,6 +115,7 @@ class TDTestCase:
                 v = f'nchar({self.binary_length+1})'
                 v_error = f'nchar({self.binary_length-1})'
                 tdSql.error(f'alter table {self.ntbname} modify column {key} {v_error}')
+                tdSql.error(f'alter table {self.ntbname} set tag {key} = "abcd1"')
                 tdSql.execute(f'alter table {self.ntbname} modify column {key} {v}')
                 tdSql.query(f'describe {self.ntbname}')
                 result = tdCom.getOneRow(1,'NCHAR')
@@ -122,6 +123,7 @@ class TDTestCase:
             else:
                 for v in self.column_dict.values():
                     tdSql.error(f'alter table {self.ntbname} modify column {key} {v}')
+                    tdSql.error(f'alter table {self.ntbname} set tag {key} = "abcd1"')
         for key,values in self.column_dict.items():
             rename_str = f'{tdCom.getLongName(constant.COL_NAME_LENGTH_MAX,"letters")}'
             tdSql.execute(f'alter table {self.ntbname} rename column {key} {rename_str}')
@@ -285,6 +287,7 @@ class TDTestCase:
                 v = f'binary({self.binary_length+1})'
                 v_error = f'binary({self.binary_length-1})'
                 tdSql.error(f'alter table {self.stbname} modify column {key} {v_error}')
+                tdSql.error(f'alter table {self.stbname} set tag {key} = "abcd1"')
                 tdSql.execute(f'alter table {self.stbname} modify column {key} {v}')
                 tdSql.query(f'describe {self.stbname}')
                 result = tdCom.getOneRow(1,'VARCHAR')
@@ -297,6 +300,7 @@ class TDTestCase:
                 v = f'nchar({self.binary_length+1})'
                 v_error = f'nchar({self.binary_length-1})'
                 tdSql.error(f'alter table {self.stbname} modify column {key} {v_error}')
+                tdSql.error(f'alter table {self.stbname} set tag {key} = "abcd1"')
                 tdSql.execute(f'alter table {self.stbname} modify column {key} {v}')
                 tdSql.query(f'describe {self.stbname}')
                 result = tdCom.getOneRow(1,'NCHAR')
@@ -308,6 +312,7 @@ class TDTestCase:
             else:
                 for v in self.column_dict.values():
                     tdSql.error(f'alter table {self.stbname} modify column {key} {v}')
+                    tdSql.error(f'alter table {self.stbname} set tag {key} = "abcd1"')
         for key,values in self.column_dict.items():
             rename_str = f'{tdCom.getLongName(constant.COL_NAME_LENGTH_MAX,"letters")}'
             tdSql.error(f'alter table {self.stbname} rename column {key} {rename_str}')

tests/system-test/1-insert/drop.py

@@ -115,10 +115,41 @@ class TDTestCase:
                 tdSql.query(f'select * from {stbname} where {k} = {self.ts}')
                 tdSql.checkRows(self.tbnum) 
         tdSql.execute(f'drop database {self.dbname}')
-        
+    def drop_topic_check(self):
+        tdSql.execute(f'create database {self.dbname} replica {self.replicaVar}')
+        tdSql.execute(f'use {self.dbname}')
+        stbname = tdCom.getLongName(5,"letters")
+        topic_name = tdCom.getLongName(5,"letters")
+        tdSql.execute(f'create table {stbname} (ts timestamp,c0 int) tags(t0 int)')
+        tdSql.execute(f'create topic {topic_name} as select * from {self.dbname}.{stbname}')
+        tdSql.query(f'select * from information_schema.ins_topics where topic_name = "{topic_name}"')
+        tdSql.checkEqual(tdSql.queryResult[0][3],f'create topic {topic_name} as select * from {self.dbname}.{stbname}')
+        tdSql.execute(f'drop topic {topic_name}')
+        tdSql.execute(f'create topic {topic_name} as select c0 from {self.dbname}.{stbname}')
+        tdSql.query(f'select * from information_schema.ins_topics where topic_name = "{topic_name}"')
+        tdSql.checkEqual(tdSql.queryResult[0][3],f'create topic {topic_name} as select c0 from {self.dbname}.{stbname}')
+        tdSql.execute(f'drop topic {topic_name}')
+        tdSql.execute(f'drop database {self.dbname}')
+
+    def drop_stream_check(self):
+        tdSql.execute(f'create database {self.dbname} replica {self.replicaVar}')
+        tdSql.execute(f'use {self.dbname}')
+        stbname = tdCom.getLongName(5,"letters")
+        stream_name = tdCom.getLongName(5,"letters")
+        tdSql.execute(f'create table {stbname} (ts timestamp,c0 int) tags(t0 int)')
+        tdSql.execute(f'create stream {stream_name} into stb as select * from {self.dbname}.{stbname} partition by tbname')
+        tdSql.query(f'select * from information_schema.ins_streams where stream_name = "{stream_name}"')
+        print(tdSql.queryResult)
+        tdSql.checkEqual(tdSql.queryResult[0][2],f'create stream {stream_name} into stb as select * from {self.dbname}.{stbname} partition by tbname')
+        tdSql.execute(f'drop stream {stream_name}')
+        tdSql.execute(f'create stream {stream_name} into stb as select c0 from {self.dbname}.{stbname} partition by tbname')
+        tdSql.query(f'select * from information_schema.ins_streams where stream_name = "{stream_name}"')
+        tdSql.checkEqual(tdSql.queryResult[0][2],f'create stream {stream_name} into stb as select c0 from {stbname} partition by tbname')
     def run(self):
-        self.drop_ntb_check()
-        self.drop_stb_ctb_check()
+        # self.drop_ntb_check()
+        # self.drop_stb_ctb_check()
+        # self.drop_topic_check()
+        self.drop_stream_check()
         pass
     def stop(self):
         tdSql.close()