xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

temp

This commit is contained in:
tomchon 2021-06-09 11:12:42 +08:00
parent 73b6c43496
commit 4949dd4671
2 changed files with 33 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/pytest/tools/taosdemoAllTest/insertRestful.json
View File

@ -40,7 +40,7 @@
"auto_create_table": "no", "auto_create_table": "no",
"batch_create_tbl_num": 10, "batch_create_tbl_num": 10,
"data_source": "rand", "data_source": "rand",
"insert_mode": "restful", "insert_mode": "rest",
"insert_rows": 10, "insert_rows": 10,
"childtable_limit": 0, "childtable_limit": 0,
"childtable_offset":0, "childtable_offset":0,

67
tests/pytest/tools/taosdemoAllTest/taosdemoTestSubWithJson.py
View File

@ -73,49 +73,49 @@ class TDTestCase:
os.system("rm -rf ./subscribe_res*") os.system("rm -rf ./subscribe_res*")
os.system("rm -rf ./all_subscribe_res*") os.system("rm -rf ./all_subscribe_res*")
# # subscribe: sync # subscribe: sync
# os.system("%staosdemo -f tools/taosdemoAllTest/subInsertdata.json" % binPath) os.system("%staosdemo -f tools/taosdemoAllTest/subInsertdata.json" % binPath)
# os.system("nohup %staosdemo -f tools/taosdemoAllTest/subSync.json &" % binPath) os.system("nohup %staosdemo -f tools/taosdemoAllTest/subSync.json &" % binPath)
# query_pid = int(subprocess.getstatusoutput('ps aux|grep "taosdemoAllTest/subSync.json" |grep -v "grep"|awk \'{print $2}\'')[1]) query_pid = int(subprocess.getstatusoutput('ps aux|grep "taosdemoAllTest/subSync.json" |grep -v "grep"|awk \'{print $2}\'')[1])
# # insert extral data # insert extral data
# tdSql.execute("use db") tdSql.execute("use db")
# tdSql.execute("insert into stb00_0 values(1614218412000,'R','bf3',8637,98.861045)") tdSql.execute("insert into stb00_0 values(1614218412000,'R','bf3',8637,98.861045)")
# tdSql.execute("insert into stb00_1 values(1614218412000,'R','bf3',8637,78.861045)(1614218422000,'R','bf3',8637,98.861045)") tdSql.execute("insert into stb00_1 values(1614218412000,'R','bf3',8637,78.861045)(1614218422000,'R','bf3',8637,98.861045)")
# sleep(5) sleep(5)
# # merge result files # merge result files
# os.system("cat subscribe_res0.txt* > all_subscribe_res0.txt") os.system("cat subscribe_res0.txt* > all_subscribe_res0.txt")
# os.system("cat subscribe_res1.txt* > all_subscribe_res1.txt") os.system("cat subscribe_res1.txt* > all_subscribe_res1.txt")
# os.system("cat subscribe_res2.txt* > all_subscribe_res2.txt") os.system("cat subscribe_res2.txt* > all_subscribe_res2.txt")
# os.system("cat subscribe_res3.txt* > all_subscribe_res3.txt") os.system("cat subscribe_res3.txt* > all_subscribe_res3.txt")
# # correct subscribeTimes testcase # correct subscribeTimes testcase
# subTimes0 = self.subTimes("all_subscribe_res0.txt") subTimes0 = self.subTimes("all_subscribe_res0.txt")
# self.assertCheck("all_subscribe_res0.txt",subTimes0 ,22) self.assertCheck("all_subscribe_res0.txt",subTimes0 ,22)
# subTimes1 = self.subTimes("all_subscribe_res1.txt") subTimes1 = self.subTimes("all_subscribe_res1.txt")
# self.assertCheck("all_subscribe_res1.txt",subTimes1 ,24) self.assertCheck("all_subscribe_res1.txt",subTimes1 ,24)
# subTimes2 = self.subTimes("all_subscribe_res2.txt") subTimes2 = self.subTimes("all_subscribe_res2.txt")
# self.assertCheck("all_subscribe_res2.txt",subTimes2 ,21) self.assertCheck("all_subscribe_res2.txt",subTimes2 ,21)
# subTimes3 = self.subTimes("all_subscribe_res3.txt") subTimes3 = self.subTimes("all_subscribe_res3.txt")
# self.assertCheck("all_subscribe_res3.txt",subTimes3 ,13) self.assertCheck("all_subscribe_res3.txt",subTimes3 ,13)
# # correct data testcase # correct data testcase
# os.system("kill -9 %d" % query_pid) os.system("kill -9 %d" % query_pid)
# sleep(3) sleep(3)
# os.system("rm -rf ./subscribe_res*") os.system("rm -rf ./subscribe_res*")
# os.system("rm -rf ./all_subscribe*") os.system("rm -rf ./all_subscribe*")
# sql number lager 100 # sql number lager 100
os.system("%staosdemo -f tools/taosdemoAllTest/subInsertdataMaxsql100.json" % binPath) # os.system("%staosdemo -f tools/taosdemoAllTest/subInsertdataMaxsql100.json" % binPath)
# assert os.system("%staosdemo -f tools/taosdemoAllTest/subSyncSpecMaxsql100.json" % binPath) != 0 # # assert os.system("%staosdemo -f tools/taosdemoAllTest/subSyncSpecMaxsql100.json" % binPath) != 0
# assert os.system("%staosdemo -f tools/taosdemoAllTest/subSyncSuperMaxsql100.json" % binPath) != 0 # # assert os.system("%staosdemo -f tools/taosdemoAllTest/subSyncSuperMaxsql100.json" % binPath) != 0
os.system("%staosdemo -f tools/taosdemoAllTest/subSyncKeepStart.json" % binPath) # os.system("%staosdemo -f tools/taosdemoAllTest/subSyncKeepStart.json" % binPath)
# tdSql.execute("insert into db.stb00_1 values(1614218412000,'R','bf3',8637,78.861045)(1614218413000,'R','bf3',8637,98.861045)") # tdSql.execute("insert into db.stb00_1 values(1614218412000,'R','bf3',8637,78.861045)(1614218413000,'R','bf3',8637,98.861045)")
@ -143,9 +143,6 @@ class TDTestCase:
# delete useless files # delete useless files
os.system("rm -rf ./insert_res.txt") os.system("rm -rf ./insert_res.txt")
os.system("rm -rf tools/taosdemoAllTest/*.py.sql") os.system("rm -rf tools/taosdemoAllTest/*.py.sql")