Skip to content

TDengine
TDengine

taosdata / TDengine
1 年多 前同步成功

通知 1185
Star 22016
Fork 4786
TDengine
TDengine
提交 92c0b281 编写于 作者: H happyguoxy
浏览文件
操作

[TD-5460]<test>:test database update=1

上级 746a316f
显示空白变更内容
内联 并排
Showing with 1913 addition and 0 deletion
tests/pytest/import_merge/import_update_1.py 0 → 100644
浏览文件 @ 92c0b281
###################################################################
# 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 tdLog
from util.cases import tdCases
from util.sql import tdSql
from util.dnodes import *
import random
import time
class TDTestCase:
def init(self, conn, logSql):
tdLog.debug("start to execute %s" % __file__)
tdSql.init(conn.cursor(), logSql)
self.ts = 1600000000000
self.num = 50
self.num4096 = 5
def getBuildPath(self):
selfPath = os.path.dirname(os.path.realpath(__file__))
if ("community" in selfPath):
projPath = selfPath[:selfPath.find("community")]
else:
projPath = selfPath[:selfPath.find("tests")]
for root, dirs, files in os.walk(projPath):
if ("taosd" in files):
rootRealPath = os.path.dirname(os.path.realpath(root))
if ("packaging" not in rootRealPath):
buildPath = root[:len(root)-len("/build/bin")]
break
return buildPath
def run(self):
tdSql.prepare()
# test case for https://jira.taosdata.com:18080/browse/TD-5062
startTime = time.time()
tdSql.execute('''drop database if exists test_updata_1 ;''')
# update 0 不更新 ; update 1 覆盖更新 ;update 2 合并更新
tdLog.info("========== test database updata = 1 ==========")
tdSql.execute('''create database test_updata_1 update 1 minrows 10 maxrows 200 ;''')
tdSql.execute('''use test_updata_1;''')
tdSql.execute('''create stable stable_1
(ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint,
q_bool bool , q_binary binary(10) , q_nchar nchar(10) , q_float float , q_double double , q_ts timestamp)
tags(loc nchar(20) , t_int int);''')
tdSql.execute('''create table table_1 using stable_1 tags('table_1' , '1' )''')
tdSql.execute('''create table table_2 using stable_1 tags('table_2' , '2' )''')
tdSql.execute('''create table table_3 using stable_1 tags('table_3' , '3' )''')
#regular table
tdSql.execute('''create table regular_table_1
(ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint,
q_bool bool , q_binary binary(10) , q_nchar nchar(10) , q_float float , q_double double , q_ts timestamp) ;''')
tdSql.execute('''create table regular_table_2
(ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint,
q_bool bool , q_binary binary(10) , q_nchar nchar(10) , q_float float , q_double double , q_ts timestamp) ;''')
tdSql.execute('''create table regular_table_3
(ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint,
q_bool bool , q_binary binary(10) , q_nchar nchar(10) , q_float float , q_double double , q_ts timestamp) ;''')
tdLog.info("========== test1.1 : insert data , check data==========")
tdLog.info("========== regular_table ==========")
tdSql.execute('''insert into regular_table_1 values( %d , 0, 0, 0, 0, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 200))
sql = '''select * from regular_table_1 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.execute('''insert into regular_table_1 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 200))
sql = '''select * from regular_table_1 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into regular_table_1 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 500))
sql = '''select * from regular_table_1 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into regular_table_1 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 500))
sql = '''select * from regular_table_1 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdLog.info("========== stable ==========")
tdSql.execute('''insert into table_1 values( %d , 0, 0, 0, 0, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 200))
sql = '''select * from table_1 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
sql = '''select * from stable_1 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.execute('''insert into table_1 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 200))
sql = '''select * from table_1 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_1 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 500))
sql = '''select * from table_1 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_1 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 500))
sql = '''select * from table_1 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdLog.info("========== 4096 regular_table ==========")
sql = "create table regular_table_4096_1 (ts timestamp, "
for i in range(500):
sql += "int_%d int, " % (i + 1)
for i in range(500,1000):
sql += "smallint_%d smallint, " % (i + 1)
for i in range(1000,1500):
sql += "tinyint_%d tinyint, " % (i + 1)
for i in range(1500,2000):
sql += "double_%d double, " % (i + 1)
for i in range(2000,2500):
sql += "float_%d float, " % (i + 1)
for i in range(2500,3000):
sql += "bool_%d bool, " % (i + 1)
for i in range(3000,3500):
sql += "bigint_%d bigint, " % (i + 1)
for i in range(3500,3800):
sql += "nchar_%d nchar(4), " % (i + 1)
for i in range(3800,4090):
sql += "binary_%d binary(10), " % (i + 1)
for i in range(4090,4094):
sql += "timestamp_%d timestamp, " % (i + 1)
sql += "col4095 binary(22))"
tdLog.info(len(sql))
tdSql.execute(sql)
for i in range(self.num4096):
sql = "insert into regular_table_4096_1 values(%d, "
for j in range(4090):
str = "'%s', " % 'NULL'
sql += str
for j in range(4090,4094):
str = "%s, " % (self.ts + j)
sql += str
sql += "'%s')" % (self.ts + i)
tdSql.execute(sql % (self.ts + i))
tdSql.query('''select * from regular_table_4096_1 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4095,'1600000000000')
sql = '''insert into regular_table_4096_1 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-10 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-10 20:26:44.090','1500000000000');'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_1 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4095,'1500000000000')
tdLog.info("========== 4096 stable ==========")
sql = "create stable stable_4096_1 (ts timestamp, "
for i in range(500):
sql += "int_%d int, " % (i + 1)
for i in range(500,1000):
sql += "smallint_%d smallint, " % (i + 1)
for i in range(1000,1500):
sql += "tinyint_%d tinyint, " % (i + 1)
for i in range(1500,2000):
sql += "double_%d double, " % (i + 1)
for i in range(2000,2500):
sql += "float_%d float, " % (i + 1)
for i in range(2500,3000):
sql += "bool_%d bool, " % (i + 1)
for i in range(3000,3500):
sql += "bigint_%d bigint, " % (i + 1)
for i in range(3500,3800):
sql += "nchar_%d nchar(4), " % (i + 1)
for i in range(3800,4090):
sql += "binary_%d binary(10), " % (i + 1)
for i in range(4090,4092):
sql += "timestamp_%d timestamp, " % (i + 1)
sql += " col4093 binary(22)) "
sql += " tags (loc nchar(20),tag_1 int) "
tdLog.info(len(sql))
tdSql.execute(sql)
sql = " create table table_4096_1 using stable_4096_1 tags ('table_4096_1',1); "
tdSql.execute(sql)
for i in range(self.num4096):
sql = "insert into table_4096_1 values(%d, "
for j in range(4090):
str = "'%s', " % 'NULL'
sql += str
for j in range(4090,4092):
str = "%s, " % (self.ts + j)
sql += str
sql += "'%s')" % (self.ts + i)
tdSql.execute(sql % (self.ts + i))
tdSql.query('''select * from table_4096_1 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4094)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
tdSql.query('''select * from stable_4096_1 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
sql = '''insert into table_4096_1 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-10 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-10 20:26:44.090','1500000000000');'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_1 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4093,'1500000000000')
tdSql.query("select * from stable_4096_1 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4093,'1500000000000')
# minrows 10 maxrows 200
for i in range(self.num):
tdSql.execute('''insert into regular_table_1 values(%d, %d, %d, %d, %d, 0, 'binary.%s', 'nchar.%s', %f, %f, %d)'''
% (self.ts -100 + i, i, i, i, i, i, i, i, i, self.ts -100 + i))
tdSql.execute('''insert into regular_table_1 values(%d, %d, %d, %d, %d, false, 'binary%s', 'nchar%s', %f, %f, %d)'''
% (self.ts + i, random.randint(-2147483647, 2147483647),
random.randint(-9223372036854775807, 9223372036854775807), random.randint(-32767, 32767),
random.randint(-127, 127), random.randint(-100, 100), random.randint(-10000, 10000),
random.uniform(-100000,100000), random.uniform(-1000000000,1000000000), self.ts + i))
tdSql.execute('''insert into table_1 values(%d, %d, %d, %d, %d, 0, 'binary.%s', 'nchar.%s', %f, %f, %d)'''
% (self.ts -100 + i, i, i, i, i, i, i, i, i, self.ts -100 + i))
tdSql.execute('''insert into table_1 values(%d, %d, %d, %d, %d, false, 'binary%s', 'nchar%s', %f, %f, %d)'''
% (self.ts + i, random.randint(-2147483647, 2147483647),
random.randint(-9223372036854775807, 9223372036854775807), random.randint(-32767, 32767),
random.randint(-127, 127), random.randint(-100, 100), random.randint(-10000, 10000),
random.uniform(-100000,100000), random.uniform(-1000000000,1000000000), self.ts + i))
tdLog.info("========== regular_table ==========")
tdSql.execute('''insert into regular_table_1 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 200))
sql = '''select * from regular_table_1 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into regular_table_1 values( %d , 0, 0, 0, 0, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 200))
sql = '''select * from regular_table_1 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+0')
tdSql.checkData(0,7,'nchar+0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.error('''insert into regular_table_1 values( %d , -2147483648, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_1 values( %d , -2147483647, -9223372036854775808, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_1 values( %d , -2147483647, -9223372036854775807, -32768, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_1 values( %d , -2147483647, -9223372036854775807, -32767, -128, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_1 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0123', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_1 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.execute('''insert into regular_table_1 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-012', 'nchar-0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
sql = '''select * from regular_table_1 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,-2147483647)
tdSql.checkData(0,2,-9223372036854775807)
tdSql.checkData(0,3,-32767)
tdSql.checkData(0,4,-127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-012')
tdSql.checkData(0,7,'nchar-0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.error('''insert into regular_table_1 values( %d , 2147483648, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_1 values( %d , 2147483647, 9223372036854775808, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_1 values( %d , 2147483647, 9223372036854775807, 32768, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_1 values( %d , 2147483647, 9223372036854775807, 32767, 128, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_1 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0123', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_1 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.execute('''insert into regular_table_1 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+012', 'nchar+0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
sql = '''select * from regular_table_1 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,2147483647)
tdSql.checkData(0,2,9223372036854775807)
tdSql.checkData(0,3,32767)
tdSql.checkData(0,4,127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+012')
tdSql.checkData(0,7,'nchar+0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdLog.info("========== stable ==========")
tdSql.execute('''insert into table_1 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 200))
sql = '''select * from table_1 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_1 values( %d , 0, 0, 0, 0, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 200))
sql = '''select * from table_1 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+0')
tdSql.checkData(0,7,'nchar+0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
sql = '''select * from stable_1 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+0')
tdSql.checkData(0,7,'nchar+0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.error('''insert into table_1 values( %d , -2147483648, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_1 values( %d , -2147483647, -9223372036854775808, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_1 values( %d , -2147483647, -9223372036854775807, -32768, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_1 values( %d , -2147483647, -9223372036854775807, -32767, -128, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_1 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0123', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_1 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.execute('''insert into table_1 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-012', 'nchar-0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
sql = '''select * from table_1 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,-2147483647)
tdSql.checkData(0,2,-9223372036854775807)
tdSql.checkData(0,3,-32767)
tdSql.checkData(0,4,-127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-012')
tdSql.checkData(0,7,'nchar-0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
sql = '''select * from stable_1 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,-2147483647)
tdSql.checkData(0,2,-9223372036854775807)
tdSql.checkData(0,3,-32767)
tdSql.checkData(0,4,-127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-012')
tdSql.checkData(0,7,'nchar-0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.error('''insert into table_1 values( %d , 2147483648, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_1 values( %d , 2147483647, 9223372036854775808, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_1 values( %d , 2147483647, 9223372036854775807, 32768, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_1 values( %d , 2147483647, 9223372036854775807, 32767, 128, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_1 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0123', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_1 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.execute('''insert into table_1 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+012', 'nchar+0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
sql = '''select * from table_1 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,2147483647)
tdSql.checkData(0,2,9223372036854775807)
tdSql.checkData(0,3,32767)
tdSql.checkData(0,4,127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+012')
tdSql.checkData(0,7,'nchar+0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
sql = '''select * from stable_1 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,2147483647)
tdSql.checkData(0,2,9223372036854775807)
tdSql.checkData(0,3,32767)
tdSql.checkData(0,4,127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+012')
tdSql.checkData(0,7,'nchar+0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdLog.info("========== 4096 regular_table ==========")
sql = '''insert into regular_table_4096_1 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-13 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-13 20:26:44.090','1600000000000');'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_1 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4095,'1600000000000')
sql = '''insert into regular_table_4096_1 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-10 20:26:40.000' , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL);'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_1 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4095,None)
tdLog.info("========== 4096 stable ==========")
sql = '''insert into table_4096_1 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-13 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-13 20:26:44.090','1600000000000');'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_1 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
tdSql.query("select * from stable_4096_1 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
sql = '''insert into table_4096_1 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-10 20:26:40.000' , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL);'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_1 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4093,None)
tdSql.query("select * from stable_4096_1 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4093,None)
tdLog.info("========== test1.2 : insert data , taosdemo force data dropping disk , check data==========")
tdLog.info("========== regular_table ==========")
tdSql.execute('''insert into regular_table_2 values( %d , 0, 0, 0, 0, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 200))
sql = '''select * from regular_table_2 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.execute('''insert into regular_table_2 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 200))
sql = '''select * from regular_table_2 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into regular_table_2 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 500))
sql = '''select * from regular_table_2 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into regular_table_2 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 500))
sql = '''select * from regular_table_2 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdLog.info("========== stable ==========")
tdSql.execute('''insert into table_2 values( %d , 0, 0, 0, 0, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 200))
sql = '''select * from table_2 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
sql = '''select * from stable_1 where loc = 'table_2' and ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.execute('''insert into table_2 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 200))
sql = '''select * from table_2 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where loc = 'table_2' and ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_2 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 500))
sql = '''select * from table_2 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where loc = 'table_2' and ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_2 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 500))
sql = '''select * from table_2 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where loc = 'table_2' and ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdLog.info("========== 4096 regular_table ==========")
sql = "create table regular_table_4096_2 (ts timestamp, "
for i in range(500):
sql += "int_%d int, " % (i + 1)
for i in range(500,1000):
sql += "smallint_%d smallint, " % (i + 1)
for i in range(1000,1500):
sql += "tinyint_%d tinyint, " % (i + 1)
for i in range(1500,2000):
sql += "double_%d double, " % (i + 1)
for i in range(2000,2500):
sql += "float_%d float, " % (i + 1)
for i in range(2500,3000):
sql += "bool_%d bool, " % (i + 1)
for i in range(3000,3500):
sql += "bigint_%d bigint, " % (i + 1)
for i in range(3500,3800):
sql += "nchar_%d nchar(4), " % (i + 1)
for i in range(3800,4090):
sql += "binary_%d binary(10), " % (i + 1)
for i in range(4090,4094):
sql += "timestamp_%d timestamp, " % (i + 1)
sql += "col4095 binary(22))"
tdLog.info(len(sql))
tdSql.execute(sql)
for i in range(self.num4096):
sql = "insert into regular_table_4096_2 values(%d, "
for j in range(4090):
str = "'%s', " % 'NULL'
sql += str
for j in range(4090,4094):
str = "%s, " % (self.ts + j)
sql += str
sql += "'%s')" % (self.ts + i)
tdSql.execute(sql % (self.ts + i))
tdSql.query('''select * from regular_table_4096_2 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4095,'1600000000000')
sql = '''insert into regular_table_4096_2 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-10 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-10 20:26:44.090','1500000000000');'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_2 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4095,'1500000000000')
tdLog.info("========== 4096 stable ==========")
sql = "create stable stable_4096_2 (ts timestamp, "
for i in range(500):
sql += "int_%d int, " % (i + 1)
for i in range(500,1000):
sql += "smallint_%d smallint, " % (i + 1)
for i in range(1000,1500):
sql += "tinyint_%d tinyint, " % (i + 1)
for i in range(1500,2000):
sql += "double_%d double, " % (i + 1)
for i in range(2000,2500):
sql += "float_%d float, " % (i + 1)
for i in range(2500,3000):
sql += "bool_%d bool, " % (i + 1)
for i in range(3000,3500):
sql += "bigint_%d bigint, " % (i + 1)
for i in range(3500,3800):
sql += "nchar_%d nchar(4), " % (i + 1)
for i in range(3800,4090):
sql += "binary_%d binary(10), " % (i + 1)
for i in range(4090,4092):
sql += "timestamp_%d timestamp, " % (i + 1)
sql += " col4093 binary(22)) "
sql += " tags (loc nchar(20),tag_1 int) "
tdLog.info(len(sql))
tdSql.execute(sql)
sql = " create table table_4096_2 using stable_4096_2 tags ('table_4096_2',1); "
tdSql.execute(sql)
for i in range(self.num4096):
sql = "insert into table_4096_2 values(%d, "
for j in range(4090):
str = "'%s', " % 'NULL'
sql += str
for j in range(4090,4092):
str = "%s, " % (self.ts + j)
sql += str
sql += "'%s')" % (self.ts + i)
tdSql.execute(sql % (self.ts + i))
tdSql.query('''select * from table_4096_2 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4094)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
tdSql.query('''select * from stable_4096_2 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
sql = '''insert into table_4096_2 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-10 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-10 20:26:44.090','1500000000000');'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_2 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4093,'1500000000000')
tdSql.query("select * from stable_4096_2 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4093,'1500000000000')
# taosdemo force data dropping disk
buildPath = self.getBuildPath()
if (buildPath == ""):
tdLog.exit("taosd not found!")
else:
tdLog.info("taosd found in %s" % buildPath)
binPath = buildPath+ "/build/bin/"
os.system("%staosdemo -N -d taosdemo -t 100 -n 100 -l 1000 -y" % binPath)
tdSql.execute('''insert into table_2 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 200))
sql = '''select * from table_2 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where loc = 'table_2' and ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_2 values( %d , 0, 0, 0, 0, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 200))
sql = '''select * from table_2 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+0')
tdSql.checkData(0,7,'nchar+0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
sql = '''select * from stable_1 where loc = 'table_2' and ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+0')
tdSql.checkData(0,7,'nchar+0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.error('''insert into table_2 values( %d , -2147483648, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_2 values( %d , -2147483647, -9223372036854775808, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_2 values( %d , -2147483647, -9223372036854775807, -32768, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_2 values( %d , -2147483647, -9223372036854775807, -32767, -128, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_2 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0123', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_2 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.execute('''insert into table_2 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-012', 'nchar-0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
sql = '''select * from table_2 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,-2147483647)
tdSql.checkData(0,2,-9223372036854775807)
tdSql.checkData(0,3,-32767)
tdSql.checkData(0,4,-127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-012')
tdSql.checkData(0,7,'nchar-0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
sql = '''select * from stable_1 where loc = 'table_2' and ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,-2147483647)
tdSql.checkData(0,2,-9223372036854775807)
tdSql.checkData(0,3,-32767)
tdSql.checkData(0,4,-127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-012')
tdSql.checkData(0,7,'nchar-0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
tdSql.error('''insert into table_2 values( %d , 2147483648, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_2 values( %d , 2147483647, 9223372036854775808, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_2 values( %d , 2147483647, 9223372036854775807, 32768, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_2 values( %d , 2147483647, 9223372036854775807, 32767, 128, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_2 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0123', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_2 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.execute('''insert into table_2 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+012', 'nchar+0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
sql = '''select * from table_2 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,2147483647)
tdSql.checkData(0,2,9223372036854775807)
tdSql.checkData(0,3,32767)
tdSql.checkData(0,4,127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+012')
tdSql.checkData(0,7,'nchar+0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
sql = '''select * from stable_1 where loc = 'table_2' and ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,2147483647)
tdSql.checkData(0,2,9223372036854775807)
tdSql.checkData(0,3,32767)
tdSql.checkData(0,4,127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+012')
tdSql.checkData(0,7,'nchar+0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
tdLog.info("========== 4096 regular_table ==========")
sql = '''insert into regular_table_4096_2 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-13 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-13 20:26:44.090','1600000000000');'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_2 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4095,'1600000000000')
sql = '''insert into regular_table_4096_2 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-10 20:26:40.000' , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL);'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_2 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4095,None)
tdLog.info("========== 4096 stable ==========")
sql = '''insert into table_4096_2 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-13 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-13 20:26:44.090','1600000000000');'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_2 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
tdSql.query("select * from stable_4096_2 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
sql = '''insert into table_4096_2 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-10 20:26:40.000' , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL);'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_2 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4093,None)
tdSql.query("select * from stable_4096_2 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4093,None)
tdLog.info("========== test1.3 : insert data , tdDnodes restart force data dropping disk , check data==========")
tdLog.info("========== regular_table ==========")
tdSql.execute('''insert into regular_table_3 values( %d , 0, 0, 0, 0, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 200))
sql = '''select * from regular_table_3 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.execute('''insert into regular_table_3 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 200))
sql = '''select * from regular_table_3 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into regular_table_3 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 500))
sql = '''select * from regular_table_3 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into regular_table_3 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 500))
sql = '''select * from regular_table_3 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdLog.info("========== stable ==========")
tdSql.execute('''insert into table_3 values( %d , 0, 0, 0, 0, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 200))
sql = '''select * from table_3 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
sql = '''select * from stable_1 where loc = 'table_3' and ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-0')
tdSql.checkData(0,7,'nchar-0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.execute('''insert into table_3 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 200))
sql = '''select * from table_3 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where loc = 'table_3' and ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_3 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 500))
sql = '''select * from table_3 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where loc = 'table_3' and ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_3 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts + 500))
sql = '''select * from table_3 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where loc = 'table_3' and ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdLog.info("========== 4096 regular_table ==========")
sql = "create table regular_table_4096_3 (ts timestamp, "
for i in range(500):
sql += "int_%d int, " % (i + 1)
for i in range(500,1000):
sql += "smallint_%d smallint, " % (i + 1)
for i in range(1000,1500):
sql += "tinyint_%d tinyint, " % (i + 1)
for i in range(1500,2000):
sql += "double_%d double, " % (i + 1)
for i in range(2000,2500):
sql += "float_%d float, " % (i + 1)
for i in range(2500,3000):
sql += "bool_%d bool, " % (i + 1)
for i in range(3000,3500):
sql += "bigint_%d bigint, " % (i + 1)
for i in range(3500,3800):
sql += "nchar_%d nchar(4), " % (i + 1)
for i in range(3800,4090):
sql += "binary_%d binary(10), " % (i + 1)
for i in range(4090,4094):
sql += "timestamp_%d timestamp, " % (i + 1)
sql += "col4095 binary(22))"
tdLog.info(len(sql))
tdSql.execute(sql)
for i in range(self.num4096):
sql = "insert into regular_table_4096_3 values(%d, "
for j in range(4090):
str = "'%s', " % 'NULL'
sql += str
for j in range(4090,4094):
str = "%s, " % (self.ts + j)
sql += str
sql += "'%s')" % (self.ts + i)
tdSql.execute(sql % (self.ts + i))
tdSql.query('''select * from regular_table_4096_3 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4095,'1600000000000')
sql = '''insert into regular_table_4096_3 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-10 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-10 20:26:44.090','1500000000000');'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_3 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4095,'1500000000000')
tdLog.info("========== 4096 stable ==========")
sql = "create stable stable_4096_3 (ts timestamp, "
for i in range(500):
sql += "int_%d int, " % (i + 1)
for i in range(500,1000):
sql += "smallint_%d smallint, " % (i + 1)
for i in range(1000,1500):
sql += "tinyint_%d tinyint, " % (i + 1)
for i in range(1500,2000):
sql += "double_%d double, " % (i + 1)
for i in range(2000,2500):
sql += "float_%d float, " % (i + 1)
for i in range(2500,3000):
sql += "bool_%d bool, " % (i + 1)
for i in range(3000,3500):
sql += "bigint_%d bigint, " % (i + 1)
for i in range(3500,3800):
sql += "nchar_%d nchar(4), " % (i + 1)
for i in range(3800,4090):
sql += "binary_%d binary(10), " % (i + 1)
for i in range(4090,4092):
sql += "timestamp_%d timestamp, " % (i + 1)
sql += " col4093 binary(22)) "
sql += " tags (loc nchar(20),tag_1 int) "
tdLog.info(len(sql))
tdSql.execute(sql)
sql = " create table table_4096_3 using stable_4096_3 tags ('table_4096_3',1); "
tdSql.execute(sql)
for i in range(self.num4096):
sql = "insert into table_4096_3 values(%d, "
for j in range(4090):
str = "'%s', " % 'NULL'
sql += str
for j in range(4090,4092):
str = "%s, " % (self.ts + j)
sql += str
sql += "'%s')" % (self.ts + i)
tdSql.execute(sql % (self.ts + i))
tdSql.query('''select * from table_4096_3 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4094)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
tdSql.query('''select * from stable_4096_3 where ts = %d ;''' %(self.ts))
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,'NULL')
tdSql.checkData(0,3801,'NULL')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
sql = '''insert into table_4096_3 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-10 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-10 20:26:44.090','1500000000000');'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_3 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4093,'1500000000000')
tdSql.query("select * from stable_4096_3 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-10 20:26:44.090')
tdSql.checkData(0,4093,'1500000000000')
# tdDnodes restart force data dropping disk
tdDnodes.stop(1)
tdDnodes.start(1)
tdLog.info("========== regular_table ==========")
tdSql.execute('''insert into regular_table_3 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 200))
sql = '''select * from regular_table_3 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into regular_table_3 values( %d , 0, 0, 0, 0, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 200))
sql = '''select * from regular_table_3 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+0')
tdSql.checkData(0,7,'nchar+0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.error('''insert into regular_table_3 values( %d , -2147483648, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_3 values( %d , -2147483647, -9223372036854775808, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_3 values( %d , -2147483647, -9223372036854775807, -32768, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_3 values( %d , -2147483647, -9223372036854775807, -32767, -128, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_3 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0123', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into regular_table_3 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.execute('''insert into regular_table_3 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-012', 'nchar-0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
sql = '''select * from regular_table_3 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,-2147483647)
tdSql.checkData(0,2,-9223372036854775807)
tdSql.checkData(0,3,-32767)
tdSql.checkData(0,4,-127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-012')
tdSql.checkData(0,7,'nchar-0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
tdSql.error('''insert into regular_table_3 values( %d , 2147483648, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_3 values( %d , 2147483647, 9223372036854775808, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_3 values( %d , 2147483647, 9223372036854775807, 32768, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_3 values( %d , 2147483647, 9223372036854775807, 32767, 128, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_3 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0123', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into regular_table_3 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.execute('''insert into regular_table_3 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+012', 'nchar+0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
sql = '''select * from regular_table_3 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,2147483647)
tdSql.checkData(0,2,9223372036854775807)
tdSql.checkData(0,3,32767)
tdSql.checkData(0,4,127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+012')
tdSql.checkData(0,7,'nchar+0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
tdLog.info("========== stable ==========")
tdSql.execute('''insert into table_3 values( %d , NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL);''' %(self.ts - 200))
sql = '''select * from table_3 where ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
sql = '''select * from stable_1 where loc = 'table_3' and ts = %d ;''' %(self.ts - 200)
tdSql.query(sql)
tdSql.checkData(0,1,None)
tdSql.checkData(0,2,None)
tdSql.checkData(0,3,None)
tdSql.checkData(0,4,None)
tdSql.checkData(0,5,None)
tdSql.checkData(0,6,None)
tdSql.checkData(0,7,None)
tdSql.checkData(0,8,None)
tdSql.checkData(0,9,None)
tdSql.checkData(0,10,None)
tdSql.execute('''insert into table_3 values( %d , 0, 0, 0, 0, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 200))
sql = '''select * from table_3 where ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+0')
tdSql.checkData(0,7,'nchar+0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
sql = '''select * from stable_1 where loc = 'table_3' and ts = %d ;''' %(self.ts + 200)
tdSql.query(sql)
tdSql.checkData(0,1,0)
tdSql.checkData(0,2,0)
tdSql.checkData(0,3,0)
tdSql.checkData(0,4,0)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+0')
tdSql.checkData(0,7,'nchar+0')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:40.000')
tdSql.error('''insert into table_3 values( %d , -2147483648, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_3 values( %d , -2147483647, -9223372036854775808, -32767, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_3 values( %d , -2147483647, -9223372036854775807, -32768, -127, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_3 values( %d , -2147483647, -9223372036854775807, -32767, -128, 0, 'binary-0', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_3 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0123', 'nchar-0', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.error('''insert into table_3 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-0', 'nchar-01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
tdSql.execute('''insert into table_3 values( %d , -2147483647, -9223372036854775807, -32767, -127, 0, 'binary-012', 'nchar-0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts - 500))
sql = '''select * from table_3 where ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,-2147483647)
tdSql.checkData(0,2,-9223372036854775807)
tdSql.checkData(0,3,-32767)
tdSql.checkData(0,4,-127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-012')
tdSql.checkData(0,7,'nchar-0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
sql = '''select * from stable_1 where loc = 'table_3' and ts = %d ;''' %(self.ts - 500)
tdSql.query(sql)
tdSql.checkData(0,1,-2147483647)
tdSql.checkData(0,2,-9223372036854775807)
tdSql.checkData(0,3,-32767)
tdSql.checkData(0,4,-127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary-012')
tdSql.checkData(0,7,'nchar-0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
tdSql.error('''insert into table_3 values( %d , 2147483648, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_3 values( %d , 2147483647, 9223372036854775808, 32767, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_3 values( %d , 2147483647, 9223372036854775807, 32768, 127, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_3 values( %d , 2147483647, 9223372036854775807, 32767, 128, 0, 'binary+0', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_3 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0123', 'nchar+0', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.error('''insert into table_3 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+0', 'nchar+01234', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
tdSql.execute('''insert into table_3 values( %d , 2147483647, 9223372036854775807, 32767, 127, 0, 'binary+012', 'nchar+0123', 0.000000, 0.000000, 1600000000000);''' %(self.ts + 500))
sql = '''select * from table_3 where ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,2147483647)
tdSql.checkData(0,2,9223372036854775807)
tdSql.checkData(0,3,32767)
tdSql.checkData(0,4,127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+012')
tdSql.checkData(0,7,'nchar+0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
sql = '''select * from stable_1 where loc = 'table_3' and ts = %d ;''' %(self.ts + 500)
tdSql.query(sql)
tdSql.checkData(0,1,2147483647)
tdSql.checkData(0,2,9223372036854775807)
tdSql.checkData(0,3,32767)
tdSql.checkData(0,4,127)
tdSql.checkData(0,5,'False')
tdSql.checkData(0,6,'binary+012')
tdSql.checkData(0,7,'nchar+0123')
tdSql.checkData(0,8,0)
tdSql.checkData(0,9,0)
tdSql.checkData(0,10,'2020-09-13 20:26:44.090')
tdLog.info("========== 4096 regular_table ==========")
sql = '''insert into regular_table_4096_3 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-13 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-13 20:26:44.090','1600000000000');'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_3 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4095,'1600000000000')
sql = '''insert into regular_table_4096_3 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4095 )
values('2020-09-10 20:26:40.000' , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL);'''
tdSql.execute(sql)
tdSql.query("select * from regular_table_4096_3 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4095,None)
tdLog.info("========== 4096 stable ==========")
sql = '''insert into table_4096_3 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-13 20:26:40.000' , 1 , 501 , 101 , 1501 , 2001 , 1 , 3001 , '3501' , '3801' ,'2020-09-13 20:26:44.090','1600000000000');'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_3 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
tdSql.query("select * from stable_4096_3 where ts ='2020-09-13 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,1)
tdSql.checkData(0,501,501)
tdSql.checkData(0,1001,101)
tdSql.checkData(0,1501,1501)
tdSql.checkData(0,2001,2001)
tdSql.checkData(0,2501,'True')
tdSql.checkData(0,3001,3001)
tdSql.checkData(0,3501,'3501')
tdSql.checkData(0,3801,'3801')
tdSql.checkData(0,4091,'2020-09-13 20:26:44.090')
tdSql.checkData(0,4093,'1600000000000')
sql = '''insert into table_4096_3 (ts , int_1,smallint_501 , tinyint_1001 , double_1501 , float_2001 , bool_2501 ,
bigint_3001 , nchar_3501 , binary_3801 , timestamp_4091 , col4093 )
values('2020-09-10 20:26:40.000' , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL , NULL);'''
tdSql.execute(sql)
tdSql.query("select * from table_4096_3 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4094)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4093,None)
tdSql.query("select * from stable_4096_3 where ts ='2020-09-10 20:26:40.000';")
tdSql.checkCols(4096)
tdSql.checkData(0,1,None)
tdSql.checkData(0,501,None)
tdSql.checkData(0,1001,None)
tdSql.checkData(0,1501,None)
tdSql.checkData(0,2001,None)
tdSql.checkData(0,2501,None)
tdSql.checkData(0,3001,None)
tdSql.checkData(0,3501,None)
tdSql.checkData(0,3801,None)
tdSql.checkData(0,4091,None)
tdSql.checkData(0,4093,None)
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())
\ No newline at end of file
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或