Merge remote-tracking branch 'origin/develop' into hotfix/crash
This commit is contained in:
Shengliang Guan
commit
1a8c806f55
|
|
@ -24,19 +24,23 @@ last_tb = ""
|
|||
last_stb = ""
|
||||
written = 0
|
||||
last_timestamp = 0
|
||||
colAdded = False
|
||||
killed = False
|
||||
|
||||
|
||||
class Test (Thread):
|
||||
def __init__(self, threadId, name, events):
|
||||
def __init__(self, threadId, name, events, q):
|
||||
Thread.__init__(self)
|
||||
self.threadId = threadId
|
||||
self.name = name
|
||||
self.dataEvent, self.dbEvent, self.queryEvent = events
|
||||
self.q = q
|
||||
|
||||
def create_table(self):
|
||||
tdLog.info("create_table")
|
||||
global last_tb
|
||||
global written
|
||||
global killed
|
||||
|
||||
current_tb = "tb%d" % int(round(time.time() * 1000))
|
||||
|
||||
|
|
@ -51,8 +55,14 @@ class Test (Thread):
|
|||
current_tb)
|
||||
last_tb = current_tb
|
||||
written = 0
|
||||
killed = False
|
||||
except Exception as e:
|
||||
tdLog.info(repr(e))
|
||||
tdLog.info("killed: %d error: %s" % (killed, e.args[0]))
|
||||
if killed and (e.args[0] == 'network unavailable'):
|
||||
tdLog.info("database killed, expect failed")
|
||||
return 0
|
||||
return -1
|
||||
return 0
|
||||
|
||||
def insert_data(self):
|
||||
tdLog.info("insert_data")
|
||||
|
|
@ -74,22 +84,33 @@ class Test (Thread):
|
|||
for j in range(0, insertRows):
|
||||
if (last_tb == ""):
|
||||
tdLog.info("no table, return")
|
||||
return
|
||||
tdSql.execute(
|
||||
'insert into %s values (%d + %da, %d, "test")' %
|
||||
(last_tb, start_time, last_timestamp, last_timestamp))
|
||||
written = written + 1
|
||||
last_timestamp = last_timestamp + 1
|
||||
return 0
|
||||
try:
|
||||
tdSql.execute(
|
||||
'insert into %s values (%d + %da, %d, "test")' %
|
||||
(last_tb, start_time, last_timestamp, last_timestamp))
|
||||
written = written + 1
|
||||
last_timestamp = last_timestamp + 1
|
||||
except Exception as e:
|
||||
if killed:
|
||||
tdLog.info(
|
||||
"database killed, expect failed %s" %
|
||||
e.args[0])
|
||||
return 0
|
||||
tdLog.info(repr(e))
|
||||
return -1
|
||||
return 0
|
||||
|
||||
def query_data(self):
|
||||
tdLog.info("query_data")
|
||||
global last_tb
|
||||
global written
|
||||
global killed
|
||||
|
||||
if (written > 0):
|
||||
if not killed and last_tb != "":
|
||||
tdLog.info("query data from table")
|
||||
tdSql.query("select * from %s" % last_tb)
|
||||
tdSql.checkRows(written)
|
||||
return 0
|
||||
|
||||
def create_stable(self):
|
||||
tdLog.info("create_stable")
|
||||
|
|
@ -123,6 +144,7 @@ class Test (Thread):
|
|||
(last_tb, start_time, last_timestamp))
|
||||
written = written + 1
|
||||
last_timestamp = last_timestamp + 1
|
||||
return 0
|
||||
|
||||
def drop_stable(self):
|
||||
tdLog.info("drop_stable")
|
||||
|
|
@ -139,22 +161,57 @@ class Test (Thread):
|
|||
last_stb = ""
|
||||
last_tb = ""
|
||||
written = 0
|
||||
return 0
|
||||
|
||||
def alter_table_to_add_col(self):
|
||||
tdLog.info("alter_table_to_add_col")
|
||||
global last_stb
|
||||
global colAdded
|
||||
|
||||
if last_stb != "" and colAdded == False:
|
||||
tdSql.execute(
|
||||
"alter table %s add column col binary(20)" %
|
||||
last_stb)
|
||||
colAdded = True
|
||||
return 0
|
||||
|
||||
def alter_table_to_drop_col(self):
|
||||
tdLog.info("alter_table_to_drop_col")
|
||||
global last_stb
|
||||
global colAdded
|
||||
|
||||
if last_stb != "" and colAdded:
|
||||
tdSql.execute("alter table %s drop column col" % last_stb)
|
||||
colAdded = False
|
||||
return 0
|
||||
|
||||
def restart_database(self):
|
||||
tdLog.info("restart_database")
|
||||
global last_tb
|
||||
global written
|
||||
global killed
|
||||
|
||||
tdDnodes.stop(1)
|
||||
killed = True
|
||||
tdDnodes.start(1)
|
||||
tdLog.sleep(10)
|
||||
killed = False
|
||||
return 0
|
||||
|
||||
def force_restart_database(self):
|
||||
tdLog.info("force_restart_database")
|
||||
global last_tb
|
||||
global written
|
||||
global killed
|
||||
|
||||
tdDnodes.forcestop(1)
|
||||
last_tb = ""
|
||||
written = 0
|
||||
killed = True
|
||||
tdDnodes.start(1)
|
||||
# tdLog.sleep(10)
|
||||
killed = False
|
||||
return 0
|
||||
|
||||
def drop_table(self):
|
||||
tdLog.info("drop_table")
|
||||
|
|
@ -167,6 +224,7 @@ class Test (Thread):
|
|||
tdSql.execute("drop table %s" % last_tb)
|
||||
last_tb = ""
|
||||
written = 0
|
||||
return 0
|
||||
|
||||
def query_data_from_stable(self):
|
||||
tdLog.info("query_data_from_stable")
|
||||
|
|
@ -178,6 +236,7 @@ class Test (Thread):
|
|||
else:
|
||||
tdLog.info("will query data from super table")
|
||||
tdSql.execute('select * from %s' % last_stb)
|
||||
return 0
|
||||
|
||||
def reset_query_cache(self):
|
||||
tdLog.info("reset_query_cache")
|
||||
|
|
@ -187,39 +246,45 @@ class Test (Thread):
|
|||
tdLog.info("reset query cache")
|
||||
tdSql.execute("reset query cache")
|
||||
tdLog.sleep(1)
|
||||
return 0
|
||||
|
||||
def reset_database(self):
|
||||
tdLog.info("reset_database")
|
||||
global last_tb
|
||||
global last_stb
|
||||
global written
|
||||
global killed
|
||||
|
||||
tdDnodes.forcestop(1)
|
||||
killed = True
|
||||
tdDnodes.deploy(1)
|
||||
tdDnodes.start(1)
|
||||
tdSql.prepare()
|
||||
last_tb = ""
|
||||
last_stb = ""
|
||||
written = 0
|
||||
killed = False
|
||||
return 0
|
||||
|
||||
def delete_datafiles(self):
|
||||
tdLog.info("delete_data_files")
|
||||
global last_tb
|
||||
global last_stb
|
||||
global written
|
||||
global killed
|
||||
|
||||
dnodesDir = tdDnodes.getDnodesRootDir()
|
||||
tdDnodes.forcestop(1)
|
||||
killed = True
|
||||
dataDir = dnodesDir + '/dnode1/data/*'
|
||||
deleteCmd = 'rm -rf %s' % dataDir
|
||||
os.system(deleteCmd)
|
||||
|
||||
tdDnodes.start(1)
|
||||
tdSql.prepare()
|
||||
last_tb = ""
|
||||
last_stb = ""
|
||||
written = 0
|
||||
|
||||
tdDnodes.start(1)
|
||||
tdSql.prepare()
|
||||
killed = False
|
||||
return 0
|
||||
|
||||
def run(self):
|
||||
dataOp = {
|
||||
1: self.insert_data,
|
||||
|
|
@ -235,6 +300,8 @@ class Test (Thread):
|
|||
7: self.reset_database,
|
||||
8: self.delete_datafiles,
|
||||
9: self.drop_stable,
|
||||
10: self.alter_table_to_add_col,
|
||||
11: self.alter_table_to_drop_col,
|
||||
}
|
||||
|
||||
queryOp = {
|
||||
|
|
@ -247,16 +314,28 @@ class Test (Thread):
|
|||
self.dataEvent.wait()
|
||||
tdLog.notice("first thread")
|
||||
randDataOp = random.randint(1, 1)
|
||||
dataOp.get(randDataOp, lambda: "ERROR")()
|
||||
self.dataEvent.clear()
|
||||
self.queryEvent.clear()
|
||||
self.dbEvent.set()
|
||||
ret1 = dataOp.get(randDataOp, lambda: "ERROR")()
|
||||
|
||||
if ret1 == -1:
|
||||
self.q.put(-1)
|
||||
tdLog.exit("first thread failed")
|
||||
else:
|
||||
self.q.put(1)
|
||||
|
||||
if (self.q.get() != -2):
|
||||
self.dataEvent.clear()
|
||||
self.queryEvent.clear()
|
||||
self.dbEvent.set()
|
||||
else:
|
||||
self.q.put(-1)
|
||||
tdLog.exit("second thread failed, first thread exit too")
|
||||
|
||||
|
||||
elif (self.threadId == 2):
|
||||
while True:
|
||||
self.dbEvent.wait()
|
||||
tdLog.notice("second thread")
|
||||
randDbOp = random.randint(1, 9)
|
||||
randDbOp = random.randint(1, 11)
|
||||
dbOp.get(randDbOp, lambda: "ERROR")()
|
||||
self.dbEvent.clear()
|
||||
self.dataEvent.clear()
|
||||
|
|
@ -298,6 +377,10 @@ class TDTestCase:
|
|||
test2.join()
|
||||
test3.join()
|
||||
|
||||
while not q.empty():
|
||||
if (q.get() != 0):
|
||||
tdLog.exit("failed to end of test")
|
||||
|
||||
tdLog.info("end of test")
|
||||
|
||||
def stop(self):
|
||||
|
|
|
|||
|
|
@ -14,6 +14,7 @@
|
|||
import sys
|
||||
import random
|
||||
import threading
|
||||
import queue
|
||||
|
||||
from util.log import *
|
||||
from util.cases import *
|
||||
|
|
@ -24,13 +25,16 @@ last_tb = ""
|
|||
last_stb = ""
|
||||
written = 0
|
||||
last_timestamp = 0
|
||||
colAdded = False
|
||||
killed = False
|
||||
|
||||
|
||||
class Test (threading.Thread):
|
||||
def __init__(self, threadId, name):
|
||||
def __init__(self, threadId, name, q):
|
||||
threading.Thread.__init__(self)
|
||||
self.threadId = threadId
|
||||
self.name = name
|
||||
self.q = q
|
||||
|
||||
self.threadLock = threading.Lock()
|
||||
|
||||
|
|
@ -38,11 +42,12 @@ class Test (threading.Thread):
|
|||
tdLog.info("create_table")
|
||||
global last_tb
|
||||
global written
|
||||
global killed
|
||||
|
||||
current_tb = "tb%d" % int(round(time.time() * 1000))
|
||||
|
||||
if (current_tb == last_tb):
|
||||
return
|
||||
return 0
|
||||
else:
|
||||
tdLog.info("will create table %s" % current_tb)
|
||||
|
||||
|
|
@ -52,8 +57,14 @@ class Test (threading.Thread):
|
|||
current_tb)
|
||||
last_tb = current_tb
|
||||
written = 0
|
||||
killed = False
|
||||
except Exception as e:
|
||||
tdLog.info(repr(e))
|
||||
tdLog.info("killed: %d error: %s" % (killed, e.args[0]))
|
||||
if killed and (e.args[0] == 'network unavailable'):
|
||||
tdLog.info("database killed, expect failed")
|
||||
return 0
|
||||
return -1
|
||||
return 0
|
||||
|
||||
def insert_data(self):
|
||||
tdLog.info("insert_data")
|
||||
|
|
@ -75,22 +86,34 @@ class Test (threading.Thread):
|
|||
for j in range(0, insertRows):
|
||||
if (last_tb == ""):
|
||||
tdLog.info("no table, return")
|
||||
return
|
||||
tdSql.execute(
|
||||
'insert into %s values (%d + %da, %d, "test")' %
|
||||
(last_tb, start_time, last_timestamp, last_timestamp))
|
||||
written = written + 1
|
||||
last_timestamp = last_timestamp + 1
|
||||
return 0
|
||||
|
||||
try:
|
||||
tdSql.execute(
|
||||
'insert into %s values (%d + %da, %d, "test")' %
|
||||
(last_tb, start_time, last_timestamp, last_timestamp))
|
||||
written = written + 1
|
||||
last_timestamp = last_timestamp + 1
|
||||
except Exception as e:
|
||||
if killed:
|
||||
tdLog.info(
|
||||
"database killed, expect failed %s" %
|
||||
e.args[0])
|
||||
return 0
|
||||
tdLog.info(repr(e))
|
||||
return -1
|
||||
return 0
|
||||
|
||||
def query_data(self):
|
||||
tdLog.info("query_data")
|
||||
global last_tb
|
||||
global written
|
||||
global killed
|
||||
|
||||
if (written > 0):
|
||||
if not killed and last_tb != "":
|
||||
tdLog.info("query data from table")
|
||||
tdSql.query("select * from %s" % last_tb)
|
||||
tdSql.checkRows(written)
|
||||
return 0
|
||||
|
||||
def create_stable(self):
|
||||
tdLog.info("create_stable")
|
||||
|
|
@ -101,9 +124,7 @@ class Test (threading.Thread):
|
|||
|
||||
current_stb = "stb%d" % int(round(time.time() * 1000))
|
||||
|
||||
if (current_stb == last_stb):
|
||||
return
|
||||
else:
|
||||
if (current_stb != last_stb):
|
||||
tdLog.info("will create stable %s" % current_stb)
|
||||
tdLog.info(
|
||||
'create table %s(ts timestamp, c1 int, c2 nchar(10)) tags (t1 int, t2 nchar(10))' %
|
||||
|
|
@ -131,6 +152,8 @@ class Test (threading.Thread):
|
|||
written = written + 1
|
||||
last_timestamp = last_timestamp + 1
|
||||
|
||||
return 0
|
||||
|
||||
def drop_stable(self):
|
||||
tdLog.info("drop_stable")
|
||||
global last_stb
|
||||
|
|
@ -139,31 +162,63 @@ class Test (threading.Thread):
|
|||
|
||||
if (last_stb == ""):
|
||||
tdLog.info("no super table")
|
||||
return
|
||||
else:
|
||||
tdLog.info("will drop last super table")
|
||||
tdLog.info("will drop last super table %s" % last_stb)
|
||||
tdSql.execute('drop table %s' % last_stb)
|
||||
last_stb = ""
|
||||
last_tb = ""
|
||||
written = 0
|
||||
return 0
|
||||
|
||||
def alter_table_to_add_col(self):
|
||||
tdLog.info("alter_table_to_add_col")
|
||||
global last_stb
|
||||
global colAdded
|
||||
|
||||
if last_stb != "" and not colAdded:
|
||||
tdSql.execute(
|
||||
"alter table %s add column col binary(20)" %
|
||||
last_stb)
|
||||
colAdded = True
|
||||
return 0
|
||||
|
||||
def alter_table_to_drop_col(self):
|
||||
tdLog.info("alter_table_to_drop_col")
|
||||
global last_stb
|
||||
global colAdded
|
||||
|
||||
if last_stb != "" and colAdded:
|
||||
tdSql.execute("alter table %s drop column col" % last_stb)
|
||||
colAdded = False
|
||||
return 0
|
||||
|
||||
def restart_database(self):
|
||||
tdLog.info("restart_database")
|
||||
global last_tb
|
||||
global written
|
||||
global killed
|
||||
|
||||
tdDnodes.stop(1)
|
||||
killed = True
|
||||
tdDnodes.start(1)
|
||||
# tdLog.sleep(5)
|
||||
tdLog.sleep(10)
|
||||
killed = False
|
||||
return 0
|
||||
|
||||
def force_restart_database(self):
|
||||
tdLog.info("force_restart_database")
|
||||
global last_tb
|
||||
global written
|
||||
global killed
|
||||
|
||||
tdDnodes.forcestop(1)
|
||||
last_tb = ""
|
||||
written = 0
|
||||
killed = True
|
||||
tdDnodes.start(1)
|
||||
# tdLog.sleep(10)
|
||||
killed = False
|
||||
return 0
|
||||
|
||||
def drop_table(self):
|
||||
tdLog.info("drop_table")
|
||||
|
|
@ -176,6 +231,7 @@ class Test (threading.Thread):
|
|||
tdSql.execute("drop table %s" % last_tb)
|
||||
last_tb = ""
|
||||
written = 0
|
||||
return 0
|
||||
|
||||
def query_data_from_stable(self):
|
||||
tdLog.info("query_data_from_stable")
|
||||
|
|
@ -183,10 +239,10 @@ class Test (threading.Thread):
|
|||
|
||||
if (last_stb == ""):
|
||||
tdLog.info("no super table")
|
||||
return
|
||||
else:
|
||||
tdLog.info("will query data from super table")
|
||||
tdSql.execute('select * from %s' % last_stb)
|
||||
return 0
|
||||
|
||||
def reset_query_cache(self):
|
||||
tdLog.info("reset_query_cache")
|
||||
|
|
@ -196,39 +252,45 @@ class Test (threading.Thread):
|
|||
tdLog.info("reset query cache")
|
||||
tdSql.execute("reset query cache")
|
||||
# tdLog.sleep(1)
|
||||
return 0
|
||||
|
||||
def reset_database(self):
|
||||
tdLog.info("reset_database")
|
||||
global last_tb
|
||||
global last_stb
|
||||
global written
|
||||
global killed
|
||||
|
||||
tdDnodes.forcestop(1)
|
||||
killed = True
|
||||
tdDnodes.deploy(1)
|
||||
tdDnodes.start(1)
|
||||
tdSql.prepare()
|
||||
last_tb = ""
|
||||
last_stb = ""
|
||||
written = 0
|
||||
killed = False
|
||||
return 0
|
||||
|
||||
def delete_datafiles(self):
|
||||
tdLog.info("delete_data_files")
|
||||
global last_tb
|
||||
global last_stb
|
||||
global written
|
||||
global killed
|
||||
|
||||
dnodesDir = tdDnodes.getDnodesRootDir()
|
||||
tdDnodes.forcestop(1)
|
||||
killed = True
|
||||
dataDir = dnodesDir + '/dnode1/data/*'
|
||||
deleteCmd = 'rm -rf %s' % dataDir
|
||||
os.system(deleteCmd)
|
||||
|
||||
tdDnodes.start(1)
|
||||
tdSql.prepare()
|
||||
last_tb = ""
|
||||
last_stb = ""
|
||||
written = 0
|
||||
|
||||
tdDnodes.start(1)
|
||||
tdSql.prepare()
|
||||
killed = False
|
||||
return 0
|
||||
|
||||
def run(self):
|
||||
dataOp = {
|
||||
1: self.insert_data,
|
||||
|
|
@ -246,6 +308,8 @@ class Test (threading.Thread):
|
|||
7: self.reset_database,
|
||||
8: self.delete_datafiles,
|
||||
9: self.drop_stable,
|
||||
10: self.alter_table_to_add_col,
|
||||
11: self.alter_table_to_drop_col,
|
||||
}
|
||||
|
||||
if (self.threadId == 1):
|
||||
|
|
@ -253,16 +317,38 @@ class Test (threading.Thread):
|
|||
self.threadLock.acquire()
|
||||
tdLog.notice("first thread")
|
||||
randDataOp = random.randint(1, 3)
|
||||
dataOp.get(randDataOp, lambda: "ERROR")()
|
||||
self.threadLock.release()
|
||||
ret1 = dataOp.get(randDataOp, lambda: "ERROR")()
|
||||
|
||||
if ret1 == -1:
|
||||
self.q.put(-1)
|
||||
tdLog.exit("first thread failed")
|
||||
else:
|
||||
self.q.put(1)
|
||||
|
||||
if (self.q.get() != -2):
|
||||
self.threadLock.release()
|
||||
else:
|
||||
self.q.put(-1)
|
||||
tdLog.exit("second thread failed, first thread exit too")
|
||||
|
||||
elif (self.threadId == 2):
|
||||
while True:
|
||||
tdLog.notice("second thread")
|
||||
self.threadLock.acquire()
|
||||
randDbOp = random.randint(1, 9)
|
||||
dbOp.get(randDbOp, lambda: "ERROR")()
|
||||
self.threadLock.release()
|
||||
tdLog.notice("second thread")
|
||||
randDbOp = random.randint(1, 11)
|
||||
ret2 = dbOp.get(randDbOp, lambda: "ERROR")()
|
||||
|
||||
if ret2 == -1:
|
||||
self.q.put(-2)
|
||||
tdLog.exit("second thread failed")
|
||||
else:
|
||||
self.q.put(2)
|
||||
|
||||
if (self.q.get() != -1):
|
||||
self.threadLock.release()
|
||||
else:
|
||||
self.q.put(-2)
|
||||
tdLog.exit("first thread failed, second exit too")
|
||||
|
||||
|
||||
class TDTestCase:
|
||||
|
|
@ -273,14 +359,19 @@ class TDTestCase:
|
|||
def run(self):
|
||||
tdSql.prepare()
|
||||
|
||||
test1 = Test(1, "data operation")
|
||||
test2 = Test(2, "db operation")
|
||||
q = queue.Queue()
|
||||
test1 = Test(1, "data operation", q)
|
||||
test2 = Test(2, "db operation", q)
|
||||
|
||||
test1.start()
|
||||
test2.start()
|
||||
test1.join()
|
||||
test2.join()
|
||||
|
||||
while not q.empty():
|
||||
if (q.get() != 0):
|
||||
tdLog.exit("failed to end of test")
|
||||
|
||||
tdLog.info("end of test")
|
||||
|
||||
def stop(self):
|
||||
|
|
|
|||
|
|
@ -25,6 +25,7 @@ class Test:
|
|||
self.last_tb = ""
|
||||
self.last_stb = ""
|
||||
self.written = 0
|
||||
self.colAdded = False
|
||||
|
||||
def create_table(self):
|
||||
tdLog.info("create_table")
|
||||
|
|
@ -39,6 +40,7 @@ class Test:
|
|||
current_tb)
|
||||
self.last_tb = current_tb
|
||||
self.written = 0
|
||||
self.colAdded = False
|
||||
|
||||
def insert_data(self):
|
||||
tdLog.info("insert_data")
|
||||
|
|
@ -50,28 +52,52 @@ class Test:
|
|||
insertRows = 10
|
||||
tdLog.info("insert %d rows to %s" % (insertRows, self.last_tb))
|
||||
for i in range(0, insertRows):
|
||||
ret = tdSql.execute(
|
||||
'insert into %s values (now + %dm, %d, "%s")' %
|
||||
(self.last_tb, i, i, "->" + str(i)))
|
||||
if self.colAdded:
|
||||
ret = tdSql.execute(
|
||||
'insert into %s values (now + %dm, %d, "%s", "%s")' %
|
||||
(self.last_tb, i, i, "->" + str(i)), "col")
|
||||
else:
|
||||
ret = tdSql.execute(
|
||||
'insert into %s values (now + %dm, %d, "%s")' %
|
||||
(self.last_tb, i, i, "->" + str(i)))
|
||||
|
||||
self.written = self.written + 1
|
||||
|
||||
tdLog.info("insert earlier data")
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 5m , 10, " - 5m")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 6m , 10, " - 6m")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 7m , 10, " - 7m")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 8m , 10, " - 8m")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
if self.colAdded:
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 5m , 10, " - 5m", "col")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 6m , 10, " - 6m", "col")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 7m , 10, " - 7m", "col")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 8m , 10, " - 8m", "col")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
else:
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 5m , 10, " - 5m")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 6m , 10, " - 6m")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 7m , 10, " - 7m")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
tdSql.execute(
|
||||
'insert into %s values (now - 8m , 10, " - 8m")' %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
|
||||
def query_data(self):
|
||||
tdLog.info("query_data")
|
||||
|
|
@ -88,21 +114,48 @@ class Test:
|
|||
return
|
||||
else:
|
||||
tdLog.info("will create stable %s" % current_stb)
|
||||
|
||||
db = "db"
|
||||
tdSql.execute("drop database if exists %s" % (db))
|
||||
tdSql.execute("reset query cache")
|
||||
tdSql.execute("create database %s maxrows 200 maxtables 30" % (db))
|
||||
tdSql.execute("use %s" % (db))
|
||||
|
||||
tdSql.execute(
|
||||
'create table %s(ts timestamp, c1 int, c2 nchar(10)) tags (t1 int, t2 nchar(10))' %
|
||||
current_stb)
|
||||
self.last_stb = current_stb
|
||||
self.colAdded = False
|
||||
|
||||
current_tb = "tb%d" % int(round(time.time() * 1000))
|
||||
sqlcmd = "create table %s using %s tags (1, 'test')" %(current_tb, self.last_stb)
|
||||
tdSql.execute(sqlcmd)
|
||||
self.last_tb = current_tb
|
||||
self.written = 0
|
||||
for k in range(1, 300):
|
||||
current_tb = "tb%d" % int(round(time.time() * 1000))
|
||||
sqlcmd = "create table %s using %s tags (1, 'test')" % (
|
||||
current_tb, self.last_stb)
|
||||
tdSql.execute(sqlcmd)
|
||||
self.last_tb = current_tb
|
||||
self.written = 0
|
||||
|
||||
for j in range(1, 100):
|
||||
tdSql.execute(
|
||||
"insert into %s values (now + %da, 27, 'wsnchar')" %
|
||||
(self.last_tb, j))
|
||||
self.written = self.written + 1
|
||||
|
||||
def alter_table_to_add_col(self):
|
||||
tdLog.info("alter_table_to_add_col")
|
||||
|
||||
if self.last_stb != "" and not self.colAdded:
|
||||
tdSql.execute(
|
||||
"insert into %s values (now, 27, 'wsnchar')" %
|
||||
self.last_tb)
|
||||
self.written = self.written + 1
|
||||
"alter table %s add column col binary(20)" %
|
||||
self.last_stb)
|
||||
self.colAdded = True
|
||||
|
||||
def alter_table_to_drop_col(self):
|
||||
tdLog.info("alter_table_to_drop_col")
|
||||
|
||||
if self.last_stb != "" and self.colAdded:
|
||||
tdSql.execute("alter table %s drop column col" % self.last_stb)
|
||||
self.colAdded = False
|
||||
|
||||
def drop_stable(self):
|
||||
tdLog.info("drop_stable")
|
||||
|
|
@ -126,16 +179,16 @@ class Test:
|
|||
tdSql.execute('select * from %s' % self.last_stb)
|
||||
|
||||
def restart_database(self):
|
||||
tdLog.info("restart_databae")
|
||||
tdLog.info("restart_database")
|
||||
tdDnodes.stop(1)
|
||||
tdDnodes.start(1)
|
||||
tdLog.sleep(5)
|
||||
tdLog.sleep(10)
|
||||
|
||||
def force_restart_database(self):
|
||||
tdLog.info("force_restart_database")
|
||||
tdDnodes.forcestop(1)
|
||||
tdDnodes.start(1)
|
||||
tdLog.sleep(5)
|
||||
tdLog.sleep(10)
|
||||
tdSql.prepare()
|
||||
self.last_tb = ""
|
||||
self.last_stb = ""
|
||||
|
|
@ -161,7 +214,7 @@ class Test:
|
|||
self.last_tb = ""
|
||||
self.written = 0
|
||||
tdDnodes.start(1)
|
||||
tdLog.sleep(5)
|
||||
tdLog.sleep(10)
|
||||
tdSql.prepare()
|
||||
self.last_tb = ""
|
||||
self.last_stb = ""
|
||||
|
|
@ -209,10 +262,12 @@ class TDTestCase:
|
|||
10: test.delete_datafiles,
|
||||
11: test.query_data_from_stable,
|
||||
12: test.drop_stable,
|
||||
13: test.alter_table_to_add_col,
|
||||
14: test.alter_table_to_drop_col,
|
||||
}
|
||||
|
||||
for x in range(1, 1000):
|
||||
r = random.randint(1, 12)
|
||||
r = random.randint(1, 14)
|
||||
tdLog.notice("iteration %d run func %d" % (x, r))
|
||||
switch.get(r, lambda: "ERROR")()
|
||||
|
||||
|
|
|
|||
|
|
@ -126,7 +126,7 @@ class Test:
|
|||
def delete_datafiles(self):
|
||||
tdLog.info("delete data files")
|
||||
dnodesDir = tdDnodes.getDnodesRootDir()
|
||||
dataDir = dnodesDir + '/dnode1/*'
|
||||
dataDir = dnodesDir + '/dnode1/data/*'
|
||||
deleteCmd = 'rm -rf %s' % dataDir
|
||||
os.system(deleteCmd)
|
||||
|
||||
|
|
|
|||
|
|
@ -41,16 +41,12 @@ class TDSql:
|
|||
def prepare(self):
|
||||
tdLog.info("prepare database:db")
|
||||
s = 'reset query cache'
|
||||
print(s)
|
||||
self.cursor.execute(s)
|
||||
s = 'drop database if exists db'
|
||||
print(s)
|
||||
self.cursor.execute(s)
|
||||
s = 'create database db'
|
||||
print(s)
|
||||
self.cursor.execute(s)
|
||||
s = 'use db'
|
||||
print(s)
|
||||
self.cursor.execute(s)
|
||||
|
||||
def error(self, sql):
|
||||
|
|
@ -74,7 +70,6 @@ class TDSql:
|
|||
|
||||
def query(self, sql):
|
||||
self.sql = sql
|
||||
print(sql)
|
||||
self.cursor.execute(sql)
|
||||
self.queryResult = self.cursor.fetchall()
|
||||
self.queryRows = len(self.queryResult)
|
||||
|
|
@ -191,7 +186,6 @@ class TDSql:
|
|||
|
||||
def execute(self, sql):
|
||||
self.sql = sql
|
||||
print(sql)
|
||||
self.affectedRows = self.cursor.execute(sql)
|
||||
return self.affectedRows
|
||||
|
||||
|
|
|
|||
|
|
@ -334,9 +334,10 @@ cd ../../../debug; make
|
|||
./test.sh -f unique/arbitrator/dn3_mn1_replica_change_dropDnod.sim
|
||||
./test.sh -f unique/arbitrator/dn3_mn1_replica_change.sim
|
||||
./test.sh -f unique/arbitrator/dn3_mn1_stopDnode_timeout.sim
|
||||
./test.sh -f unique/arbitrator/dn3_mn1_vnode_change.sim
|
||||
./test.sh -f unique/arbitrator/dn3_mn1_vnode_corruptFile_offline.sim
|
||||
./test.sh -f unique/arbitrator/dn3_mn1_vnode_corruptFile_online.sim
|
||||
#./test.sh -f unique/arbitrator/dn3_mn1_vnode_change.sim
|
||||
#./test.sh -f unique/arbitrator/dn3_mn1_vnode_corruptFile_offline.sim
|
||||
#./test.sh -f unique/arbitrator/dn3_mn1_vnode_corruptFile_online.sim
|
||||
#./test.sh -f unique/arbitrator/dn3_mn1_vnode_createErrData_online.sim
|
||||
./test.sh -f unique/arbitrator/dn3_mn1_vnode_noCorruptFile_offline.sim
|
||||
./test.sh -f unique/arbitrator/dn3_mn1_vnode_delDir.sim
|
||||
./test.sh -f unique/arbitrator/dn3_mn1_r2_vnode_delDir.sim
|
||||
|
|
|
|||
|
|
@ -149,7 +149,7 @@ if $dnode3Vtatus != master then
|
|||
goto wait_dnode4_vgroup_offline
|
||||
endi
|
||||
|
||||
system echo "haha, nothing......" > ../../../sim/dnode4/data/vnode/vnode2/tsdb/data/f1643.data
|
||||
system echo "haha, nothing......" > ../../../sim/dnode4/data/vnode/vnode2/tsdb/data/v2f1643.data
|
||||
#system rm -rf ../../../sim/dnode4/data/vnode/*
|
||||
sleep 1000
|
||||
|
||||
|
|
|
|||
|
|
@ -174,7 +174,7 @@ if $system_content != 3 then
|
|||
return -1
|
||||
endi
|
||||
|
||||
system echo "haha, nothing......" > ../../../sim/dnode3/data/vnode/vnode2/tsdb/data/f1643.data
|
||||
system echo "haha, nothing......" > ../../../sim/dnode3/data/vnode/vnode2/tsdb/data/v2f1643.data
|
||||
|
||||
print ============== step3-1: insert some news data for let version changed
|
||||
sql insert into $tb values ( now + 0a , $x ) ( now + 1a , $x ) ( now + 2a , $x )
|
||||
|
|
|
|||
|
|
@ -47,7 +47,7 @@ system sh/exec.sh -n dnode1 -s start
|
|||
sleep 3000
|
||||
sql connect
|
||||
|
||||
print ============== step2: start dnode2/dnode3 and add into cluster , then create database with replica 2, and create table, insert data
|
||||
print ============== step2: start dnode2/dnode3 and add into cluster , then create database with replica 2, and create table, insert data to can fall disc
|
||||
system sh/exec.sh -n dnode2 -s start
|
||||
system sh/exec.sh -n dnode3 -s start
|
||||
#system sh/exec.sh -n dnode4 -s start
|
||||
|
|
@ -56,18 +56,18 @@ sql create dnode $hostname3
|
|||
#sql create dnode $hostname4
|
||||
sleep 3000
|
||||
|
||||
$totalTableNum = 10
|
||||
$totalTableNum = 4
|
||||
$sleepTimer = 3000
|
||||
|
||||
$db = db
|
||||
sql create database $db replica 2 maxTables $totalTableNum
|
||||
sql create database $db cache 1 replica 2 maxTables $totalTableNum
|
||||
sql use $db
|
||||
|
||||
# create table , insert data
|
||||
$stb = stb
|
||||
sql create table $stb (ts timestamp, c1 int) tags(t1 int)
|
||||
$rowNum = 100
|
||||
$tblNum = $totalTableNum
|
||||
$rowNum = 128 * 1024
|
||||
$tblNum = 1
|
||||
$totalRows = 0
|
||||
$tsStart = 1420041600000
|
||||
|
||||
|
|
@ -81,6 +81,7 @@ while $i < $tblNum
|
|||
$ts = $tsStart + $x
|
||||
sql insert into $tb values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x ) ( $ts + 10a , $x ) ( $ts + 11a , $x ) ( $ts + 12a , $x ) ( $ts + 13a , $x ) ( $ts + 14a , $x ) ( $ts + 15a , $x ) ( $ts + 16a , $x ) ( $ts + 17a , $x ) ( $ts + 18a , $x ) ( $ts + 19a , $x ) ( $ts + 20a , $x ) ( $ts + 21a , $x ) ( $ts + 22a , $x ) ( $ts + 23a , $x ) ( $ts + 24a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 35a , $x ) ( $ts + 36a , $x ) ( $ts + 37a , $x ) ( $ts + 38a , $x ) ( $ts + 39a , $x ) ( $ts + 40a , $x ) ( $ts + 41a , $x ) ( $ts + 42a , $x ) ( $ts + 43a , $x ) ( $ts + 44a , $x ) ( $ts + 45a , $x ) ( $ts + 46a , $x ) ( $ts + 47a , $x ) ( $ts + 48a , $x ) ( $ts + 49a , $x ) ( $ts + 50a , $x ) ( $ts + 51a , $x ) ( $ts + 52a , $x ) ( $ts + 53a , $x ) ( $ts + 54a , $x ) ( $ts + 55a , $x ) ( $ts + 56a , $x ) ( $ts + 57a , $x ) ( $ts + 58a , $x ) ( $ts + 59a , $x )
|
||||
$x = $x + 60
|
||||
$tsLast = $ts + 60
|
||||
endw
|
||||
$totalRows = $totalRows + $x
|
||||
print info: inserted $x rows into $tb and totalRows: $totalRows
|
||||
|
|
@ -95,7 +96,7 @@ if $data00 != $totalRows then
|
|||
endi
|
||||
|
||||
print ============== step3: corrupt vnode data file in dnode3, not stop dnode3
|
||||
system echo "haha, nothing......" > ../../../sim/dnode3/data/vnode/vnode2/tsdb/data/f1643.data
|
||||
system echo "haha, nothing......" > ../../../sim/dnode3/data/vnode/vnode2/tsdb/data/v2f1643.data
|
||||
sleep 1000
|
||||
|
||||
print ============== step4: insert new data, and run query
|
||||
|
|
@ -108,6 +109,43 @@ if $data00 != $totalRows then
|
|||
return -1
|
||||
endi
|
||||
|
||||
print show dnodes
|
||||
sql show dnodes
|
||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
|
||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
|
||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||
|
||||
print show vgroups
|
||||
sql show vgroups
|
||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1 $data5_1 $data6_1 $data7_1 $data8_1 $data9_1
|
||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2 $data5_2 $data6_2 $data7_2 $data8_2 $data9_2
|
||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $data7_3 $data8_3 $data9_3
|
||||
|
||||
|
||||
$tsStart = $tsLast + 1
|
||||
$i = 0
|
||||
while $i < $tblNum
|
||||
$tb = tb . $i
|
||||
#sql create table $tb using $stb tags( $i )
|
||||
|
||||
$x = 0
|
||||
while $x < $rowNum
|
||||
$ts = $tsStart + $x
|
||||
sql insert into $tb values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x ) ( $ts + 10a , $x ) ( $ts + 11a , $x ) ( $ts + 12a , $x ) ( $ts + 13a , $x ) ( $ts + 14a , $x ) ( $ts + 15a , $x ) ( $ts + 16a , $x ) ( $ts + 17a , $x ) ( $ts + 18a , $x ) ( $ts + 19a , $x ) ( $ts + 20a , $x ) ( $ts + 21a , $x ) ( $ts + 22a , $x ) ( $ts + 23a , $x ) ( $ts + 24a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 35a , $x ) ( $ts + 36a , $x ) ( $ts + 37a , $x ) ( $ts + 38a , $x ) ( $ts + 39a , $x ) ( $ts + 40a , $x ) ( $ts + 41a , $x ) ( $ts + 42a , $x ) ( $ts + 43a , $x ) ( $ts + 44a , $x ) ( $ts + 45a , $x ) ( $ts + 46a , $x ) ( $ts + 47a , $x ) ( $ts + 48a , $x ) ( $ts + 49a , $x ) ( $ts + 50a , $x ) ( $ts + 51a , $x ) ( $ts + 52a , $x ) ( $ts + 53a , $x ) ( $ts + 54a , $x ) ( $ts + 55a , $x ) ( $ts + 56a , $x ) ( $ts + 57a , $x ) ( $ts + 58a , $x ) ( $ts + 59a , $x )
|
||||
$x = $x + 60
|
||||
$tsLast = $ts + 60
|
||||
endw
|
||||
$totalRows = $totalRows + $x
|
||||
print info: inserted $x rows into $tb and totalRows: $totalRows
|
||||
$i = $i + 1
|
||||
endw
|
||||
|
||||
sql select count(*) from $stb
|
||||
print data00 $data00
|
||||
if $data00 != $totalRows then
|
||||
return -1
|
||||
endi
|
||||
|
||||
print ============== step5: stop dnode2, and check if dnode3 sync ok
|
||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
||||
sleep $sleepTimer
|
||||
|
|
@ -242,7 +280,8 @@ if $dnode3Vtatus != offline then
|
|||
goto wait_dnode3_vgroup_offline
|
||||
endi
|
||||
|
||||
print ============== step7: restart dnode3, and run query
|
||||
print ============== step7: restart dnode2/dnode3, and run query
|
||||
system sh/exec.sh -n dnode2 -s start
|
||||
system sh/exec.sh -n dnode3 -s start
|
||||
sleep $sleepTimer
|
||||
$loopCnt = 0
|
||||
|
|
@ -288,7 +327,7 @@ print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $dat
|
|||
$dnode2Vtatus = $data7_2
|
||||
$dnode3Vtatus = $data4_2
|
||||
|
||||
if $dnode2Vtatus != offline then
|
||||
if $dnode2Vtatus != slave then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_master_1
|
||||
endi
|
||||
|
|
|
|||
|
|
@ -0,0 +1,315 @@
|
|||
system sh/stop_dnodes.sh
|
||||
system sh/deploy.sh -n dnode1 -i 1
|
||||
system sh/deploy.sh -n dnode2 -i 2
|
||||
system sh/deploy.sh -n dnode3 -i 3
|
||||
system sh/deploy.sh -n dnode4 -i 4
|
||||
|
||||
system sh/cfg.sh -n dnode1 -c numOfMnodes -v 1
|
||||
system sh/cfg.sh -n dnode2 -c numOfMnodes -v 1
|
||||
system sh/cfg.sh -n dnode3 -c numOfMnodes -v 1
|
||||
system sh/cfg.sh -n dnode4 -c numOfMnodes -v 1
|
||||
|
||||
system sh/cfg.sh -n dnode1 -c walLevel -v 2
|
||||
system sh/cfg.sh -n dnode2 -c walLevel -v 2
|
||||
system sh/cfg.sh -n dnode3 -c walLevel -v 2
|
||||
system sh/cfg.sh -n dnode4 -c walLevel -v 2
|
||||
|
||||
system sh/cfg.sh -n dnode1 -c balanceInterval -v 10
|
||||
system sh/cfg.sh -n dnode2 -c balanceInterval -v 10
|
||||
system sh/cfg.sh -n dnode3 -c balanceInterval -v 10
|
||||
system sh/cfg.sh -n dnode4 -c balanceInterval -v 10
|
||||
|
||||
system sh/cfg.sh -n dnode1 -c numOfTotalVnodes -v 4
|
||||
system sh/cfg.sh -n dnode2 -c numOfTotalVnodes -v 4
|
||||
system sh/cfg.sh -n dnode3 -c numOfTotalVnodes -v 4
|
||||
system sh/cfg.sh -n dnode4 -c numOfTotalVnodes -v 4
|
||||
|
||||
system sh/cfg.sh -n dnode1 -c alternativeRole -v 1
|
||||
system sh/cfg.sh -n dnode2 -c alternativeRole -v 2
|
||||
system sh/cfg.sh -n dnode3 -c alternativeRole -v 2
|
||||
system sh/cfg.sh -n dnode4 -c alternativeRole -v 2
|
||||
|
||||
system sh/cfg.sh -n dnode1 -c maxtablesPerVnode -v 4
|
||||
system sh/cfg.sh -n dnode2 -c maxtablesPerVnode -v 4
|
||||
system sh/cfg.sh -n dnode3 -c maxtablesPerVnode -v 4
|
||||
system sh/cfg.sh -n dnode4 -c maxtablesPerVnode -v 4
|
||||
|
||||
system sh/cfg.sh -n dnode1 -c arbitrator -v $arbitrator
|
||||
system sh/cfg.sh -n dnode2 -c arbitrator -v $arbitrator
|
||||
system sh/cfg.sh -n dnode3 -c arbitrator -v $arbitrator
|
||||
system sh/cfg.sh -n dnode4 -c arbitrator -v $arbitrator
|
||||
|
||||
print ============== step0: start tarbitrator
|
||||
system sh/exec_tarbitrator.sh -s start
|
||||
|
||||
print ============== step1: start dnode1, only deploy mnode
|
||||
system sh/exec.sh -n dnode1 -s start
|
||||
sleep 3000
|
||||
sql connect
|
||||
|
||||
print ============== step2: start dnode2/dnode3 and add into cluster , then create database with replica 2, and create table, insert data
|
||||
system sh/exec.sh -n dnode2 -s start
|
||||
system sh/exec.sh -n dnode3 -s start
|
||||
#system sh/exec.sh -n dnode4 -s start
|
||||
sql create dnode $hostname2
|
||||
sql create dnode $hostname3
|
||||
#sql create dnode $hostname4
|
||||
sleep 3000
|
||||
|
||||
$totalTableNum = 10
|
||||
$sleepTimer = 3000
|
||||
|
||||
$db = db
|
||||
sql create database $db replica 2 maxTables $totalTableNum
|
||||
sql use $db
|
||||
|
||||
# create table , insert data
|
||||
$stb = stb
|
||||
sql create table $stb (ts timestamp, c1 int) tags(t1 int)
|
||||
$rowNum = 100
|
||||
$tblNum = $totalTableNum
|
||||
$totalRows = 0
|
||||
$tsStart = 1420041600000
|
||||
|
||||
$i = 0
|
||||
while $i < $tblNum
|
||||
$tb = tb . $i
|
||||
sql create table $tb using $stb tags( $i )
|
||||
|
||||
$x = 0
|
||||
while $x < $rowNum
|
||||
$ts = $tsStart + $x
|
||||
sql insert into $tb values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x ) ( $ts + 10a , $x ) ( $ts + 11a , $x ) ( $ts + 12a , $x ) ( $ts + 13a , $x ) ( $ts + 14a , $x ) ( $ts + 15a , $x ) ( $ts + 16a , $x ) ( $ts + 17a , $x ) ( $ts + 18a , $x ) ( $ts + 19a , $x ) ( $ts + 20a , $x ) ( $ts + 21a , $x ) ( $ts + 22a , $x ) ( $ts + 23a , $x ) ( $ts + 24a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 25a , $x ) ( $ts + 26a , $x ) ( $ts + 27a , $x ) ( $ts + 28a , $x ) ( $ts + 29a , $x ) ( $ts + 30a , $x ) ( $ts + 31a , $x ) ( $ts + 32a , $x ) ( $ts + 33a , $x ) ( $ts + 34a , $x ) ( $ts + 35a , $x ) ( $ts + 36a , $x ) ( $ts + 37a , $x ) ( $ts + 38a , $x ) ( $ts + 39a , $x ) ( $ts + 40a , $x ) ( $ts + 41a , $x ) ( $ts + 42a , $x ) ( $ts + 43a , $x ) ( $ts + 44a , $x ) ( $ts + 45a , $x ) ( $ts + 46a , $x ) ( $ts + 47a , $x ) ( $ts + 48a , $x ) ( $ts + 49a , $x ) ( $ts + 50a , $x ) ( $ts + 51a , $x ) ( $ts + 52a , $x ) ( $ts + 53a , $x ) ( $ts + 54a , $x ) ( $ts + 55a , $x ) ( $ts + 56a , $x ) ( $ts + 57a , $x ) ( $ts + 58a , $x ) ( $ts + 59a , $x )
|
||||
$x = $x + 60
|
||||
endw
|
||||
$totalRows = $totalRows + $x
|
||||
print info: inserted $x rows into $tb and totalRows: $totalRows
|
||||
$i = $i + 1
|
||||
endw
|
||||
|
||||
sql select count(*) from $stb
|
||||
sleep 1000
|
||||
print data00 $data00
|
||||
if $data00 != $totalRows then
|
||||
return -1
|
||||
endi
|
||||
|
||||
print ============== step3: corrupt vnode data file in dnode3, not stop dnode3
|
||||
system echo "haha, nothing......" > ../../../sim/dnode3/data/vnode/vnode2/tsdb/data/v2f1643.data
|
||||
sleep 1000
|
||||
|
||||
print ============== step4: insert new data, and run query
|
||||
sql insert into $tb values ( now + 0a , $x ) ( now + 1a , $x ) ( now + 2a , $x )
|
||||
$totalRows = $totalRows + 3
|
||||
|
||||
sql select count(*) from $stb
|
||||
print data00 $data00
|
||||
if $data00 != $totalRows then
|
||||
return -1
|
||||
endi
|
||||
|
||||
print ============== step5: stop dnode2, and check if dnode3 sync ok
|
||||
system sh/exec.sh -n dnode2 -s stop -x SIGINT
|
||||
sleep $sleepTimer
|
||||
|
||||
$loopCnt = 0
|
||||
wait_dnode2_offline_0:
|
||||
$loopCnt = $loopCnt + 1
|
||||
if $loopCnt == 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
sql show dnodes
|
||||
if $rows != 3 then
|
||||
sleep 2000
|
||||
goto wait_dnode2_offline_0
|
||||
endi
|
||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
|
||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
|
||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||
#print $data0_4 $data1_4 $data2_4 $data3_4 $data4_4
|
||||
#print $data0_5 $data1_5 $data2_5 $data3_5 $data4_5
|
||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||
#$dnode1Status = $data4_1
|
||||
$dnode2Status = $data4_2
|
||||
$dnode3Status = $data4_3
|
||||
$dnode4Status = $data4_4
|
||||
#$dnode5Status = $data4_5
|
||||
|
||||
if $dnode2Status != offline then
|
||||
sleep 2000
|
||||
goto wait_dnode2_offline_0
|
||||
endi
|
||||
|
||||
$loopCnt = 0
|
||||
wait_dnode3_vgroup_master:
|
||||
$loopCnt = $loopCnt + 1
|
||||
if $loopCnt == 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
sql show vgroups
|
||||
if $rows != 1 then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_master
|
||||
endi
|
||||
print show vgroups:
|
||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1 $data5_1 $data6_1 $data7_1 $data8_1 $data9_1
|
||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2 $data5_2 $data6_2 $data7_2 $data8_2 $data9_2
|
||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $data7_3 $data8_3 $data9_3
|
||||
$dnode2Vtatus = $data7_2
|
||||
$dnode3Vtatus = $data4_2
|
||||
|
||||
if $dnode2Vtatus != offline then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_master
|
||||
endi
|
||||
if $dnode3Vtatus != master then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_master
|
||||
endi
|
||||
|
||||
sql select count(*) from $stb
|
||||
print data00 $data00
|
||||
if $data00 != $totalRows then
|
||||
return -1
|
||||
endi
|
||||
|
||||
print ============== step6: stop dnode3 for falling disc
|
||||
system sh/exec.sh -n dnode3 -s stop -x SIGINT
|
||||
sleep $sleepTimer
|
||||
|
||||
$loopCnt = 0
|
||||
wait_dnode3_offline_0:
|
||||
$loopCnt = $loopCnt + 1
|
||||
if $loopCnt == 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
sql show dnodes
|
||||
if $rows != 3 then
|
||||
sleep 2000
|
||||
goto wait_dnode3_offline_0
|
||||
endi
|
||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
|
||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
|
||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||
#print $data0_4 $data1_4 $data2_4 $data3_4 $data4_4
|
||||
#print $data0_5 $data1_5 $data2_5 $data3_5 $data4_5
|
||||
#print $data0_6 $data1_6 $data2_6 $data3_6 $data4_6
|
||||
#$dnode1Status = $data4_1
|
||||
$dnode2Status = $data4_2
|
||||
$dnode3Status = $data4_3
|
||||
$dnode4Status = $data4_4
|
||||
#$dnode5Status = $data4_5
|
||||
|
||||
if $dnode2Status != offline then
|
||||
sleep 2000
|
||||
goto wait_dnode3_offline_0
|
||||
endi
|
||||
|
||||
if $dnode3Status != offline then
|
||||
sleep 2000
|
||||
goto wait_dnode3_offline_0
|
||||
endi
|
||||
|
||||
|
||||
$loopCnt = 0
|
||||
wait_dnode3_vgroup_offline:
|
||||
$loopCnt = $loopCnt + 1
|
||||
if $loopCnt == 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
sql show vgroups
|
||||
if $rows != 1 then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_offline
|
||||
endi
|
||||
print show vgroups:
|
||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1 $data5_1 $data6_1 $data7_1 $data8_1 $data9_1
|
||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2 $data5_2 $data6_2 $data7_2 $data8_2 $data9_2
|
||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $data7_3 $data8_3 $data9_3
|
||||
$dnode2Vtatus = $data7_2
|
||||
$dnode3Vtatus = $data4_2
|
||||
|
||||
if $dnode2Vtatus != offline then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_offline
|
||||
endi
|
||||
if $dnode3Vtatus != offline then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_offline
|
||||
endi
|
||||
|
||||
print ============== step7: restart dnode2/dnode3, and run query
|
||||
system sh/exec.sh -n dnode2 -s start
|
||||
system sh/exec.sh -n dnode3 -s start
|
||||
sleep $sleepTimer
|
||||
$loopCnt = 0
|
||||
wait_dnode3_reready:
|
||||
$loopCnt = $loopCnt + 1
|
||||
if $loopCnt == 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
sql show dnodes
|
||||
if $rows != 3 then
|
||||
sleep 2000
|
||||
goto wait_dnode3_reready
|
||||
endi
|
||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1
|
||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2
|
||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3
|
||||
$dnode1Status = $data4_1
|
||||
$dnode2Status = $data4_2
|
||||
$dnode3Status = $data4_3
|
||||
|
||||
if $dnode3Status != ready then
|
||||
sleep 2000
|
||||
goto wait_dnode3_reready
|
||||
endi
|
||||
|
||||
$loopCnt = 0
|
||||
wait_dnode3_vgroup_master_1:
|
||||
$loopCnt = $loopCnt + 1
|
||||
if $loopCnt == 10 then
|
||||
return -1
|
||||
endi
|
||||
|
||||
sql show vgroups
|
||||
if $rows != 1 then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_master_1
|
||||
endi
|
||||
print show vgroups:
|
||||
print $data0_1 $data1_1 $data2_1 $data3_1 $data4_1 $data5_1 $data6_1 $data7_1 $data8_1 $data9_1
|
||||
print $data0_2 $data1_2 $data2_2 $data3_2 $data4_2 $data5_2 $data6_2 $data7_2 $data8_2 $data9_2
|
||||
print $data0_3 $data1_3 $data2_3 $data3_3 $data4_3 $data5_3 $data6_3 $data7_3 $data8_3 $data9_3
|
||||
$dnode2Vtatus = $data7_2
|
||||
$dnode3Vtatus = $data4_2
|
||||
|
||||
if $dnode2Vtatus != slave then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_master_1
|
||||
endi
|
||||
if $dnode3Vtatus != master then
|
||||
sleep 2000
|
||||
goto wait_dnode3_vgroup_master_1
|
||||
endi
|
||||
|
||||
sql select count(*) from $stb
|
||||
print data00 $data00
|
||||
if $data00 != $totalRows then
|
||||
return -1
|
||||
endi
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
|
|
@ -370,21 +370,20 @@ sql alter table stb drop column c1
|
|||
|
||||
sql alter table stb add tag t2 int
|
||||
sql alter table stb add tag t3 int
|
||||
sql alter table stb add tag t4 int
|
||||
sql_error alter table stb drop tag t1
|
||||
|
||||
$ts = $tsEnd + 10000
|
||||
sql insert into tb2 values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x )
|
||||
sql insert into tb3 values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x )
|
||||
sql insert into tb4 values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x )
|
||||
sql insert into tb5 values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x )
|
||||
sql insert into tb2 values ( $ts + 0a , $x , $x , $x ) ( $ts + 1a , $x , $x , $x ) ( $ts + 2a , $x , $x , $x ) ( $ts + 3a , $x , $x , $x ) ( $ts + 4a , $x , $x , $x ) ( $ts + 5a , $x , $x , $x ) ( $ts + 6a , $x , $x , $x ) ( $ts + 7a , $x , $x , $x ) ( $ts + 8a , $x , $x , $x ) ( $ts + 9a , $x , $x , $x )
|
||||
sql insert into tb3 values ( $ts + 0a , $x , $x , $x ) ( $ts + 1a , $x , $x , $x ) ( $ts + 2a , $x , $x , $x ) ( $ts + 3a , $x , $x , $x ) ( $ts + 4a , $x , $x , $x ) ( $ts + 5a , $x , $x , $x ) ( $ts + 6a , $x , $x , $x ) ( $ts + 7a , $x , $x , $x ) ( $ts + 8a , $x , $x , $x ) ( $ts + 9a , $x , $x , $x )
|
||||
sql insert into tb4 values ( $ts + 0a , $x , $x , $x ) ( $ts + 1a , $x , $x , $x ) ( $ts + 2a , $x , $x , $x ) ( $ts + 3a , $x , $x , $x ) ( $ts + 4a , $x , $x , $x ) ( $ts + 5a , $x , $x , $x ) ( $ts + 6a , $x , $x , $x ) ( $ts + 7a , $x , $x , $x ) ( $ts + 8a , $x , $x , $x ) ( $ts + 9a , $x , $x , $x )
|
||||
sql insert into tb5 values ( $ts + 0a , $x , $x , $x ) ( $ts + 1a , $x , $x , $x ) ( $ts + 2a , $x , $x , $x ) ( $ts + 3a , $x , $x , $x ) ( $ts + 4a , $x , $x , $x ) ( $ts + 5a , $x , $x , $x ) ( $ts + 6a , $x , $x , $x ) ( $ts + 7a , $x , $x , $x ) ( $ts + 8a , $x , $x , $x ) ( $ts + 9a , $x , $x , $x )
|
||||
|
||||
|
||||
$ts = $tsStart
|
||||
sql insert into tb14 using stb tags(14) values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x )
|
||||
sql insert into tb15 using stb tags(15) values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x )
|
||||
sql insert into tb16 using stb tags(16) values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x )
|
||||
sql insert into tb17 using stb tags(17) values ( $ts + 0a , $x ) ( $ts + 1a , $x ) ( $ts + 2a , $x ) ( $ts + 3a , $x ) ( $ts + 4a , $x ) ( $ts + 5a , $x ) ( $ts + 6a , $x ) ( $ts + 7a , $x ) ( $ts + 8a , $x ) ( $ts + 9a , $x )
|
||||
sql insert into tb14 using stb tags(14, 14, 14) values ( $ts + 0a , $x , $x , $x ) ( $ts + 1a , $x , $x , $x ) ( $ts + 2a , $x , $x , $x ) ( $ts + 3a , $x , $x , $x ) ( $ts + 4a , $x , $x , $x ) ( $ts + 5a , $x , $x , $x ) ( $ts + 6a , $x , $x , $x ) ( $ts + 7a , $x , $x , $x ) ( $ts + 8a , $x , $x , $x ) ( $ts + 9a , $x , $x , $x )
|
||||
sql insert into tb15 using stb tags(15, 15, 15) values ( $ts + 0a , $x , $x , $x ) ( $ts + 1a , $x , $x , $x ) ( $ts + 2a , $x , $x , $x ) ( $ts + 3a , $x , $x , $x ) ( $ts + 4a , $x , $x , $x ) ( $ts + 5a , $x , $x , $x ) ( $ts + 6a , $x , $x , $x ) ( $ts + 7a , $x , $x , $x ) ( $ts + 8a , $x , $x , $x ) ( $ts + 9a , $x , $x , $x )
|
||||
sql insert into tb16 using stb tags(16, 16, 16) values ( $ts + 0a , $x , $x , $x ) ( $ts + 1a , $x , $x , $x ) ( $ts + 2a , $x , $x , $x ) ( $ts + 3a , $x , $x , $x ) ( $ts + 4a , $x , $x , $x ) ( $ts + 5a , $x , $x , $x ) ( $ts + 6a , $x , $x , $x ) ( $ts + 7a , $x , $x , $x ) ( $ts + 8a , $x , $x , $x ) ( $ts + 9a , $x , $x , $x )
|
||||
sql insert into tb17 using stb tags(17, 17, 17) values ( $ts + 0a , $x , $x , $x ) ( $ts + 1a , $x , $x , $x ) ( $ts + 2a , $x , $x , $x ) ( $ts + 3a , $x , $x , $x ) ( $ts + 4a , $x , $x , $x ) ( $ts + 5a , $x , $x , $x ) ( $ts + 6a , $x , $x , $x ) ( $ts + 7a , $x , $x , $x ) ( $ts + 8a , $x , $x , $x ) ( $ts + 9a , $x , $x , $x )
|
||||
|
||||
$totalRows = $totalRows + 80
|
||||
sql select count(*) from $stb
|
||||
|
|
|
|||
Loading…
Reference in New Issue