Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
6c5372aa
T
TDengine
项目概览
taosdata
/
TDengine
大约 2 年 前同步成功
通知
1193
Star
22018
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看板
未验证
提交
6c5372aa
编写于
10月 27, 2022
作者:
H
Hui Li
提交者:
GitHub
10月 27, 2022
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #17699 from taosdata/test/TD-19854_1
test: add index cases
上级
60f15299
74c6709d
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
651 addition
and
0 deletion
+651
-0
tests/system-test/2-query/select_index.py
tests/system-test/2-query/select_index.py
+651
-0
未找到文件。
tests/system-test/2-query/select_index.py
0 → 100755
浏览文件 @
6c5372aa
###################################################################
# Copyright (c) 2016 by TAOS Technologies, Inc.
# All rights reserved.
#
# This file is proprietary and confidential to TAOS Technologies.
# No part of this file may be reproduced, stored, transmitted,
# disclosed or used in any form or by any means other than as
# expressly provided by the written permission from Jianhui Tao
#
###################################################################
# -*- coding: utf-8 -*-
import
random
import
os
import
time
import
taos
import
subprocess
from
faker
import
Faker
from
util.log
import
tdLog
from
util.cases
import
tdCases
from
util.sql
import
tdSql
from
util.dnodes
import
tdDnodes
from
util.dnodes
import
*
class
TDTestCase
:
updatecfgDict
=
{
'maxSQLLength'
:
1048576
,
'debugFlag'
:
143
,
"querySmaOptimize"
:
1
}
def
init
(
self
,
conn
,
logSql
):
tdLog
.
debug
(
"start to execute %s"
%
__file__
)
tdSql
.
init
(
conn
.
cursor
(),
logSql
)
self
.
testcasePath
=
os
.
path
.
split
(
__file__
)[
0
]
self
.
testcaseFilename
=
os
.
path
.
split
(
__file__
)[
-
1
]
os
.
system
(
"rm -rf %s/%s.sql"
%
(
self
.
testcasePath
,
self
.
testcaseFilename
))
self
.
db
=
"ind_sel"
def
dropandcreateDB_random
(
self
,
database
,
n
,
vgroups
):
ts
=
1630000000000
num_random
=
100
fake
=
Faker
(
'zh_CN'
)
tdSql
.
execute
(
'''drop database if exists %s ;'''
%
database
)
tdSql
.
execute
(
'''create database %s keep 36500 vgroups %d ;'''
%
(
database
,
vgroups
))
tdSql
.
execute
(
'''use %s;'''
%
database
)
tdSql
.
execute
(
'''create stable %s.stable_1 (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint , q_float float , q_double double , q_bool bool , q_binary binary(100) , q_nchar nchar(100) , q_ts timestamp ,
\
q_binary1 binary(100) , q_nchar1 nchar(100) ,q_binary2 binary(100) , q_nchar2 nchar(100) ,q_binary3 binary(100) , q_nchar3 nchar(100) ,q_binary4 binary(100) , q_nchar4 nchar(100) ,
\
q_binary5 binary(100) , q_nchar5 nchar(100) ,q_binary6 binary(100) , q_nchar6 nchar(100) ,q_binary7 binary(100) , q_nchar7 nchar(100) ,q_binary8 binary(100) , q_nchar8 nchar(100) ,
\
q_int_null int , q_bigint_null bigint , q_smallint_null smallint , q_tinyint_null tinyint, q_float_null float , q_double_null double , q_bool_null bool , q_binary_null binary(20) , q_nchar_null nchar(20) , q_ts_null timestamp)
\
tags(loc nchar(100) , t_int int , t_bigint bigint , t_smallint smallint , t_tinyint tinyint, t_bool bool , t_binary binary(100) , t_nchar nchar(100) ,t_float float , t_double double , t_ts timestamp);'''
%
database
)
tdSql
.
execute
(
'''create stable %s.stable_2 (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint , q_float float , q_double double , q_bool bool , q_binary binary(100) , q_nchar nchar(100) , q_ts timestamp ,
\
q_int_null int , q_bigint_null bigint , q_smallint_null smallint , q_tinyint_null tinyint, q_float_null float , q_double_null double , q_bool_null bool , q_binary_null binary(20) , q_nchar_null nchar(20) , q_ts_null timestamp)
\
tags(loc nchar(100) , t_int int , t_bigint bigint , t_smallint smallint , t_tinyint tinyint, t_bool bool , t_binary binary(100) , t_nchar nchar(100) ,t_float float , t_double double , t_ts timestamp);'''
%
database
)
for
i
in
range
(
10
*
n
):
tdSql
.
execute
(
'''create table %s.bj_%d (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint , q_float float , q_double double , q_bool bool , q_binary binary(100) , q_nchar nchar(100) , q_ts timestamp ) ;'''
%
(
database
,
i
))
tdSql
.
execute
(
'''create table %s.sh_%d (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint , q_float float , q_double double , q_bool bool , q_binary binary(100) , q_nchar nchar(100) , q_ts timestamp ) ;'''
%
(
database
,
i
))
tdSql
.
execute
(
'''create table %s.bj_table_%d_r (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint , q_float float , q_double double , q_bool bool , q_binary binary(100) , q_nchar nchar(100) , q_ts timestamp ) ;'''
%
(
database
,
i
))
tdSql
.
execute
(
'''create table %s.sh_table_%d_r (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint , q_float float , q_double double , q_bool bool , q_binary binary(100) , q_nchar nchar(100) , q_ts timestamp ) ;'''
%
(
database
,
i
))
tdSql
.
execute
(
'''create table %s.hn_table_%d_r
\
(ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint , q_float float , q_double double , q_bool bool , q_binary binary(100) , q_nchar nchar(100) , q_ts timestamp ,
\
q_binary1 binary(100) , q_nchar1 nchar(100) ,q_binary2 binary(100) , q_nchar2 nchar(100) ,q_binary3 binary(100) , q_nchar3 nchar(100) ,q_binary4 binary(100) , q_nchar4 nchar(100) ,
\
q_binary5 binary(100) , q_nchar5 nchar(100) ,q_binary6 binary(100) , q_nchar6 nchar(100) ,q_binary7 binary(100) , q_nchar7 nchar(100) ,q_binary8 binary(100) , q_nchar8 nchar(100) ,
\
q_int_null int , q_bigint_null bigint , q_smallint_null smallint , q_tinyint_null tinyint, q_float_null float , q_double_null double , q_bool_null bool , q_binary_null binary(20) , q_nchar_null nchar(20) , q_ts_null timestamp) ;'''
%
(
database
,
i
))
tdSql
.
execute
(
'''create table %s.bj_stable_1_%d using %s.stable_1 tags('bj_stable_1_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
tdSql
.
execute
(
'''create table %s.sh_table_%d_a using %s.stable_1 tags('sh_a_table_1_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
tdSql
.
execute
(
'''create table %s.sh_table_%d_b using %s.stable_1 tags('sh_b_table_1_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
tdSql
.
execute
(
'''create table %s.sh_table_%d_c using %s.stable_1 tags('sh_c_table_1_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
tdSql
.
execute
(
'''create table %s.bj_table_%d_a using %s.stable_1 tags('bj_a_table_1_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
tdSql
.
execute
(
'''create table %s.bj_table_%d_b using %s.stable_1 tags('bj_b_table_1_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
tdSql
.
execute
(
'''create table %s.bj_table_%d_c using %s.stable_1 tags('bj_c_table_1_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
tdSql
.
execute
(
'''create table %s.tj_table_%d_a using %s.stable_2 tags('tj_a_table_2_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
tdSql
.
execute
(
'''create table %s.tj_table_%d_b using %s.stable_2 tags('tj_b_table_2_%d', '%d' , '%d', '%d' , '%d' , 1 , 'binary1.%s' , 'nchar1.%s' , '%f', '%f' ,'%d') ;'''
%
(
database
,
i
,
database
,
i
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pyfloat
(),
fake
.
pyfloat
(),
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)))
# insert data
for
i
in
range
(
num_random
*
n
):
tdSql
.
execute
(
'''insert into %s.bj_stable_1_1 (ts , q_int , q_bigint , q_smallint , q_tinyint , q_float , q_double , q_bool , q_binary , q_nchar, q_ts,
\
q_binary1 , q_nchar1 , q_binary2 , q_nchar2 , q_binary3 , q_nchar3 , q_binary4 , q_nchar4 , q_binary5 , q_nchar5 , q_binary6 , q_nchar6 , q_binary7 , q_nchar7, q_binary8 , q_nchar8)
\
values(%d, %d, %d, %d, %d, %f, %f, 0, 'binary.%s', 'nchar.%s', %d, 'binary1.%s', 'nchar1.%s', 'binary2.%s', 'nchar2.%s', 'binary3.%s', 'nchar3.%s',
\
'binary4.%s', 'nchar4.%s', 'binary5.%s', 'nchar5.%s', 'binary6.%s', 'nchar6.%s', 'binary7.%s', 'nchar7.%s', 'binary8.%s', 'nchar8.%s') ;'''
%
(
database
,
ts
+
i
*
1000
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pyfloat
()
,
fake
.
pyfloat
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
ts
+
i
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()))
tdSql
.
execute
(
'''insert into %s.hn_table_1_r (ts , q_int , q_bigint , q_smallint , q_tinyint , q_float , q_double, q_bool , q_binary , q_nchar, q_ts,
\
q_binary1 , q_nchar1 , q_binary2 , q_nchar2 , q_binary3 , q_nchar3 , q_binary4 , q_nchar4 , q_binary5 , q_nchar5 , q_binary6 , q_nchar6 , q_binary7 , q_nchar7, q_binary8 , q_nchar8)
\
values(%d, %d, %d, %d, %d, %f, %f, 0, 'binary.%s', 'nchar.%s', %d, 'binary1.%s', 'nchar1.%s', 'binary2.%s', 'nchar2.%s', 'binary3.%s', 'nchar3.%s',
\
'binary4.%s', 'nchar4.%s', 'binary5.%s', 'nchar5.%s', 'binary6.%s', 'nchar6.%s', 'binary7.%s', 'nchar7.%s', 'binary8.%s', 'nchar8.%s') ;'''
%
(
database
,
ts
+
i
*
1000
,
fake
.
random_int
(
min
=-
2147483647
,
max
=
2147483647
,
step
=
1
)
,
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
)
,
fake
.
random_int
(
min
=-
32767
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
127
,
max
=
127
,
step
=
1
)
,
fake
.
pyfloat
()
,
fake
.
pyfloat
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
ts
+
i
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()))
tdSql
.
execute
(
'''insert into %s.bj_stable_1_2 (ts , q_int , q_bigint , q_smallint , q_tinyint , q_float , q_double, q_bool , q_binary , q_nchar, q_ts,
\
q_binary1 , q_nchar1 , q_binary2 , q_nchar2 , q_binary3 , q_nchar3 , q_binary4 , q_nchar4 , q_binary5 , q_nchar5 , q_binary6 , q_nchar6 , q_binary7 , q_nchar7, q_binary8 , q_nchar8)
\
values(%d, %d, %d, %d, %d, %f, %f, 1, 'binary.%s', 'nchar.%s', %d, 'binary1.%s', 'nchar1.%s', 'binary2.%s', 'nchar2.%s', 'binary3.%s', 'nchar3.%s',
\
'binary4.%s', 'nchar4.%s', 'binary5.%s', 'nchar5.%s', 'binary6.%s', 'nchar6.%s', 'binary7.%s', 'nchar7.%s', 'binary8.%s', 'nchar8.%s') ;'''
%
(
database
,
ts
+
i
*
1000
,
fake
.
random_int
(
min
=
0
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=
0
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=
0
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=
0
,
max
=
127
,
step
=
1
)
,
fake
.
pyfloat
()
,
fake
.
pyfloat
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
ts
+
i
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()))
tdSql
.
execute
(
'''insert into %s.hn_table_2_r (ts , q_int , q_bigint , q_smallint , q_tinyint , q_float , q_double, q_bool , q_binary , q_nchar, q_ts,
\
q_binary1 , q_nchar1 , q_binary2 , q_nchar2 , q_binary3 , q_nchar3 , q_binary4 , q_nchar4 , q_binary5 , q_nchar5 , q_binary6 , q_nchar6 , q_binary7 , q_nchar7, q_binary8 , q_nchar8)
\
values(%d, %d, %d, %d, %d, %f, %f, 1, 'binary.%s', 'nchar.%s', %d, 'binary1.%s', 'nchar1.%s', 'binary2.%s', 'nchar2.%s', 'binary3.%s', 'nchar3.%s',
\
'binary4.%s', 'nchar4.%s', 'binary5.%s', 'nchar5.%s', 'binary6.%s', 'nchar6.%s', 'binary7.%s', 'nchar7.%s', 'binary8.%s', 'nchar8.%s') ;'''
%
(
database
,
ts
+
i
*
1000
,
fake
.
random_int
(
min
=
0
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=
0
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=
0
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=
0
,
max
=
127
,
step
=
1
)
,
fake
.
pyfloat
()
,
fake
.
pyfloat
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
ts
+
i
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()))
tdSql
.
execute
(
'''insert into %s.bj_stable_1_3 (ts , q_int , q_bigint , q_smallint , q_tinyint , q_float , q_double, q_bool , q_binary , q_nchar, q_ts,
\
q_binary1 , q_nchar1 , q_binary2 , q_nchar2 , q_binary3 , q_nchar3 , q_binary4 , q_nchar4 , q_binary5 , q_nchar5 , q_binary6 , q_nchar6 , q_binary7 , q_nchar7, q_binary8 , q_nchar8)
\
values(%d, %d, %d, %d, %d, %f, %f, 0, 'binary.%s', 'nchar.%s', %d, 'binary1.%s', 'nchar1.%s', 'binary2.%s', 'nchar2.%s', 'binary3.%s', 'nchar3.%s',
\
'binary4.%s', 'nchar4.%s', 'binary5.%s', 'nchar5.%s', 'binary6.%s', 'nchar6.%s', 'binary7.%s', 'nchar7.%s', 'binary8.%s', 'nchar8.%s') ;'''
%
(
database
,
ts
+
i
*
1000
,
fake
.
random_int
(
min
=-
0
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
0
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
0
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
0
,
max
=
127
,
step
=
1
)
,
fake
.
pyfloat
()
,
fake
.
pyfloat
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
ts
+
i
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()))
tdSql
.
execute
(
'''insert into %s.bj_stable_1_4 (ts , q_int , q_bigint , q_smallint , q_tinyint , q_float , q_double, q_bool , q_binary , q_nchar, q_ts,
\
q_binary1 , q_nchar1 , q_binary2 , q_nchar2 , q_binary3 , q_nchar3 , q_binary4 , q_nchar4 , q_binary5 , q_nchar5 , q_binary6 , q_nchar6 , q_binary7 , q_nchar7, q_binary8 , q_nchar8)
\
values(%d, %d, %d, %d, %d, %f, %f, 0, 'binary.%s', 'nchar.%s', %d, 'binary1.%s', 'nchar1.%s', 'binary2.%s', 'nchar2.%s', 'binary3.%s', 'nchar3.%s',
\
'binary4.%s', 'nchar4.%s', 'binary5.%s', 'nchar5.%s', 'binary6.%s', 'nchar6.%s', 'binary7.%s', 'nchar7.%s', 'binary8.%s', 'nchar8.%s') ;'''
%
(
database
,
ts
+
i
*
1000
+
1
,
fake
.
random_int
(
min
=-
0
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
0
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
0
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
0
,
max
=
127
,
step
=
1
)
,
fake
.
pyfloat
()
,
fake
.
pyfloat
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
ts
+
i
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()))
tdSql
.
execute
(
'''insert into %s.bj_stable_1_5 (ts , q_int , q_bigint , q_smallint , q_tinyint , q_float , q_double, q_bool , q_binary , q_nchar, q_ts,
\
q_binary1 , q_nchar1 , q_binary2 , q_nchar2 , q_binary3 , q_nchar3 , q_binary4 , q_nchar4 , q_binary5 , q_nchar5 , q_binary6 , q_nchar6 , q_binary7 , q_nchar7, q_binary8 , q_nchar8)
\
values(%d, %d, %d, %d, %d, %f, %f, 0, 'binary.%s', 'nchar.%s', %d, 'binary1.%s', 'nchar1.%s', 'binary2.%s', 'nchar2.%s', 'binary3.%s', 'nchar3.%s',
\
'binary4.%s', 'nchar4.%s', 'binary5.%s', 'nchar5.%s', 'binary6.%s', 'nchar6.%s', 'binary7.%s', 'nchar7.%s', 'binary8.%s', 'nchar8.%s') ;'''
%
(
database
,
ts
+
i
*
1000
+
10
,
fake
.
random_int
(
min
=-
0
,
max
=
2147483647
,
step
=
1
),
fake
.
random_int
(
min
=-
0
,
max
=
9223372036854775807
,
step
=
1
),
fake
.
random_int
(
min
=-
0
,
max
=
32767
,
step
=
1
)
,
fake
.
random_int
(
min
=-
0
,
max
=
127
,
step
=
1
)
,
fake
.
pyfloat
()
,
fake
.
pyfloat
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
ts
+
i
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()
,
fake
.
pystr
()))
tdSql
.
query
(
"select count(*) from %s.stable_1;"
%
database
)
tdSql
.
checkData
(
0
,
0
,
5
*
num_random
*
n
)
tdSql
.
query
(
"select count(*) from %s.hn_table_1_r;"
%
database
)
tdSql
.
checkData
(
0
,
0
,
num_random
*
n
)
def
func_index_check
(
self
,
database
,
func
,
column
):
fake
=
Faker
(
'zh_CN'
)
fake_data
=
fake
.
random_int
(
min
=
1
,
max
=
20
,
step
=
1
)
tdLog
.
info
(
"
\n
=============constant(%s)_check ====================
\n
"
%
func
)
tdSql
.
execute
(
" create sma index sma_index_name1 on stable_1 function(%s(%s)) interval(%dm); "
%
(
func
,
column
,
fake_data
))
sql
=
" select %s(%s) from %s.stable_1 interval(1m) "
%
(
func
,
column
,
database
)
tdLog
.
info
(
sql
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
flush_before_value
=
tdSql
.
queryResult
[
i
][
0
]
tdLog
.
info
(
"
\n
=============flush database ====================
\n
"
)
tdSql
.
execute
(
" flush database %s;"
%
database
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
flush_after_value
=
tdSql
.
queryResult
[
i
][
0
]
self
.
value_check
(
flush_before_value
,
flush_after_value
)
tdLog
.
info
(
"
\n
=============drop index ====================
\n
"
)
tdSql
.
execute
(
" drop index sma_index_name1;"
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
drop_index_value
=
tdSql
.
queryResult
[
i
][
0
]
self
.
value_check
(
flush_before_value
,
drop_index_value
)
def
constant_check
(
self
,
database
,
func
,
column
):
tdLog
.
info
(
"
\n
=============constant(%s)_check ====================
\n
"
%
column
)
sql
=
" select %s(%s) from %s.stable_1 "
%
(
func
,
column
,
database
)
tdLog
.
info
(
sql
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
flush_before_value
=
tdSql
.
queryResult
[
i
][
0
]
tdLog
.
info
(
"
\n
=============flush database ====================
\n
"
)
tdSql
.
execute
(
" flush database %s;"
%
database
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
flush_after_value
=
tdSql
.
queryResult
[
i
][
0
]
self
.
value_check
(
flush_before_value
,
flush_after_value
)
def
constant_table_check
(
self
,
database
,
func
,
column
):
tdLog
.
info
(
"
\n
=============constant(%s)_check ====================
\n
"
%
column
)
sql
=
" select %s(%s) from %s.bj_stable_1_1 "
%
(
func
,
column
,
database
)
tdLog
.
info
(
sql
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
flush_before_value
=
tdSql
.
queryResult
[
i
][
0
]
tdLog
.
info
(
"
\n
=============flush database ====================
\n
"
)
tdSql
.
execute
(
" flush database %s;"
%
database
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
flush_after_value
=
tdSql
.
queryResult
[
i
][
0
]
self
.
value_check
(
flush_before_value
,
flush_after_value
)
def
constant_str_check
(
self
,
database
,
func
,
column
):
tdLog
.
info
(
"
\n
=============constant(%s)_check ====================
\n
"
%
column
)
sql
=
" select %s('%s') from %s.stable_1 "
%
(
func
,
column
,
database
)
tdLog
.
info
(
sql
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
flush_before_value
=
tdSql
.
queryResult
[
i
][
0
]
tdLog
.
info
(
"
\n
=============flush database ====================
\n
"
)
tdSql
.
execute
(
" flush database %s;"
%
database
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
print
(
"row=%d, result=%s "
%
(
i
,
tdSql
.
queryResult
[
i
][
0
]))
flush_after_value
=
tdSql
.
queryResult
[
i
][
0
]
self
.
value_check
(
flush_before_value
,
flush_after_value
)
def
constant_error_check
(
self
,
database
,
func
,
column
):
tdLog
.
info
(
"
\n
=============constant(%s)_check ====================
\n
"
%
column
)
error_sql
=
" select %s('%s') "
%
(
func
,
column
)
tdLog
.
info
(
error_sql
)
tdSql
.
error
(
error_sql
)
tdLog
.
info
(
"
\n
=============flush database ====================
\n
"
)
tdSql
.
execute
(
" flush database %s;"
%
database
)
tdSql
.
error
(
error_sql
)
def
derivative_sql
(
self
,
database
):
fake
=
Faker
(
'zh_CN'
)
fake_data
=
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
)
tdLog
.
info
(
"
\n
=============derivative sql ====================
\n
"
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 "
%
(
'q_smallint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 "
%
(
'q_bigint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 "
%
(
'q_tinyint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 "
%
(
'q_int'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 "
%
(
'q_float'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 "
%
(
'q_double'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 "
%
(
'q_smallint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 "
%
(
'q_bigint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 "
%
(
'q_tinyint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 "
%
(
'q_int'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 "
%
(
'q_float'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 "
%
(
'q_double'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts"
%
(
'q_smallint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts "
%
(
'q_bigint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts "
%
(
'q_tinyint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts "
%
(
'q_int'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts "
%
(
'q_float'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts "
%
(
'q_double'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts "
%
(
'q_smallint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts "
%
(
'q_bigint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts "
%
(
'q_tinyint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts "
%
(
'q_int'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts "
%
(
'q_float'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts "
%
(
'q_double'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts desc"
%
(
'q_smallint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts desc "
%
(
'q_bigint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts desc "
%
(
'q_tinyint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts desc "
%
(
'q_int'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts desc "
%
(
'q_float'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,0) from %s.stable_1 order by ts desc "
%
(
'q_double'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc "
%
(
'q_smallint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc "
%
(
'q_bigint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc "
%
(
'q_tinyint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc "
%
(
'q_int'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc "
%
(
'q_float'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc"
%
(
'q_double'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc limit 3000"
%
(
'q_smallint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc limit 3000 "
%
(
'q_bigint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc limit 3000 "
%
(
'q_tinyint'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc limit 3000 "
%
(
'q_int'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc limit 3000 "
%
(
'q_float'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
sql
=
" select derivative(%s,%ds,1) from %s.stable_1 order by ts desc limit 3000"
%
(
'q_double'
,
fake_data
,
database
)
self
.
derivative_data_check
(
"%s"
%
self
.
db
,
"%s"
%
sql
)
def
derivative_data_check
(
self
,
database
,
sql
):
tdLog
.
info
(
"
\n
=============derivative_data(%s)_check ====================
\n
"
%
sql
)
tdLog
.
info
(
sql
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
#print("row=%d, result=%s " %(i,tdSql.queryResult[i][0]))
flush_before_value
=
tdSql
.
queryResult
[
i
][
0
]
#flush_before_value1 = tdSql.queryResult[i][1]
tdLog
.
info
(
"
\n
=============flush database ====================
\n
"
)
tdSql
.
execute
(
" flush database %s;"
%
database
)
tdSql
.
query
(
sql
)
queryRows
=
len
(
tdSql
.
queryResult
)
for
i
in
range
(
queryRows
):
#print("row=%d, result=%s " %(i,tdSql.queryResult[i][0]))
flush_after_value
=
tdSql
.
queryResult
[
i
][
0
]
#flush_after_value1 = tdSql.queryResult[i][1]
self
.
value_check
(
flush_before_value
,
flush_after_value
)
#self.value_check(flush_before_value1,flush_after_value1)
def
value_check
(
self
,
flush_before_value
,
flush_after_value
):
if
flush_before_value
==
flush_after_value
:
tdLog
.
info
(
f
"checkEqual success, flush_before_value=
{
flush_before_value
}
,flush_after_value=
{
flush_after_value
}
"
)
else
:
tdLog
.
exit
(
f
"checkEqual error, flush_before_value==
{
flush_before_value
}
,flush_after_value=
{
flush_after_value
}
"
)
def
run
(
self
):
fake
=
Faker
(
'zh_CN'
)
fake_data
=
fake
.
random_int
(
min
=-
9223372036854775807
,
max
=
9223372036854775807
,
step
=
1
)
fake_float
=
fake
.
pyfloat
()
fake_str
=
fake
.
pystr
()
startTime
=
time
.
time
()
os
.
system
(
"rm -rf %s/%s.sql"
%
(
self
.
testcasePath
,
self
.
testcaseFilename
))
self
.
dropandcreateDB_random
(
"%s"
%
self
.
db
,
1
,
2
)
#TD-19818
self
.
func_index_check
(
"%s"
%
self
.
db
,
'max'
,
'q_int'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'max'
,
'q_bigint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'max'
,
'q_smallint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'max'
,
'q_tinyint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'max'
,
'q_float'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'max'
,
'q_double'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'min'
,
'q_int'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'min'
,
'q_bigint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'min'
,
'q_smallint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'min'
,
'q_tinyint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'min'
,
'q_float'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'min'
,
'q_double'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'SUM'
,
'q_int'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'SUM'
,
'q_bigint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'SUM'
,
'q_smallint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'SUM'
,
'q_tinyint'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'SUM'
,
'q_float'
)
self
.
func_index_check
(
"%s"
%
self
.
db
,
'SUM'
,
'q_double'
)
#TD-19854
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'%d'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'%f'
%
fake_float
)
self
.
constant_str_check
(
"%s"
%
self
.
db
,
'count'
,
'%s'
%
fake_str
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%d as int))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%f as int))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%d as smallint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%f as smallint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%d as bigint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%f as bigint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%d as tinyint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%f as tinyint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%d as float))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%f as float))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%d as double))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'count'
,
'(cast(%f as double))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'%d'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'%f'
%
fake_float
)
self
.
constant_error_check
(
"%s"
%
self
.
db
,
'sum'
,
'%s'
%
fake_str
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%d as int))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%f as int))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%d as smallint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%f as smallint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%d as bigint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%f as bigint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%d as tinyint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%f as tinyint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%d as float))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%f as float))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%d as double))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'sum'
,
'(cast(%f as double))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'%d'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'%f'
%
fake_float
)
self
.
constant_error_check
(
"%s"
%
self
.
db
,
'avg'
,
'%s'
%
fake_str
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%d as int))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%f as int))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%d as smallint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%f as smallint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%d as bigint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%f as bigint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%d as tinyint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%f as tinyint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%d as float))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%f as float))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%d as double))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'avg'
,
'(cast(%f as double))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'%d'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'%f'
%
fake_float
)
self
.
constant_error_check
(
"%s"
%
self
.
db
,
'stddev'
,
'%s'
%
fake_str
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%d as int))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%f as int))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%d as smallint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%f as smallint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%d as bigint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%f as bigint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%d as tinyint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%f as tinyint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%d as float))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%f as float))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%d as double))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'stddev'
,
'(cast(%f as double))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'%d'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'%f'
%
fake_float
)
self
.
constant_error_check
(
"%s"
%
self
.
db
,
'spread'
,
'%s'
%
fake_str
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%d as int))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%f as int))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%d as smallint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%f as smallint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%d as bigint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%f as bigint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%d as tinyint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%f as tinyint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%d as float))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%f as float))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%d as double))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'spread'
,
'(cast(%f as double))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'%d'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'%f'
%
fake_float
)
self
.
constant_str_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'%s'
%
fake_str
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%d as int))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%f as int))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%d as smallint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%f as smallint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%d as bigint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%f as bigint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%d as tinyint))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%f as tinyint))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%d as float))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%f as float))'
%
fake_float
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%d as double))'
%
fake_data
)
self
.
constant_check
(
"%s"
%
self
.
db
,
'hyperloglog'
,
'(cast(%f as double))'
%
fake_float
)
percentile_data
=
fake
.
random_int
(
min
=-
0
,
max
=
100
,
step
=
1
)
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'%d,%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'%f,%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_error_check
(
"%s"
%
self
.
db
,
'percentile'
,
'%s,%d'
%
(
fake_str
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%d as int)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%f as int)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%d as smallint)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%f as smallint)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%d as bigint)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%f as bigint)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%d as tinyint)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%f as tinyint)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%d as float)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%f as float)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%d as double)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'percentile'
,
'(cast(%f as double)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'%d,%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'%f,%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_error_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'%s,%d'
%
(
fake_str
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%d as int)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%f as int)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%d as smallint)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%f as smallint)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%d as bigint)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%f as bigint)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%d as tinyint)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%f as tinyint)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%d as float)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%f as float)),%d'
%
(
fake_float
,
percentile_data
))
self
.
constant_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%d as double)),%d'
%
(
fake_data
,
percentile_data
))
self
.
constant_table_check
(
"%s"
%
self
.
db
,
'apercentile'
,
'(cast(%f as double)),%d'
%
(
fake_float
,
percentile_data
))
# percentile_data = fake.random_int(min=-0, max=1, step=1)
# self.constant_table_check("%s" %self.db,'histogram','%d' %fake_data,'user_input','[-10000,0,10000]','%d' %percentile_data)
# self.constant_check("%s" %self.db,'histogram','%f,%d' %(fake_float,percentile_data))
# self.constant_error_check("%s" %self.db,'histogram','%s,%d' %(fake_str,percentile_data))
#TD-19843
self
.
derivative_sql
(
"%s"
%
self
.
db
)
#taos -f sql
print
(
"taos -f sql start!"
)
taos_cmd1
=
"taos -f %s/%s.sql"
%
(
self
.
testcasePath
,
self
.
testcaseFilename
)
_
=
subprocess
.
check_output
(
taos_cmd1
,
shell
=
True
)
print
(
"taos -f sql over!"
)
endTime
=
time
.
time
()
print
(
"total time %ds"
%
(
endTime
-
startTime
))
def
stop
(
self
):
tdSql
.
close
()
tdLog
.
success
(
"%s successfully executed"
%
__file__
)
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.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录