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

Merge pull request #17568 from taosdata/test/td-19625 

test: add cachemodel for last
This commit is contained in:
Hui Li 2022-10-27 11:16:09 +08:00 committed by GitHub
parent 6c5372aad2 d4f678f0d6
commit b467bad419
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tests/system-test/2-query/last.py
View File

@ -17,6 +17,7 @@ class TDTestCase:
self.ts = 1537146000000 self.ts = 1537146000000
self.binary_str = 'taosdata' self.binary_str = 'taosdata'
self.nchar_str = '涛思数据' self.nchar_str = '涛思数据'
self.cachemodel = None
def set_create_normaltable_sql(self, ntbname, column_dict): def set_create_normaltable_sql(self, ntbname, column_dict):
column_sql = '' column_sql = ''
@ -36,7 +37,8 @@ class TDTestCase:
return create_stb_sql return create_stb_sql
def last_check_stb_tb_base(self): def last_check_stb_tb_base(self):
tdSql.prepare() tdSql.execute(
f'create database if not exists db cachemodel "{self.cachemodel}"')
stbname = f'db.{tdCom.getLongName(5, "letters")}' stbname = f'db.{tdCom.getLongName(5, "letters")}'
column_dict = { column_dict = {
'col1': 'tinyint', 'col1': 'tinyint',
@ -112,7 +114,8 @@ class TDTestCase:
tdSql.execute('drop database db') tdSql.execute('drop database db')
def last_check_ntb_base(self): def last_check_ntb_base(self):
tdSql.prepare() tdSql.execute(
f'create database if not exists db cachemodel "{self.cachemodel}"')
ntbname = f'db.{tdCom.getLongName(5, "letters")}' ntbname = f'db.{tdCom.getLongName(5, "letters")}'
column_dict = { column_dict = {
'col1': 'tinyint', 'col1': 'tinyint',
@ -191,7 +194,7 @@ class TDTestCase:
} }
tdSql.execute( tdSql.execute(
f"create database if not exists {dbname} vgroups {vgroup_num}") f'create database if not exists {dbname} vgroups {vgroup_num} cachemodel "{self.cachemodel}"')
tdSql.execute(f'use {dbname}') tdSql.execute(f'use {dbname}')
# build 20 child tables,every table insert 10 rows # build 20 child tables,every table insert 10 rows
@ -244,9 +247,11 @@ class TDTestCase:
tdSql.execute(f'drop database {dbname}') tdSql.execute(f'drop database {dbname}')
def run(self): def run(self):
self.last_check_stb_tb_base() for cachemodel in ["None", "last_row", "last_value", "both"]:
self.last_check_ntb_base() self.cachemodel = cachemodel
self.last_check_stb_distribute() self.last_check_stb_tb_base()
self.last_check_ntb_base()
self.last_check_stb_distribute()
def stop(self): def stop(self):
tdSql.close() tdSql.close()