test:add testcase of taosd command
This commit is contained in:
chenhaoran
parent
7db984bdc4
commit
a8002d7541
|
|
@ -0,0 +1,468 @@
|
|||
|
||||
import taos
|
||||
import sys
|
||||
import time
|
||||
import socket
|
||||
import os
|
||||
import platform
|
||||
if platform.system().lower() == 'windows':
|
||||
import wexpect as taosExpect
|
||||
else:
|
||||
import pexpect as taosExpect
|
||||
|
||||
from util.log import *
|
||||
from util.sql import *
|
||||
from util.cases import *
|
||||
from util.dnodes import *
|
||||
|
||||
class TDTestCase:
|
||||
#updatecfgDict = {'clientCfg': {'serverPort': 7080, 'firstEp': 'trd02:7080', 'secondEp':'trd02:7080'},\
|
||||
# 'serverPort': 7080, 'firstEp': 'trd02:7080'}
|
||||
# hostname = socket.gethostname()
|
||||
# if (platform.system().lower() == 'windows' and not tdDnodes.dnodes[0].remoteIP == ""):
|
||||
# try:
|
||||
# config = eval(tdDnodes.dnodes[0].remoteIP)
|
||||
# hostname = config["host"]
|
||||
# except Exception:
|
||||
# hostname = tdDnodes.dnodes[0].remoteIP
|
||||
# serverPort = '7080'
|
||||
# rpcDebugFlagVal = '143'
|
||||
# clientCfgDict = {'serverPort': '', 'firstEp': '', 'secondEp':'', 'rpcDebugFlag':'135', 'fqdn':''}
|
||||
# clientCfgDict["serverPort"] = serverPort
|
||||
# clientCfgDict["firstEp"] = hostname + ':' + serverPort
|
||||
# clientCfgDict["secondEp"] = hostname + ':' + serverPort
|
||||
# clientCfgDict["rpcDebugFlag"] = rpcDebugFlagVal
|
||||
# clientCfgDict["fqdn"] = hostname
|
||||
|
||||
# updatecfgDict = {'clientCfg': {}, 'serverPort': '', 'firstEp': '', 'secondEp':'', 'rpcDebugFlag':'135', 'fqdn':''}
|
||||
# updatecfgDict["clientCfg"] = clientCfgDict
|
||||
# updatecfgDict["serverPort"] = serverPort
|
||||
# updatecfgDict["firstEp"] = hostname + ':' + serverPort
|
||||
# updatecfgDict["secondEp"] = hostname + ':' + serverPort
|
||||
# updatecfgDict["fqdn"] = hostname
|
||||
|
||||
# print ("===================: ", updatecfgDict)
|
||||
|
||||
def init(self, conn, logSql):
|
||||
tdLog.debug(f"start to excute {__file__}")
|
||||
tdSql.init(conn.cursor())
|
||||
|
||||
def getBuildPath(self):
|
||||
selfPath = os.path.dirname(os.path.realpath(__file__))
|
||||
|
||||
if ("community" in selfPath):
|
||||
projPath = selfPath[:selfPath.find("community")]
|
||||
else:
|
||||
projPath = selfPath[:selfPath.find("tests")]
|
||||
|
||||
for root, dirs, files in os.walk(projPath):
|
||||
if ("taosd" in files or "taosd.exe" 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 get_process_pid(self,processname):
|
||||
#origin artical link：https://blog.csdn.net/weixin_45623536/article/details/122099062
|
||||
process_info_list = []
|
||||
process = os.popen('ps -A | grep %s'% processname)
|
||||
process_info = process.read()
|
||||
for i in process_info.split(' '):
|
||||
if i != "":
|
||||
process_info_list.append(i)
|
||||
print(process_info_list)
|
||||
if len(process_info_list) != 0 :
|
||||
pid = int(process_info_list[0])
|
||||
else :
|
||||
pid = 0
|
||||
return pid
|
||||
|
||||
def checkAndstopPro(self,processName,startAction):
|
||||
i = 1
|
||||
count = 10
|
||||
for i in range(count):
|
||||
taosdPid=self.get_process_pid(processName)
|
||||
if taosdPid != 0 and taosdPid != "" :
|
||||
tdLog.info("stop taosd %s ,kill pid :%s "%(startAction,taosdPid))
|
||||
os.system("kill -9 %d"%taosdPid)
|
||||
break
|
||||
else:
|
||||
tdLog.info( "wait start taosd ,times: %d "%i)
|
||||
sleep
|
||||
i+= 1
|
||||
else :
|
||||
tdLog.exit("taosd %s is not running "%startAction)
|
||||
|
||||
def taosdCommandStop(self,startAction,taosdCmdRun):
|
||||
processName="taosd"
|
||||
taosdCmd = taosdCmdRun + startAction
|
||||
tdLog.printNoPrefix("%s"%taosdCmd)
|
||||
os.system(f"nohup {taosdCmd} & ")
|
||||
self.checkAndstopPro(processName,startAction)
|
||||
|
||||
def taosdCommandExe(self,startAction,taosdCmdRun):
|
||||
taosdCmd = taosdCmdRun + startAction
|
||||
tdLog.printNoPrefix("%s"%taosdCmd)
|
||||
os.system(f"{taosdCmd}")
|
||||
|
||||
def run(self):
|
||||
tdSql.prepare()
|
||||
# time.sleep(2)
|
||||
tdSql.query("create user testpy pass 'testpy'")
|
||||
|
||||
#hostname = socket.gethostname()
|
||||
#tdLog.info ("hostname: %s" % hostname)
|
||||
|
||||
buildPath = self.getBuildPath()
|
||||
if (buildPath == ""):
|
||||
tdLog.exit("taosd not found!")
|
||||
else:
|
||||
tdLog.info("taosd found in %s" % buildPath)
|
||||
cfgPath = buildPath + "/../sim/psim/cfg"
|
||||
taosdCfgPath = buildPath + "/../sim/dnode1/cfg"
|
||||
|
||||
|
||||
taosdCmdRun= buildPath + '/build/bin/taosd'
|
||||
tdLog.info("cfgPath: %s" % cfgPath)
|
||||
# keyDict['h'] = self.hostname
|
||||
# keyDict['c'] = cfgPath
|
||||
# keyDict['P'] = self.serverPort
|
||||
tdDnodes.stop(1)
|
||||
|
||||
startAction = " --help"
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
self.taosdCommandExe(startAction,taosdCmdRun)
|
||||
|
||||
startAction = " -h"
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
self.taosdCommandExe(startAction,taosdCmdRun)
|
||||
|
||||
startAction=" -a jsonFile:./taosdCaseTmp.json"
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
os.system("echo \'{\"queryPolicy\":\"3\"}\' > taosdCaseTmp.json")
|
||||
self.taosdCommandStop(startAction,taosdCmdRun)
|
||||
|
||||
startAction = " -a jsonFile:./taosdCaseTmp.json -C "
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
self.taosdCommandExe(startAction,taosdCmdRun)
|
||||
|
||||
os.system("rm -rf taosdCaseTmp.json")
|
||||
|
||||
startAction = " -c " + taosdCfgPath
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
self.taosdCommandStop(startAction,taosdCmdRun)
|
||||
|
||||
startAction = " -s"
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
self.taosdCommandExe(startAction,taosdCmdRun)
|
||||
|
||||
startAction = " -e TAOS_QUERY_POLICY=2 "
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
self.taosdCommandStop(startAction,taosdCmdRun)
|
||||
|
||||
|
||||
startAction=" -E taosdCaseTmp/.env"
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
os.system(" mkdir -p taosdCaseTmp/.env ")
|
||||
os.system("echo \'TAOS_QUERY_POLICY=3\' > taosdCaseTmp/.env ")
|
||||
self.taosdCommandStop(startAction,taosdCmdRun)
|
||||
os.system(" rm -rf taosdCaseTmp/.env ")
|
||||
|
||||
startAction = " -V"
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
self.taosdCommandExe(startAction,taosdCmdRun)
|
||||
|
||||
startAction = " -k"
|
||||
tdLog.printNoPrefix("================================ parameter: %s"%startAction)
|
||||
self.taosdCommandExe(startAction,taosdCmdRun)
|
||||
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -h %s fail"%keyDict['h'])
|
||||
# else:
|
||||
# #dataDbName = ["information_schema", "performance_schema", "db", newDbName]
|
||||
# tdSql.query("select * from information_schema.ins_databases")
|
||||
# #tdSql.getResult("select * from information_schema.ins_databases")
|
||||
# for i in range(tdSql.queryRows):
|
||||
# if tdSql.getData(i, 0) == newDbName:
|
||||
# break
|
||||
# else:
|
||||
# tdLog.exit("create db fail after taos -h %s fail"%keyDict['h'])
|
||||
|
||||
# tdSql.query('drop database %s'%newDbName)
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -P")
|
||||
# #tdDnodes.stop(1)
|
||||
# #sleep(3)
|
||||
# #tdDnodes.start(1)
|
||||
# #sleep(3)
|
||||
# #keyDict['P'] = 6030
|
||||
# newDbName = "dbpp"
|
||||
# sqlString = 'create database ' + newDbName + ';'
|
||||
# retCode = taos_command(buildPath, "P", keyDict['P'], "taos>", keyDict['c'], sqlString)
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -P %s fail"%keyDict['P'])
|
||||
# else:
|
||||
# tdSql.query("select * from information_schema.ins_databases")
|
||||
# for i in range(tdSql.queryRows):
|
||||
# if tdSql.getData(i, 0) == newDbName:
|
||||
# break
|
||||
# else:
|
||||
# tdLog.exit("create db fail after taos -P %s fail"%keyDict['P'])
|
||||
|
||||
# tdSql.query('drop database %s'%newDbName)
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -u")
|
||||
# newDbName="dbu"
|
||||
# sqlString = 'create database ' + newDbName + ';'
|
||||
# retCode = taos_command(buildPath, "u", keyDict['u'], "taos>", keyDict['c'], sqlString, "p", keyDict['p'])
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -u %s -p%s fail"%(keyDict['u'], keyDict['p']))
|
||||
# else:
|
||||
# tdSql.query("select * from information_schema.ins_databases")
|
||||
# for i in range(tdSql.queryRows):
|
||||
# if tdSql.getData(i, 0) == newDbName:
|
||||
# break
|
||||
# else:
|
||||
# tdLog.exit("create db fail after taos -u %s -p%s fail"%(keyDict['u'], keyDict['p']))
|
||||
|
||||
# tdSql.query('drop database %s'%newDbName)
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -A")
|
||||
# newDbName="dbaa"
|
||||
# retCode, retVal = taos_command(buildPath, "p", keyDict['p'], "taos>", keyDict['c'], '', "A", '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -A fail")
|
||||
|
||||
# sqlString = 'create database ' + newDbName + ';'
|
||||
# retCode = taos_command(buildPath, "u", keyDict['u'], "taos>", keyDict['c'], sqlString, 'a', retVal)
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -u %s -a %s"%(keyDict['u'], retVal))
|
||||
|
||||
# tdSql.query("select * from information_schema.ins_databases")
|
||||
# for i in range(tdSql.queryRows):
|
||||
# if tdSql.getData(i, 0) == newDbName:
|
||||
# break
|
||||
# else:
|
||||
# tdLog.exit("create db fail after taos -u %s -a %s fail"%(keyDict['u'], retVal))
|
||||
|
||||
# tdSql.query('drop database %s'%newDbName)
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -s")
|
||||
# newDbName="dbss"
|
||||
# keyDict['s'] = "\"create database " + newDbName + "\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -s fail")
|
||||
|
||||
# print ("========== check new db ==========")
|
||||
# tdSql.query("select * from information_schema.ins_databases")
|
||||
# for i in range(tdSql.queryRows):
|
||||
# if tdSql.getData(i, 0) == newDbName:
|
||||
# break
|
||||
# else:
|
||||
# tdLog.exit("create db fail after taos -s %s fail"%(keyDict['s']))
|
||||
|
||||
# keyDict['s'] = "\"create table " + newDbName + ".stb (ts timestamp, c int) tags (t int)\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -s create table fail")
|
||||
|
||||
# keyDict['s'] = "\"create table " + newDbName + ".ctb0 using " + newDbName + ".stb tags (0) " + newDbName + ".ctb1 using " + newDbName + ".stb tags (1)\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -s create table fail")
|
||||
|
||||
# keyDict['s'] = "\"insert into " + newDbName + ".ctb0 values('2021-04-01 08:00:00.000', 10)('2021-04-01 08:00:01.000', 20) " + newDbName + ".ctb1 values('2021-04-01 08:00:00.000', 11)('2021-04-01 08:00:01.000', 21)\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -s insert data fail")
|
||||
|
||||
# sqlString = "select * from " + newDbName + ".ctb0"
|
||||
# tdSql.query(sqlString)
|
||||
# tdSql.checkData(0, 0, '2021-04-01 08:00:00.000')
|
||||
# tdSql.checkData(0, 1, 10)
|
||||
# tdSql.checkData(1, 0, '2021-04-01 08:00:01.000')
|
||||
# tdSql.checkData(1, 1, 20)
|
||||
# sqlString = "select * from " + newDbName + ".ctb1"
|
||||
# tdSql.query(sqlString)
|
||||
# tdSql.checkData(0, 0, '2021-04-01 08:00:00.000')
|
||||
# tdSql.checkData(0, 1, 11)
|
||||
# tdSql.checkData(1, 0, '2021-04-01 08:00:01.000')
|
||||
# tdSql.checkData(1, 1, 21)
|
||||
|
||||
# keyDict['s'] = "\"select * from " + newDbName + ".ctb0\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "2021-04-01 08:00:01.000", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -r show fail")
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -r")
|
||||
# keyDict['s'] = "\"select * from " + newDbName + ".ctb0\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "1617235200000", keyDict['c'], '', 'r', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -r show fail")
|
||||
|
||||
# keyDict['s'] = "\"select * from " + newDbName + ".ctb1\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "1617235201000", keyDict['c'], '', 'r', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -r show fail")
|
||||
|
||||
# tdSql.query('drop database %s'%newDbName)
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -f")
|
||||
# pwd=os.getcwd()
|
||||
# newDbName="dbf"
|
||||
# sqlFile = pwd + "/0-others/sql.txt"
|
||||
# sql1 = "echo create database " + newDbName + " > " + sqlFile
|
||||
# sql2 = "echo use " + newDbName + " >> " + sqlFile
|
||||
# if platform.system().lower() == 'windows':
|
||||
# sql3 = "echo create table ntbf (ts timestamp, c binary(40)) >> " + sqlFile
|
||||
# sql4 = "echo insert into ntbf values (\"2021-04-01 08:00:00.000\", \"test taos -f1\")(\"2021-04-01 08:00:01.000\", \"test taos -f2\") >> " + sqlFile
|
||||
# else:
|
||||
# sql3 = "echo 'create table ntbf (ts timestamp, c binary(40))' >> " + sqlFile
|
||||
# sql4 = "echo 'insert into ntbf values (\"2021-04-01 08:00:00.000\", \"test taos -f1\")(\"2021-04-01 08:00:01.000\", \"test taos -f2\")' >> " + sqlFile
|
||||
# sql5 = "echo show databases >> " + sqlFile
|
||||
# os.system(sql1)
|
||||
# os.system(sql2)
|
||||
# os.system(sql3)
|
||||
# os.system(sql4)
|
||||
# os.system(sql5)
|
||||
|
||||
# keyDict['f'] = pwd + "/0-others/sql.txt"
|
||||
# retCode = taos_command(buildPath, "f", keyDict['f'], 'performance_schema', keyDict['c'], '', '', '')
|
||||
# print("============ ret code: ", retCode)
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -f fail")
|
||||
|
||||
# print ("========== check new db ==========")
|
||||
# tdSql.query("select * from information_schema.ins_databases")
|
||||
# for i in range(tdSql.queryRows):
|
||||
# #print ("dbseq: %d, dbname: %s"%(i, tdSql.getData(i, 0)))
|
||||
# if tdSql.getData(i, 0) == newDbName:
|
||||
# break
|
||||
# else:
|
||||
# tdLog.exit("create db fail after taos -f fail")
|
||||
|
||||
# sqlString = "select * from " + newDbName + ".ntbf"
|
||||
# tdSql.query(sqlString)
|
||||
# tdSql.checkData(0, 0, '2021-04-01 08:00:00.000')
|
||||
# tdSql.checkData(0, 1, 'test taos -f1')
|
||||
# tdSql.checkData(1, 0, '2021-04-01 08:00:01.000')
|
||||
# tdSql.checkData(1, 1, 'test taos -f2')
|
||||
|
||||
# shellCmd = "rm -f " + sqlFile
|
||||
# os.system(shellCmd)
|
||||
# tdSql.query('drop database %s'%newDbName)
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -C")
|
||||
# #newDbName="dbcc"
|
||||
# retCode, retVal = taos_command(buildPath, "C", keyDict['C'], "buildinfo", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -C fail")
|
||||
|
||||
|
||||
# #print ("-C return content:\n ", retVal)
|
||||
# totalCfgItem = {"firstEp":['', '', ''], }
|
||||
# for line in retVal.splitlines():
|
||||
# strList = line.split()
|
||||
# if (len(strList) > 2):
|
||||
# totalCfgItem[strList[1]] = strList
|
||||
|
||||
# #print ("dict content:\n ", totalCfgItem)
|
||||
# firstEp = keyDict["h"] + ':' + keyDict['P']
|
||||
# if (totalCfgItem["firstEp"][2] != firstEp) and (totalCfgItem["firstEp"][0] != 'cfg_file'):
|
||||
# tdLog.exit("taos -C return firstEp error!")
|
||||
|
||||
# if (totalCfgItem["rpcDebugFlag"][2] != self.rpcDebugFlagVal) and (totalCfgItem["rpcDebugFlag"][0] != 'cfg_file'):
|
||||
# tdLog.exit("taos -C return rpcDebugFlag error!")
|
||||
|
||||
# count = os.cpu_count()
|
||||
# if (totalCfgItem["numOfCores"][2] != count) and (totalCfgItem["numOfCores"][0] != 'default'):
|
||||
# tdLog.exit("taos -C return numOfCores error!")
|
||||
|
||||
# version = totalCfgItem["version"][2]
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -V")
|
||||
# #newDbName="dbvv"
|
||||
# retCode, retVal = taos_command(buildPath, "V", keyDict['V'], "", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -V fail")
|
||||
|
||||
# version = 'version: ' + version
|
||||
# retVal = retVal.replace("\n", "")
|
||||
# retVal = retVal.replace("\r", "")
|
||||
# if retVal != version:
|
||||
# print ("return version: [%s]"%retVal)
|
||||
# print ("dict version: [%s]"%version)
|
||||
# tdLog.exit("taos -V version not match")
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -d")
|
||||
# newDbName="dbd"
|
||||
# sqlString = 'create database ' + newDbName + ';'
|
||||
# retCode = taos_command(buildPath, "d", keyDict['d'], "taos>", keyDict['c'], sqlString, '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -d %s fail"%(keyDict['d']))
|
||||
# else:
|
||||
# tdSql.query("select * from information_schema.ins_databases")
|
||||
# for i in range(tdSql.queryRows):
|
||||
# if tdSql.getData(i, 0) == newDbName:
|
||||
# break
|
||||
# else:
|
||||
# tdLog.exit("create db fail after taos -d %s fail"%(keyDict['d']))
|
||||
|
||||
# tdSql.query('drop database %s'%newDbName)
|
||||
|
||||
# retCode = taos_command(buildPath, "d", 'dbno', "taos>", keyDict['c'], sqlString, '', '')
|
||||
# if retCode != "TAOS_FAIL":
|
||||
# tdLog.exit("taos -d dbno fail")
|
||||
|
||||
# tdLog.printNoPrefix("================================ parameter: -w")
|
||||
# newDbName="dbw"
|
||||
# keyDict['s'] = "\"create database " + newDbName + "\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -w fail")
|
||||
|
||||
# keyDict['s'] = "\"create table " + newDbName + ".ntb (ts timestamp, c binary(128))\""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -w create table fail")
|
||||
|
||||
# keyDict['s'] = "\"insert into " + newDbName + ".ntb values('2021-04-01 08:00:00.001', 'abcd0123456789')('2021-04-01 08:00:00.002', 'abcd012345678901234567890123456789') \""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -w insert data fail")
|
||||
|
||||
# keyDict['s'] = "\"insert into " + newDbName + ".ntb values('2021-04-01 08:00:00.003', 'aaaaaaaaaaaaaaaaaaaa')('2021-04-01 08:00:01.004', 'bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb') \""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -w insert data fail")
|
||||
|
||||
# keyDict['s'] = "\"insert into " + newDbName + ".ntb values('2021-04-01 08:00:00.005', 'cccccccccccccccccccc')('2021-04-01 08:00:01.006', 'dddddddddddddddddddddddddddddddddddddddd') \""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "Query OK", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -w insert data fail")
|
||||
|
||||
# keyDict['s'] = "\"select * from " + newDbName + ".ntb \""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "aaaaaaaaaaaaaaaaaaaa", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -w insert data fail")
|
||||
|
||||
# keyDict['s'] = "\"select * from " + newDbName + ".ntb \""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "dddddddddddddddddddddddddddddddddddddddd", keyDict['c'], '', '', '')
|
||||
# if retCode != "TAOS_FAIL":
|
||||
# tdLog.exit("taos -w insert data fail")
|
||||
|
||||
# keyDict['s'] = "\"select * from " + newDbName + ".ntb \""
|
||||
# retCode = taos_command(buildPath, "s", keyDict['s'], "dddddddddddddddddddddddddddddddddddddddd", keyDict['c'], '', 'w', '60')
|
||||
# if retCode != "TAOS_OK":
|
||||
# tdLog.exit("taos -w insert data fail")
|
||||
|
||||
# tdSql.query('drop database %s'%newDbName)
|
||||
|
||||
def stop(self):
|
||||
tdSql.close()
|
||||
tdLog.success(f"{__file__} successfully executed")
|
||||
|
||||
tdCases.addLinux(__file__, TDTestCase())
|
||||
tdCases.addWindows(__file__, TDTestCase())
|
||||
Loading…
Reference in New Issue