Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
9468f458
T
TDengine
项目概览
taosdata
/
TDengine
大约 1 年 前同步成功
通知
1184
Star
22015
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看板
体验新版 GitCode,发现更多精彩内容 >>
未验证
提交
9468f458
编写于
6月 08, 2021
作者:
H
huili
提交者:
GitHub
6月 08, 2021
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #6398 from taosdata/test/SessionWindow
[TD-4043]<test>case for session window
上级
e9859237
034cd7d8
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
126 addition
and
0 deletion
+126
-0
tests/pytest/query/querySession.py
tests/pytest/query/querySession.py
+126
-0
未找到文件。
tests/pytest/query/querySession.py
0 → 100644
浏览文件 @
9468f458
###################################################################
# 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
sys
import
taos
from
util.log
import
*
from
util.cases
import
*
from
util.sql
import
*
class
TDTestCase
:
def
init
(
self
,
conn
,
logSql
):
tdLog
.
debug
(
"start to execute %s"
%
__file__
)
tdSql
.
init
(
conn
.
cursor
())
def
run
(
self
):
tdSql
.
prepare
()
print
(
"==============step1"
)
tdSql
.
execute
(
"create table if not exists st (ts timestamp, tagtype int) tags(dev nchar(50), tag2 binary(16))"
)
tdSql
.
execute
(
'CREATE TABLE if not exists dev_001 using st tags("dev_01", "tag_01")'
)
tdSql
.
execute
(
'CREATE TABLE if not exists dev_002 using st tags("dev_02", "tag_02")'
)
print
(
"==============step2"
)
tdSql
.
execute
(
"""INSERT INTO dev_001 VALUES('2020-05-13 10:00:00.000', 1)('2020-05-13 10:00:00.005', 2)('2020-05-13 10:00:00.011', 3)
('2020-05-13 10:00:01.011', 4)('2020-05-13 10:00:01.611', 5)('2020-05-13 10:00:02.612', 6)
('2020-05-13 10:01:02.612', 7)('2020-05-13 10:02:02.612', 8)('2020-05-13 10:03:02.613', 9)
('2020-05-13 11:00:00.000', 10)('2020-05-13 12:00:00.000', 11)('2020-05-13 13:00:00.001', 12)
('2020-05-14 13:00:00.001', 13)('2020-05-15 14:00:00.000', 14)('2020-05-20 10:00:00.000', 15)
('2020-05-27 10:00:00.001', 16) dev_002 VALUES('2020-05-13 10:00:00.000', 1)('2020-05-13 10:00:00.005', 2)('2020-05-13 10:00:00.009', 3)('2020-05-13 10:00:00.0021', 4)
('2020-05-13 10:00:00.031', 5)('2020-05-13 10:00:00.036', 6)('2020-05-13 10:00:00.51', 7)
"""
)
# session(ts,5a)
tdSql
.
query
(
"select count(*) from dev_001 session(ts,5a)"
)
tdSql
.
checkRows
(
15
)
tdSql
.
checkData
(
0
,
1
,
2
)
# session(ts,1s)
tdSql
.
query
(
"select count(*) from dev_001 session(ts,1s)"
)
tdSql
.
checkRows
(
12
)
tdSql
.
checkData
(
0
,
1
,
5
)
tdSql
.
query
(
"select count(*) from dev_001 session(ts,1000a)"
)
tdSql
.
checkRows
(
12
)
tdSql
.
checkData
(
0
,
1
,
5
)
# session(ts,1m)
tdSql
.
query
(
"select count(*) from dev_001 session(ts,1m)"
)
tdSql
.
checkRows
(
9
)
tdSql
.
checkData
(
0
,
1
,
8
)
# session(ts,1h)
tdSql
.
query
(
"select count(*) from dev_001 session(ts,1h)"
)
tdSql
.
checkRows
(
6
)
tdSql
.
checkData
(
0
,
1
,
11
)
# session(ts,1d)
tdSql
.
query
(
"select count(*) from dev_001 session(ts,1d)"
)
tdSql
.
checkRows
(
4
)
tdSql
.
checkData
(
0
,
1
,
13
)
# session(ts,1w)
tdSql
.
query
(
"select count(*) from dev_001 session(ts,1w)"
)
tdSql
.
checkRows
(
2
)
tdSql
.
checkData
(
0
,
1
,
15
)
# session with where
tdSql
.
query
(
"select count(*),first(tagtype),last(tagtype),avg(tagtype),sum(tagtype),min(tagtype),max(tagtype),leastsquares(tagtype, 1, 1),spread(tagtype) from dev_001 where ts <'2020-05-20 0:0:0' session(ts,1d)"
)
tdSql
.
checkRows
(
2
)
tdSql
.
checkData
(
0
,
1
,
13
)
tdSql
.
checkData
(
0
,
2
,
1
)
tdSql
.
checkData
(
0
,
3
,
13
)
tdSql
.
checkData
(
0
,
4
,
7
)
tdSql
.
checkData
(
0
,
5
,
91
)
tdSql
.
checkData
(
0
,
6
,
1
)
tdSql
.
checkData
(
0
,
7
,
13
)
tdSql
.
checkData
(
0
,
8
,
'{slop:1.000000, intercept:0.000000}'
)
tdSql
.
checkData
(
0
,
9
,
12
)
# tdsql err
tdSql
.
error
(
"select * from dev_001 session(ts,1w)"
)
tdSql
.
error
(
"select count(*) from st session(ts,1w)"
)
tdSql
.
error
(
"select count(*) from dev_001 group by tagtype session(ts,1w) "
)
tdSql
.
error
(
"select count(*) from dev_001 session(ts,1n)"
)
tdSql
.
error
(
"select count(*) from dev_001 session(ts,1y)"
)
tdSql
.
error
(
"select count(*) from dev_001 session(ts,0s)"
)
tdSql
.
error
(
"select count(*) from dev_001 session(i,1y)"
)
tdSql
.
error
(
"select count(*) from dev_001 session(ts,1d) where ts <'2020-05-20 0:0:0'"
)
#test precision us
tdSql
.
execute
(
"create database test precision 'us'"
)
tdSql
.
execute
(
"use test"
)
tdSql
.
execute
(
"create table dev_001 (ts timestamp ,i timestamp ,j int)"
)
tdSql
.
execute
(
"insert into dev_001 values(1623046993681000,now,1)(1623046993681001,now+1s,2)(1623046993681002,now+2s,3)(1623046993681004,now+5s,4)"
)
# session(ts,1u)
tdSql
.
query
(
"select count(*) from dev_001 session(ts,1u)"
)
tdSql
.
checkRows
(
2
)
tdSql
.
checkData
(
0
,
1
,
3
)
tdSql
.
error
(
"select count(*) from dev_001 session(i,1s)"
)
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.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录