mirror of
https://github.com/taosdata/TDengine
synced 2026-05-24 10:09:01 +00:00
d69c5977db
* restore .gitmodules
* Revert "[TD-13408]<test>: move tests directory out"
This reverts commit 7db7bd9337.
* revert to make tests back
* immigrate file change in stand-alone repo to TDengine
* remove tests repository checkout
Co-authored-by: tangfangzhi <fztang@taosdata.com>
97 lines
4.1 KiB
Python
97 lines
4.1 KiB
Python
###################################################################
|
|
# Copyright (c) 2020 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 *
|
|
from functions.function_elapsed_case import *
|
|
|
|
class TDTestCase:
|
|
def init(self, conn, logSql):
|
|
tdLog.debug("start to execute %s" % __file__)
|
|
tdSql.init(conn.cursor())
|
|
|
|
def genTime(self, no):
|
|
h = int(no / 60)
|
|
hs = "%d" %h
|
|
if h < 10:
|
|
hs = "0%d" %h
|
|
|
|
m = int(no % 60)
|
|
ms = "%d" %m
|
|
if m < 10:
|
|
ms = "0%d" %m
|
|
|
|
return hs, ms
|
|
|
|
def general(self):
|
|
# normal table
|
|
tdSql.execute("create database wxy_db minrows 10 maxrows 200")
|
|
tdSql.execute("use wxy_db")
|
|
tdSql.execute("create table t1(ts timestamp, i int, b bigint, f float, d double, bin binary(10), s smallint, t tinyint, bl bool, n nchar(10), ts1 timestamp)")
|
|
for i in range(1, 1001):
|
|
hs, ms = self.genTime(i)
|
|
if i < 500:
|
|
ret = tdSql.execute("insert into t1(ts, i, b) values (\"2021-11-22 %s:%s:00\", %d, 1)" % (hs, ms, i))
|
|
else:
|
|
ret = tdSql.execute("insert into t1(ts, i, b) values (\"2021-11-22 %s:%s:00\", %d, 0)" % (hs, ms, i))
|
|
tdSql.query("select count(*) from t1")
|
|
tdSql.checkEqual(int(tdSql.getData(0, 0)), 1000)
|
|
|
|
# empty normal table
|
|
tdSql.execute("create table t2(ts timestamp, i int, b bigint, f float, d double, bin binary(10), s smallint, t tinyint, bl bool, n nchar(10), ts1 timestamp)")
|
|
|
|
tdSql.execute("create database wxy_db_ns precision \"ns\"")
|
|
tdSql.execute("use wxy_db_ns")
|
|
tdSql.execute("create table t1 (ts timestamp, f float)")
|
|
tdSql.execute("insert into t1 values('2021-11-18 00:00:00.000000100', 1)"
|
|
"('2021-11-18 00:00:00.000000200', 2)"
|
|
"('2021-11-18 00:00:00.000000300', 3)"
|
|
"('2021-11-18 00:00:00.000000500', 4)")
|
|
|
|
# super table
|
|
tdSql.execute("use wxy_db")
|
|
tdSql.execute("create stable st1(ts timestamp, i int, b bigint, f float, d double, bin binary(10), s smallint, t tinyint, bl bool, n nchar(10), ts1 timestamp) tags(id int)")
|
|
tdSql.execute("create table st1s1 using st1 tags(1)")
|
|
tdSql.execute("create table st1s2 using st1 tags(2)")
|
|
for i in range(1, 1001):
|
|
hs, ms = self.genTime(i)
|
|
if 0 == i % 2:
|
|
ret = tdSql.execute("insert into st1s1(ts, i) values (\"2021-11-22 %s:%s:00\", %d)" % (hs, ms, i))
|
|
else:
|
|
ret = tdSql.execute("insert into st1s2(ts, i) values (\"2021-11-22 %s:%s:00\", %d)" % (hs, ms, i))
|
|
tdSql.query("select count(*) from st1s1")
|
|
tdSql.checkEqual(int(tdSql.getData(0, 0)), 500)
|
|
tdSql.query("select count(*) from st1s2")
|
|
tdSql.checkEqual(int(tdSql.getData(0, 0)), 500)
|
|
# empty super table
|
|
tdSql.execute("create stable st2(ts timestamp, i int, b bigint, f float, d double, bin binary(10), s smallint, t tinyint, bl bool, n nchar(10), ts1 timestamp) tags(id int)")
|
|
tdSql.execute("create table st2s1 using st1 tags(1)")
|
|
tdSql.execute("create table st2s2 using st1 tags(2)")
|
|
|
|
tdSql.execute("create stable st3(ts timestamp, i int, b bigint, f float, d double, bin binary(10), s smallint, t tinyint, bl bool, n nchar(10), ts1 timestamp) tags(id int)")
|
|
|
|
def run(self):
|
|
tdSql.prepare()
|
|
self.general()
|
|
ElapsedCase().run()
|
|
|
|
|
|
def stop(self):
|
|
tdSql.close()
|
|
tdLog.success("%s successfully executed" % __file__)
|
|
|
|
tdCases.addWindows(__file__, TDTestCase())
|
|
tdCases.addLinux(__file__, TDTestCase())
|