Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
cad03d72
TDengine
项目概览
taosdata
/
TDengine
接近 2 年 前同步成功
通知
1192
Star
22018
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
cad03d72
编写于
6月 14, 2022
作者:
C
cpwu
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix case
上级
ae0b4c04
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
83 addition
and
21 deletion
+83
-21
tests/system-test/1-insert/create_retentions.py
tests/system-test/1-insert/create_retentions.py
+83
-21
未找到文件。
tests/system-test/1-insert/create_retentions.py
浏览文件 @
cad03d72
import
datetime
import
datetime
from
dataclasses
import
dataclass
from
typing
import
List
from
util.log
import
*
from
util.log
import
*
from
util.sql
import
*
from
util.sql
import
*
from
util.cases
import
*
from
util.cases
import
*
...
@@ -28,6 +30,23 @@ CHAR_COL = [ BINARY_COL, NCHAR_COL, ]
...
@@ -28,6 +30,23 @@ CHAR_COL = [ BINARY_COL, NCHAR_COL, ]
BOOLEAN_COL
=
[
BOOL_COL
,
]
BOOLEAN_COL
=
[
BOOL_COL
,
]
TS_TYPE_COL
=
[
TS_COL
,
]
TS_TYPE_COL
=
[
TS_COL
,
]
@
dataclass
class
DataSet
:
ts_data
:
List
[
int
]
=
None
int_data
:
List
[
int
]
=
None
bint_data
:
List
[
int
]
=
None
sint_data
:
List
[
int
]
=
None
tint_data
:
List
[
int
]
=
None
int_un_data
:
List
[
int
]
=
None
bint_un_data
:
List
[
int
]
=
None
sint_un_data
:
List
[
int
]
=
None
tint_un_data
:
List
[
int
]
=
None
float_data
:
List
[
float
]
=
None
double_data
:
List
[
float
]
=
None
binary_data
:
List
[
str
]
=
None
nchar_data
:
List
[
str
]
=
None
class
TDTestCase
:
class
TDTestCase
:
def
init
(
self
,
conn
,
logSql
):
def
init
(
self
,
conn
,
logSql
):
...
@@ -37,10 +56,13 @@ class TDTestCase:
...
@@ -37,10 +56,13 @@ class TDTestCase:
@
property
@
property
def
create_databases_sql_err
(
self
):
def
create_databases_sql_err
(
self
):
return
[
return
[
"create database if not exists db1 retentions 0s:1d"
,
"create database db1 retentions 0s:1d"
,
"create database if not exists db1 retentions 1s:1y"
,
"create database db3 retentions 1s:0d"
,
"create database if not exists db1 retentions 1s:1n"
,
"create database db1 retentions 1s:1y"
,
"create database if not exists db1 retentions 1s:1n,2s:2d,3s:3d,4s:4d"
,
"create database db1 retentions 1s:1n"
,
"create database db2 retentions 1w:1d ;"
,
"create database db5 retentions 1s:1d,3s:3d,2s:2d"
,
"create database db1 retentions 1s:1n,2s:2d,3s:3d,4s:4d"
,
]
]
@
property
@
property
...
@@ -62,6 +84,8 @@ class TDTestCase:
...
@@ -62,6 +84,8 @@ class TDTestCase:
return
[
return
[
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(ceil) delay 1"
,
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(ceil) delay 1"
,
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(count) delay 1"
,
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(count) delay 1"
,
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(min) delay 0"
,
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(min) delay -1.0"
,
f
"create stable stb2 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int,
{
BINARY_COL
}
binary(16)) tags (tag1 int) rollup(avg) delay 1"
,
f
"create stable stb2 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int,
{
BINARY_COL
}
binary(16)) tags (tag1 int) rollup(avg) delay 1"
,
f
"create stable stb2 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int,
{
BINARY_COL
}
nchar(16)) tags (tag1 int) rollup(avg) delay 1"
,
f
"create stable stb2 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int,
{
BINARY_COL
}
nchar(16)) tags (tag1 int) rollup(avg) delay 1"
,
]
]
...
@@ -69,7 +93,12 @@ class TDTestCase:
...
@@ -69,7 +93,12 @@ class TDTestCase:
@
property
@
property
def
create_stable_sql_current
(
self
):
def
create_stable_sql_current
(
self
):
return
[
return
[
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(avg) delay 5"
,
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) delay 5"
,
f
"create stable stb2 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(min) delay 5"
,
f
"create stable stb3 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(max) delay 5"
,
f
"create stable stb4 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(sum) delay 5"
,
f
"create stable stb5 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(last) delay 5"
,
f
"create stable stb6 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) rollup(first) delay 5"
,
]
]
def
test_create_stb
(
self
):
def
test_create_stb
(
self
):
...
@@ -80,6 +109,9 @@ class TDTestCase:
...
@@ -80,6 +109,9 @@ class TDTestCase:
tdSql
.
execute
(
cur_sql
)
tdSql
.
execute
(
cur_sql
)
tdSql
.
query
(
"show stables"
)
tdSql
.
query
(
"show stables"
)
tdSql
.
checkRows
(
len
(
self
.
create_stable_sql_current
))
tdSql
.
checkRows
(
len
(
self
.
create_stable_sql_current
))
tdSql
.
execute
(
"use db"
)
# because db is a noraml database, not a rollup database, can not create a rollup database
tdSql
.
error
(
f
"create stable stb1 (
{
PRIMARY_COL
}
timestamp,
{
INT_COL
}
int) tags (tag1 int) delay 5"
)
def
test_create_databases
(
self
):
def
test_create_databases
(
self
):
for
err_sql
in
self
.
create_databases_sql_err
:
for
err_sql
in
self
.
create_databases_sql_err
:
...
@@ -120,27 +152,57 @@ class TDTestCase:
...
@@ -120,27 +152,57 @@ class TDTestCase:
for
i
in
range
(
4
):
for
i
in
range
(
4
):
tdSql
.
execute
(
f
'create table ct
{
i
+
1
}
using stb1 tags (
{
i
+
1
}
)'
)
tdSql
.
execute
(
f
'create table ct
{
i
+
1
}
using stb1 tags (
{
i
+
1
}
)'
)
def
__
create_
data_set
(
self
,
rows
):
def
__data_set
(
self
,
rows
):
now_time
=
int
(
datetime
.
datetime
.
timestamp
(
datetime
.
datetime
.
now
())
*
1000
)
now_time
=
int
(
datetime
.
datetime
.
timestamp
(
datetime
.
datetime
.
now
())
*
1000
)
pos_data
=
[]
data_set
=
DataSet
()
neg_data
=
[]
# neg_data_set = DataSet()
spec_data
=
[]
data_set
.
ts_data
=
[
None
,
None
,
None
]
data_set
.
int_data
=
[
None
,
None
,
None
]
data_set
.
bint_data
=
[
None
,
None
,
None
]
data_set
.
sint_data
=
[
None
,
None
,
None
]
data_set
.
tint_data
=
[
None
,
None
,
None
]
data_set
.
int_un_data
=
[
None
,
None
,
None
]
data_set
.
bint_un_data
=
[
None
,
None
,
None
]
data_set
.
sint_un_data
=
[
None
,
None
,
None
]
data_set
.
tint_un_data
=
[
None
,
None
,
None
]
data_set
.
float_data
=
[
None
,
None
,
None
]
data_set
.
double_data
=
[
None
,
None
,
None
]
data_set
.
binary_data
=
[
None
,
None
,
None
]
data_set
.
nchar_data
=
[
None
,
None
,
None
]
for
i
in
range
(
rows
):
for
i
in
range
(
rows
):
pos_data
.
append
(
data_set
.
ts_data
.
append
(
now_time
+
1
*
i
)
(
data_set
.
int_data
.
append
(
i
)
now_time
-
i
*
1000
,
i
,
11111
*
i
,
111
*
i
%
32767
,
11
*
i
%
127
,
1.11
*
i
,
1100.0011
*
i
,
data_set
.
bint_data
.
append
(
11111
*
i
)
i
%
2
,
f
'binary
{
i
}
'
,
f
'nchar_测试_
{
i
}
'
,
now_time
+
1
*
i
,
11
*
i
%
127
,
111
*
i
%
32767
,
i
,
11111
*
i
data_set
.
sint_data
.
append
(
111
*
i
%
32767
)
)
data_set
.
tint_data
.
append
(
11
*
i
%
127
)
)
data_set
.
int_un_data
.
append
(
i
)
neg_data
.
append
(
data_set
.
bint_un_data
.
append
(
11111
*
i
)
(
data_set
.
sint_un_data
.
append
(
111
*
i
%
32767
)
now_time
-
i
*
7776000000
,
-
i
,
-
11111
*
i
,
-
111
*
i
%
32767
,
-
11
*
i
%
127
,
-
1.11
*
i
,
-
1100.0011
*
i
,
data_set
.
tint_un_data
.
append
(
11
*
i
%
127
)
i
%
2
,
f
'binary
{
i
}
'
,
f
'nchar_测试_
{
i
}
'
,
now_time
+
1
*
i
,
11
*
i
%
127
,
111
*
i
%
32767
,
i
,
11111
*
i
data_set
.
float_data
.
append
(
1.11
*
i
)
)
data_set
.
double_data
.
append
(
1100.0011
*
i
)
)
data_set
.
binary_data
.
append
(
f
'binary
{
i
}
'
)
data_set
.
nchar_data
.
append
(
f
'nchar_测试_
{
i
}
'
)
# neg_data_set.ts_data.append(-1 * i)
# neg_data_set.int_data.append(-i)
# neg_data_set.bint_data.append(-11111 * i)
# neg_data_set.sint_data.append(-111 * i % 32767)
# neg_data_set.tint_data.append(-11 * i % 127)
# neg_data_set.int_un_data.append(-i)
# neg_data_set.bint_un_data.append(-11111 * i)
# neg_data_set.sint_un_data.append(-111 * i % 32767)
# neg_data_set.tint_un_data.append(-11 * i % 127)
# neg_data_set.float_data.append(-1.11 * i)
# neg_data_set.double_data.append(-1100.0011 * i)
# neg_data_set.binary_data.append(f'binary{i}')
# neg_data_set.nchar_data.append(f'nchar_测试_{i}')
return
data_set
def
__insert_data
(
self
,
rows
):
def
__insert_data
(
self
,
rows
):
now_time
=
int
(
datetime
.
datetime
.
timestamp
(
datetime
.
datetime
.
now
())
*
1000
)
now_time
=
int
(
datetime
.
datetime
.
timestamp
(
datetime
.
datetime
.
now
())
*
1000
)
data
=
self
.
__data_set
(
rows
)
for
i
in
range
(
rows
):
for
i
in
range
(
rows
):
tdSql
.
execute
(
tdSql
.
execute
(
f
'''insert into ct1 values (
f
'''insert into ct1 values (
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录