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

enh: check existence of files properly in multilevel.py

This commit is contained in:
Benguang Zhao 2023-10-17 16:02:22 +08:00
parent c4e9069a66
commit e463e0690d
1 changed files with 33 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
tests/system-test/0-others/multilevel.py
View File

@ -17,6 +17,28 @@ from util.cases import *
from util.sql import * from util.sql import *
from util.common import * from util.common import *
from util.sqlset import * from util.sqlset import *
import glob
def scanFiles(pattern):
res = []
for f in glob.iglob(pattern):
res += [f]
return res
def checkFiles(pattern, state):
res = scanFiles(pattern)
tdLog.info(res)
num = len(res)
if num:
if state:
tdLog.info("%s: %d files exist. expect: files exist" % (pattern, num))
else:
tdLog.exit("%s: %d files exist. expect: files not exist." % (pattern, num))
else:
if state:
tdLog.exit("%s: %d files exist. expect: files exist" % (pattern, num))
else:
tdLog.info("%s: %d files exist. expect: files not exist." % (pattern, num))
class TDTestCase: class TDTestCase:
def init(self, conn, logSql, replicaVar=1): def init(self, conn, logSql, replicaVar=1):
@ -41,8 +63,8 @@ class TDTestCase:
tdDnodes.start(1) tdDnodes.start(1)
tdLog.info("================= step2") tdLog.info("================= step2")
tdSql.haveFile('/mnt/data1/',1) checkFiles(r'/mnt/data1/*/*',1)
tdSql.haveFile('/mnt/data2/',0) checkFiles(r'/mnt/data2/*/*',0)
tdDnodes.stop(1) tdDnodes.stop(1)
def dir_not_exist(self): def dir_not_exist(self):
tdLog.info("============== dir_not_exist test ===============") tdLog.info("============== dir_not_exist test ===============")
@ -156,9 +178,9 @@ class TDTestCase:
tdDnodes.start(1) tdDnodes.start(1)
for i in dir_list: for i in dir_list:
if i == '/mnt/data000': if i == '/mnt/data000':
tdSql.haveFile(i,1) checkFiles("%s/*/*" % i, 1)
else: else:
tdSql.haveFile(i,0) checkFiles("%s/*/*" % i, 0)
def more_than_16_disks(self): def more_than_16_disks(self):
tdLog.info("============== more_than_16_disks test ===============") tdLog.info("============== more_than_16_disks test ===============")
@ -223,7 +245,8 @@ class TDTestCase:
for i in range(10,30): for i in range(10,30):
tdSql.execute(f'insert into tb1 values(now-{i}d,10)') tdSql.execute(f'insert into tb1 values(now-{i}d,10)')
tdSql.execute('flush database dbtest') tdSql.execute('flush database dbtest')
tdSql.haveFile('/mnt/data1/',1) time.sleep(3)
checkFiles('/mnt/data1/vnode/*/tsdb/v*',1)
tdDnodes.stop(1) tdDnodes.stop(1)
cfg={ cfg={
'/mnt/data1 0 1' : 'dataDir', '/mnt/data1 0 1' : 'dataDir',
@ -234,14 +257,14 @@ class TDTestCase:
tdSql.createDir('/mnt/data3') tdSql.createDir('/mnt/data3')
tdDnodes.deploy(1,cfg) tdDnodes.deploy(1,cfg)
tdDnodes.start(1) tdDnodes.start(1)
tdSql.haveFile('/mnt/data1/',1) checkFiles('/mnt/data1/vnode/*/tsdb/v*',1)
tdSql.haveFile('/mnt/data2/',0) checkFiles('/mnt/data2/vnode/*/tsdb/v*',0)
tdSql.haveFile('/mnt/data3/',0) checkFiles('/mnt/data3/vnode/*/tsdb/v*',0)
tdSql.execute('alter database dbtest keep 10d,365d,3650d') tdSql.execute('alter database dbtest keep 10d,365d,3650d')
tdSql.execute('trim database dbtest') tdSql.execute('trim database dbtest')
time.sleep(3) time.sleep(3)
tdSql.haveFile('/mnt/data1/',1) checkFiles('/mnt/data1/vnode/*/tsdb/v*',1)
tdSql.haveFile('/mnt/data2/',1) checkFiles('/mnt/data2/vnode/*/tsdb/v*',1)
def run(self): def run(self):
self.basic() self.basic()