Skip to content

T
TDengine

taosdata / TDengine
1 年多 前同步成功

通知 1185
Star 22016
Fork 4786
T
TDengine
未验证 提交 175aa665 编写于 作者: haoranc's avatar haoranc 提交者： GitHub
浏览文件
操作

Update compatibility.py

上级 b3657f6e
隐藏空白更改
内联 并排
Showing with 65 addition and 65 deletion
tests/system-test/0-others/compatibility.py
浏览文件 @ 175aa665
...@@ -84,71 +84,71 @@ class TDTestCase: ...@@ -84,71 +84,71 @@ class TDTestCase:
tableNumbers=100 tableNumbers=100
recordNumbers1=100 recordNumbers1=100
recordNumbers2=1000 recordNumbers2=1000
tdsqlF=tdCom.newTdSql() # tdsqlF=tdCom.newTdSql()
print(tdsqlF) # print(tdsqlF)
tdsqlF.query(f"SELECT SERVER_VERSION();") # tdsqlF.query(f"SELECT SERVER_VERSION();")
print(tdsqlF.query(f"SELECT SERVER_VERSION();")) # print(tdsqlF.query(f"SELECT SERVER_VERSION();"))
oldServerVersion=tdsqlF.queryResult[0][0] # oldServerVersion=tdsqlF.queryResult[0][0]
tdLog.info(f"Base server version is {oldServerVersion}") # tdLog.info(f"Base server version is {oldServerVersion}")
tdsqlF.query(f"SELECT CLIENT_VERSION();") # tdsqlF.query(f"SELECT CLIENT_VERSION();")
# the oldClientVersion can't be updated in the same python process,so the version is new compiled verison # # the oldClientVersion can't be updated in the same python process,so the version is new compiled verison
oldClientVersion=tdsqlF.queryResult[0][0] # oldClientVersion=tdsqlF.queryResult[0][0]
tdLog.info(f"Base client version is {oldClientVersion}") # tdLog.info(f"Base client version is {oldClientVersion}")
tdLog.printNoPrefix(f"==========step1:prepare and check data in old version-{oldServerVersion}") # tdLog.printNoPrefix(f"==========step1:prepare and check data in old version-{oldServerVersion}")
tdLog.info(f"taosBenchmark -t {tableNumbers} -n {recordNumbers1} -y ") # tdLog.info(f"taosBenchmark -t {tableNumbers} -n {recordNumbers1} -y ")
os.system(f"taosBenchmark -t {tableNumbers} -n {recordNumbers1} -y ") # os.system(f"taosBenchmark -t {tableNumbers} -n {recordNumbers1} -y ")
sleep(3) # sleep(3)
# tdsqlF.query(f"select count(*) from {stb}") # # tdsqlF.query(f"select count(*) from {stb}")
# tdsqlF.checkData(0,0,tableNumbers*recordNumbers1) # # tdsqlF.checkData(0,0,tableNumbers*recordNumbers1)
os.system("pkill taosd") # os.system("pkill taosd")
sleep(1) # sleep(1)
tdLog.printNoPrefix("==========step2:update new version ") # tdLog.printNoPrefix("==========step2:update new version ")
self.buildTaosd(bPath) # self.buildTaosd(bPath)
tdDnodes.start(1) # tdDnodes.start(1)
sleep(1) # sleep(1)
tdsql=tdCom.newTdSql() # tdsql=tdCom.newTdSql()
print(tdsql) # print(tdsql)
tdsql.query(f"SELECT SERVER_VERSION();") # tdsql.query(f"SELECT SERVER_VERSION();")
nowServerVersion=tdsql.queryResult[0][0] # nowServerVersion=tdsql.queryResult[0][0]
tdLog.info(f"New server version is {nowServerVersion}") # tdLog.info(f"New server version is {nowServerVersion}")
tdsql.query(f"SELECT CLIENT_VERSION();") # tdsql.query(f"SELECT CLIENT_VERSION();")
nowClientVersion=tdsql.queryResult[0][0] # nowClientVersion=tdsql.queryResult[0][0]
tdLog.info(f"New client version is {nowClientVersion}") # tdLog.info(f"New client version is {nowClientVersion}")
tdLog.printNoPrefix(f"==========step3:prepare and check data in new version-{nowServerVersion}") # tdLog.printNoPrefix(f"==========step3:prepare and check data in new version-{nowServerVersion}")
tdsql.query(f"select count(*) from {stb}") # tdsql.query(f"select count(*) from {stb}")
tdsql.checkData(0,0,tableNumbers*recordNumbers1) # tdsql.checkData(0,0,tableNumbers*recordNumbers1)
os.system(f"taosBenchmark -t {tableNumbers} -n {recordNumbers2} -y ") # os.system(f"taosBenchmark -t {tableNumbers} -n {recordNumbers2} -y ")
tdsql.query(f"select count(*) from {stb}") # tdsql.query(f"select count(*) from {stb}")
tdsql.checkData(0,0,tableNumbers*recordNumbers2) # tdsql.checkData(0,0,tableNumbers*recordNumbers2)
tdsql=tdCom.newTdSql() # tdsql=tdCom.newTdSql()
tdLog.printNoPrefix(f"==========step4:verify backticks in taos Sql-TD18542") # tdLog.printNoPrefix(f"==========step4:verify backticks in taos Sql-TD18542")
tdsql.execute("drop database if exists db") # tdsql.execute("drop database if exists db")
tdsql.execute("create database db") # tdsql.execute("create database db")
tdsql.execute("use db") # tdsql.execute("use db")
tdsql.execute("create stable db.stb1 (ts timestamp, c1 int) tags (t1 int);") # tdsql.execute("create stable db.stb1 (ts timestamp, c1 int) tags (t1 int);")
tdsql.execute("insert into db.ct1 using db.stb1 TAGS(1) values(now(),11);") # tdsql.execute("insert into db.ct1 using db.stb1 TAGS(1) values(now(),11);")
tdsql.error(" insert into `db.ct2` using db.stb1 TAGS(9) values(now(),11);") # tdsql.error(" insert into `db.ct2` using db.stb1 TAGS(9) values(now(),11);")
tdsql.error(" insert into db.`db.ct2` using db.stb1 TAGS(9) values(now(),11);") # tdsql.error(" insert into db.`db.ct2` using db.stb1 TAGS(9) values(now(),11);")
tdsql.execute("insert into `db`.ct3 using db.stb1 TAGS(3) values(now(),13);") # tdsql.execute("insert into `db`.ct3 using db.stb1 TAGS(3) values(now(),13);")
tdsql.query("select * from db.ct3") # tdsql.query("select * from db.ct3")
tdsql.checkData(0,1,13) # tdsql.checkData(0,1,13)
tdsql.execute("insert into db.`ct4` using db.stb1 TAGS(4) values(now(),14);") # tdsql.execute("insert into db.`ct4` using db.stb1 TAGS(4) values(now(),14);")
tdsql.query("select * from db.ct4") # tdsql.query("select * from db.ct4")
tdsql.checkData(0,1,14) # tdsql.checkData(0,1,14)
tdsql.query("describe information_schema.ins_databases;") # tdsql.query("describe information_schema.ins_databases;")
qRows=tdsql.queryRows # qRows=tdsql.queryRows
for i in range(qRows) : # for i in range(qRows) :
if tdsql.queryResult[i][0]=="retentions" : # if tdsql.queryResult[i][0]=="retentions" :
return True # return True
else: # else:
return False # return False
def stop(self): def stop(self):
tdSql.close() tdSql.close()
tdLog.success(f"{__file__} successfully executed") tdLog.success(f"{__file__} successfully executed")
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或