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

add function to delete data files.

This commit is contained in:
Shuduo Sang 2020-05-21 18:05:29 +08:00
parent c736e05cea
commit f7181a5e04
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/pytest/random-test/random-test.py
View File

@ -108,6 +108,18 @@ class Test:
tdDnodes.start(1) tdDnodes.start(1)
tdSql.prepare() tdSql.prepare()
def delete_datafiles(self):
tdLog.info("delete data files")
dnodesDir = tdDnodes.getDnodesRootDir()
dataDir = dnodesDir + '/dnode1/*'
deleteCmd = 'rm -rf %s' % dataDir
os.system(deleteCmd)
self.current_tb = ""
self.last_tb = ""
self.written = 0
tdDnodes.start(1)
tdSql.prepare()
class TDTestCase: class TDTestCase:
def init(self, conn, logSql): def init(self, conn, logSql):
@ -129,10 +141,11 @@ class TDTestCase:
7: test.drop_table, 7: test.drop_table,
8: test.reset_query_cache, 8: test.reset_query_cache,
9: test.reset_database, 9: test.reset_database,
10: test.delete_datafiles,
} }
for x in range(1, 100): for x in range(1, 100):
r = random.randint(1, 9) r = random.randint(1, 10)
tdLog.notice("iteration %d run func %d" % (x, r)) tdLog.notice("iteration %d run func %d" % (x, r))
switch.get(r, lambda: "ERROR")() switch.get(r, lambda: "ERROR")()