未验证 提交 7dac9977 编写于 作者: H Hui Li 提交者: GitHub

Merge pull request #7911 from taosdata/test/TD-6635-m

[TD-6635]<test>:modify python file about ts = 1600000**
...@@ -55,7 +55,7 @@ class TDTestCase: ...@@ -55,7 +55,7 @@ class TDTestCase:
tdSql.execute('''drop database if exists test_updata_0 ;''') tdSql.execute('''drop database if exists test_updata_0 ;''')
# update 0 不更新 ; update 1 覆盖更新 ;update 2 合并更新 # update 0 不更新 ; update 1 覆盖更新 ;update 2 合并更新
tdLog.info("========== test database updata = 0 ==========") tdLog.info("========== test database updata = 0 ==========")
tdSql.execute('''create database test_updata_0 update 0 minrows 10 maxrows 200 ;''') tdSql.execute('''create database test_updata_0 update 0 minrows 10 maxrows 200 keep 36500;;''')
tdSql.execute('''use test_updata_0;''') tdSql.execute('''use test_updata_0;''')
tdSql.execute('''create stable stable_1 tdSql.execute('''create stable stable_1
(ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint, (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint,
......
...@@ -55,7 +55,7 @@ class TDTestCase: ...@@ -55,7 +55,7 @@ class TDTestCase:
tdSql.execute('''drop database if exists test_updata_1 ;''') tdSql.execute('''drop database if exists test_updata_1 ;''')
# update 0 不更新 ; update 1 覆盖更新 ;update 2 合并更新 # update 0 不更新 ; update 1 覆盖更新 ;update 2 合并更新
tdLog.info("========== test database updata = 1 ==========") tdLog.info("========== test database updata = 1 ==========")
tdSql.execute('''create database test_updata_1 update 1 minrows 10 maxrows 200 ;''') tdSql.execute('''create database test_updata_1 update 1 minrows 10 maxrows 200 keep 36500;''')
tdSql.execute('''use test_updata_1;''') tdSql.execute('''use test_updata_1;''')
tdSql.execute('''create stable stable_1 tdSql.execute('''create stable stable_1
(ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint, (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint,
......
...@@ -55,7 +55,7 @@ class TDTestCase: ...@@ -55,7 +55,7 @@ class TDTestCase:
tdSql.execute('''drop database if exists test_updata_2 ;''') tdSql.execute('''drop database if exists test_updata_2 ;''')
# update 0 不更新 ; update 1 覆盖更新 ;update 2 合并更新 # update 0 不更新 ; update 1 覆盖更新 ;update 2 合并更新
tdLog.info("========== test database updata = 2 ==========") tdLog.info("========== test database updata = 2 ==========")
tdSql.execute('''create database test_updata_2 update 2 minrows 10 maxrows 200 ;''') tdSql.execute('''create database test_updata_2 update 2 minrows 10 maxrows 200 keep 36500;''')
tdSql.execute('''use test_updata_2;''') tdSql.execute('''use test_updata_2;''')
tdSql.execute('''create stable stable_1 tdSql.execute('''create stable stable_1
(ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint, (ts timestamp , q_int int , q_bigint bigint , q_smallint smallint , q_tinyint tinyint,
......
...@@ -29,7 +29,9 @@ class TDTestCase: ...@@ -29,7 +29,9 @@ class TDTestCase:
tdLog.debug("start to execute %s" % __file__) tdLog.debug("start to execute %s" % __file__)
tdSql.init(conn.cursor(), logSql) tdSql.init(conn.cursor(), logSql)
self.ts = 1600000000000 os.system("rm -rf query/nestedQuery/nestedQuery.py.sql")
now = time.time()
self.ts = int(round(now * 1000))
self.num = 10 self.num = 10
self.fornum = 20 self.fornum = 20
...@@ -464,8 +466,7 @@ class TDTestCase: ...@@ -464,8 +466,7 @@ class TDTestCase:
tdLog.info(sql) tdLog.info(sql)
tdLog.info(len(sql)) tdLog.info(len(sql))
tdSql.query(sql) tdSql.query(sql)
#tdSql.error(sql) #tdSql.checkData(0,0,'2020-09-13 20:26:40.000')
tdSql.checkData(0,0,'2020-09-13 20:26:40.000')
tdSql.checkRows(6*self.num) tdSql.checkRows(6*self.num)
...@@ -533,7 +534,7 @@ class TDTestCase: ...@@ -533,7 +534,7 @@ class TDTestCase:
tdLog.info(sql) tdLog.info(sql)
tdLog.info(len(sql)) tdLog.info(len(sql))
tdSql.query(sql) tdSql.query(sql)
tdSql.checkData(0,0,'2020-09-13 20:26:40.000') #tdSql.checkData(0,0,'2020-09-13 20:26:40.000')
tdSql.checkRows(6*self.num) tdSql.checkRows(6*self.num)
#2 select column from (select * form regular_table ) where <\>\in\and\or order by #2 select column from (select * form regular_table ) where <\>\in\and\or order by
...@@ -550,7 +551,7 @@ class TDTestCase: ...@@ -550,7 +551,7 @@ class TDTestCase:
tdLog.info(sql) tdLog.info(sql)
tdLog.info(len(sql)) tdLog.info(len(sql))
tdSql.query(sql) tdSql.query(sql)
tdSql.checkData(0,0,'2020-09-13 20:26:40.000') #tdSql.checkData(0,0,'2020-09-13 20:26:40.000')
tdSql.checkRows(6*self.num) tdSql.checkRows(6*self.num)
#join: select column from (select column form regular_table1,regular_table2 )where t1.ts=t2.ts and <\>\in\and\or order by #join: select column from (select column form regular_table1,regular_table2 )where t1.ts=t2.ts and <\>\in\and\or order by
...@@ -587,7 +588,7 @@ class TDTestCase: ...@@ -587,7 +588,7 @@ class TDTestCase:
tdLog.info(sql) tdLog.info(sql)
tdLog.info(len(sql)) tdLog.info(len(sql))
tdSql.query(sql) tdSql.query(sql)
tdSql.checkData(0,0,'2020-09-13 20:26:40.000') #tdSql.checkData(0,0,'2020-09-13 20:26:40.000')
tdSql.checkRows(6*self.num) tdSql.checkRows(6*self.num)
# select ts,* from (select column\tag form stable1,stable2 where t1.ts = t2.ts and <\>\in\and\or order by ) # select ts,* from (select column\tag form stable1,stable2 where t1.ts = t2.ts and <\>\in\and\or order by )
...@@ -686,7 +687,7 @@ class TDTestCase: ...@@ -686,7 +687,7 @@ class TDTestCase:
tdLog.info(sql) tdLog.info(sql)
tdLog.info(len(sql)) tdLog.info(len(sql))
tdSql.query(sql) tdSql.query(sql)
tdSql.checkData(0,0,'2020-09-13 20:26:40.000') #tdSql.checkData(0,0,'2020-09-13 20:26:40.000')
tdSql.checkRows(6*self.num) tdSql.checkRows(6*self.num)
#5 select distinct column\tag from (select * form stable where <\>\in\and\or order by limit offset ) #5 select distinct column\tag from (select * form stable where <\>\in\and\or order by limit offset )
......
...@@ -17,6 +17,8 @@ from util.log import tdLog ...@@ -17,6 +17,8 @@ from util.log import tdLog
from util.cases import tdCases from util.cases import tdCases
from util.sql import tdSql from util.sql import tdSql
import random import random
import time
import os
class TDTestCase: class TDTestCase:
...@@ -24,7 +26,9 @@ class TDTestCase: ...@@ -24,7 +26,9 @@ class TDTestCase:
tdLog.debug("start to execute %s" % __file__) tdLog.debug("start to execute %s" % __file__)
tdSql.init(conn.cursor(), logSql) tdSql.init(conn.cursor(), logSql)
self.ts = 1600000000000 os.system("rm -rf query/nestquery_last_row.py.sql")
now = time.time()
self.ts = int(round(now * 1000))
self.num = 10 self.num = 10
def run(self): def run(self):
......
...@@ -25,7 +25,8 @@ class TDTestCase: ...@@ -25,7 +25,8 @@ class TDTestCase:
tdLog.debug("start to execute %s" % __file__) tdLog.debug("start to execute %s" % __file__)
tdSql.init(conn.cursor(), logSql) tdSql.init(conn.cursor(), logSql)
self.ts = 1600000000000 now = time.time()
self.ts = int(round(now * 1000))
self.num = 10 self.num = 10
def run(self): def run(self):
......
...@@ -26,7 +26,8 @@ class TDTestCase: ...@@ -26,7 +26,8 @@ class TDTestCase:
tdLog.debug("start to execute %s" % __file__) tdLog.debug("start to execute %s" % __file__)
tdSql.init(conn.cursor(), logSql) tdSql.init(conn.cursor(), logSql)
self.ts = 1538548685000 now = time.time()
self.ts = int(round(now * 1000))
self.num = 100 self.num = 100
def get_random_string(self, length): def get_random_string(self, length):
......
...@@ -22,7 +22,7 @@ ...@@ -22,7 +22,7 @@
"cache": 50, "cache": 50,
"blocks": 8, "blocks": 8,
"precision": "ms", "precision": "ms",
"keep": 365, "keep": 36500,
"minRows": 100, "minRows": 100,
"maxRows": 4096, "maxRows": 4096,
"comp":2, "comp":2,
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册