Merge pull request #17844 from taosdata/test/TD-20059

test:add replica parameters for all testcase

packaging/testpackage.sh

@@ -211,7 +211,8 @@ elif [[ ${packgeName} =~ "tar" ]];then
 
     if [ ${diffNumbers} != 0 ];then
         echoColor R "The number and names of files is different from the previous installation package"
-        echoColor Y `cat ${installPath}/diffFile.log`
+        diffLog=`cat ${installPath}/diffFile.log`
+        echoColor Y "${diffLog}"
         exit -1
     else 
         echoColor G "The number and names of files are the same as previous installation packages"

tests/develop-test/5-taos-tools/taosbenchmark/auto_create_table_json.py

@@ -25,7 +25,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
 

tests/develop-test/5-taos-tools/taosbenchmark/commandline.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/custom_col_tag.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/default_json.py

@@ -23,7 +23,8 @@ class TDTestCase:
         [TD-11510] taosBenchmark test cases
         """
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/demo.py

@@ -27,7 +27,8 @@ class TDTestCase:
         """
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/insert_alltypes_json.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/invalid_commandline.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/json_tag.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/limit_offset_json.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/query_json.py

@@ -29,7 +29,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/sample_csv_json.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/sml_interlace.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/sml_json_alltypes.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/sml_telnet_alltypes.py

@@ -24,7 +24,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/taosadapter_json.py

@@ -25,7 +25,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosbenchmark/telnet_tcp.py

@@ -25,7 +25,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

tests/develop-test/5-taos-tools/taosdump/taosdumpTestInspect.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -52,7 +53,7 @@ class TDTestCase:
         return paths[0]
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeBigInt.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeBinary.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeBool.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeDouble.py

@@ -28,7 +28,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -51,7 +52,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeFloat.py

@@ -28,7 +28,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -51,7 +52,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeInt.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeJson.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeSmallInt.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -49,7 +50,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeTinyInt.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -49,7 +50,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeUnsignedBigInt.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeUnsignedInt.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeUnsignedSmallInt.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/develop-test/5-taos-tools/taosdump/taosdumpTestTypeUnsignedTinyInt.py

@@ -27,7 +27,8 @@ class TDTestCase:
         '''
         return
 
-    def init(self, conn, logSql, replicaVarl=1):
+    def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.tmpdir = "tmp"
@@ -50,7 +51,7 @@ class TDTestCase:
         return buildPath
 
     def run(self):
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdSql.execute("drop database if exists db")
         tdSql.execute("create database db  days 11 keep 3649 blocks 8 ")

tests/system-test/0-others/cachemodel.py

@@ -15,6 +15,7 @@ class TDTestCase:
     "jniDebugFlag":143 ,"simDebugFlag":143,"dDebugFlag":143, "dDebugFlag":143,"vDebugFlag":143,"mDebugFlag":143,"qDebugFlag":143,
     "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"udfDebugFlag":143}
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), True)
 

tests/system-test/0-others/compatibility.py

@@ -23,6 +23,7 @@ class TDTestCase:
         return
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/fsync.py

@@ -27,6 +27,7 @@ TS_TYPE_COL = [ TS_COL, ]
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/show.py

@@ -21,6 +21,7 @@ from util.sqlset import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.setsql = TDSetSql()

tests/system-test/0-others/sysinfo.py

@@ -21,6 +21,7 @@ from util.common import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.dbname = 'db'

tests/system-test/0-others/taosShell.py

@@ -109,6 +109,7 @@ class TDTestCase:
     print ("===================: ", updatecfgDict)
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/taosShellError.py

@@ -111,6 +111,7 @@ class TDTestCase:
     print ("===================: ", updatecfgDict)
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/taosShellNetChk.py

@@ -111,6 +111,7 @@ class TDTestCase:
     print ("===================: ", updatecfgDict)
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/taosdMonitor.py

@@ -285,6 +285,7 @@ class TDTestCase:
     print ("===================: ", updatecfgDict)
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/taosdShell.py

@@ -45,6 +45,7 @@ class TDTestCase:
     # print ("===================: ", updatecfgDict)
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/taosdlog.py

@@ -11,6 +11,7 @@ from util.dnodes import *
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/telemetry.py

@@ -174,6 +174,7 @@ class TDTestCase:
     print ("===================: ", updatecfgDict)
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/0-others/udfTest.py

@@ -14,6 +14,7 @@ import subprocess
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), logSql)
 

tests/system-test/0-others/udf_cfg1.py

@@ -16,6 +16,7 @@ class TDTestCase:
                      "jniDebugFlag": 143, "simDebugFlag": 143, "dDebugFlag": 143, "dDebugFlag": 143, "vDebugFlag": 143, "mDebugFlag": 143, "qDebugFlag": 143,
                      "wDebugFlag": 143, "sDebugFlag": 143, "tsdbDebugFlag": 143, "tqDebugFlag": 143, "fsDebugFlag": 143, "fnDebugFlag": 143 ,"udf":0}
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), logSql)
 

tests/system-test/0-others/udf_cfg2.py

@@ -16,6 +16,7 @@ class TDTestCase:
                      "jniDebugFlag": 143, "simDebugFlag": 143, "dDebugFlag": 143, "dDebugFlag": 143, "vDebugFlag": 143, "mDebugFlag": 143, "qDebugFlag": 143,
                      "wDebugFlag": 143, "sDebugFlag": 143, "tsdbDebugFlag": 143, "tqDebugFlag": 143, "fsDebugFlag": 143, "fnDebugFlag": 143 ,"udf":1}
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), logSql)
 

tests/system-test/0-others/udf_cluster.py

@@ -20,6 +20,7 @@ class MyDnodes(TDDnodes):
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         self.TDDnodes = None
         self.depoly_cluster(3)

tests/system-test/0-others/udf_create.py

@@ -16,6 +16,7 @@ import threading
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), logSql)
 

tests/system-test/0-others/udf_restart_taosd.py

@@ -13,6 +13,7 @@ import subprocess
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), logSql)
 

tests/system-test/0-others/user_control.py

@@ -155,6 +155,7 @@ class User:
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

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

@@ -12,6 +12,7 @@ from util.dnodes import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(),logSql)
         self.buffer_boundary = [3,4097,8193,12289,16384]

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

@@ -21,6 +21,7 @@ from util import constant
 from util.common import *
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.setsql = TDSetSql()

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

@@ -22,6 +22,7 @@ from util.sqlset import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.setsql = TDSetSql()

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

@@ -143,6 +143,7 @@ class BSMAschema:
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), False)
         self.precision = "ms"

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

@@ -45,6 +45,7 @@ NTBNAME = "nt1"
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), True)
 

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

@@ -29,6 +29,7 @@ class TDTestCase:
     "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"fnDebugFlag":143}
     
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

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

@@ -32,6 +32,7 @@ from util.common import *
 class TDTestCase:
     
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.special_name = ['!','@','#','$','%','^','&','*','(',')','[',']','{','}',\

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

@@ -24,6 +24,7 @@ from util.sqlset import TDSetSql
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), True)
         self.dbname = 'db_test'

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

@@ -30,6 +30,7 @@ if platform.system().lower() == 'windows':
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), False)
         self._conn = conn

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

@@ -63,6 +63,7 @@ class TDTestCase:
 
     # init
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         # tdSql.prepare()

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

@@ -9,6 +9,7 @@ import threading
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
 

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

@@ -8,6 +8,7 @@ import time
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self.dbname = "test"

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

@@ -58,6 +58,7 @@ DATA_PRE2 = f"data2"
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), False)
         self.taos_cfg_path = tdDnodes.dnodes[0].cfgPath

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

@@ -61,6 +61,7 @@ class TDTestCase:
 
     # init
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         # tdSql.init(conn.cursor())
         # tdSql.prepare()

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

@@ -25,6 +25,7 @@ import json
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)
         self._conn = conn

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

@@ -29,6 +29,7 @@ if platform.system().lower() == 'windows':
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), False)
         self._conn = conn

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

@@ -21,6 +21,7 @@ from util.common import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         # prepare data

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

@@ -19,6 +19,7 @@ from util.common import *
 class TDTestCase:
     updatecfgDict = {'ttlUnit':5,'ttlPushInterval':3}
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.ntbname = 'ntb'

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

@@ -6,6 +6,7 @@ from util.common import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.ts = 1537146000000

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

@@ -58,6 +58,7 @@ class TDTestCase:
 
     # init
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         # tdSql.prepare()

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

@@ -58,6 +58,7 @@ class TDTestCase:
 
     # init
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         # tdSql.prepare()

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

@@ -135,6 +135,7 @@ class TDTestCase:
     updatecfgDict = {"querySmaOptimize": 1}
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), False)
         self.precision = "ms"

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

@@ -21,6 +21,7 @@ from util.common import *
 from util.sqlset import TDSetSql
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(),logSql)
         self.setsql = TDSetSql()

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

@@ -24,6 +24,7 @@ from util.common import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.dbname = 'db_test'

tests/system-test/2-query/Now.py

@@ -8,6 +8,7 @@ from util.sqlset import *
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
         self.setsql = TDSetSql()

tests/system-test/2-query/Timediff.py

@@ -5,6 +5,7 @@ from util.gettime import *
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
         self.get_time = GetTime()

tests/system-test/2-query/To_iso8601.py

@@ -11,6 +11,7 @@ import os
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
         self.rowNum = 10

tests/system-test/2-query/To_unixtimestamp.py

@@ -11,6 +11,7 @@ from util.sqlset import TDSetSql
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
         self.setsql = TDSetSql()

tests/system-test/2-query/Today.py

@@ -11,6 +11,7 @@ import pandas as pd
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
         self.today_date = datetime.datetime.strptime(datetime.datetime.now().strftime("%Y-%m-%d"), "%Y-%m-%d")

tests/system-test/2-query/abs.py

@@ -15,12 +15,14 @@ class TDTestCase:
     #                  "wDebugFlag": 143, "sDebugFlag": 143, "tsdbDebugFlag": 143, "tqDebugFlag": 143, "fsDebugFlag": 143, "udfDebugFlag": 143}
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), False)
         self.tb_nums = 10
         self.row_nums = 20
         self.ts = 1434938400000
         self.time_step = 1000
+        self.replicaVar = int(replicaVar)
 
     def insert_datas_and_check_abs(self ,tbnums , rownums , time_step ):
         tdLog.info(" prepare datas for auto check abs function ")
@@ -28,7 +30,7 @@ class TDTestCase:
         stbname = f"{dbname}.stb"
         ctbname_pre = f"{dbname}.sub_tb_"
 
-        tdSql.execute(f" create database {dbname} ")
+        tdSql.execute(f" create database {dbname} replica {self.replicaVar} ")
         tdSql.execute(f" use {dbname} ")
         tdSql.execute(f" create stable {stbname} (ts timestamp, c1 int, c2 bigint, c3 smallint, c4 tinyint,\
              c5 float, c6 double, c7 bool, c8 binary(16),c9 nchar(32), c10 timestamp) tags (t1 int)")
@@ -125,7 +127,7 @@ class TDTestCase:
     def prepare_tag_datas(self, dbname="testdb"):
         # prepare datas
         tdSql.execute(
-            f"create database if not exists {dbname} keep 3650 duration 1000")
+            f"create database if not exists {dbname} keep 3650 duration 1000  replica {self.replicaVar} ")
         tdSql.execute(" use testdb ")
         tdSql.execute(
             f'''create table {dbname}.stb1
@@ -456,7 +458,7 @@ class TDTestCase:
         dbname = "bound_test"
 
         tdSql.execute(f"drop database if exists {dbname}")
-        tdSql.execute(f"create database if not exists {dbname}")
+        tdSql.execute(f"create database if not exists {dbname}  replica {self.replicaVar}  ")
         time.sleep(3)
         tdSql.execute(f"use {dbname}")
         tdSql.execute(
@@ -589,7 +591,7 @@ class TDTestCase:
 
 
     def run(self):  # sourcery skip: extract-duplicate-method, remove-redundant-fstring
-        tdSql.prepare()
+        tdSql.prepare(replica=f"{self.replicaVar}")
 
         tdLog.printNoPrefix("==========step1:create table ==============")
 

tests/system-test/2-query/and_or_for_byte.py

@@ -15,6 +15,7 @@ class TDTestCase:
     #                  "wDebugFlag": 143, "sDebugFlag": 143, "tsdbDebugFlag": 143, "tqDebugFlag": 143, "fsDebugFlag": 143, "udfDebugFlag": 143}
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), False)
         self.tb_nums = 10

tests/system-test/2-query/apercentile.py

@@ -19,6 +19,7 @@ from util.sqlset import TDSetSql
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(),False)
         self.rowNum = 10

tests/system-test/2-query/arccos.py

@@ -13,6 +13,7 @@ class TDTestCase:
     # "jniDebugFlag":143 ,"simDebugFlag":143,"dDebugFlag":143, "dDebugFlag":143,"vDebugFlag":143,"mDebugFlag":143,"qDebugFlag":143,
     # "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"udfDebugFlag":143}
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/arcsin.py

@@ -13,6 +13,7 @@ class TDTestCase:
     # "jniDebugFlag":143 ,"simDebugFlag":143,"dDebugFlag":143, "dDebugFlag":143,"vDebugFlag":143,"mDebugFlag":143,"qDebugFlag":143,
     # "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"udfDebugFlag":143}
     def init(self, conn,  logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/arctan.py

@@ -13,6 +13,7 @@ class TDTestCase:
     # "jniDebugFlag":143 ,"simDebugFlag":143,"dDebugFlag":143, "dDebugFlag":143,"vDebugFlag":143,"mDebugFlag":143,"qDebugFlag":143,
     # "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"udfDebugFlag":143}
     def init(self, conn,  logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/avg.py

@@ -11,6 +11,7 @@ class TDTestCase:
     # "jniDebugFlag":143 ,"simDebugFlag":143,"dDebugFlag":143, "dDebugFlag":143,"vDebugFlag":143,"mDebugFlag":143,"qDebugFlag":143,
     # "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"udfDebugFlag":143}
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), False)
         self.setsql = TDSetSql()

tests/system-test/2-query/between.py

@@ -10,6 +10,7 @@ from util.cases import *
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/bottom.py

@@ -22,6 +22,7 @@ from util.sqlset import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
         self.dbname = 'db_test'

tests/system-test/2-query/cast.py

@@ -13,6 +13,7 @@ from util.dnodes import *
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
         self.dbname = "db"

tests/system-test/2-query/ceil.py

@@ -14,6 +14,7 @@ class TDTestCase:
     # "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"udfDebugFlag":143}
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/char_length.py

@@ -27,6 +27,7 @@ TS_TYPE_COL = [TS_COL]
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/check_tsdb.py

@@ -13,6 +13,7 @@ class TDTestCase:
     # "jniDebugFlag":143 ,"simDebugFlag":143,"dDebugFlag":143, "dDebugFlag":143,"vDebugFlag":143,"mDebugFlag":143,"qDebugFlag":143,
     # "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"udfDebugFlag":143}
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor(), False)
 

tests/system-test/2-query/concat.py

@@ -27,6 +27,7 @@ TS_TYPE_COL = [ TS_COL, ]
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/concat2.py

@@ -27,6 +27,7 @@ TS_TYPE_COL = [ TS_COL, ]
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/concat_ws.py

@@ -27,6 +27,7 @@ TS_TYPE_COL = [ TS_COL, ]
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/concat_ws2.py

@@ -27,6 +27,7 @@ TS_TYPE_COL = [ TS_COL, ]
 class TDTestCase:
 
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/cos.py

@@ -13,6 +13,7 @@ class TDTestCase:
     # "jniDebugFlag":143 ,"simDebugFlag":143,"dDebugFlag":143, "dDebugFlag":143,"vDebugFlag":143,"mDebugFlag":143,"qDebugFlag":143,
     # "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"udfDebugFlag":143}
     def init(self, conn,  logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug(f"start to excute {__file__}")
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/count.py

@@ -4,6 +4,7 @@ from util.cases import *
 from util.sqlset import *
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(),False)
         self.setsql = TDSetSql()

tests/system-test/2-query/count_partition.py

@@ -5,6 +5,7 @@ from util.cases import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor())
 

tests/system-test/2-query/csum.py

@@ -27,6 +27,7 @@ from util.dnodes import *
 
 class TDTestCase:
     def init(self, conn, logSql, replicaVar=1):
+        self.replicaVar = int(replicaVar)
         tdLog.debug("start to execute %s" % __file__)
         tdSql.init(conn.cursor(), logSql)