Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
939dfae8
T
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
939dfae8
编写于
10月 25, 2022
作者:
J
jiacy-jcy
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
test:update test case for TD-19816
上级
90645bd4
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
71 addition
and
5 deletion
+71
-5
tests/system-test/0-others/show.py
tests/system-test/0-others/show.py
+71
-5
未找到文件。
tests/system-test/0-others/show.py
浏览文件 @
939dfae8
...
...
@@ -15,28 +15,30 @@
from
util.log
import
*
from
util.cases
import
*
from
util.sql
import
*
import
subprocess
from
util.common
import
*
from
util.sqlset
import
*
class
TDTestCase
:
def
init
(
self
,
conn
,
logSql
):
tdLog
.
debug
(
"start to execute %s"
%
__file__
)
tdSql
.
init
(
conn
.
cursor
())
self
.
dbname
=
'db'
self
.
setsql
=
TDSetSql
()
self
.
ins_param_list
=
[
'dnodes'
,
'mnodes'
,
'qnodes'
,
'cluster'
,
'functions'
,
'users'
,
'grants'
,
'topics'
,
'subscriptions'
,
'streams'
]
self
.
perf_param
=
[
'apps'
,
'connections'
,
'consumers'
,
'queries'
,
'transactions'
]
self
.
perf_param_list
=
[
'apps'
,
'connections'
,
'consumers'
,
'queries'
,
'trans'
]
def
ins_check
(
self
):
tdSql
.
prepare
()
for
param
in
self
.
ins_param_list
:
tdSql
.
query
(
f
'show
{
param
}
'
)
show_result
=
tdSql
.
queryResult
tdSql
.
query
(
f
'select * from information_schema.ins_
{
param
}
'
)
select_result
=
tdSql
.
queryResult
tdSql
.
checkEqual
(
show_result
,
select_result
)
tdSql
.
execute
(
'drop database db'
)
def
perf_check
(
self
):
tdSql
.
prepare
()
for
param
in
range
(
len
(
self
.
perf_param_list
)):
tdSql
.
query
(
f
'show
{
self
.
perf_param
[
param
]
}
'
)
if
len
(
tdSql
.
queryResult
)
!=
0
:
...
...
@@ -46,11 +48,74 @@ class TDTestCase:
tdSql
.
checkEqual
(
show_result
,
select_result
)
else
:
continue
def
run
(
self
):
tdSql
.
execute
(
'drop database db'
)
def
set_stb_sql
(
self
,
stbname
,
column_dict
,
tag_dict
):
column_sql
=
''
tag_sql
=
''
for
k
,
v
in
column_dict
.
items
():
column_sql
+=
f
"
{
k
}
{
v
}
, "
for
k
,
v
in
tag_dict
.
items
():
tag_sql
+=
f
"
{
k
}
{
v
}
, "
create_stb_sql
=
f
'create stable
{
stbname
}
(
{
column_sql
[:
-
2
]
}
) tags (
{
tag_sql
[:
-
2
]
}
)'
return
create_stb_sql
def
show_sql
(
self
):
tdSql
.
prepare
()
tdSql
.
execute
(
'use db'
)
stbname
=
f
'`
{
tdCom
.
getLongName
(
5
)
}
`'
tbname
=
f
'`
{
tdCom
.
getLongName
(
3
)
}
`'
column_dict
=
{
'`ts`'
:
'timestamp'
,
'`col1`'
:
'tinyint'
,
'`col2`'
:
'smallint'
,
'`col3`'
:
'int'
,
'`col4`'
:
'bigint'
,
'`col5`'
:
'tinyint unsigned'
,
'`col6`'
:
'smallint unsigned'
,
'`col7`'
:
'int unsigned'
,
'`col8`'
:
'bigint unsigned'
,
'`col9`'
:
'float'
,
'`col10`'
:
'double'
,
'`col11`'
:
'bool'
,
'`col12`'
:
'varchar(20)'
,
'`col13`'
:
'nchar(20)'
}
tag_dict
=
{
'`t1`'
:
'tinyint'
,
'`t2`'
:
'smallint'
,
'`t3`'
:
'int'
,
'`t4`'
:
'bigint'
,
'`t5`'
:
'tinyint unsigned'
,
'`t6`'
:
'smallint unsigned'
,
'`t7`'
:
'int unsigned'
,
'`t8`'
:
'bigint unsigned'
,
'`t9`'
:
'float'
,
'`t10`'
:
'double'
,
'`t11`'
:
'bool'
,
'`t12`'
:
'varchar(20)'
,
'`t13`'
:
'nchar(20)'
,
'`t14`'
:
'timestamp'
}
create_table_sql
=
self
.
set_stb_sql
(
stbname
,
column_dict
,
tag_dict
)
tdSql
.
execute
(
create_table_sql
)
tdSql
.
query
(
f
'show create table
{
stbname
}
'
)
query_result
=
tdSql
.
queryResult
tdSql
.
checkEqual
(
query_result
[
0
][
1
].
lower
(),
create_table_sql
)
tdSql
.
execute
(
f
'create table
{
tbname
}
using
{
stbname
}
tags(1,1,1,1,1,1,1,1,1.000000e+00,1.000000e+00,true,"abc","abc123",0)'
)
tag_sql
=
'('
for
tag_keys
in
tag_dict
.
keys
():
tag_sql
+=
f
'
{
tag_keys
}
, '
tags
=
f
'
{
tag_sql
[:
-
2
]
}
)'
sql
=
f
'create table
{
tbname
}
using
{
stbname
}
{
tags
}
tags (1, 1, 1, 1, 1, 1, 1, 1, 1.000000e+00, 1.000000e+00, true, "abc", "abc123", 0)'
tdSql
.
query
(
f
'show create table
{
tbname
}
'
)
query_result
=
tdSql
.
queryResult
tdSql
.
checkEqual
(
query_result
[
0
][
1
].
lower
(),
sql
)
tdSql
.
execute
(
'drop database db'
)
def
run
(
self
):
self
.
ins_check
()
self
.
perf_check
()
self
.
show_sql
()
def
stop
(
self
):
tdSql
.
close
()
...
...
@@ -58,3 +123,4 @@ class TDTestCase:
tdCases
.
addWindows
(
__file__
,
TDTestCase
())
tdCases
.
addLinux
(
__file__
,
TDTestCase
())
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录