test:modify base version 3100 in rollingup cases
This commit is contained in:
parent
d7116f7758
commit
0b88efdee9
|
@ -452,7 +452,7 @@
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeRestartDnodeInsertDataAsync.py -N 6 -M 3
|
,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeRestartDnodeInsertDataAsync.py -N 6 -M 3
|
||||||
#,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeRestartDnodeInsertDataAsync.py -N 6 -M 3 -n 3
|
#,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeRestartDnodeInsertDataAsync.py -N 6 -M 3 -n 3
|
||||||
,,n,system-test,python3 ./test.py -f 6-cluster/manually-test/6dnode3mnodeInsertLessDataAlterRep3to1to3.py -N 6 -M 3
|
,,n,system-test,python3 ./test.py -f 6-cluster/manually-test/6dnode3mnodeInsertLessDataAlterRep3to1to3.py -N 6 -M 3
|
||||||
#,,n,system-test,python ./test.py -f 6-cluster/5dnode3mnodeRoll.py -N 3 -C 1
|
,,n,system-test,python ./test.py -f 6-cluster/5dnode3mnodeRoll.py -N 3 -C 1
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeAdd1Ddnoe.py -N 7 -M 3 -C 6
|
,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeAdd1Ddnoe.py -N 7 -M 3 -C 6
|
||||||
,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeAdd1Ddnoe.py -N 7 -M 3 -C 6 -n 3
|
,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeAdd1Ddnoe.py -N 7 -M 3 -C 6 -n 3
|
||||||
#,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeDrop.py -N 5
|
#,,y,system-test,./pytest.sh python3 ./test.py -f 6-cluster/5dnode3mnodeDrop.py -N 5
|
||||||
|
|
|
@ -198,7 +198,8 @@ class TDTestCase:
|
||||||
|
|
||||||
# checkout deleted data
|
# checkout deleted data
|
||||||
tdsql.execute("insert into deldata.ct1 values ( now()-0s, 0, 0, 0, 0, 0.0, 0.0, 0, 'binary0', 'nchar0', now()+0a ) ( now()-10s, 1, 11111, 111, 11, 1.11, 11.11, 1, 'binary1', 'nchar1', now()+1a ) ( now()-20s, 2, 22222, 222, 22, 2.22, 22.22, 0, 'binary2', 'nchar2', now()+2a ) ( now()-30s, 3, 33333, 333, 33, 3.33, 33.33, 1, 'binary3', 'nchar3', now()+3a );")
|
tdsql.execute("insert into deldata.ct1 values ( now()-0s, 0, 0, 0, 0, 0.0, 0.0, 0, 'binary0', 'nchar0', now()+0a ) ( now()-10s, 1, 11111, 111, 11, 1.11, 11.11, 1, 'binary1', 'nchar1', now()+1a ) ( now()-20s, 2, 22222, 222, 22, 2.22, 22.22, 0, 'binary2', 'nchar2', now()+2a ) ( now()-30s, 3, 33333, 333, 33, 3.33, 33.33, 1, 'binary3', 'nchar3', now()+3a );")
|
||||||
tdsql.query("flush database deldata;select avg(c1) from deldata.ct1;")
|
tdsql.execute("flush database deldata;")
|
||||||
|
tdsql.query("select avg(c1) from deldata.ct1;")
|
||||||
|
|
||||||
|
|
||||||
tdsql=tdCom.newTdSql()
|
tdsql=tdCom.newTdSql()
|
||||||
|
|
|
@ -27,7 +27,7 @@ import threading
|
||||||
import time
|
import time
|
||||||
import json
|
import json
|
||||||
|
|
||||||
BASEVERSION = "3.0.7.0"
|
BASEVERSION = "3.1.0.0"
|
||||||
|
|
||||||
class TDTestCase:
|
class TDTestCase:
|
||||||
|
|
||||||
|
@ -245,6 +245,9 @@ class TDTestCase:
|
||||||
os.system("LD_LIBRARY_PATH=/usr/lib taos -f 0-others/TS-3131.tsql")
|
os.system("LD_LIBRARY_PATH=/usr/lib taos -f 0-others/TS-3131.tsql")
|
||||||
# self.buildTaosd(bPath)
|
# self.buildTaosd(bPath)
|
||||||
|
|
||||||
|
# add deleted data
|
||||||
|
os.system("LD_LIBRARY_PATH=/usr/lib taos -f 0-others/deletedData.sql")
|
||||||
|
|
||||||
threads=[]
|
threads=[]
|
||||||
threads.append(threading.Thread(target=self.insertAllData, args=(cPath_temp,dbname,tableNumbers1,recordNumbers1)))
|
threads.append(threading.Thread(target=self.insertAllData, args=(cPath_temp,dbname,tableNumbers1,recordNumbers1)))
|
||||||
for tr in threads:
|
for tr in threads:
|
||||||
|
@ -285,6 +288,11 @@ class TDTestCase:
|
||||||
tdsql1.query(f"select count(*) from db4096.stb0")
|
tdsql1.query(f"select count(*) from db4096.stb0")
|
||||||
tdsql1.checkData(0,0,50000)
|
tdsql1.checkData(0,0,50000)
|
||||||
|
|
||||||
|
# checkout deleted data
|
||||||
|
tdsql.execute("insert into deldata.ct1 values ( now()-0s, 0, 0, 0, 0, 0.0, 0.0, 0, 'binary0', 'nchar0', now()+0a ) ( now()-10s, 1, 11111, 111, 11, 1.11, 11.11, 1, 'binary1', 'nchar1', now()+1a ) ( now()-20s, 2, 22222, 222, 22, 2.22, 22.22, 0, 'binary2', 'nchar2', now()+2a ) ( now()-30s, 3, 33333, 333, 33, 3.33, 33.33, 1, 'binary3', 'nchar3', now()+3a );")
|
||||||
|
tdsql.query("flush database deldata;select avg(c1) from deldata.ct1;")
|
||||||
|
|
||||||
|
|
||||||
# tdsql1.query("show streams;")
|
# tdsql1.query("show streams;")
|
||||||
# tdsql1.checkRows(2)
|
# tdsql1.checkRows(2)
|
||||||
tdsql1.query("select *,tbname from d0.almlog where mcid='m0103';")
|
tdsql1.query("select *,tbname from d0.almlog where mcid='m0103';")
|
||||||
|
|
Loading…
Reference in New Issue