From ab604310d3e08ac3f5d34914111b4fa8349e970d Mon Sep 17 00:00:00 2001
From: jiacy-jcy <714897623@qq.com>
Date: Thu, 13 Oct 2022 17:44:48 +0800
Subject: [PATCH 1/5] test:add test case for  alter buffer and pages

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

diff --git a/tests/system-test/1-insert/alter_database.py b/tests/system-test/1-insert/alter_database.py
new file mode 100644
index 0000000000..fa23f9ef4f
--- /dev/null
+++ b/tests/system-test/1-insert/alter_database.py
@@ -0,0 +1,56 @@
+import taos
+import sys
+import time
+import socket
+import os
+import threading
+
+from util.log import *
+from util.sql import *
+from util.cases import *
+from util.dnodes import *
+
+class TDTestCase:
+    def init(self, conn, logSql):
+        tdLog.debug("start to execute %s" % __file__)
+        tdSql.init(conn.cursor(),logSql)
+        self.buffer_boundary = [3,4097,8193,12289,16384]
+        self.buffer_error = [self.buffer_boundary[0]-1,self.buffer_boundary[-1]+1,12289,96]
+        # pages_boundary >= 64
+        self.pages_boundary = [64,128,512]
+        self.pages_error = [256,self.pages_boundary[0]-1]
+    def alter_buffer(self):
+        tdSql.execute('create database db')
+        for buffer in self.buffer_boundary:
+            tdSql.execute(f'alter database db buffer {buffer}')
+            tdSql.query('select * from information_schema.ins_databases where name = "db"')
+            tdSql.checkEqual(tdSql.queryResult[0][8],buffer)    
+        tdSql.execute('drop database db')
+        tdSql.execute('create database db vgroups 10')
+        for buffer in self.buffer_error:
+            tdSql.error(f'alter database db buffer {buffer}')
+        tdSql.execute('drop database db')
+    
+    def alter_pages(self):
+        tdSql.execute('create database db')
+        for pages in self.pages_boundary:
+            tdSql.execute(f'alter database db pages {pages}')
+            tdSql.query('select * from information_schema.ins_databases where name = "db"')
+            tdSql.checkEqual(tdSql.queryResult[0][10],pages)
+        tdSql.execute('drop database db')
+        tdSql.execute('create database db')
+        for pages in self.pages_error:
+            tdSql.error(f'alter database db pages {pages}')
+        tdSql.execute('drop database db')
+
+    def run(self):
+        tdSql.error('create database db1 vgroups 10 buffer 12289')
+        self.alter_buffer()
+        self.alter_pages()
+
+    def stop(self):
+        tdSql.close()
+        tdLog.success(f"{__file__} successfully executed")
+
+tdCases.addLinux(__file__, TDTestCase())
+tdCases.addWindows(__file__, TDTestCase())
\ No newline at end of file

From 03469918b8c645c9c5e0e1f1be0fe65d39ad6a7c Mon Sep 17 00:00:00 2001
From: jiacy-jcy <714897623@qq.com>
Date: Thu, 13 Oct 2022 17:51:54 +0800
Subject: [PATCH 2/5] update

---
 tests/system-test/1-insert/alter_database.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/tests/system-test/1-insert/alter_database.py b/tests/system-test/1-insert/alter_database.py
index fa23f9ef4f..d3a55ee0a6 100644
--- a/tests/system-test/1-insert/alter_database.py
+++ b/tests/system-test/1-insert/alter_database.py
@@ -18,7 +18,7 @@ class TDTestCase:
         self.buffer_error = [self.buffer_boundary[0]-1,self.buffer_boundary[-1]+1,12289,96]
         # pages_boundary >= 64
         self.pages_boundary = [64,128,512]
-        self.pages_error = [256,self.pages_boundary[0]-1]
+        self.pages_error = [self.pages_boundary[0]-1]
     def alter_buffer(self):
         tdSql.execute('create database db')
         for buffer in self.buffer_boundary:
@@ -39,6 +39,8 @@ class TDTestCase:
             tdSql.checkEqual(tdSql.queryResult[0][10],pages)
         tdSql.execute('drop database db')
         tdSql.execute('create database db')
+        tdSql.query('select * from information_schema.ins_databases where name = "db"')
+        self.pages_error.append(tdSql.queryResult[0][10])
         for pages in self.pages_error:
             tdSql.error(f'alter database db pages {pages}')
         tdSql.execute('drop database db')

From bc803c3f07db1f6b01968d83ad9f6eed826b38d6 Mon Sep 17 00:00:00 2001
From: jiacy-jcy <714897623@qq.com>
Date: Thu, 13 Oct 2022 17:54:19 +0800
Subject: [PATCH 3/5] add test case into ci

---
 tests/system-test/fulltest.sh | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/system-test/fulltest.sh b/tests/system-test/fulltest.sh
index 1c6aef6286..32eaa6dc34 100755
--- a/tests/system-test/fulltest.sh
+++ b/tests/system-test/fulltest.sh
@@ -18,7 +18,7 @@ python3 ./test.py -f 0-others/sysinfo.py
 python3 ./test.py -f 0-others/user_control.py
 python3 ./test.py -f 0-others/fsync.py
 python3 ./test.py  -f 0-others/compatibility.py   
-
+python3 ./test.py -f 1-insert/alter_database.py
 python3 ./test.py -f 1-insert/influxdb_line_taosc_insert.py
 python3 ./test.py -f 1-insert/opentsdb_telnet_line_taosc_insert.py
 python3 ./test.py -f 1-insert/opentsdb_json_taosc_insert.py

From 4d0c7732f13a5fd6da82ec0576105678970b868d Mon Sep 17 00:00:00 2001
From: jiacy-jcy <714897623@qq.com>
Date: Mon, 17 Oct 2022 11:20:10 +0800
Subject: [PATCH 4/5] test:add test case for create wrong topic

---
 tests/system-test/7-tmq/create_wrong_topic.py | 77 +++++++++++++++++++
 1 file changed, 77 insertions(+)
 create mode 100644 tests/system-test/7-tmq/create_wrong_topic.py

diff --git a/tests/system-test/7-tmq/create_wrong_topic.py b/tests/system-test/7-tmq/create_wrong_topic.py
new file mode 100644
index 0000000000..d18cb0260e
--- /dev/null
+++ b/tests/system-test/7-tmq/create_wrong_topic.py
@@ -0,0 +1,77 @@
+import taos
+import sys
+import time
+import socket
+import os
+import threading
+from util.common import *
+
+from util.log import *
+from util.sql import *
+from util.cases import *
+from util.dnodes import *
+from util.sqlset import *
+
+class TDTestCase:
+    def init(self, conn, logSql):
+        tdLog.debug("start to execute %s" % __file__)
+        tdSql.init(conn.cursor(),logSql)
+        self.setsql = TDSetSql()
+        self.rowNum = 10
+        self.ts = 1537146000000
+        self.binary_str = 'taosdata'
+        self.nchar_str = '涛思数据'
+        self.column_dict = {
+            'ts'  : 'timestamp',
+            'col1': 'tinyint',
+            'col2': 'smallint',
+            'col3': 'int',
+            'col4': 'bigint',
+            'col5': 'tinyint unsigned',
+            'col6': 'smallint unsigned',
+            'col7': 'int unsigned',
+            'col8': 'bigint unsigned',
+            'col9': 'float',
+            'col10': 'double',
+            }
+        self.error_topic = ['avg','count','spread','stddev','sum','hyperloglog']
+    def insert_data(self,column_dict,tbname,row_num):
+        insert_sql = self.setsql.set_insertsql(column_dict,tbname)
+        for i in range(row_num):
+            insert_list = []
+            self.setsql.insert_values(column_dict,i,insert_sql,insert_list,self.ts)
+    def wrong_topic(self):
+        tdSql.prepare()
+        tdSql.execute('use db')
+        stbname = f'db.{tdCom.getLongName(5, "letters")}'
+        tag_dict = {
+            't0':'int'
+        }
+        tag_values = [
+            f'1'
+            ]
+        tdSql.execute(self.setsql.set_create_stable_sql(stbname,self.column_dict,tag_dict))
+        tdSql.execute(f"create table {stbname}_tb1 using {stbname} tags({tag_values[0]})")
+        self.insert_data(self.column_dict,f'{stbname}_tb1',self.rowNum)
+        for column in self.column_dict.keys():
+            for func in self.error_topic:
+                if func.lower() != 'count' and column.lower() != 'ts':
+                    tdSql.error(f'create topic tpn as select {func}({column}) from {stbname}')
+                elif func.lower() == 'count' :
+                    tdSql.error(f'create topic tpn as select {func}(*) from {stbname}')
+        for column in self.column_dict.keys():
+            if column.lower() != 'ts':
+                tdSql.error(f'create topic tpn as select apercentile({column},50) from {stbname}')
+                tdSql.error(f'create topic tpn as select leastquares({column},1,1) from {stbname}_tb1')
+                tdSql.error(f'create topic tpn as select HISTOGRAM({column},user_input,[1,3,5,7],0) from {stbname}')
+                tdSql.error(f'create topic tpn as select percentile({column},1) from {stbname}_tb1')
+        pass
+    def run(self):
+        self.wrong_topic()
+
+    def stop(self):
+        tdSql.close()
+        tdLog.success(f"{__file__} successfully executed")
+
+tdCases.addLinux(__file__, TDTestCase())
+tdCases.addWindows(__file__, TDTestCase())
\ No newline at end of file

From b850c61720e81f6ad3df4aec6f6d5eae1c212b77 Mon Sep 17 00:00:00 2001
From: jiacy-jcy <714897623@qq.com>
Date: Mon, 17 Oct 2022 11:26:00 +0800
Subject: [PATCH 5/5] test :add test case into ci

---
 tests/system-test/fulltest.sh | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/system-test/fulltest.sh b/tests/system-test/fulltest.sh
index 2686156f0f..fe2337662c 100755
--- a/tests/system-test/fulltest.sh
+++ b/tests/system-test/fulltest.sh
@@ -279,7 +279,7 @@ python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_insertdatas_stop_
 python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups.py  -N 4 -M 1
 # python3 test.py -f 6-cluster/vnode/4dnode1mnode_basic_replica3_vgroups_stopOne.py -N 4 -M 1
 
-
+python3 ./test.py -f 7-tmq/create_wrong_topic.py
 python3 ./test.py -f 7-tmq/dropDbR3ConflictTransaction.py -N 3
 python3 ./test.py -f 7-tmq/basic5.py
 python3 ./test.py -f 7-tmq/subscribeDb.py