update crash_gen

This commit is contained in:
Ping Xiao 2023-05-22 20:10:13 +08:00
parent f3491310a9
commit 7b20d2fa7d
1 changed files with 4 additions and 2 deletions

View File

@ -1722,12 +1722,14 @@ class TaskCreateDb(StateTransitionTask):
vg_nums = random.randint(1, 8) vg_nums = random.randint(1, 8)
cache_model = Dice.choice(['none', 'last_row', 'last_value', 'both']) cache_model = Dice.choice(['none', 'last_row', 'last_value', 'both'])
buffer = random.randint(3, 128) buffer = random.randint(3, 128)
walRetentionPeriod = random.randint(1, 10000)
dbName = self._db.getName() dbName = self._db.getName()
self.execWtSql(wt, "create database {} {} {} vgroups {} cachemodel '{}' buffer {} ".format(dbName, repStr, self.execWtSql(wt, "create database {} {} {} vgroups {} cachemodel '{}' buffer {} wal_retention_period {} ".format(dbName, repStr,
updatePostfix, updatePostfix,
vg_nums, vg_nums,
cache_model, cache_model,
buffer)) buffer,
walRetentionPeriod))
if dbName == "db_0" and Config.getConfig().use_shadow_db: if dbName == "db_0" and Config.getConfig().use_shadow_db:
self.execWtSql(wt, "create database {} {} {} ".format("db_s", repStr, updatePostfix)) self.execWtSql(wt, "create database {} {} {} ".format("db_s", repStr, updatePostfix))