testcase-subscribe of super table

This commit is contained in:
tomchon 2021-05-19 17:55:11 +08:00
parent abe9b75667
commit 75fef03688
4 changed files with 40 additions and 14 deletions

View File

@ -35,10 +35,10 @@
"super_tables": [{
"name": "stb0",
"child_table_exists":"no",
"childtable_count": 200,
"childtable_count": 100,
"childtable_prefix": "stb00_",
"auto_create_table": "no",
"batch_create_tbl_num": 10,
"batch_create_tbl_num": 1000,
"data_source": "rand",
"insert_mode": "taosc",
"insert_rows": 10,

View File

@ -0,0 +1,28 @@
{
"filetype":"subscribe",
"cfgdir": "/etc/taos",
"host": "127.0.0.1",
"port": 6030,
"user": "root",
"password": "taosdata",
"databases": "db",
"confirm_parameter_prompt": "no",
"super_table_query":
{
"stblname": "stb0",
"threads":2,
"mode":"sync",
"interval":0,
"restart":"no",
"keepProgress":"no",
"sqls": [
{
"sql": "select * from xxxx where ts >= '2021-02-25 10:00:01.000' ",
"result": "./subscribe_res2.txt"
},
{
"sql": "select * from xxxx where ts > '2021-02-25 10:00:04.000' ",
"result": "./subscribe_res3.txt"
}]
}
}

View File

@ -11,12 +11,12 @@
{
"concurrent":2,
"mode":"sync",
"interval":0,
"restart":"yes",
"keepProgress":"yes",
"interval":10000,
"restart":"no",
"keepProgress":"no",
"sqls": [
{
"sql": "select * from stb00_0",
"sql": "select * from stb0",
"result": "./subscribe_res0.txt"
},
{
@ -421,17 +421,13 @@
"stblname": "stb0",
"threads":2,
"mode":"sync",
"interval":10000,
"restart":"yes",
"keepProgress":"yes",
"interval":0,
"restart":"no",
"keepProgress":"no",
"sqls": [
{
"sql": "select * from xxxx where ts >= '2021-02-25 10:00:01.000' ",
"result": "./subscribe_res2.txt"
},
{
"sql": "select * from xxxx where ts > '2021-02-25 10:00:04.000' ",
"result": "./subscribe_res3.txt"
}]
}
}

View File

@ -113,7 +113,9 @@ class TDTestCase:
# query times less than or equal to 100
os.system("%staosdemo -f tools/taosdemoAllTest/subInsertdataMaxsql100.json" % binPath)
os.system("%staosdemo -f tools/taosdemoAllTest/subSyncMaxsql100.json" % binPath)
# os.system("%staosdemo -f tools/taosdemoAllTest/subSyncMaxsql100.json" % binPath)
os.system("%staosdemo -f tools/taosdemoAllTest/subSupermaxsql100.json" % binPath)
# delete useless files
os.system("rm -rf ./insert_res.txt")