Skip to content

T
TDengine

小楼昨夜-听风雨 / TDengine
与 Fork 源项目一致

Fork自 taosdata / TDengine

通知 1
Star 0
Fork 0
T
TDengine

体验新版 GitCode，发现更多精彩内容 >>

提交 6e4702f0 编写于 作者: L liuyq-617
浏览文件
操作

add test case for update

上级 d6e3486c
显示空白变更内容
内联 并排
Showing with 0 addition and 51 deletion
tests/pytest/update/append_commit_data.py
浏览文件 @ 6e4702f0
...@@ -46,9 +46,7 @@ class TDTestCase: ...@@ -46,9 +46,7 @@ class TDTestCase:
print("==========step2") print("==========step2")
print("restart to commit ") print("restart to commit ")
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from db.t1") tdSql.query("select * from db.t1")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for k in range(0,100): for k in range(0,100):
...@@ -59,9 +57,7 @@ class TDTestCase: ...@@ -59,9 +57,7 @@ class TDTestCase:
(t0+k*200+i) (t0+k*200+i)
) )
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from db.t1") tdSql.query("select * from db.t1")
tdSql.checkRows(insertRows+200*k) tdSql.checkRows(insertRows+200*k)
print("==========step2") print("==========step2")
...@@ -75,9 +71,7 @@ class TDTestCase: ...@@ -75,9 +71,7 @@ class TDTestCase:
'insert into t2 values (%d, 1)' % 'insert into t2 values (%d, 1)' %
(t0+i)) (t0+i))
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t2") tdSql.query("select * from t2")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
......
tests/pytest/update/merge_commit_data.py
浏览文件 @ 6e4702f0
...@@ -44,9 +44,7 @@ class TDTestCase: ...@@ -44,9 +44,7 @@ class TDTestCase:
'insert into t1 values (%d , 1)' % 'insert into t1 values (%d , 1)' %
(t0 + i)) (t0 + i))
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t1") tdSql.query("select * from t1")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
...@@ -75,9 +73,6 @@ class TDTestCase: ...@@ -75,9 +73,6 @@ class TDTestCase:
tdSql.query("select * from t2") tdSql.query("select * from t2")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t2") tdSql.query("select * from t2")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(-100,0): for i in range(-100,0):
...@@ -87,9 +82,7 @@ class TDTestCase: ...@@ -87,9 +82,7 @@ class TDTestCase:
tdSql.query("select * from t2") tdSql.query("select * from t2")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t2") tdSql.query("select * from t2")
tdSql.checkRows(insertRows+100) tdSql.checkRows(insertRows+100)
print("==========step3") print("==========step3")
...@@ -103,9 +96,7 @@ class TDTestCase: ...@@ -103,9 +96,7 @@ class TDTestCase:
tdSql.query("select * from t3") tdSql.query("select * from t3")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t3") tdSql.query("select * from t3")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(-6000,0): for i in range(-6000,0):
...@@ -115,9 +106,7 @@ class TDTestCase: ...@@ -115,9 +106,7 @@ class TDTestCase:
tdSql.query("select * from t3") tdSql.query("select * from t3")
tdSql.checkRows(insertRows+6000) tdSql.checkRows(insertRows+6000)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t3") tdSql.query("select * from t3")
tdSql.checkRows(insertRows+6000) tdSql.checkRows(insertRows+6000)
print("==========step4") print("==========step4")
...@@ -131,9 +120,7 @@ class TDTestCase: ...@@ -131,9 +120,7 @@ class TDTestCase:
tdSql.query("select * from t4") tdSql.query("select * from t4")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t4") tdSql.query("select * from t4")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(0,100): for i in range(0,100):
...@@ -143,9 +130,7 @@ class TDTestCase: ...@@ -143,9 +130,7 @@ class TDTestCase:
tdSql.query("select * from t4") tdSql.query("select * from t4")
tdSql.checkRows(insertRows+100) tdSql.checkRows(insertRows+100)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t4") tdSql.query("select * from t4")
tdSql.checkRows(insertRows+100) tdSql.checkRows(insertRows+100)
print("==========step5") print("==========step5")
...@@ -159,9 +144,7 @@ class TDTestCase: ...@@ -159,9 +144,7 @@ class TDTestCase:
tdSql.query("select * from t5") tdSql.query("select * from t5")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t5") tdSql.query("select * from t5")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(0,6000): for i in range(0,6000):
...@@ -171,9 +154,7 @@ class TDTestCase: ...@@ -171,9 +154,7 @@ class TDTestCase:
tdSql.query("select * from t5") tdSql.query("select * from t5")
tdSql.checkRows(insertRows+6000) tdSql.checkRows(insertRows+6000)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t5") tdSql.query("select * from t5")
tdSql.checkRows(insertRows+6000) tdSql.checkRows(insertRows+6000)
print("==========step6") print("==========step6")
...@@ -187,9 +168,7 @@ class TDTestCase: ...@@ -187,9 +168,7 @@ class TDTestCase:
tdSql.query("select * from t6") tdSql.query("select * from t6")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t6") tdSql.query("select * from t6")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(0,100): for i in range(0,100):
...@@ -201,9 +180,7 @@ class TDTestCase: ...@@ -201,9 +180,7 @@ class TDTestCase:
tdSql.query("select sum(a) from t6") tdSql.query("select sum(a) from t6")
tdSql.checkData(0,0,'300') tdSql.checkData(0,0,'300')
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t6") tdSql.query("select * from t6")
tdSql.checkRows(insertRows+100) tdSql.checkRows(insertRows+100)
tdSql.query("select sum(a) from t6") tdSql.query("select sum(a) from t6")
...@@ -217,9 +194,7 @@ class TDTestCase: ...@@ -217,9 +194,7 @@ class TDTestCase:
tdSql.query("select sum(a) from t6") tdSql.query("select sum(a) from t6")
tdSql.checkData(0,0,'400') tdSql.checkData(0,0,'400')
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t6") tdSql.query("select * from t6")
tdSql.checkRows(insertRows+200) tdSql.checkRows(insertRows+200)
tdSql.query("select sum(a) from t6") tdSql.query("select sum(a) from t6")
...@@ -235,9 +210,7 @@ class TDTestCase: ...@@ -235,9 +210,7 @@ class TDTestCase:
tdSql.query("select * from t7") tdSql.query("select * from t7")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t7") tdSql.query("select * from t7")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(100,300): for i in range(100,300):
...@@ -249,9 +222,7 @@ class TDTestCase: ...@@ -249,9 +222,7 @@ class TDTestCase:
tdSql.query("select sum(a) from t7") tdSql.query("select sum(a) from t7")
tdSql.checkData(0,0,'500') tdSql.checkData(0,0,'500')
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t7") tdSql.query("select * from t7")
tdSql.checkRows(insertRows+100) tdSql.checkRows(insertRows+100)
tdSql.query("select sum(a) from t7") tdSql.query("select sum(a) from t7")
...@@ -267,9 +238,7 @@ class TDTestCase: ...@@ -267,9 +238,7 @@ class TDTestCase:
tdSql.query("select * from t8") tdSql.query("select * from t8")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t8") tdSql.query("select * from t8")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(6000): for i in range(6000):
...@@ -281,9 +250,7 @@ class TDTestCase: ...@@ -281,9 +250,7 @@ class TDTestCase:
tdSql.query("select sum(a) from t8") tdSql.query("select sum(a) from t8")
tdSql.checkData(0,0,'12000') tdSql.checkData(0,0,'12000')
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t8") tdSql.query("select * from t8")
tdSql.checkRows(6000) tdSql.checkRows(6000)
tdSql.query("select sum(a) from t8") tdSql.query("select sum(a) from t8")
...@@ -299,9 +266,7 @@ class TDTestCase: ...@@ -299,9 +266,7 @@ class TDTestCase:
tdSql.query("select * from t9") tdSql.query("select * from t9")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t9") tdSql.query("select * from t9")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(-100,100): for i in range(-100,100):
...@@ -313,9 +278,7 @@ class TDTestCase: ...@@ -313,9 +278,7 @@ class TDTestCase:
tdSql.query("select sum(a) from t9") tdSql.query("select sum(a) from t9")
tdSql.checkData(0,0,'500') tdSql.checkData(0,0,'500')
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t9") tdSql.query("select * from t9")
tdSql.checkRows(300) tdSql.checkRows(300)
tdSql.query("select sum(a) from t9") tdSql.query("select sum(a) from t9")
...@@ -331,9 +294,7 @@ class TDTestCase: ...@@ -331,9 +294,7 @@ class TDTestCase:
tdSql.query("select * from t10") tdSql.query("select * from t10")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t10") tdSql.query("select * from t10")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(-6000,100): for i in range(-6000,100):
...@@ -345,9 +306,7 @@ class TDTestCase: ...@@ -345,9 +306,7 @@ class TDTestCase:
tdSql.query("select sum(a) from t10") tdSql.query("select sum(a) from t10")
tdSql.checkData(0,0,'12300') tdSql.checkData(0,0,'12300')
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t10") tdSql.query("select * from t10")
tdSql.checkRows(6200) tdSql.checkRows(6200)
tdSql.query("select sum(a) from t10") tdSql.query("select sum(a) from t10")
...@@ -363,9 +322,7 @@ class TDTestCase: ...@@ -363,9 +322,7 @@ class TDTestCase:
tdSql.query("select * from t11") tdSql.query("select * from t11")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t11") tdSql.query("select * from t11")
tdSql.checkRows(insertRows) tdSql.checkRows(insertRows)
for i in range(100): for i in range(100):
...@@ -381,9 +338,7 @@ class TDTestCase: ...@@ -381,9 +338,7 @@ class TDTestCase:
tdSql.query("select sum(a) from t11") tdSql.query("select sum(a) from t11")
tdSql.checkData(0,0,'11500') tdSql.checkData(0,0,'11500')
tdDnodes.stop(1) tdDnodes.stop(1)
time.sleep(5)
tdDnodes.start(1) tdDnodes.start(1)
time.sleep(5)
tdSql.query("select * from t11") tdSql.query("select * from t11")
tdSql.checkRows(6000) tdSql.checkRows(6000)
tdSql.query("select sum(a) from t11") tdSql.query("select sum(a) from t11")
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或