Merge pull request #9083 from taosdata/dev/chr

 [TD-11861][TD-11094][TD-11399][TD-10789][TD-6677]<test>: modify testcase that it will exit without continuing execution when json files have been checked unsuccessfully

taos-tools @ 0b4a16e9

-Subproject commit 78519c0c90a261b6a559c6bbe7f3d3b5a7b630b4
+Subproject commit 0b4a16e96b5cc9cb6e4f8cacf6a1f3028c91adb0

tests/pytest/fulltest.sh

@@ -52,6 +52,8 @@ python3 ./test.py -f table/create_db_from_normal_db.py
 #stable
 python3 ./test.py -f stable/insert.py
 python3 test.py -f tools/taosdemoAllTest/taosdemoTestInsertWithJsonStmt.py
+python3 test.py -f tools/taosdemoAllTest/taosdemoTestInsertWithJsonSml.py
+python3 test.py -f tag_lite/json_tag_extra.py
 
 # tag
 python3 ./test.py -f tag_lite/filter.py
@@ -223,6 +225,7 @@ python3 ./test.py -f perfbenchmark/bug3433.py
 python3 test.py -f tools/taosdemoAllTest/taosdemoTestInsertWithJson.py
 python3 test.py -f tools/taosdemoAllTest/taosdemoTestQueryWithJson.py
 python3 test.py -f tools/taosdemoAllTest/taosdemoTestInsertAllType.py
+python3 test.py -f tools/taosdemoAllTest/taosdemoTestInsertShell.py
 
 #query
 python3 test.py -f query/distinctOneColTb.py

tests/pytest/functions/variable_httpDbNameMandatory.py

@@ -34,11 +34,15 @@ class TDTestCase:
 
     def getBuildPath(self) -> str:
         selfPath = os.path.dirname(os.path.realpath(__file__))
+        global cfgPath
 
         if ("community" in selfPath):
             projPath = selfPath[:selfPath.find("community")]
+            cfgPath = projPath + "/community/sim/dnode1/cfg"
         else:
             projPath = selfPath[:selfPath.find("tests")]
+            cfgPath = projPath + "/sim/dnode1/cfg"
+
 
         for root, dirs, files in os.walk(projPath):
             if ("taosd" in files):
@@ -53,8 +57,10 @@ class TDTestCase:
 
         if ("community" in selfPath):
             cfgDir = self.getBuildPath() + "/community/sim/dnode1/cfg"
+            
         else:
             cfgDir = self.getBuildPath() + "/sim/dnode1/cfg"
+
         return cfgDir
 
     def getCfgFile(self) -> str:
@@ -85,8 +91,8 @@ class TDTestCase:
     def TS834(self):
         tdLog.printNoPrefix("==========TS-782==========")
         tdSql.prepare()
-
-        cfgfile = self.getCfgFile()
+        buildPath = self.getBuildPath()
+        cfgfile = cfgPath + "/taos.cfg"
 
         tdSql.execute("show variables")
         res_com = tdSql.cursor.fetchall()

tests/pytest/tag_lite/json_tag_extra.py

+###################################################################
+#           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, db_test.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 -*-
+
+import sys
+import taos
+from util.log import tdLog
+from util.cases import tdCases
+from util.sql import tdSql
+import time
+import random
+
+class TDTestCase:
+
+    def init(self, conn, logSql):
+        tdLog.debug("start to execute %s" % __file__)
+        tdSql.init(conn.cursor(), logSql)
+
+    def run(self):
+        tdSql.prepare()
+        tdSql.execute("drop database if exists db_json;")
+        print("==============step1 tag format =======")
+        tdLog.info("create database   ")
+        tdSql.execute("create database db_json")
+        tdSql.execute("use db_json")    
+        # test  tag format 
+        tdSql.execute("create table if not exists  jsons1(ts timestamp, dataInt int, dataStr nchar(50)) tags(jtag json)")
+        tdSql.error("create table if not exists  jsons1(ts timestamp, dataInt int, dataStr nchar(50)) tags(jtag json(10000000))")
+        tdSql.error("create table if not exists  jsons1(ts timestamp, dataInt int, dataStr nchar(50)) tags(jtag json,jtag1 json)")
+        tdSql.error("create table if not exists  jsons1(ts timestamp, dataInt int, dataStr nchar(50)) tags(jtag json,dataBool bool)")
+        
+        tdSql.execute("CREATE TABLE if not exists  jsons1_1 using  jsons1 tags('{\"loc\":\"fff\",\"id\":5}')")
+
+        # two stables: jsons1 jsons2 ,test  tag's value  and  key  
+        tdSql.execute("insert into  jsons1_1(ts,dataInt)  using  jsons1 tags('{\"loc+\":\"fff\",\"id\":5}') values (now,12)")
+
+        tdSql.error("CREATE TABLE if not exists  jsons1_1 using  jsons1 tags('{oc:\"fff\",\"id\":5}')")
+        tdSql.error("CREATE TABLE if not exists  jsons1_1 using  jsons1 tags('{\"loc\":fff,\"id\":5}')")
+        tdSql.error("CREATE TABLE if not exists  jsons1_1 using  jsons1 tags('3333')")
+        tdSql.error("CREATE TABLE if not exists  jsons1_1 using  jsons1 tags('{\"loc\":}')")
+        tdSql.error("CREATE TABLE if not exists  jsons1_1 using  jsons1 tags('{\"loc\":bool)")
+        tdSql.error("CREATE TABLE if not exists  jsons1_1 using  jsons1 tags(true)")
+        tdSql.error("CREATE TABLE if not exists  jsons1_1 using  jsons1 tags('[{\"num\":5}]')")
+
+        # test object and key max length. max key length is 256, max object length is 4096 include abcd.
+        tdSql.execute("create table if not exists  jsons4(ts timestamp, dataInt int, dataStr nchar(50)) tags(jtag json)")
+
+        char1= ''.join(['abcd']*64)
+        char2=''.join(char1)
+        char3= ''.join(['abcd']*1022)
+        print(len(char3))   # 4088
+        tdSql.execute("CREATE TABLE if not exists  jsons4_1 using  jsons4 tags('{\"%s\":5}')" % char1)  # len(key)=256
+        tdSql.error("CREATE TABLE if not exists  jsons4_1 using  jsons4 tags('{\"%s1\":5}')" % char2)   # len(key)=257
+        tdSql.execute("CREATE TABLE if not exists  jsons4_2 using  jsons4 tags('{\"T\":\"%s\"}')" % char3)  # len(object)=4096
+        tdSql.error("CREATE TABLE if not exists  jsons4_2 using  jsons4 tags('{\"TS\":\"%s\"}')" % char3)   # len(object)=4097
+
+        tdSql.execute("insert into  jsons1_1 values(now, 1, 'json1')")
+        tdSql.execute("insert into  jsons1_1 values(now+1s, 1, 'json1')")
+        tdSql.execute("insert into  jsons1_2 using  jsons1 tags('{\"num\":5,\"location\":\"beijing\"}') values (now, 1, 'json2')")
+        tdSql.execute("insert into  jsons1_3 using  jsons1 tags('{\"num\":34,\"location\":\"beijing\",\"level\":\"l1\"}') values (now, 1, 'json3')")
+        tdSql.execute("insert into  jsons1_4 using  jsons1 tags('{\"class\":55,\"location\":\"beijing\",\"name\":\"name4\"}') values (now, 1, 'json4')")
+
+        # test : json'vaule is null and 
+        tdSql.execute("create table if not exists  jsons2(ts timestamp, dataInt2 int, dataStr2 nchar(50)) tags(jtag2 json)")
+        tdSql.execute("CREATE TABLE if not exists  jsons2_1 using  jsons2 tags('{}')")
+        tdSql.query("select jtag2 from  jsons2_1")
+        tdSql.checkData(0, 0, None)
+        tdSql.execute("CREATE TABLE if not exists  jsons2_2 using  jsons2 tags('')")
+        tdSql.query("select jtag2 from  jsons2_2")
+        tdSql.checkData(0, 0, None)
+        tdSql.execute("CREATE TABLE if not exists  jsons2_3 using  jsons2 tags('null')")
+        tdSql.query("select jtag2 from  jsons2_3")
+        tdSql.checkData(0, 0, None) 
+        tdSql.execute("CREATE TABLE if not exists  jsons2_4 using  jsons2 tags('\t')")
+        tdSql.query("select jtag2 from  jsons2_4")
+        tdSql.checkData(0, 0, None)
+        tdSql.execute("CREATE TABLE if not exists  jsons2_5 using  jsons2 tags(' ')")
+        tdSql.query("select jtag2 from  jsons2_5")
+        tdSql.checkData(0, 0, None)
+        tdSql.execute("CREATE TABLE if not exists  jsons2_6 using  jsons2 tags('{\"nv\":null,\"tea\":true,\"\":false,\"\":123,\"tea\":false}')")
+        tdSql.query("select jtag2 from  jsons2_6")
+        tdSql.checkData(0, 0, "{\"nv\":null,\"tea\":true}")
+        tdSql.execute("CREATE TABLE if not exists  jsons2_7 using  jsons2 tags('{\"test7\":\"\"}')")
+        tdSql.query("select jtag2 from  jsons2_7")
+        tdSql.checkData(0, 0, "{\"test7\":\"\"}")
+        tdSql.execute("CREATE TABLE if not exists  jsons2_8 using  jsons2 tags('{\"nv\":null,\"tea\":123,\"\":false,\"\":123,\"tea\":false}')")
+        tdSql.query("select jtag2 from  jsons2_8")
+        tdSql.checkData(0, 0, "{\"nv\":null,\"tea\":123}")
+
+        print("==============step2 alter json table==")
+        tdLog.info("alter stable add tag")
+        tdSql.error("ALTER STABLE  jsons2 add tag jtag3 nchar(20)")
+        tdSql.error("ALTER STABLE  jsons2 drop tag jtag2")
+        tdSql.execute("ALTER STABLE jsons2 change tag jtag2 jtag3")
+        tdSql.query("select jtag3->'tea' from  jsons2_6")
+        tdSql.checkData(0, 0, "true")       
+        tdSql.error("ALTER TABLE  jsons2_6 SET TAG jtag3='{\"tea-=[].;!@#$%^&*()/\":}'")
+        tdSql.execute("ALTER TABLE  jsons2_6 SET TAG jtag3='{\"tea-=[].;!@#$%^&*()/\":false}'")
+        tdSql.query("select jtag3 from  jsons2_6")
+        tdSql.checkData(0, 0, "{\"tea-=[].;!@#$%^&*()/\":false}")
+        tdSql.execute("ALTER TABLE  jsons1_1 SET TAG jtag='{\"sex\":\"femail\",\"age\":35}'")
+        tdSql.query("select jtag from  jsons1_1")
+        tdSql.checkData(0, 0, "{\"sex\":\"femail\",\"age\":35}")
+       
+
+
+        print("==============step3")
+        tdLog.info("select table")
+
+        tdSql.query("select jtag from  jsons1_1")
+        tdSql.checkData(0, 0, "{\"sex\":\"femail\",\"age\":35}")
+
+        tdSql.query("select jtag from  jsons1 where  jtag->'name'='name4'")
+        tdSql.checkData(0, 0, "{\"class\":55,\"location\":\"beijing\",\"name\":\"name4\"}")
+
+
+        tdSql.query("select * from  jsons1")
+        tdSql.checkRows(6)
+
+        tdSql.query("select * from  jsons1_1")
+        tdSql.checkRows(3)
+
+        tdSql.query("select * from  jsons1 where jtag->'location'='beijing'")
+        tdSql.checkRows(3)
+
+        tdSql.query("select jtag->'location' from  jsons1_2")
+        tdSql.checkData(0, 0, "\"beijing\"")
+
+
+        tdSql.query("select jtag->'num' from  jsons1 where jtag->'level'='l1'")
+        tdSql.checkData(0, 0, 34)
+
+        tdSql.query("select jtag->'location' from  jsons1")
+        tdSql.checkRows(4)
+
+        tdSql.query("select jtag from  jsons1_1")
+        tdSql.checkRows(1)
+
+        tdSql.query("select * from  jsons1 where jtag contains 'sex' or jtag contains 'num'")
+        tdSql.checkRows(5)
+
+        tdSql.query("select * from  jsons1 where jtag contains 'sex' and jtag contains 'num'")
+        tdSql.checkRows(0)
+
+        tdSql.query("select jtag->'sex' from  jsons1 where jtag contains 'sex' or jtag contains 'num'")
+        tdSql.checkData(0, 0, "\"femail\"")
+        tdSql.checkRows(3)
+
+        tdSql.query("select *,tbname from  jsons1 where jtag->'location'='beijing'")
+        tdSql.checkRows(3)
+
+        tdSql.query("select *,tbname from  jsons1 where jtag->'num'=5 or jtag contains 'sex'")
+        tdSql.checkRows(4)
+
+        # test with tbname
+        tdSql.query("select * from  jsons1 where tbname = 'jsons1_1'")
+        tdSql.checkRows(3)
+
+        tdSql.query("select * from  jsons1 where tbname = 'jsons1_1' or jtag contains 'num'")
+        tdSql.checkRows(5)
+
+        tdSql.query("select * from  jsons1 where tbname = 'jsons1_1' and jtag contains 'num'")
+        tdSql.checkRows(0)
+
+        tdSql.query("select * from  jsons1 where tbname = 'jsons1_1' or jtag->'num'=5")
+        tdSql.checkRows(4)
+
+        # test where condition like
+        tdSql.query("select *,tbname from  jsons1 where jtag->'location' like 'bei%'")
+        tdSql.checkRows(3)
+
+        tdSql.query("select *,tbname from  jsons1 where jtag->'location' like 'bei%' and jtag->'location'='beijin'")
+        tdSql.checkRows(0)
+
+        tdSql.query("select *,tbname from  jsons1 where jtag->'location' like 'bei%' or jtag->'location'='beijin'")
+        tdSql.checkRows(3)
+
+        tdSql.query("select *,tbname from  jsons1 where jtag->'location' like 'bei%' and jtag->'num'=34")
+        tdSql.checkRows(1)
+
+        tdSql.query("select *,tbname from  jsons1 where (jtag->'location' like 'shanghai%' or jtag->'num'=34) and jtag->'class'=55")
+        tdSql.checkRows(0)
+
+        tdSql.query("select * from  jsons1 where jtag->'num' like '5%'")
+        tdSql.checkRows(0)
+
+        # # test where condition in
+        # tdSql.query("select * from  jsons1 where jtag->'location' in ('beijing')")
+        # tdSql.checkRows(3)
+
+        # tdSql.query("select * from  jsons1 where jtag->'num' in (5,34)")
+        # tdSql.checkRows(2)
+
+        # tdSql.error("select * from  jsons1 where jtag->'num' in ('5',34)")
+
+        # tdSql.query("select * from  jsons1 where jtag->'location' in ('beijing') and jtag->'class'=55")
+        # tdSql.checkRows(1)
+
+        # test where condition match
+        tdSql.query("select * from  jsons1 where jtag->'location' match 'jin$'")
+        tdSql.checkRows(0)
+
+        tdSql.query("select * from  jsons1 where jtag->'location' match 'jin'")
+        tdSql.checkRows(3)
+
+        tdSql.query("select * from  jsons1 where datastr match 'json' and jtag->'location' match 'jin'")
+        tdSql.checkRows(3)
+
+        tdSql.query("select * from  jsons1 where jtag->'num' match '5'")
+        tdSql.checkRows(0)
+
+        # test json string parse
+        tdSql.error("CREATE TABLE if not exists  jsons1_5 using  jsons1 tags('efwewf')")
+        tdSql.execute("CREATE TABLE if not exists  jsons1_5 using  jsons1 tags('\t')")
+        tdSql.execute("CREATE TABLE if not exists  jsons1_6 using  jsons1 tags('')")
+
+        tdSql.query("select jtag from  jsons1_6")
+        tdSql.checkData(0, 0, None)
+
+        tdSql.execute("CREATE TABLE if not exists  jsons1_7 using  jsons1 tags('{}')")
+        tdSql.query("select jtag from  jsons1_7")
+        tdSql.checkData(0, 0, None)
+
+        tdSql.execute("CREATE TABLE if not exists  jsons1_8 using  jsons1 tags('null')")
+        tdSql.query("select jtag from  jsons1_8")
+        tdSql.checkData(0, 0, None)
+
+        tdSql.execute("CREATE TABLE if not exists  jsons1_9 using  jsons1 tags('{\"\":4,\"time\":null}')")
+        tdSql.query("select jtag from  jsons1_9")
+        tdSql.checkData(0, 0, "{\"time\":null}")
+
+        tdSql.execute("CREATE TABLE if not exists  jsons1_10 using  jsons1 tags('{\"k1\":\"\",\"k1\":\"v1\",\"k2\":true,\"k3\":false,\"k4\":55}')")
+        tdSql.query("select jtag from  jsons1_10")
+        tdSql.checkData(0, 0, "{\"k1\":\"\",\"k2\":true,\"k3\":false,\"k4\":55}")
+
+        tdSql.query("select jtag->'k2' from  jsons1_10")
+        tdSql.checkData(0, 0, "true")
+
+        tdSql.query("select jtag from  jsons1 where jtag->'k1'=''")
+        tdSql.checkRows(1)
+
+        tdSql.query("select jtag from  jsons1 where jtag->'k2'=true")
+        tdSql.checkRows(1)
+
+        tdSql.query("select jtag from  jsons1 where jtag is null")
+        tdSql.checkRows(4)
+
+        tdSql.query("select jtag from  jsons1 where jtag is not null")
+        tdSql.checkRows(6)
+
+        tdSql.query("select * from  jsons1 where jtag->'location' is not null")
+        tdSql.checkRows(3)
+
+        tdSql.query("select tbname,jtag from  jsons1 where jtag->'location' is null")
+        tdSql.checkRows(7)
+
+        tdSql.query("select * from  jsons1 where jtag->'num' is not null")
+        tdSql.checkRows(2)
+
+        tdSql.query("select * from  jsons1 where jtag->'location'='null'")
+        tdSql.checkRows(0)
+
+        tdSql.query("select * from  jsons1 where jtag->'num'=null")
+        tdSql.checkRows(0)
+
+        # test distinct
+        tdSql.query("select distinct jtag from  jsons1")
+        tdSql.checkRows(7)
+
+        tdSql.query("select distinct jtag->'location' from  jsons1")
+        tdSql.checkRows(2)
+
+        # test chinese
+        tdSql.execute("CREATE TABLE if not exists  jsons1_11 using  jsons1 tags('{\"k1\":\"中国\",\"k5\":\"是是是\"}')")
+
+        tdSql.query("select tbname,jtag from  jsons1 where jtag->'k1' match '中'")
+        tdSql.checkRows(1)
+
+        tdSql.query("select tbname,jtag from  jsons1 where jtag->'k1'='中国'")
+        tdSql.checkRows(1)
+
+        #test dumplicate key with normal colomn
+        tdSql.execute("INSERT INTO  jsons1_12 using  jsons1 tags('{\"tbname\":\"tt\",\"databool\":true,\"dataStr\":\"是是是\"}') values(now, 4, \"你就会\")")
+
+        tdSql.query("select *,tbname,jtag from  jsons1 where jtag->'dataStr' match '是'")
+        tdSql.checkRows(1)
+
+        tdSql.query("select tbname,jtag->'tbname' from  jsons1 where jtag->'tbname'='tt'")
+        tdSql.checkRows(1)
+
+        # test  filter : and /or / in/ like
+        tdSql.query("select * from jsons1 where jtag->'num' is not null or jtag contains 'class' and jtag contains 'databool'")
+        tdSql.checkRows(2)
+
+        tdSql.query("select * from jsons1 where jtag->'num' is not null and jtag contains 'class' or jtag contains 'databool'")
+        tdSql.checkRows(1)
+        tdSql.checkData(0, 1, 4)
+
+        tdSql.query("select * from jsons1 where jtag->'num' is not null or jtag contains 'class' and jtag contains 'databool' and jtag->'k1' match '中'  and  jtag->'location' like 'bei%'")
+        tdSql.checkRows(2)
+
+        tdSql.query("select * from jsons1 where datastr like '你就会' and ( jtag->'num' is not null or jtag contains 'tbname' and jtag contains 'databool' )")
+        tdSql.checkRows(1)
+        tdSql.checkData(0, 1, 4)
+
+        tdSql.error("select * from jsons1 where datastr like '你就会' and jtag->'num' is not null or jtag contains 'class' and jtag contains 'databool'")
+
+
+        tdSql.error("select * from jsons1 where datastr like '你就会' or jtag->'num' is not null or jtag contains 'class' and jtag contains 'databool' and jtag->'k1' match '中' or  jtag->'location' in ('beijing')  and  jtag->'location' like 'bei%' ")
+
+        tdSql.query("select * from jsons1 where datastr like '你就会' and (jtag->'num' is not null or jtag contains 'class' and jtag contains 'databool' and jtag->'k1' match '中' and  jtag->'location' like 'bei%' )")
+        tdSql.checkRows(0)
+      
+        tdSql.error("select *,tbname,jtag from  jsons1 where dataBool=true")
+
+        # test error
+        tdSql.error("CREATE TABLE if not exists  jsons1_13 using  jsons1 tags(3333)")
+        tdSql.execute("CREATE TABLE if not exists  jsons1_13 using  jsons1 tags('{\"1loc\":\"fff\",\";id\":5}')")
+        tdSql.error("CREATE TABLE if not exists  jsons1_13 using  jsons1 tags('{\"。loc\":\"fff\",\"fsd\":5}')")
+        tdSql.error("CREATE TABLE if not exists  jsons1_13 using  jsons1 tags('{\"试试\":\"fff\",\";id\":5}')")
+        tdSql.error("insert into  jsons1_13 using  jsons1 tags(3)")
+
+        # test  query  normal column,tag and tbname 
+        tdSql.execute("create stable if not exists  jsons3(ts timestamp, dataInt3 int, dataBool3  bool, dataStr3 nchar(50)) tags(jtag3 json)")
+        tdSql.execute("create table jsons3_2 using  jsons3 tags('{\"t\":true,\"t123\":123,\"\":\"true\"}')")
+        
+        tdSql.execute("create table jsons3_3 using  jsons3 tags('{\"t\":true,\"t123\":456,\"k1\":true,\"str1\":\"111\"}')")
+        tdSql.execute("insert into jsons3_3 values(now, 4, true, 'test')")
+
+        tdSql.execute("insert into jsons3_4 using  jsons3 tags('{\"t\":true,\"t123\":789,\"k1\":false,\"s\":null,\"str1\":\"112\"}')  values(now, 5, true, 'test')")
+        tdSql.query("select * from  jsons3 where jtag3->'k1'=true")
+        tdSql.checkRows(1)
+        tdSql.error("select  jtag3->k1 from  jsons3 ")
+        tdSql.error("select  jtag3 from  jsons3 where jtag3->'k1'")
+        tdSql.error("select  jtag3 from  jsons3 where jtag3 contains 'k1'=true")
+        tdSql.error("select  jtag3 contains 'k1' from  jsons3;")
+        tdSql.error("select  jtag3 contains 'k1'=true from  jsons3;")
+        tdSql.error("select  jtag3->'k1'=true from  jsons3;")
+        tdSql.execute("insert into jsons3_5 using  jsons3 tags('{\"t\":true,\"t123\":789,\"k1\":123,\"s\":null}')  values(now, 5, true, 'test')")
+        tdSql.execute("insert into jsons3_5 using  jsons3 tags('{\"t\":true,\"t123\":012,\"k2\":null,\"s\":null}')  values(now+1s, 5, true, 'test')")
+        tdSql.query("select jtag3 from  jsons3_5")
+        tdSql.checkData(0, 0, '{\"t\":true,\"t123\":789,\"k1\":123,\"s\":null}')        
+        tdSql.execute("insert into jsons3_6 using  jsons3 tags('{\"t\":true,\"t123\":789,\"k1\":false,\"s\":null}')  values(now, 5, true, 'test')")
+        tdSql.query("select jtag3 from jsons3 where jtag3->'t123'=12 or jtag3 contains 'k1'")
+        tdSql.checkRows(4)
+        tdSql.query("select distinct jtag3 from jsons3 where jtag3->'t123'=12 or jtag3 contains 'k1'")
+        tdSql.checkRows(4)
+
+
+        tdSql.execute("INSERT INTO  jsons1_14 using  jsons1 tags('{\"tbname\":\"tt\",\"location\":\"tianjing\",\"dataStr\":\"是是是\"}') values(now,5, \"你就会\")")
+
+        tdSql.query("select ts,jtag->'tbname',tbname from  jsons1 where dataint>=1 and jtag contains 'tbname'")
+        tdSql.checkRows(2)
+        tdSql.checkData(0, 1, '\"tt\"')
+
+        tdSql.query("select ts,jtag->'tbname',jtag->'location',tbname from  jsons1 where dataint between 1 and 5 and jtag->'location'='tianjing'")
+        tdSql.checkRows(1)
+        tdSql.checkData(0, 3, 'jsons1_14')
+
+        tdSql.query("select ts,jtag3->'tbname', jtag3->'str1',tbname from  jsons3 where jtag3->'t123'  between 456 and 789 and jtag3->'str1' like '11%' ")
+        tdSql.checkRows(2)
+        for i in range(1):
+            if tdSql.queryResult[i][1] == 'jsons3_3':
+                tdSql.checkData(i, 2, 111) 
+
+        tdSql.query("select  jtag3->'',dataint3 from  jsons3")
+        tdSql.checkRows(5)
+        for i in range(4):
+            if tdSql.queryResult[i][1] == 4:
+                tdSql.checkData(i, 0, None) 
+        tdSql.query("select tbname,dataint3,jtag3->'k1' from jsons3;")
+        tdSql.checkRows(5)
+        for i in range(4):
+            if tdSql.queryResult[i][1] == 4:
+                tdSql.checkData(i, 2, 'true') 
+
+        # Select_exprs is SQL function -Aggregation function  , tests includes group by and order by 
+ 
+        tdSql.query("select  avg(dataInt),count(dataint),sum(dataint) from jsons1 group by jtag->'location' order by jtag->'location';")
+        tdSql.checkData(2, 3, '\"tianjing\"')        
+        tdSql.checkRows(3)
+        for i in range(2):
+            if tdSql.queryResult[i][3] == 'beijing':
+                tdSql.checkData(i, 0, 1) 
+                tdSql.checkData(i, 1, 3) 
+        tdSql.error("select  avg(dataInt) as 123 ,count(dataint),sum(dataint)  from jsons1 group by jtag->'location' order by 123")
+        tdSql.error("select avg(dataInt) as avgdata ,count(dataint),sum(dataint)  from jsons1 group by jtag->'location' order by  avgdata ;")
+        tdSql.query("select  avg(dataInt),count(dataint),sum(dataint)   from jsons1 group by jtag->'location' order by ts;")
+        tdSql.checkRows(3)
+        tdSql.error("select  avg(dataInt),count(dataint),sum(dataint)   from jsons1 group by jtag->'age' order by tbname;")
+        #notice,it should return error ****
+        tdSql.error("select  avg(dataInt),count(dataint),sum(dataint)   from jsons1 group by jtag->'age' order by  jtag->'num' ;")
+        tdSql.query("select  avg(dataInt),count(dataint),sum(dataint)   from jsons1 group by jtag->'age' order by  jtag->'age' ;")
+        tdSql.checkRows(2)
+        tdSql.error("select  avg(dataInt)   from jsons1 group by jtag->'location' order by dataInt;")
+        tdSql.error("select  avg(dataInt),tbname   from jsons1 group by jtag->'location' order by tbname;")
+        tdSql.execute("CREATE TABLE if not exists  jsons1_15 using  jsons1 tags('{\"tbname\":\"tt\",\"location\":\"beijing\"}')")
+        tdSql.execute("insert into  jsons1_15 values(now+1s, 2, 'json1')")
+        tdSql.error("select twa(dataint) from jsons1 group by jtag->'location' order by jtag->'location';")
+        tdSql.error("select  irate(dataint) from jsons1 where jtag->'location' in ('beijing','tianjing') or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.query(" select stddev(dataint) from jsons1 group by jtag->'location';")
+        tdSql.checkRows(3)
+        tdSql.query(" select stddev(dataint) from jsons1  where  jtag->'location'='beijing';")
+        tdSql.checkRows(1)
+        tdSql.error(" select LEASTSQUARES(dataint,1,2) from jsons1_1 where  jtag->'location' ='beijing' ;")
+
+
+
+        # Select_exprs is SQL function -Selection function
+
+        tdSql.query(" select  min(dataint),jtag from jsons1 where jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing' or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)
+        tdSql.checkData(0, 0, 1)
+        tdSql.query(" select  max(dataint),jtag from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)
+        tdSql.checkData(0, 0, 12)
+        tdSql.query(" select  first(*) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)
+        tdSql.query(" select  last(*) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)
+        tdSql.error(" select  last(*),jtag from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.query(" select  last_row(*) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)
+        tdSql.query(" select  apercentile(dataint,0) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)
+        tdSql.query(" select  apercentile(dataint,50) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)     
+        tdSql.query(" select  apercentile(dataint,90) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)    
+        tdSql.query(" select  apercentile(dataint,100) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)   
+        tdSql.query(" select  apercentile(dataint,0,'t-digest') from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)
+        tdSql.query(" select  apercentile(dataint,50,'t-digest') from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1) 
+        tdSql.query(" select  apercentile(dataint,100,'t-digest') from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkRows(1)   
+        tdSql.query("select  top(dataint,1)  from jsons1 group by jtag->'location';")
+        tdSql.query("select  tbname,top(dataint,1)  from jsons1 group by jtag->'location' order by jtag->'location' asc;")
+        tdSql.query("select  tbname,top(dataint,1)  from jsons1 group by jtag->'location' order by jtag->'location'  desc;")
+        tdSql.query("select  top(dataint,1)  from jsons1 group by jtag->'location' order by  ts desc;")
+        tdSql.query("select  top(dataint,1)  from jsons1 group by jtag->'location' order by  ts asc;")
+        tdSql.query("select  top(dataint,100)  from jsons1 group by jtag->'location';")
+        tdSql.query("select  bottom(dataint,1)  from jsons1 group by jtag->'location';")
+        tdSql.query("select  bottom(dataint,100)  from jsons1 group by jtag->'location';")
+
+        tdSql.execute("create table if not exists jsons_interp(ts timestamp, dataInt int, dataBool bool, datafloat float, datadouble double,dataStr nchar(50)) tags(jtag json)")
+        tdSql.execute("insert into jsons_interp_1 using jsons_interp tags('{\"nv\":null,\"tea\":true,\"rate\":456,\"tea\":false}') values ('2021-07-25 02:19:54.119',2,'true',0.9,0.1,'123')")
+        tdSql.execute("insert into jsons_interp_1 values ('2021-07-25 02:19:54.219',3,'true',-4.8,-5.5,'123') ")
+        tdSql.execute("insert into jsons_interp_2 using jsons_interp tags('{\"nv\":null,\"tea\":true,\"level\":\"123456\",\"rate\":123,\"tea\":false}') values ('2021-07-25 02:19:54.319',4,'true',0.9,0.1,'123')")
+        tdSql.execute("insert into jsons_interp_2 values ('2021-07-25 02:19:54.419',5,'true',-5.1,1.3,'123') ")
+        tdSql.query("select  interp(dataint) as itd from jsons_interp where (jtag->'rate'=123 or jtag->'rate'=456)   and ts >= '2021-07-25 02:19:53.19' and ts<= '2021-07-25 02:19:54.519'  every(100a) group by tbname order by ts desc ;")
+        tdSql.checkRows(4)   
+        tdSql.checkData(0,1,3)
+        tdSql.checkData(2,1,5)
+
+        tdSql.query("select  interp(dataint) as itd from jsons_interp where (jtag->'rate'=123 or jtag->'rate'=456)   and ts >= '2021-07-25 02:19:53.19' and ts<= '2021-07-25 02:19:54.519'  every(100a) group by tbname order by tbname asc;")
+        tdSql.checkRows(4)   
+        tdSql.checkData(0,1,2)
+        tdSql.checkData(2,1,4)
+
+        #  Select_exprs is SQL function -Calculation  function
+        tdSql.error(" select  diff(dataint) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.error(" select  Derivative(dataint) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.query(" select  SPREAD(dataint) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.checkData(0, 0, 11) 
+        tdSql.query(" select  ceil(dataint) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.query(" select  floor(dataint) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        tdSql.query(" select  round(dataint) from jsons1 where  jtag->'location'= 'beijing' or  jtag->'location'= 'tianjing'or jtag contains 'num' or jtag->'age'=35 ;")
+        #need insert new data --data type is double or float and tests ceil floor round .
+        tdSql.execute("create table if not exists jsons7(ts timestamp, dataInt int, dataBool bool, datafloat float, datadouble double,dataStr nchar(50)) tags(jtag json)")
+        tdSql.execute("insert into jsons7_1 using jsons7 tags('{\"nv\":null,\"tea\":true,\"\":false,\" \":123,\"tea\":false}') values (now+2s,2,'true',0.9,0.1,'123')")
+        tdSql.execute("insert into jsons7_1 using jsons7 tags('{\"nv\":null,\"tea\":true,\"tea\":false}') values (now+3s,2,'true',0.9,0.1,'123')")
+        tdSql.query("select * from jsons7 where jtag->'tea'=0 ;")
+        tdSql.checkRows(0)
+        tdSql.query("select * from jsons7 where jtag->'tea'=3;")
+        # tdSql.checkRows(0)
+        tdSql.execute("insert into jsons7_1 values (now+1s,3,'true',-4.8,-5.5,'123') ")
+        tdSql.execute("insert into jsons7_1 values (now+2s,4,'true',1.9998,2.00001,'123') ")
+        tdSql.execute("insert into jsons7_2 using jsons7 tags('{\"nv\":null,\"tea\":true,\"\":false,\"tag\":123,\"tea\":false}') values (now,5,'true',4.01,2.2,'123') ")
+        tdSql.execute("insert into jsons7_2 using jsons7 tags('{\"nv\":null,\"tea\":true,\"tag\":123,\"tea\":false}') values (now+5s,5,'false',4.01,2.2,'123') ")
+        tdSql.execute("insert into jsons7_2 (ts,datadouble) values (now+3s,-0.9) ")
+        tdSql.execute("insert into jsons7_2 (ts,datadouble) values (now+4s,-2.9) ")
+        tdSql.execute("insert into jsons7_2 (ts,datafloat) values (now+1s,-0.9) ")
+        tdSql.execute("insert into jsons7_2 (ts,datafloat) values (now+2s,-1.9) ")
+        tdSql.execute("CREATE TABLE if not exists jsons7_3 using jsons7 tags('{\"nv\":null,\"tea\":true,\"\":false,\"tag\":4569,\"tea\":false}') ")
+        tdSql.query("select ts,ceil(dataint),ceil(datafloat),ceil(datadouble) from jsons7 where jtag contains 'tea';")
+        tdSql.query("select ceil(dataint),ceil(datafloat),ceil(datadouble) from jsons7 where jtag contains 'tea';")
+        tdSql.query("select ts,floor(dataint),floor(datafloat),floor(datadouble) from jsons7 where jtag contains 'tea';")
+        tdSql.query("select floor(dataint),floor(datafloat),floor(datadouble) from jsons7 where jtag contains 'tea';")
+        tdSql.query("select ts,round(dataint),round(datafloat),round(datadouble) from jsons7 where jtag contains 'tea';")
+        tdSql.query("select round(dataint),round(datafloat),round(datadouble) from jsons7 where jtag contains 'tea';")
+
+        #modify one same key and diffirent data type,include negative number of double  
+        tdSql.execute("insert into jsons7_4 using jsons7 tags('{\"nv\":null,\"tea\":123,\"tag\":123,\"tea\":false}') values (now+1s,5,'true',4.01,2.2,'abc'); ")
+        tdSql.execute("insert into jsons7_5 using jsons7 tags('{\"nv\":null,\"tea\":\"app\",\"tag\":123,\"tea\":false}') values (now+2s,5,'true',4.01,2.2,'abc'); ")
+        tdSql.error("insert into jsons7_6 using jsons7 tags('{\"nv\":null,\"tea\":-1.111111111111111111111111111111111111111111111111111111111111111111111,\"tag\":123,\"tea\":false}') values (now+3s,5,'true',4.01,2.2,'123'); ")
+        tdSql.execute("insert into jsons7_6 using jsons7 tags('{\"nv\":null,\"tea\":-1.111111111,\"tag\":123,\"tea\":false}') values (now,5,'false',4.01,2.2,'t123'); ")
+        tdSql.query("select  jtag from jsons7 where jtag->'tea'>-1.01;")
+        # tdSql.checkRows(2)   
+        
+        # test join
+        tdSql.execute("create table if not exists jsons6(ts timestamp, dataInt int, dataBool bool, dataStr nchar(50)) tags(jtag json)")
+        tdSql.execute("create table if not exists jsons5(ts timestamp, dataInt int, dataBool bool, dataStr nchar(50)) tags(jtag json)")
+        tdSql.execute("CREATE TABLE if not exists jsons6_1 using jsons6 tags('{\"loc\":\"fff\",\"id\":6,\"user\":\"ffc\"}')")
+        tdSql.execute("CREATE TABLE if not exists jsons6_2 using jsons6 tags('{\"loc\":\"ffc\",\"id\":5}')")
+        tdSql.execute("insert into jsons6_1 values ('2020-04-18 15:00:00.000', 1, false, 'json1')")
+        tdSql.execute("insert into jsons6_2 values ('2020-04-18 15:00:01.000', 2, false, 'json1')")
+        tdSql.execute("insert into jsons5_1 using jsons5 tags('{\"loc\":\"fff\",\"num\":5,\"location\":\"beijing\"}') values ('2020-04-18 15:00:00.000', 2, true, 'json2')")
+        tdSql.execute("insert into jsons5_2 using jsons5 tags('{\"loc\":\"fff\",\"id\":5,\"location\":\"beijing\"}') values ('2020-04-18 15:00:01.000', 2, true, 'json2')")
+        tdSql.error("select 'sss',33,a.jtag->'loc' from jsons6 a,jsons5 b where a.ts=b.ts and a.jtag->'loc'=b.jtag->'loc'")
+        tdSql.error("select 'sss',33,a.jtag->'loc' from jsons6 a,jsons5 b where a.ts=b.ts and a.jtag->'user'=b.jtag->'loc';")
+        tdSql.query("select 'sss',33,a.jtag->'loc' from jsons6 a,jsons5 b where a.ts=b.ts and a.jtag->'id'=b.jtag->'id'")
+        tdSql.checkData(0, 0, "sss")
+        tdSql.checkData(0, 2, "\"ffc\"")
+
+
+
+        # #nested query 
+        tdSql.error("select jtag->'tag' from (select tbname,jtag,ts,ceil(dataint) as cdata,ceil(datafloat) ,ceil(datadouble) from jsons7 where jtag contains 'tea') where cdata=3 ") # not currently supported
+        tdSql.error("select jtag from (select tbname,jtag,ts,ceil(dataint) as cdata,ceil(datafloat) ,ceil(datadouble) from jsons7 where jtag contains 'tea') where jtag->'tag'=123 ")  # not currently supported
+        tdSql.query("select * from (select tbname,jtag->'tea',ts,ceil(dataint) as cdata,ceil(datafloat) ,ceil(datadouble) from jsons7 where jtag contains 'tea') where cdata=5 ")
+        tdSql.checkRows(5)
+        for i in range(5):
+            if tdSql.queryResult[i][0] == 'jsons7_4':
+                tdSql.checkData(i, 1, 123) 
+                tdSql.checkData(i, 3, 5) 
+            if tdSql.queryResult[i][0] == 'jsons7_5':
+                tdSql.checkData(i, 1, "\"app\"") 
+
+        # query  child table 
+        tdSql.error("select * from  jsons3_2 where jtag3->'k1'=true;")
+        # tdSql.checkData(0, 0, None)
+        # tdSql.checkRows(3)
+
+        # union all :max times is 100
+        unioSql = "select ts,jtag->'tbname',jtag->'location',tbname from  jsons1 where dataint between 1 and 5 and jtag->'location'='tianjing' union all "
+        for i in range(99):
+            if (i < 98):
+                unioSql +=  "select ts,jtag->'tbname',jtag->'location',tbname from  jsons1 where dataint between 1 and 5 and jtag->'location'='tianjing' union all "
+            else:
+                print(i)                
+                unioSql +=  " select ts,jtag->'tbname',jtag->'location',tbname from  jsons1 where dataint between 1 and 5 and jtag->'location'='tianjing'"
+        tdSql.query(unioSql)
+        tdSql.checkRows(100)
+        unioSql +=  " union all   select ts,jtag->'tbname',jtag->'location',tbname from  jsons1 where dataint between 1 and 5 and jtag->'location'='tianjing'"
+        tdSql.error(unioSql)
+
+        
+
+        # fuction testcase : stddev, supported data type: int\str\bool unsupported data type: float\double
+        tdSql.query(" select stddev(datafloat),dataint from jsons7 group by dataint;")
+        tdSql.checkRows(5)
+        tdSql.query(" select stddev(dataint) from jsons7 group by datastr;")
+        tdSql.checkRows(4)
+        tdSql.query(" select stddev(dataint) from jsons7 group by databool;")
+        tdSql.checkRows(3)
+        tdSql.error(" select stddev(dataint) from jsons7 group by datafloat;")
+        tdSql.error(" select stddev(dataint) from jsons7 group by datadouble;")
+        tdSql.execute("create table if not exists jsons8(ts timestamp, dataInt int, dataBool bool, datafloat float, datadouble double,dataStr nchar(50),datatime timestamp) tags(jtag json)")
+        tdSql.execute("insert into jsons8_1 using jsons8 tags('{\"nv\":null,\"tea\":true,\"\":false,\" \":123,\"tea\":false}') values (now,2,'true',0.9,0.1,'abc',now+60s)")
+        tdSql.execute("insert into jsons8_2 using jsons8 tags('{\"nv\":null,\"tea\":true,\"\":false,\" \":123,\"tea\":false}') values (now+5s,2,'true',0.9,0.1,'abc',now+65s)")
+        tdSql.query(" select stddev(dataint) from jsons8 group by datatime;")
+        tdSql.error(" select stddev(datatime) from jsons8 group by datadouble;")
+
+
+        # # test drop tables and databases
+        # tdSql.execute("drop table jsons1_1")
+        # tdSql.execute("drop stable jsons1")
+        # tdSql.execute("drop stable jsons3")
+        # tdSql.execute("drop stable jsons2")
+        # tdSql.execute("drop database db_json")
+
+
+
+    def stop(self):
+        tdSql.close()
+        tdLog.success("%s successfully executed" % __file__)
+
+
+tdCases.addWindows(__file__, TDTestCase())
+tdCases.addLinux(__file__, TDTestCase())

tests/pytest/tools/taosdemoAllTest/insert-1s1tntmr.json

@@ -41,7 +41,7 @@
             "batch_create_tbl_num": 10,
             "data_source": "rand",
             "insert_mode": "taosc",
-            "insert_rows": 10000,
+            "insert_rows": 100,
             "childtable_limit": 0,
             "childtable_offset":0,
             "multi_thread_write_one_tbl": "no",
@@ -67,7 +67,7 @@
             "batch_create_tbl_num": 10,
             "data_source": "rand",
             "insert_mode": "taosc",
-            "insert_rows": 20000,
+            "insert_rows": 200,
             "childtable_limit": 0,
             "childtable_offset":0,
             "multi_thread_write_one_tbl": "no",

tests/pytest/tools/taosdemoAllTest/insert-chinese.json

+{
+    "filetype": "insert",
+    "cfgdir": "/etc/taos",
+    "host": "127.0.0.1",
+    "port": 6030,
+    "user": "root",
+    "password": "taosdata",
+    "thread_count": 4,
+    "thread_count_create_tbl": 4,
+    "result_file": "./insert_res.txt",
+    "confirm_parameter_prompt": "no",
+    "insert_interval": 0,
+    "interlace_rows": 100,
+    "num_of_records_per_req": 1000,
+    "max_sql_len": 1024000,
+    "chinese": "yes",
+    "databases": [{
+        "dbinfo": {
+            "name": "db",
+            "drop": "yes",
+            "replica": 1,
+            "days": 10,
+            "cache": 50,
+            "blocks": 8,
+            "precision": "ms",
+            "keep": 36500,
+            "minRows": 100,
+            "maxRows": 4096,
+            "comp":2,
+            "walLevel":1,
+            "cachelast":0,
+            "quorum":1,
+            "fsync":3000,
+            "update": 0
+        },
+        "super_tables": [{
+            "name": "stb0",
+            "child_table_exists":"no",
+            "childtable_count": 10,
+            "childtable_prefix": "stb00_",  
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 20,
+            "data_source": "rand",
+            "insert_mode": "taosc",
+            "insert_rows": 150,
+            "childtable_limit": -1,
+            "childtable_offset":0,
+            "multi_thread_write_one_tbl": "no",
+            "interlace_rows": 0,
+            "insert_interval":0,
+            "max_sql_len": 1024000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2020-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "INT"}, {"type": "DOUBLE", "count":1}, {"type": "BINARY", "len": 16, "count":2}, {"type": "nchar", "len": 32, "count":2}],
+            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY","count":1}, {"type": "nchar", "count":2}]
+        }]
+    }]
+}

tests/pytest/tools/taosdemoAllTest/insert-drop-exist-auto-N00.json

@@ -32,7 +32,7 @@
             "update": 0
         },
         "super_tables": [{
-            "name": "stb",
+            "name": "stb1",
             "child_table_exists":"no",
             "auto_create_table": "123",   
             "childtable_count": 20,   
@@ -56,7 +56,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb2",
             "child_table_exists":"no",
             "auto_create_table": "no",   
             "childtable_count": 20,   
@@ -80,7 +80,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb3",
             "child_table_exists":"no",
             "auto_create_table": "yes",   
             "childtable_count": 20,   
@@ -104,7 +104,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb4",
             "child_table_exists":"yes",
             "auto_create_table": "123",   
             "childtable_count": 20,   
@@ -128,7 +128,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb5",
             "child_table_exists":"yes",
             "auto_create_table": "no",   
             "childtable_count": 20,   
@@ -152,7 +152,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb6",
             "child_table_exists":"yes",
             "auto_create_table": "yes",   
             "childtable_count": 20,   

tests/pytest/tools/taosdemoAllTest/insert-drop-exist-auto-Y00.json

@@ -32,7 +32,7 @@
             "update": 0
         },
         "super_tables": [{
-            "name": "stb",
+            "name": "stb1",
             "child_table_exists":"no",
             "auto_create_table": "123",   
             "childtable_count": 20,   
@@ -56,7 +56,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb2",
             "child_table_exists":"no",
             "auto_create_table": "no",   
             "childtable_count": 20,   
@@ -80,7 +80,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb3",
             "child_table_exists":"no",
             "auto_create_table": "yes",   
             "childtable_count": 20,   
@@ -104,7 +104,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb4",
             "child_table_exists":"yes",
             "auto_create_table": "123",   
             "childtable_count": 20,   
@@ -128,7 +128,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb5",
             "child_table_exists":"yes",
             "auto_create_table": "no",   
             "childtable_count": 20,   
@@ -152,7 +152,7 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb6",
             "child_table_exists":"yes",
             "auto_create_table": "yes",   
             "childtable_count": 20,   

tests/pytest/tools/taosdemoAllTest/insert-interval-speed.json

@@ -35,13 +35,13 @@
         "super_tables": [{
             "name": "stb0",
             "child_table_exists":"no",
-            "childtable_count": 100,
+            "childtable_count": 10,
             "childtable_prefix": "stb00_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 10,
             "data_source": "rand",
             "insert_mode": "taosc",
-            "insert_rows": 20000,
+            "insert_rows": 200,
             "childtable_limit": 0,
             "childtable_offset":0,
             "multi_thread_write_one_tbl": "no",
@@ -61,13 +61,13 @@
         {
             "name": "stb1",
             "child_table_exists":"no",
-            "childtable_count": 100,
+            "childtable_count": 20,
             "childtable_prefix": "stb01_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 10,
             "data_source": "rand",
             "insert_mode": "taosc",
-            "insert_rows": 20000,
+            "insert_rows": 200,
             "childtable_limit": 0,
             "childtable_offset":0,
             "multi_thread_write_one_tbl": "no",

tests/pytest/tools/taosdemoAllTest/insertBinaryLenLarge16374AllcolLar49151-error.json

+{
+    "filetype": "insert",
+    "cfgdir": "/etc/taos",
+    "host": "127.0.0.1",
+    "port": 6030,
+    "user": "root",
+    "password": "taosdata",
+    "thread_count": 4,
+    "thread_count_create_tbl": 4,
+    "result_file": "./insert_res.txt",
+    "confirm_parameter_prompt": "no",
+    "insert_interval": 0,
+    "interlace_rows": 10,
+    "num_of_records_per_req": 10240000000,
+    "max_sql_len": 10240000000, 
+    "databases": [{
+        "dbinfo": {
+            "name": "db",
+            "drop": "yes",
+            "replica": 1,
+            "days": 10,
+            "cache": 50,
+            "blocks": 8,
+            "precision": "ms",
+            "keep": 36500,
+            "minRows": 100,
+            "maxRows": 4096,
+            "comp":2,
+            "walLevel":1,
+            "cachelast":0,
+            "quorum":1,
+            "fsync":3000,
+            "update": 0
+        },
+        "super_tables": [{
+            "name": "stb2",
+            "child_table_exists":"no",
+            "childtable_count": 1,
+            "childtable_prefix": "stb02_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 12,
+            "data_source": "rand",
+            "insert_mode": "taosc",
+            "insert_rows": 1,
+            "childtable_limit": 0,
+            "childtable_offset":0,
+            "multi_thread_write_one_tbl": "no",
+            "interlace_rows": 0,
+            "insert_interval":0,
+            "max_sql_len": 1024000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2020-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "BINARY", "len": 16375, "count":1},{"type": "INT"}],
+            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
+        },
+        {
+            "name": "stb4",
+            "child_table_exists":"no",
+            "childtable_count": 1,
+            "childtable_prefix": "stb04_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 12,
+            "data_source": "rand",
+            "insert_mode": "taosc",
+            "insert_rows": 1,
+            "childtable_limit": 0,
+            "childtable_offset":0,
+            "multi_thread_write_one_tbl": "no",
+            "interlace_rows": 100,
+            "insert_interval":0,
+            "max_sql_len": 1024000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2020-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6},{"type": "TINYINT"}],
+            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
+        }]
+    }]
+}

tests/pytest/tools/taosdemoAllTest/insertBinaryLenLarge16374AllcolLar49151.json

@@ -109,58 +109,6 @@
             "tags_file": "",
             "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6}], 
             "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
-        },
-        {
-            "name": "stb2",
-            "child_table_exists":"no",
-            "childtable_count": 1,
-            "childtable_prefix": "stb02_",
-            "auto_create_table": "no",
-            "batch_create_tbl_num": 12,
-            "data_source": "rand",
-            "insert_mode": "taosc",
-            "insert_rows": 1,
-            "childtable_limit": 0,
-            "childtable_offset":0,
-            "multi_thread_write_one_tbl": "no",
-            "interlace_rows": 0,
-            "insert_interval":0,
-            "max_sql_len": 1024000,
-            "disorder_ratio": 0,
-            "disorder_range": 1000,
-            "timestamp_step": 1,
-            "start_timestamp": "2020-10-01 00:00:00.000",
-            "sample_format": "csv",
-            "sample_file": "./sample.csv",
-            "tags_file": "",
-            "columns": [{"type": "BINARY", "len": 16375, "count":1},{"type": "INT"}],
-            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
-        },
-        {
-            "name": "stb4",
-            "child_table_exists":"no",
-            "childtable_count": 1,
-            "childtable_prefix": "stb04_",
-            "auto_create_table": "no",
-            "batch_create_tbl_num": 12,
-            "data_source": "rand",
-            "insert_mode": "taosc",
-            "insert_rows": 1,
-            "childtable_limit": 0,
-            "childtable_offset":0,
-            "multi_thread_write_one_tbl": "no",
-            "interlace_rows": 100,
-            "insert_interval":0,
-            "max_sql_len": 1024000,
-            "disorder_ratio": 0,
-            "disorder_range": 1000,
-            "timestamp_step": 1,
-            "start_timestamp": "2020-10-01 00:00:00.000",
-            "sample_format": "csv",
-            "sample_file": "./sample.csv",
-            "tags_file": "",
-            "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6},{"type": "TINYINT"}],
-            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
         }]
     }]
 }

tests/pytest/tools/taosdemoAllTest/insertColumnsAndTagNum4096.json

@@ -55,7 +55,7 @@
             "sample_format": "csv",
             "sample_file": "./sample.csv",
             "tags_file": "",
-            "columns": [{"type": "INT"}, {"type": "DOUBLE", "count":1004}, {"type": "BINARY", "len": 5, "count":3075}, {"type": "BINARY", "len": 32, "count":6}],
+            "columns": [{"type": "INT"}, {"type": "DOUBLE", "count":1004}, {"type": "BINARY", "len": 1, "count":3075}, {"type": "BINARY", "len": 32, "count":6}],
             "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":7}]
         }]
     }]

tests/pytest/tools/taosdemoAllTest/querySuperMutisql100.json

@@ -11,7 +11,7 @@
     "super_table_query": {
         "stblname": "stb0",
         "query_interval": 10000,
-        "concurrent": 9,
+        "threads": 9,
         "sqls": [
           {    
               "sql": "select last_row(*) from xxxx",

tests/pytest/tools/taosdemoAllTest/sml/insert-allDataType-sml.json

@@ -35,7 +35,7 @@
         "super_tables": [{
             "name": "stb0",
             "child_table_exists":"no",
-            "childtable_count": 1000,
+            "childtable_count": 10,
             "childtable_prefix": "stb00_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 1,
@@ -55,13 +55,13 @@
             "sample_format": "csv",
             "sample_file": "./sample.csv",
             "tags_file": "",
-            "columns": [{"type": "INT"}, {"type": "TIMESTAMP"}, {"type": "BIGINT"}, {"type": "FLOAT"}, {"type": "DOUBLE"}, {"type": "SMALLINT"}, {"type": "TINYINT"}, {"type": "BOOL"}, {"type": "NCHAR","len": 16, "count":1}, {"type": "UINT"}, {"type": "UBIGINT"}, {"type": "UTINYINT"}, {"type": "USMALLINT"}, {"type": "BINARY", "len": 16, "count":1}],
+            "columns": [{"type": "INT"}, {"type": "BIGINT"}, {"type": "FLOAT"}, {"type": "DOUBLE"}, {"type": "SMALLINT"}, {"type": "TINYINT"}, {"type": "BOOL"}, {"type": "NCHAR","len": 16, "count":1}, {"type": "UINT"}, {"type": "UBIGINT"}, {"type": "UTINYINT"}, {"type": "USMALLINT"}, {"type": "BINARY", "len": 16, "count":1}],
             "tags": [{"type": "INT"}, {"type": "BIGINT"}, {"type": "FLOAT"}, {"type": "DOUBLE"}, {"type": "SMALLINT"}, {"type": "TINYINT"}, {"type": "BOOL"}, {"type": "NCHAR","len": 16, "count":1}, {"type": "UINT"}, {"type": "UBIGINT"}, {"type": "UTINYINT"}, {"type": "USMALLINT"}, {"type": "BINARY", "len": 16, "count":1}]
         },
         {
             "name": "stb1",
             "child_table_exists":"no",
-            "childtable_count": 1000,
+            "childtable_count": 20,
             "childtable_prefix": "stb01_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 10,

tests/pytest/tools/taosdemoAllTest/sml/insert-sml-json-alltype.json

@@ -35,14 +35,14 @@
         "super_tables": [{
             "name": "stb0",
             "child_table_exists":"no",
-            "childtable_count": 2,
+            "childtable_count": 1,
             "childtable_prefix": "stb00_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml", 
             "line_protocol": "json" ,
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 0,
@@ -59,16 +59,16 @@
             "tags": [{"type": "INT", "count":1}]
         },
         {
-            "name": "stb2",
+            "name": "stb1",
             "child_table_exists":"no",
-            "childtable_count": 4,
+            "childtable_count": 2,
             "childtable_prefix": "stb02_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "json" , 
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -265,6 +265,84 @@
             "tags_file": "",
             "columns": [{"type": "BINARY", "len": 16, "count":1}],
             "tags": [{"type": "BINARY", "count":1}]
+        },
+        {
+            "name": "stb10",
+            "child_table_exists":"no",
+            "childtable_count": 3,
+            "childtable_prefix": "stb10_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 100,
+            "data_source": "rand",
+            "insert_mode": "sml",
+            "line_protocol": "telnet" , 
+            "insert_rows":50,
+            "childtable_limit": -1,
+            "childtable_offset":0,
+            "interlace_rows": 32767,
+            "insert_interval":0,
+            "max_sql_len": 1025000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2012-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "UBIGINT"}],
+            "tags": [{"type": "UBIGINT", "count":1}]
+        },
+        {
+            "name": "stb11",
+            "child_table_exists":"no",
+            "childtable_count": 3,
+            "childtable_prefix": "stb11_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 100,
+            "data_source": "rand",
+            "insert_mode": "sml",
+            "line_protocol": "telnet" , 
+            "insert_rows":50,
+            "childtable_limit": -1,
+            "childtable_offset":0,
+            "interlace_rows": 32767,
+            "insert_interval":0,
+            "max_sql_len": 1025000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2012-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "UTINYINT"}],
+            "tags": [{"type": "UTINYINT", "count":1}]
+        },
+        {
+            "name": "stb12",
+            "child_table_exists":"no",
+            "childtable_count": 3,
+            "childtable_prefix": "stb12_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 100,
+            "data_source": "rand",
+            "insert_mode": "sml",
+            "line_protocol": "telnet" , 
+            "insert_rows":50,
+            "childtable_limit": -1,
+            "childtable_offset":0,
+            "interlace_rows": 32767,
+            "insert_interval":0,
+            "max_sql_len": 1025000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2012-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [ {"type": "USMALLINT"}],
+            "tags": [{"type": "USMALLINT", "count":1}]
         }]
     }]
 }

tests/pytest/tools/taosdemoAllTest/sml/insert-sml-telnet-alltype.json

@@ -35,14 +35,14 @@
         "super_tables": [{
             "name": "stb0",
             "child_table_exists":"no",
-            "childtable_count": 2,
+            "childtable_count": 1,
             "childtable_prefix": "stb00_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml", 
             "line_protocol": "telnet" ,
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 0,
@@ -61,14 +61,14 @@
         {
             "name": "stb1",
             "child_table_exists":"no",
-            "childtable_count": 3,
+            "childtable_count": 2,
             "childtable_prefix": "stb01_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -87,14 +87,14 @@
         {
             "name": "stb2",
             "child_table_exists":"no",
-            "childtable_count": 4,
+            "childtable_count": 3,
             "childtable_prefix": "stb02_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -113,14 +113,14 @@
         {
             "name": "stb3",
             "child_table_exists":"no",
-            "childtable_count": 5,
+            "childtable_count": 4,
             "childtable_prefix": "stb03_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -139,14 +139,14 @@
         {
             "name": "stb4",
             "child_table_exists":"no",
-            "childtable_count": 6,
+            "childtable_count": 5,
             "childtable_prefix": "stb04_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":30,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -165,14 +165,14 @@
         {
             "name": "stb5",
             "child_table_exists":"no",
-            "childtable_count": 15,
+            "childtable_count": 6,
             "childtable_prefix": "stb05_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":20,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -191,7 +191,7 @@
         {
             "name": "stb6",
             "child_table_exists":"no",
-            "childtable_count": 20,
+            "childtable_count": 7,
             "childtable_prefix": "stb06_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
@@ -217,14 +217,14 @@
         {
             "name": "stb7",
             "child_table_exists":"no",
-            "childtable_count": 30,
+            "childtable_count": 8 ,
             "childtable_prefix": "stb07_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":5,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -243,14 +243,14 @@
         {
             "name": "stb8",
             "child_table_exists":"no",
-            "childtable_count": 20,
+            "childtable_count": 9,
             "childtable_prefix": "stb08_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":30,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -269,14 +269,14 @@
         {
             "name": "stb9",
             "child_table_exists":"no",
-            "childtable_count": 3,
+            "childtable_count": 10,
             "childtable_prefix": "stb09_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -295,14 +295,14 @@
         {
             "name": "stb10",
             "child_table_exists":"no",
-            "childtable_count": 3,
+            "childtable_count": 11,
             "childtable_prefix": "stb10_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -321,14 +321,14 @@
         {
             "name": "stb11",
             "child_table_exists":"no",
-            "childtable_count": 3,
+            "childtable_count": 12,
             "childtable_prefix": "stb11_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,
@@ -347,14 +347,14 @@
         {
             "name": "stb12",
             "child_table_exists":"no",
-            "childtable_count": 3,
+            "childtable_count": 13,
             "childtable_prefix": "stb12_",
             "auto_create_table": "no",
             "batch_create_tbl_num": 100,
             "data_source": "rand",
             "insert_mode": "sml",
             "line_protocol": "telnet" , 
-            "insert_rows":50,
+            "insert_rows":10,
             "childtable_limit": -1,
             "childtable_offset":0,
             "interlace_rows": 32767,

tests/pytest/tools/taosdemoAllTest/sml/insert-sml-timestamp.json

+{
+    "filetype": "insert",
+    "cfgdir": "/etc/taos",
+    "host": "127.0.0.1",
+    "port": 6030,
+    "user": "root",
+    "password": "taosdata",
+    "thread_count": 4,
+    "thread_count_create_tbl": 4,
+    "result_file": "./insert_res.txt",
+    "confirm_parameter_prompt": "no",
+    "insert_interval": 0,
+    "interlace_rows": 50000,
+    "num_of_records_per_req": 50000,
+    "max_sql_len": 1025000, 
+    "databases": [{
+        "dbinfo": {
+            "name": "db",
+            "drop": "yes",
+            "replica": 1,
+            "days": 10,
+            "cache": 50,
+            "blocks": 8,
+            "precision": "ms",
+            "keep": 36500,
+            "minRows": 100,
+            "maxRows": 4096,
+            "comp":2,
+            "walLevel":1,
+            "cachelast":0,
+            "quorum":1,
+            "fsync":3000,
+            "update": 0
+        },
+        "super_tables": [{
+            "name": "stb0",
+            "child_table_exists":"no",
+            "childtable_count": 3,
+            "childtable_prefix": "stb12_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 100,
+            "data_source": "rand",
+            "insert_mode": "sml",
+            "insert_rows":50,
+            "childtable_limit": -1,
+            "childtable_offset":0,
+            "interlace_rows": 32767,
+            "insert_interval":0,
+            "max_sql_len": 1025000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2012-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [ {"type": "TIMESTAMP"}],
+            "tags": [{"type": "TIMESTAMP", "count":1}]
+        },
+        {
+            "name": "stb1",
+            "child_table_exists":"no",
+            "childtable_count": 3,
+            "childtable_prefix": "stb12_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 100,
+            "data_source": "rand",
+            "insert_mode": "sml",
+            "line_protocol": "telnet" , 
+            "insert_rows":50,
+            "childtable_limit": -1,
+            "childtable_offset":0,
+            "interlace_rows": 32767,
+            "insert_interval":0,
+            "max_sql_len": 1025000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2012-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [ {"type": "TIMESTAMP"}],
+            "tags": [{"type": "TIMESTAMP", "count":1}]
+        },
+        {
+            "name": "stb2",
+            "child_table_exists":"no",
+            "childtable_count": 3,
+            "childtable_prefix": "stb12_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 100,
+            "data_source": "rand",
+            "insert_mode": "sml",
+            "line_protocol": "json" , 
+            "insert_rows":50,
+            "childtable_limit": -1,
+            "childtable_offset":0,
+            "interlace_rows": 32767,
+            "insert_interval":0,
+            "max_sql_len": 1025000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2012-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [ {"type": "TIMESTAMP"}],
+            "tags": [{"type": "TIMESTAMP", "count":1}]
+        }]
+    }]
+}

tests/pytest/tools/taosdemoAllTest/sml/insertBinaryLenLarge16374AllcolLar49151-error-sml.json

+{
+    "filetype": "insert",
+    "cfgdir": "/etc/taos",
+    "host": "127.0.0.1",
+    "port": 6030,
+    "user": "root",
+    "password": "taosdata",
+    "thread_count": 4,
+    "thread_count_create_tbl": 4,
+    "result_file": "./insert_res.txt",
+    "confirm_parameter_prompt": "no",
+    "insert_interval": 0,
+    "interlace_rows": 10,
+    "num_of_records_per_req": 10240000000,
+    "max_sql_len": 10240000000, 
+    "databases": [{
+        "dbinfo": {
+            "name": "db",
+            "drop": "yes",
+            "replica": 1,
+            "days": 10,
+            "cache": 50,
+            "blocks": 8,
+            "precision": "ms",
+            "keep": 36500,
+            "minRows": 100,
+            "maxRows": 4096,
+            "comp":2,
+            "walLevel":1,
+            "cachelast":0,
+            "quorum":1,
+            "fsync":3000,
+            "update": 0
+        },
+        "super_tables": [{
+            "name": "stb2",
+            "child_table_exists":"no",
+            "childtable_count": 1,
+            "childtable_prefix": "stb02_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 12,
+            "data_source": "rand",
+            "insert_mode": "sml", 
+            "insert_rows": 1,
+            "childtable_limit": 0,
+            "childtable_offset":0,
+            "multi_thread_write_one_tbl": "no",
+            "interlace_rows": 0,
+            "insert_interval":0,
+            "max_sql_len": 1024000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2020-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "BINARY", "len": 16375, "count":1},{"type": "INT"}],
+            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
+        },
+        {
+            "name": "stb4",
+            "child_table_exists":"no",
+            "childtable_count": 1,
+            "childtable_prefix": "stb04_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 12,
+            "data_source": "rand",
+            "insert_mode": "sml", 
+            "insert_rows": 1,
+            "childtable_limit": 0,
+            "childtable_offset":0,
+            "multi_thread_write_one_tbl": "no",
+            "interlace_rows": 100,
+            "insert_interval":0,
+            "max_sql_len": 1024000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2020-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6},{"type": "TINYINT"}],
+            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
+        }]
+    }]
+}

tests/pytest/tools/taosdemoAllTest/sml/insertBinaryLenLarge16374AllcolLar49151-sml.json

@@ -109,58 +109,6 @@
             "tags_file": "",
             "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6}], 
             "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
-        },
-        {
-            "name": "stb2",
-            "child_table_exists":"no",
-            "childtable_count": 1,
-            "childtable_prefix": "stb02_",
-            "auto_create_table": "no",
-            "batch_create_tbl_num": 12,
-            "data_source": "rand",
-            "insert_mode": "sml", 
-            "insert_rows": 1,
-            "childtable_limit": 0,
-            "childtable_offset":0,
-            "multi_thread_write_one_tbl": "no",
-            "interlace_rows": 0,
-            "insert_interval":0,
-            "max_sql_len": 1024000,
-            "disorder_ratio": 0,
-            "disorder_range": 1000,
-            "timestamp_step": 1,
-            "start_timestamp": "2020-10-01 00:00:00.000",
-            "sample_format": "csv",
-            "sample_file": "./sample.csv",
-            "tags_file": "",
-            "columns": [{"type": "BINARY", "len": 16375, "count":1},{"type": "INT"}],
-            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
-        },
-        {
-            "name": "stb4",
-            "child_table_exists":"no",
-            "childtable_count": 1,
-            "childtable_prefix": "stb04_",
-            "auto_create_table": "no",
-            "batch_create_tbl_num": 12,
-            "data_source": "rand",
-            "insert_mode": "sml", 
-            "insert_rows": 1,
-            "childtable_limit": 0,
-            "childtable_offset":0,
-            "multi_thread_write_one_tbl": "no",
-            "interlace_rows": 100,
-            "insert_interval":0,
-            "max_sql_len": 1024000,
-            "disorder_ratio": 0,
-            "disorder_range": 1000,
-            "timestamp_step": 1,
-            "start_timestamp": "2020-10-01 00:00:00.000",
-            "sample_format": "csv",
-            "sample_file": "./sample.csv",
-            "tags_file": "",
-            "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6},{"type": "TINYINT"}],
-            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
         }]
     }]
 }

tests/pytest/tools/taosdemoAllTest/stmt/insert-drop-exist-auto-N00-stmt.json

@@ -32,14 +32,14 @@
             "update": 0
         },
         "super_tables": [{
-            "name": "stb",
+            "name": "stb1",
             "child_table_exists":"no",
             "auto_create_table": "123",   
             "childtable_count": 20,   
             "childtable_prefix": "NN123_",    
             "batch_create_tbl_num": 100,   
-            "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "data_source": "stmt",       
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -56,14 +56,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb2",
             "child_table_exists":"no",
             "auto_create_table": "no",   
             "childtable_count": 20,   
             "childtable_prefix": "NNN_",    
             "batch_create_tbl_num": 100,   
-            "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "data_source": "stmt",       
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -80,14 +80,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb3",
             "child_table_exists":"no",
             "auto_create_table": "yes",   
             "childtable_count": 20,   
             "childtable_prefix": "NNY_",    
             "batch_create_tbl_num": 100,   
-            "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "data_source": "stmt",       
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -104,14 +104,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb4",
             "child_table_exists":"yes",
             "auto_create_table": "123",   
             "childtable_count": 20,   
             "childtable_prefix": "NY123_",    
             "batch_create_tbl_num": 100,   
-            "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "data_source": "stmt",       
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -128,14 +128,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb5",
             "child_table_exists":"yes",
             "auto_create_table": "no",   
             "childtable_count": 20,   
             "childtable_prefix": "NYN_",    
             "batch_create_tbl_num": 100,   
-            "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "data_source": "stmt",       
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -152,14 +152,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb6",
             "child_table_exists":"yes",
             "auto_create_table": "yes",   
             "childtable_count": 20,   
             "childtable_prefix": "NYY_",    
             "batch_create_tbl_num": 100,   
-            "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "data_source": "stmt",       
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     

tests/pytest/tools/taosdemoAllTest/stmt/insert-drop-exist-auto-Y00-stmt.json

@@ -32,14 +32,14 @@
             "update": 0
         },
         "super_tables": [{
-            "name": "stb",
+            "name": "stb1",
             "child_table_exists":"no",
             "auto_create_table": "123",   
             "childtable_count": 20,   
             "childtable_prefix": "YN123_",    
             "batch_create_tbl_num": 100,   
             "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -56,14 +56,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb2",
             "child_table_exists":"no",
             "auto_create_table": "no",   
             "childtable_count": 20,   
             "childtable_prefix": "YNN_",    
             "batch_create_tbl_num": 100,   
             "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -80,14 +80,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb3",
             "child_table_exists":"no",
             "auto_create_table": "yes",   
             "childtable_count": 20,   
             "childtable_prefix": "YNY_",    
             "batch_create_tbl_num": 100,   
             "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -104,14 +104,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb4",
             "child_table_exists":"yes",
             "auto_create_table": "123",   
             "childtable_count": 20,   
             "childtable_prefix": "YY123_",    
             "batch_create_tbl_num": 100,   
             "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -128,14 +128,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb5",
             "child_table_exists":"yes",
             "auto_create_table": "no",   
             "childtable_count": 20,   
             "childtable_prefix": "YYN_",    
             "batch_create_tbl_num": 100,   
             "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     
@@ -152,14 +152,14 @@
             "columns": [{"type": "INT"}],
             "tags": [{"type": "TINYINT"}]
         },{
-            "name": "stb",
+            "name": "stb6",
             "child_table_exists":"yes",
             "auto_create_table": "yes",   
             "childtable_count": 20,   
             "childtable_prefix": "YYY_",    
             "batch_create_tbl_num": 100,   
             "data_source": "rand",       
-            "insert_mode": "stmt",      
+            "insert_mode": "taosc",      
             "insert_rows": 5,       
             "childtable_limit": 40,      
             "childtable_offset":0,     

tests/pytest/tools/taosdemoAllTest/stmt/insertBinaryLenLarge16374AllcolLar49151-error-stmt.json

+{
+    "filetype": "insert",
+    "cfgdir": "/etc/taos",
+    "host": "127.0.0.1",
+    "port": 6030,
+    "user": "root",
+    "password": "taosdata",
+    "thread_count": 4,
+    "thread_count_create_tbl": 4,
+    "result_file": "./insert_res.txt",
+    "confirm_parameter_prompt": "no",
+    "insert_interval": 0,
+    "interlace_rows": 10,
+    "num_of_records_per_req": 10240000000,
+    "max_sql_len": 10240000000, 
+    "databases": [{
+        "dbinfo": {
+            "name": "db",
+            "drop": "yes",
+            "replica": 1,
+            "days": 10,
+            "cache": 50,
+            "blocks": 8,
+            "precision": "ms",
+            "keep": 36500,
+            "minRows": 100,
+            "maxRows": 4096,
+            "comp":2,
+            "walLevel":1,
+            "cachelast":0,
+            "quorum":1,
+            "fsync":3000,
+            "update": 0
+        },
+        "super_tables": [{
+            "name": "stb2",
+            "child_table_exists":"no",
+            "childtable_count": 1,
+            "childtable_prefix": "stb02_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 12,
+            "data_source": "rand",
+            "insert_mode": "stmt",
+            "insert_rows": 1,
+            "childtable_limit": 0,
+            "childtable_offset":0,
+            "multi_thread_write_one_tbl": "no",
+            "interlace_rows": 0,
+            "insert_interval":0,
+            "max_sql_len": 1024000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2020-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "BINARY", "len": 16375, "count":1},{"type": "INT"}],
+            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
+        },
+        {
+            "name": "stb4",
+            "child_table_exists":"no",
+            "childtable_count": 1,
+            "childtable_prefix": "stb04_",
+            "auto_create_table": "no",
+            "batch_create_tbl_num": 12,
+            "data_source": "rand",
+            "insert_mode": "stmt",
+            "insert_rows": 1,
+            "childtable_limit": 0,
+            "childtable_offset":0,
+            "multi_thread_write_one_tbl": "no",
+            "interlace_rows": 100,
+            "insert_interval":0,
+            "max_sql_len": 1024000,
+            "disorder_ratio": 0,
+            "disorder_range": 1000,
+            "timestamp_step": 1,
+            "start_timestamp": "2020-10-01 00:00:00.000",
+            "sample_format": "csv",
+            "sample_file": "./sample.csv",
+            "tags_file": "",
+            "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6},{"type": "TINYINT"}],
+            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
+        }]
+    }]
+}

tests/pytest/tools/taosdemoAllTest/stmt/insertBinaryLenLarge16374AllcolLar49151-stmt.json

@@ -109,58 +109,6 @@
             "tags_file": "",
             "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6}], 
             "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
-        },
-        {
-            "name": "stb2",
-            "child_table_exists":"no",
-            "childtable_count": 1,
-            "childtable_prefix": "stb02_",
-            "auto_create_table": "no",
-            "batch_create_tbl_num": 12,
-            "data_source": "rand",
-            "insert_mode": "stmt",
-            "insert_rows": 1,
-            "childtable_limit": 0,
-            "childtable_offset":0,
-            "multi_thread_write_one_tbl": "no",
-            "interlace_rows": 0,
-            "insert_interval":0,
-            "max_sql_len": 1024000,
-            "disorder_ratio": 0,
-            "disorder_range": 1000,
-            "timestamp_step": 1,
-            "start_timestamp": "2020-10-01 00:00:00.000",
-            "sample_format": "csv",
-            "sample_file": "./sample.csv",
-            "tags_file": "",
-            "columns": [{"type": "BINARY", "len": 16375, "count":1},{"type": "INT"}],
-            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
-        },
-        {
-            "name": "stb4",
-            "child_table_exists":"no",
-            "childtable_count": 1,
-            "childtable_prefix": "stb04_",
-            "auto_create_table": "no",
-            "batch_create_tbl_num": 12,
-            "data_source": "rand",
-            "insert_mode": "stmt",
-            "insert_rows": 1,
-            "childtable_limit": 0,
-            "childtable_offset":0,
-            "multi_thread_write_one_tbl": "no",
-            "interlace_rows": 100,
-            "insert_interval":0,
-            "max_sql_len": 1024000,
-            "disorder_ratio": 0,
-            "disorder_range": 1000,
-            "timestamp_step": 1,
-            "start_timestamp": "2020-10-01 00:00:00.000",
-            "sample_format": "csv",
-            "sample_file": "./sample.csv",
-            "tags_file": "",
-            "columns": [{"type": "BINARY", "len": 16371, "count":3},{"type": "INT","count":6},{"type": "TINYINT"}],
-            "tags": [{"type": "TINYINT", "count":2}, {"type": "BINARY", "len": 16, "count":5}]
         }]
     }]
 }

tests/pytest/tools/taosdemoAllTest/taosdemoTestInsertAllType.py

@@ -48,7 +48,7 @@ class TDTestCase:
             tdLog.info("taosd found in %s" % buildPath)
         binPath = buildPath+ "/build/bin/"
 
-        # insert: create one  or mutiple tables per sql and insert multiple rows per sql
+        # taosc interface 
         os.system("%staosBenchmark -f tools/taosdemoAllTest/insert-allDataType.json -y " % binPath)
         tdSql.execute("use db")
         tdSql.query("select count (tbname) from stb0")
@@ -79,7 +79,52 @@ class TDTestCase:
         tdSql.checkData(0, 0, 200)
         tdSql.query("select count(*) from stb1")
         tdSql.checkData(0, 0, 200000)
-        
+
+         # insert-interface: sml
+        os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-allDataType-sml.json -y " % binPath)
+        tdSql.execute("use db")
+        tdSql.query("select count (tbname) from stb0")
+        tdSql.checkData(0, 0, 10)
+        tdSql.query("select count (tbname) from stb1")
+        tdSql.checkData(0, 0, 20)
+        # tdSql.query("select last(ts) from db.stb00_0")
+        # tdSql.checkData(0, 0, "2020-10-01 00:00:00.019000")   
+        tdSql.query("select count(*) from stb0")
+        tdSql.checkData(0, 0, 1000) 
+        # tdSql.query("select last(ts) from db.stb01_0")
+        # tdSql.checkData(0, 0, "2020-11-01 00:00:00.190000")   
+        tdSql.query("select count(*) from stb1")
+        tdSql.checkData(0, 0, 4000) 
+
+
+        #  # insert-interface: sml-json
+        # os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-sml-json-alltype.json -y " % binPath)
+        # tdSql.execute("use db")
+        # tdSql.query("show stables")
+        # for i in range(13):
+        #     for  j in range(13):
+        #         if tdSql.queryResult[i][0] == 'stb%d'%j:
+        #             # print(i,"stb%d"%j)
+        #             tdSql.checkData(i, 4, j+1)
+
+
+        # insert-interface: sml-telnet
+        os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-sml-telnet-alltype.json -y " % binPath)
+        tdSql.execute("use db")
+        tdSql.query("show stables")
+        for i in range(13):
+            for  j in range(13):
+                if tdSql.queryResult[i][0] == 'stb%d'%j:
+                    # print(i,"stb%d"%j)
+                    tdSql.checkData(i, 4, j+1)
+        for i in range(13):
+            tdSql.query("select count(*) from stb%d"%i)
+            tdSql.checkData(0, 0, (i+1)*10) 
+
+        # insert-interface: sml-telnet
+        assert os.system("%staosdemo -f tools/taosdemoAllTest/sml/insert-sml-timestamp.json -y " % binPath) !=0
+
+
         # taosdemo command line
         os.system("%staosBenchmark  -t 1000 -n 100 -T 10 -b INT,TIMESTAMP,BIGINT,FLOAT,DOUBLE,SMALLINT,TINYINT,BOOL,NCHAR,UINT,UBIGINT,UTINYINT,USMALLINT,BINARY  -y " % binPath)
         tdSql.execute("use test")

tests/pytest/tools/taosdemoAllTest/taosdemoTestInsertShell.py

+###################################################################
+#           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 -*-
+
+import sys
+import os
+from util.log import *
+from util.cases import *
+from util.sql import *
+from util.dnodes import *
+
+
+class TDTestCase:
+    def init(self, conn, logSql):
+        tdLog.debug("start to execute %s" % __file__)
+        tdSql.init(conn.cursor(), logSql)
+
+    def getBuildPath(self):
+        selfPath = os.path.dirname(os.path.realpath(__file__))
+        global cfgPath
+        if ("community" in selfPath):
+            projPath = selfPath[:selfPath.find("community")]
+            cfgPath = projPath + "/community/sim/dnode1/cfg"
+            
+        else:
+            projPath = selfPath[:selfPath.find("tests")]
+            cfgPath = projPath + "/sim/dnode1/cfg"
+
+        for root, dirs, files in os.walk(projPath):
+            if ("taosd" in files):
+                rootRealPath = os.path.dirname(os.path.realpath(root))
+                if ("packaging" not in rootRealPath):
+                    buildPath = root[:len(root)-len("/build/bin")]
+                    break
+        return buildPath
+
+    # def checkGerData():
+
+    def run(self):
+        buildPath = self.getBuildPath()
+        print("%s" % cfgPath )
+        if (buildPath == ""):
+            tdLog.exit("taosd not found!")
+        else:
+            tdLog.info("taosd found in %s" % buildPath)
+        binPath = buildPath+ "/build/bin/"
+
+        tdLog.info("create super table")
+        # create super table 
+        os.system("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db1  -a 1 -l 10 -b float,int,NCHAR\(15\) -w 4096 \
+        -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test.  " % (binPath,cfgPath))
+        tdSql.execute("use db1")
+        tdSql.query("describe meters;")
+        tdSql.checkRows(13)
+        tdSql.query("select count(*) from meters")
+        tdSql.checkData(0, 0, 1000)
+        tdSql.query("select count(tbname) from meters")
+        tdSql.checkData(0, 0, 10)
+        tdSql.query("select count(*) from `test.0`")
+        tdSql.checkData(0, 0, 100)
+
+  
+        tdLog.info("create general table -N ")
+        tdSql.execute("drop database db1;")
+        # create general table -N 
+        os.system("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db1  -a 1 -l 10 -b float,int,NCHAR\(15\) -w 4096 \
+        -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test. -N " % (binPath,cfgPath))
+        tdSql.execute("use db1")
+        tdSql.query("describe `test.0`;")
+        tdSql.checkRows(11)
+        tdSql.error("select count(*) from meters")
+        tdSql.error("select count(tbname) from meters")
+        tdSql.query("select count(*) from `test.0`")
+        tdSql.checkData(0, 0, 100)
+
+        tdLog.info("use diffrent interface stmt")
+        tdSql.execute("drop database db1;")
+        # use diffrent interface-stmt
+        os.system("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db1  -a 1 -l 10 -b float,int,BINARY\(4000\) -w 40 \
+        -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test. -I stmt " % (binPath,cfgPath))
+        tdSql.execute("use db1")
+        tdSql.query("select count(*) from meters")
+        tdSql.checkData(0, 0, 1000)
+        tdSql.query("select count(tbname) from meters")
+        tdSql.checkData(0, 0, 10)
+        tdSql.query("select count(*) from `test.0`")
+        tdSql.checkData(0, 0, 100)
+
+        # tdLog.info("use diffrent interface rest")
+        # tdSql.execute("drop database db1;")
+        # # use diffrent interface -rest
+        # os.system("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db1  -a 1 -l 10 -b float,int,NCHAR\(15\) -w 4097 \
+        # -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test. -I rest " % (binPath,cfgPath))
+        # tdSql.execute("use db1")
+        # tdSql.query("select count(*) from meters")
+        # tdSql.checkData(0, 0, 1000)
+        # tdSql.query("select count(tbname) from meters")
+        # tdSql.checkData(0, 0, 10)
+        # tdSql.query("select count(*) from `test.0`")
+        # tdSql.checkData(0, 0, 100)
+
+        tdLog.info("use diffrent interface sml")
+        tdSql.execute("drop database db1;")
+        # use diffrent interface-sml
+        os.system("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db1  -a 1 -l 10 -b float,int,NCHAR\(15\) -w 1024 \
+        -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test. -I sml " % (binPath,cfgPath))
+        tdSql.execute("use db1")
+        tdSql.query("select count(*) from meters")
+        tdSql.checkData(0, 0, 1000)
+        tdSql.query("select count(tbname) from meters")
+        tdSql.checkData(0, 0, 10)
+
+        tdLog.info("all data type")
+        tdSql.execute("drop database db1;")
+        # all data type 
+        os.system("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db1  -a 1 -l 10 \
+        -b INT,TIMESTAMP,BIGINT,FLOAT,DOUBLE,SMALLINT,TINYINT,BOOL,UINT,UBIGINT,UTINYINT,USMALLINT,BINARY\(15\),NCHAR\(15\) -w 4096 \
+        -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test. " % (binPath,cfgPath))
+        tdSql.execute("use db1")
+        tdSql.query("select count(*) from meters")
+        tdSql.checkData(0, 0, 1000)
+        tdSql.query("select count(tbname) from meters")
+        tdSql.checkData(0, 0, 10)
+        tdSql.query("select count(*) from `test.0`")
+        tdSql.checkData(0, 0, 100)
+
+        tdLog.info("all data type and interlace rows")
+        tdSql.execute("drop database db1;")
+        # all data type 
+        os.system("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db3  -a 1 -l 10\
+        -b INT,TIMESTAMP,BIGINT,FLOAT,DOUBLE,SMALLINT,TINYINT,BOOL,UINT,UBIGINT,UTINYINT,USMALLINT,BINARY\(15\),NCHAR\(15\) -w 4096\
+        -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -B 1000  -M  -x -y -O 10 -R 100  -E  -m test.  " % (binPath,cfgPath))
+        tdSql.execute("use db3")
+        tdSql.query("select count(*) from meters")
+        tdSql.checkData(0, 0, 1000)
+        tdSql.query("select count(tbname) from meters")
+        tdSql.checkData(0, 0, 10)
+        tdSql.query("select count(*) from `test.0`")
+        tdSql.checkData(0, 0, 100)
+
+        tdLog.info("all data type and too much para")
+        tdLog.info("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db1  -a 1 -l 10 -b float,int,NCHAR\(15\) -w 4096 \
+        -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test.taosdemo -u root  -c %s -h \
+        localhost -P 6030 -d db1  -a 1 -l 100 -b float,int,NCHAR\(15\) -w 4096   -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test. " % (binPath,cfgPath,cfgPath))
+        tdSql.execute("drop database db3;")
+        # repeate parameters 
+        os.system("%staosBenchmark -u root  -c %s -h localhost -P 6030 -d db1  -a 1 -l 10 -b float,int,NCHAR\(15\) -w 4096 \
+        -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test.taosdemo -u root  -c %s -h \
+        localhost -P 6030 -d db1  -a 1 -l 100 -b float,int,NCHAR\(15\) -w 4096   -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M  -x -y -O 10 -R 100  -E  -m test. " % (binPath,cfgPath,cfgPath))
+        tdSql.execute("use db1")
+        tdSql.query("select count(*) from meters")
+        tdSql.checkData(0, 0, 1000)
+        tdSql.query("select count(tbname) from meters")
+        tdSql.checkData(0, 0, 10)
+        tdSql.query("select count(*) from `test.0`")
+        tdSql.checkData(0, 0, 100)
+
+        # tdLog.info("%staosBenchmark -u root -c %s -h localhost -P 6030 -d db1 -a 1 -l 10 -b float,int,NCHAR\(4096\) \
+        #         -w 40 -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M -x -y -O 10 -R 100 -E -m test. -I stmt" % (binPath,cfgPath))
+        # # taosdemo error-exceeds  max length
+        # assert os.system("%staosBenchmark -u root -c %s -h localhost -P 6030 -d db1 -a 1 -l 10 -b float,int,NCHAR\(4096\) \
+        #         -w 40 -T 8 -i 10 -S 1000 -r 1000000 -t 10 -n 100 -M -x -y -O 10 -R 100 -E -m test. -I taosc" % (binPath,cfgPath)) != 0       
+
+        testcaseFilename = os.path.split(__file__)[-1]
+        os.system("rm -rf ./insert_res*.txt*")
+        os.system("rm -rf tools/taosdemoAllTest/%s.sql" % testcaseFilename )         
+        
+
+    def stop(self):
+        tdSql.close()
+        tdLog.success("%s successfully executed" % __file__)
+
+
+tdCases.addWindows(__file__, TDTestCase())
+tdCases.addLinux(__file__, TDTestCase())

tests/pytest/tools/taosdemoAllTest/taosdemoTestInsertWithJson.py

@@ -68,21 +68,21 @@ class TDTestCase:
         tdSql.query("select count(*) from stb1")
         tdSql.checkData(0, 0, 2000)
 
-        # restful connector insert data
-        os.system("%staosBenchmark -f tools/taosdemoAllTest/insertRestful.json -y " % binPath)
-        tdSql.execute("use db")
-        tdSql.query("select count (tbname) from stb0")
-        tdSql.checkData(0, 0, 10)
-        tdSql.query("select count (tbname) from stb1")
-        tdSql.checkData(0, 0, 10)
-        tdSql.query("select count(*) from stb00_0")
-        tdSql.checkData(0, 0, 10)
-        tdSql.query("select count(*) from stb0")
-        tdSql.checkData(0, 0, 100)
-        tdSql.query("select count(*) from stb01_1")
-        tdSql.checkData(0, 0, 20)
-        tdSql.query("select count(*) from stb1")
-        tdSql.checkData(0, 0, 200)
+        # # restful connector insert data
+        # os.system("%staosBenchmark -f tools/taosdemoAllTest/insertRestful.json -y " % binPath)
+        # tdSql.execute("use db")
+        # tdSql.query("select count (tbname) from stb0")
+        # tdSql.checkData(0, 0, 10)
+        # tdSql.query("select count (tbname) from stb1")
+        # tdSql.checkData(0, 0, 10)
+        # tdSql.query("select count(*) from stb00_0")
+        # tdSql.checkData(0, 0, 10)
+        # tdSql.query("select count(*) from stb0")
+        # tdSql.checkData(0, 0, 100)
+        # tdSql.query("select count(*) from stb01_1")
+        # tdSql.checkData(0, 0, 20)
+        # tdSql.query("select count(*) from stb1")
+        # tdSql.checkData(0, 0, 200)
 
         # default values json files 
         tdSql.execute("drop database if exists db") 
@@ -103,30 +103,30 @@ class TDTestCase:
         tdSql.query("select count (tbname) from stb1")
         tdSql.checkData(0, 0, 20)
         tdSql.query("select count(*) from stb00_0")
-        tdSql.checkData(0, 0, 10000)
+        tdSql.checkData(0, 0, 100)
         tdSql.query("select count(*) from stb0")
-        tdSql.checkData(0, 0, 100000)
+        tdSql.checkData(0, 0, 1000)
         tdSql.query("select count(*) from stb01_0")
-        tdSql.checkData(0, 0, 20000)
+        tdSql.checkData(0, 0, 200)
         tdSql.query("select count(*) from stb1")
-        tdSql.checkData(0, 0, 400000)
+        tdSql.checkData(0, 0, 4000)
 
         # insert: using parament "insert_interval to controls spped  of insert.
         # but We need to have accurate methods to control the speed, such as getting the speed value, checking the count and so on。
         os.system("%staosBenchmark -f tools/taosdemoAllTest/insert-interval-speed.json -y" % binPath)
         tdSql.execute("use db")
         tdSql.query("show stables")
-        tdSql.checkData(0, 4, 100)
+        tdSql.checkData(0, 4, 10)
         tdSql.query("select count(*) from stb00_0")
-        tdSql.checkData(0, 0, 20000)
+        tdSql.checkData(0, 0, 200)
         tdSql.query("select count(*) from stb0")
-        tdSql.checkData(0, 0, 2000000)
+        tdSql.checkData(0, 0, 2000)
         tdSql.query("show stables")
-        tdSql.checkData(1, 4, 100)
+        tdSql.checkData(1, 4, 20)
         tdSql.query("select count(*) from stb01_0")
-        tdSql.checkData(0, 0, 20000)
+        tdSql.checkData(0, 0, 200)
         tdSql.query("select count(*) from stb1")
-        tdSql.checkData(0, 0, 2000000)
+        tdSql.checkData(0, 0, 4000)
 
         # spend 2min30s for 3 testcases.
         # insert: drop and child_table_exists combination test
@@ -218,6 +218,10 @@ class TDTestCase:
         tdSql.query("select count(*) from db.stb3") 
         tdSql.checkRows(1)
         tdSql.execute("drop database if exists db") 
+        os.system("%staosBenchmark -f tools/taosdemoAllTest/insertBinaryLenLarge16374AllcolLar49151-error.json -y " % binPath)   
+        tdSql.error("select * from db.stb4")
+        tdSql.error("select * from db.stb2")
+        tdSql.execute("drop database if exists db") 
         os.system("%staosBenchmark -f tools/taosdemoAllTest/insertNumOfrecordPerReq0.json -y " % binPath)   
         tdSql.error("select count(*) from db.stb0") 
         tdSql.execute("drop database if exists db") 
@@ -353,6 +357,15 @@ class TDTestCase:
         tdSql.query('show tables like \'YYY%\'')    #child_table_exists = yes, auto_create_table varies = yes
         tdSql.checkRows(20)
 
+        # insert: test chinese encoding
+        os.system("%staosBenchmark -f tools/taosdemoAllTest/insert-chinese.json -y " % binPath)
+        tdSql.execute("use db")
+        tdSql.query("select count (tbname) from stb0")
+        tdSql.checkData(0, 0, 10)
+        tdSql.query("select count (*) from stb0")
+        tdSql.checkData(0, 0, 1500)
+
+
         # rm useless files
         os.system("rm -rf ./insert*_res.txt*")
 

tests/pytest/tools/taosdemoAllTest/taosdemoTestInsertWithJsonSml.py

@@ -56,12 +56,8 @@ class TDTestCase:
         tdSql.checkData(0, 0, 10)
         tdSql.query("select count (tbname) from stb1")
         tdSql.checkData(0, 0, 20)
-        tdSql.query("select count(*) from stb00_0")
-        tdSql.checkData(0, 0, 100)
         tdSql.query("select count(*) from stb0")
         tdSql.checkData(0, 0, 1000)
-        tdSql.query("select count(*) from stb01_1")
-        tdSql.checkData(0, 0, 200)
         tdSql.query("select count(*) from stb1")
         tdSql.checkData(0, 0, 4000)        
 
@@ -73,31 +69,27 @@ class TDTestCase:
         tdSql.checkData(0, 0, 10)
         tdSql.query("select count (tbname) from stb1")
         tdSql.checkData(0, 0, 15)
-        tdSql.query("select count(*) from stb00_0")
-        tdSql.checkData(0, 0, 150)   
         tdSql.query("select count(*) from stb0")
         tdSql.checkData(0, 0, 1500) 
-        tdSql.query("select count(*) from stb01_0")
-        tdSql.checkData(0, 0, 200)   
         tdSql.query("select count(*) from stb1")
         tdSql.checkData(0, 0, 3000) 
 
-        # insert: using parament "insert_interval to controls spped  of insert. 
-        # but We need to have accurate methods to control the speed, such as getting the speed value, checking the count and so on。
-        os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-interval-speed-sml.json -y" % binPath)
-        tdSql.execute("use db")
-        tdSql.query("select tbname from  stb0")
-        tdSql.checkRows(100 )
-        tdSql.query("select count(*) from stb00_0")
-        tdSql.checkData(0, 0, 20)   
-        tdSql.query("select count(*) from stb0")
-        tdSql.checkData(0, 0, 2000) 
-        tdSql.query("show stables")
-        tdSql.checkData(1, 4, 20)
-        tdSql.query("select count(*) from stb01_0")
-        tdSql.checkData(0, 0, 35)   
-        tdSql.query("select count(*) from stb1")
-        tdSql.checkData(0, 0, 700)           
+        # # insert: using parament "insert_interval to controls spped  of insert. 
+        # # but We need to have accurate methods to control the speed, such as getting the speed value, checking the count and so on。
+        # os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-interval-speed-sml.json -y" % binPath)
+        # tdSql.execute("use db")
+        # tdSql.query("select tbname from  db.stb0")
+        # tdSql.checkRows(100 )
+        # # tdSql.query("select count(*) from stb00_0")
+        # # tdSql.checkData(0, 0, 20)   
+        # tdSql.query("select count(*) from stb0")
+        # tdSql.checkData(0, 0, 2000) 
+        # tdSql.query("show stables")
+        # tdSql.checkData(1, 4, 20)
+        # # tdSql.query("select count(*) from stb01_0")
+        # # tdSql.checkData(0, 0, 35)   
+        # tdSql.query("select count(*) from stb1")
+        # tdSql.checkData(0, 0, 700)           
         
         # spend 2min30s for 3 testcases.
         # insert: drop and child_table_exists combination test 
@@ -142,10 +134,10 @@ class TDTestCase:
         # os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertColumnsAndTagNum4096-sml.json -y " % binPath)
         # tdSql.query("select count(*) from db.stb0")
         # tdSql.checkData(0, 0, 10000) 
-        tdSql.execute("drop database if exists db")
-        os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertInterlaceRowsLarge1M-sml.json -y " % binPath)
-        tdSql.query("select count(*) from db.stb0")
-        tdSql.checkRows(0)
+        # tdSql.execute("drop database if exists db")
+        # os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertInterlaceRowsLarge1M-sml.json -y " % binPath)
+        # tdSql.query("select count(*) from db.stb0")
+        # tdSql.checkRows(0)
         tdSql.execute("drop database if exists db") 
         os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertColumnsNum0-sml.json -y " % binPath)
         tdSql.execute("use db") 
@@ -160,11 +152,13 @@ class TDTestCase:
         tdSql.checkRows(1)
         tdSql.query("select count(*) from db.stb1") 
         tdSql.checkRows(1)
-        tdSql.error("select * from db.stb4")
-        tdSql.error("select * from db.stb2")
         tdSql.query("select count(*) from db.stb3") 
         tdSql.checkRows(1)
         tdSql.execute("drop database if exists db") 
+        os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertBinaryLenLarge16374AllcolLar49151-error-sml.json -y " % binPath)   
+        tdSql.error("select * from db.stb4")
+        tdSql.error("select * from db.stb2")
+        tdSql.execute("drop database if exists db") 
         os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertNumOfrecordPerReq0-sml.json -y " % binPath)   
         tdSql.error("select count(*) from db.stb0") 
         tdSql.execute("drop database if exists db") 
@@ -177,14 +171,17 @@ class TDTestCase:
         os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertChildTabLess0-sml.json -y " % binPath)   
         tdSql.error("use db") 
         tdSql.execute("drop database if exists blf") 
-        os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertTimestepMulRowsLargeint16-sml.json -y " % binPath)   
-        tdSql.execute("use blf") 
-        tdSql.query("select ts from blf.p_0_topics_7 limit 262800,1") 
-        tdSql.checkData(0, 0, "2020-03-31 12:00:00.000")
-        tdSql.query("select first(ts) from blf.p_0_topics_2")
-        tdSql.checkData(0, 0, "2019-10-01 00:00:00")
-        tdSql.query("select last(ts) from blf.p_0_topics_6 ")        
-        tdSql.checkData(0, 0, "2020-09-29 23:59:00")
+
+        # child table name is invalid reading,so 
+        # os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertTimestepMulRowsLargeint16-sml.json -y " % binPath)   
+        # tdSql.execute("use blf") 
+        # tdSql.query("select ts from blf.p_0_topics_7 limit 262800,1") 
+        # tdSql.checkData(0, 0, "2020-03-31 12:00:00.000")
+        # tdSql.query("select first(ts) from blf.p_0_topics_2")
+        # tdSql.checkData(0, 0, "2019-10-01 00:00:00")
+        # tdSql.query("select last(ts) from blf.p_0_topics_6 ")        
+        # tdSql.checkData(0, 0, "2020-09-29 23:59:00")
+
         # it will be commented in ci because it spend too much time to insert data, but when you can excute it when you want to test this case.
         # os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insertMaxNumPerReq-sml.json -y " % binPath)
         # tdSql.execute("use db")
@@ -200,6 +197,7 @@ class TDTestCase:
         # tdSql.checkData(0, 0, 5000000)
 
 
+
         # insert: timestamp and step 
         os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-timestep-sml.json -y " % binPath)
         tdSql.execute("use db")
@@ -207,12 +205,12 @@ class TDTestCase:
         tdSql.checkData(0, 0, 10)
         tdSql.query("select count (tbname) from stb1")
         tdSql.checkData(0, 0, 20)
-        tdSql.query("select last(ts) from db.stb00_0")
-        tdSql.checkData(0, 0, "2020-10-01 00:00:00.019000")   
+        # tdSql.query("select last(ts) from db.stb00_0")
+        # tdSql.checkData(0, 0, "2020-10-01 00:00:00.019000")   
         tdSql.query("select count(*) from stb0")
         tdSql.checkData(0, 0, 200) 
-        tdSql.query("select last(ts) from db.stb01_0")
-        tdSql.checkData(0, 0, "2020-11-01 00:00:00.190000")   
+        # tdSql.query("select last(ts) from db.stb01_0")
+        # tdSql.checkData(0, 0, "2020-11-01 00:00:00.190000")   
         tdSql.query("select count(*) from stb1")
         tdSql.checkData(0, 0, 400) 
 
@@ -228,17 +226,17 @@ class TDTestCase:
         tdSql.query("select count(*) from stb1")
         tdSql.checkData(0, 0, 10) 
 
-        # insert:  sample json
-        os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-sample-sml.json -y " % binPath)
-        tdSql.execute("use dbtest123")
-        tdSql.query("select c2 from stb0")
-        tdSql.checkData(0, 0, 2147483647)
-        tdSql.query("select * from stb1 where t1=-127")
-        tdSql.checkRows(20)
-        tdSql.query("select * from stb1 where t2=127")
-        tdSql.checkRows(10)
-        tdSql.query("select * from stb1 where t2=126")
-        tdSql.checkRows(10)
+        # insert:  doesn‘t currently supported sample json
+        assert os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-sample-sml.json -y " % binPath) != 0 
+        # tdSql.execute("use dbtest123")
+        # tdSql.query("select c2 from stb0")
+        # tdSql.checkData(0, 0, 2147483647)
+        # tdSql.query("select * from stb1 where t1=-127")
+        # tdSql.checkRows(20)
+        # tdSql.query("select * from stb1 where t2=127")
+        # tdSql.checkRows(10)
+        # tdSql.query("select * from stb1 where t2=126")
+        # tdSql.checkRows(10)
 
         # insert: test interlace parament 
         os.system("%staosBenchmark -f tools/taosdemoAllTest/sml/insert-interlace-row-sml.json -y " % binPath)

tests/pytest/tools/taosdemoAllTest/taosdemoTestInsertWithJsonStmt.py

@@ -187,6 +187,10 @@ class TDTestCase:
         tdSql.query("select count(*) from db.stb3") 
         tdSql.checkRows(1)
         tdSql.execute("drop database if exists db") 
+        os.system("%staosBenchmark -f tools/taosdemoAllTest/stmt/insertBinaryLenLarge16374AllcolLar49151-error-stmt.json -y " % binPath)   
+        tdSql.error("select * from db.stb4")
+        tdSql.error("select * from db.stb2")
+        tdSql.execute("drop database if exists db") 
         os.system("%staosBenchmark -f tools/taosdemoAllTest/stmt/insertNumOfrecordPerReq0-stmt.json -y " % binPath)   
         tdSql.error("select count(*) from db.stb0") 
         tdSql.execute("drop database if exists db") 

tests/pytest/tools/taosdemoAllTest/taosdemoTestQueryWithJson.py

@@ -174,15 +174,15 @@ class TDTestCase:
             "2020-11-01 00:00:00.004")
 
         # query times less than or equal to 100
-        os.system(
+        assert os.system(
             "%staosBenchmark -f tools/taosdemoAllTest/queryInsertdata.json" %
-            binPath)
-        os.system(
+            binPath) == 0
+        assert os.system(
             "%staosBenchmark -f tools/taosdemoAllTest/querySpeciMutisql100.json" %
-            binPath)
-        os.system(
+            binPath) != 0
+        assert os.system(
             "%staosBenchmark -f tools/taosdemoAllTest/querySuperMutisql100.json" %
-            binPath)
+            binPath) == 0
 
         # query result print QPS
         os.system(