xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix python source code for pep8 standard.

This commit is contained in:
Shuduo Sang 2020-04-27 15:23:15 +08:00
parent fd76b5f71d
commit 2777a2f0c9
68 changed files with 3808 additions and 3590 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/pytest/import_merge/importBlock1H.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -66,5 +67,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock1HO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -69,5 +70,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock1HPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -71,5 +72,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock1S.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -69,5 +70,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock1Sub.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -69,5 +70,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock1T.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -66,5 +67,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock1TO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -69,5 +70,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock1TPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -71,5 +72,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock2H.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -66,5 +67,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock2HO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -69,5 +70,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock2HPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -71,5 +72,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock2S.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -69,5 +70,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock2Sub.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -69,5 +70,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock2T.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -66,5 +67,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock2TO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -69,5 +70,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlock2TPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -71,5 +72,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importBlockbetween.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -72,5 +73,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importCacheFileH.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -82,5 +83,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importCacheFileHO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -85,5 +86,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

8
tests/pytest/import_merge/importCacheFileHPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -45,7 +46,8 @@ class TDTestCase:
startTime = self.startTime
sqlcmd = ['import into tb1 values']
for rid in range(1, 11):
if (rid == 5): continue
if (rid == 5):
continue
sqlcmd.append('(%ld, %d)' % (startTime + rid, rid))
tdSql.execute(" ".join(sqlcmd))
@ -63,7 +65,8 @@ class TDTestCase:
startTime = self.startTime + 10
sqlcmd = ['import into tb1 values']
for rid in range(1, 11):
if (rid == 5): continue
if (rid == 5):
continue
sqlcmd.append('(%ld, %d)' % (startTime + rid, rid))
tdSql.execute(" ".join(sqlcmd))
@ -87,5 +90,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importCacheFileS.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -85,5 +86,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importCacheFileSub.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -85,5 +86,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importCacheFileT.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -82,5 +83,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importCacheFileTO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -85,5 +86,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

8
tests/pytest/import_merge/importCacheFileTPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -45,7 +46,8 @@ class TDTestCase:
startTime = self.startTime
sqlcmd = ['import into tb1 values']
for rid in range(1, 11):
if (rid == 7): continue
if (rid == 7):
continue
sqlcmd.append('(%ld, %d)' % (startTime + rid, rid))
tdSql.execute(" ".join(sqlcmd))
@ -63,7 +65,8 @@ class TDTestCase:
startTime = self.startTime + 10
sqlcmd = ['import into tb1 values']
for rid in range(1, 11):
if (rid == 7): continue
if (rid == 7):
continue
sqlcmd.append('(%ld, %d)' % (startTime + rid, rid))
tdSql.execute(" ".join(sqlcmd))
@ -87,5 +90,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

7
tests/pytest/import_merge/importDataH2.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -40,7 +41,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import %d sequential data" % (self.rows / 2))
@ -64,7 +67,6 @@ class TDTestCase:
startTime = self.startTime - 1
tdSql.execute('import into tb1 values(%ld, %d)' % (startTime + 1, 1))
tdLog.info("================= step7")
tdSql.execute('reset query cache')
tdSql.query('select * from tb1 order by ts desc')
@ -87,5 +89,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataHO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -41,7 +42,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import %d sequential data" % self.rowsPerTable)
@ -76,5 +79,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataHO2.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -41,7 +42,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import %d sequential data" % self.rowsPerTable)
@ -76,5 +79,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataHPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -41,7 +42,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import %d sequential data" % self.rowsPerTable)
@ -78,5 +81,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataLastH.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -40,7 +41,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than %d rows less than %d rows will go to data and last file" %(self.rows, 10+self.rows))
tdLog.info(
"More than %d rows less than %d rows will go to data and last file" %
(self.rows, 10 + self.rows))
tdLog.info("================= step2")
tdLog.info("import 205 sequential data")
@ -72,5 +75,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataLastHO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -40,7 +41,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than %d rows less than %d rows will go to data and last file" %(self.rows, 10+self.rows))
tdLog.info(
"More than %d rows less than %d rows will go to data and last file" %
(self.rows, 10 + self.rows))
tdLog.info("================= step2")
tdLog.info("import 205 sequential data")
@ -75,5 +78,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataLastHPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -40,7 +41,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than %d rows less than %d rows will go to data and last file" %(self.rows, 10+self.rows))
tdLog.info(
"More than %d rows less than %d rows will go to data and last file" %
(self.rows, 10 + self.rows))
tdLog.info("================= step2")
tdLog.info("import 205 sequential data")
@ -77,5 +80,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataLastS.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -40,7 +41,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than %d rows less than %d rows will go to data and last file" %(self.rows, 10+self.rows))
tdLog.info(
"More than %d rows less than %d rows will go to data and last file" %
(self.rows, 10 + self.rows))
tdLog.info("================= step2")
tdLog.info("import 205 sequential data")
@ -75,5 +78,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataLastSub.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -40,7 +41,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than %d rows less than %d rows will go to data and last file" %(self.rows, 10+self.rows))
tdLog.info(
"More than %d rows less than %d rows will go to data and last file" %
(self.rows, 10 + self.rows))
tdLog.info("================= step2")
tdLog.info("import 205 sequential data")
@ -75,5 +78,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataLastT.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -36,7 +37,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than %d rows less than %d rows will go to data and last file" %(self.rows, 10+self.rows))
tdLog.info(
"More than %d rows less than %d rows will go to data and last file" %
(self.rows, 10 + self.rows))
tdLog.info("================= step2")
tdLog.info("import 205 sequential data")
@ -68,5 +71,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataLastTO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -36,7 +37,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than %d rows less than %d rows will go to data and last file" %(self.rows, 10+self.rows))
tdLog.info(
"More than %d rows less than %d rows will go to data and last file" %
(self.rows, 10 + self.rows))
tdLog.info("================= step2")
tdLog.info("import 205 sequential data")
@ -71,5 +74,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataLastTPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -36,7 +37,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than %d rows less than %d rows will go to data and last file" %(self.rows, 10+self.rows))
tdLog.info(
"More than %d rows less than %d rows will go to data and last file" %
(self.rows, 10 + self.rows))
tdLog.info("================= step2")
tdLog.info("import 205 sequential data")
@ -73,5 +76,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataS.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -36,7 +37,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import 20 sequential data")
@ -71,5 +74,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataSub.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -40,7 +41,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import %d sequential data" % (self.rows / 2))
@ -76,5 +79,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataT.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -36,7 +37,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import 20 sequential data")
@ -68,5 +71,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataTO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -36,7 +37,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import 20 sequential data")
@ -71,5 +74,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importDataTPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -36,7 +37,9 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, speed int)')
tdLog.info("More than 10 rows less than %d rows will go to data file" %self.rows)
tdLog.info(
"More than 10 rows less than %d rows will go to data file" %
self.rows)
tdLog.info("================= step2")
tdLog.info("import 20 sequential data")
@ -74,5 +77,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

10
tests/pytest/import_merge/importHORestart.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -37,7 +38,9 @@ class TDTestCase:
tdLog.info("import 10 sequential data")
startTime = self.startTime
for rid in range(1, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -47,7 +50,9 @@ class TDTestCase:
tdLog.info("import 5 data before with overlap")
startTime = self.startTime - 2
for rid in range(1, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step5")
tdDnodes.forcestop(1)
@ -62,5 +67,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

14
tests/pytest/import_merge/importHPORestart.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -37,9 +38,13 @@ class TDTestCase:
tdLog.info("import 8 sequential data with gap")
startTime = self.startTime
for rid in range(1, 4):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
for rid in range(6, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
startTime += 1
tdLog.info("================= step3")
@ -50,7 +55,9 @@ class TDTestCase:
tdLog.info("import 8 data before with partly overlap")
startTime = self.startTime - 2
for rid in range(1, 9):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step5")
tdDnodes.forcestop(1)
@ -65,5 +72,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importHRestart.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -37,7 +38,9 @@ class TDTestCase:
tdLog.info("import 10 sequential data")
startTime = self.startTime
for rid in range(1, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -61,5 +64,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importHead.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -64,5 +65,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importHeadOverlap.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -59,5 +60,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importHeadPartOverlap.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -63,5 +64,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importLastH.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -68,5 +69,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importLastHO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -71,5 +72,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importLastHPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -73,5 +74,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importLastS.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -70,5 +71,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importLastSub.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -71,5 +72,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importLastT.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -72,5 +73,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importLastTO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -75,5 +76,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importLastTPO.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -76,5 +77,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

10
tests/pytest/import_merge/importSRestart.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -44,7 +45,9 @@ class TDTestCase:
tdLog.info("import 10 sequential data")
startTime = self.startTime
for rid in range(1, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -54,7 +57,9 @@ class TDTestCase:
tdLog.info("import 20 data cover existing data")
startTime = self.startTime - 5
for rid in range(1, 21):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step5")
tdDnodes.forcestop(1)
@ -69,5 +74,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

10
tests/pytest/import_merge/importSpan.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -44,7 +45,9 @@ class TDTestCase:
tdLog.info("import 10 sequential data")
startTime = self.startTime
for rid in range(1, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -54,7 +57,9 @@ class TDTestCase:
tdLog.info("import 20 data cover existing data")
startTime = self.startTime - 5
for rid in range(1, 21):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step5")
tdSql.query('select * from tb1')
@ -64,5 +69,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

10
tests/pytest/import_merge/importSubRestart.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -44,7 +45,9 @@ class TDTestCase:
tdLog.info("import 20 sequential data")
startTime = self.startTime
for rid in range(1, 21):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -54,7 +57,9 @@ class TDTestCase:
tdLog.info("import 10 data totally repetitive")
startTime = self.startTime + 5
for rid in range(1, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step5")
tdDnodes.forcestop(1)
@ -69,5 +74,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

10
tests/pytest/import_merge/importTORestart.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -44,7 +45,9 @@ class TDTestCase:
tdLog.info("import 10 sequential data")
startTime = self.startTime
for rid in range(1, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -54,7 +57,9 @@ class TDTestCase:
tdLog.info("import 6 data after with overlap")
startTime = self.startTime + 8
for rid in range(1, 7):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step5")
tdDnodes.forcestop(1)
@ -69,5 +74,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

14
tests/pytest/import_merge/importTPORestart.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -44,9 +45,13 @@ class TDTestCase:
tdLog.info("import 8 sequential data with gap")
startTime = self.startTime
for rid in range(1, 6):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
for rid in range(8, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -56,7 +61,9 @@ class TDTestCase:
tdLog.info("import 8 data after with partly overlap")
startTime = self.startTime + 3
for rid in range(1, 9):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step5")
tdDnodes.forcestop(1)
@ -71,5 +78,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

6
tests/pytest/import_merge/importTRestart.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -44,7 +45,9 @@ class TDTestCase:
tdLog.info("import 10 sequential data")
startTime = self.startTime
for rid in range(1, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -68,5 +71,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importTail.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -64,5 +65,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

2
tests/pytest/import_merge/importTailOverlap.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -66,5 +67,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

14
tests/pytest/import_merge/importTailPartOverlap.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -44,9 +45,13 @@ class TDTestCase:
tdLog.info("import 8 sequential data with gap")
startTime = self.startTime
for rid in range(1, 6):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
for rid in range(8, 11):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step3")
tdSql.query('select * from tb1')
@ -56,7 +61,9 @@ class TDTestCase:
tdLog.info("import 8 data after with partly overlap")
startTime = self.startTime + 3
for rid in range(1, 9):
tdSql.execute('import into tb1 values(%ld, %d)' %(startTime+rid, rid))
tdSql.execute(
'import into tb1 values(%ld, %d)' %
(startTime + rid, rid))
tdLog.info("================= step5")
tdSql.query('select * from tb1')
@ -66,5 +73,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

8
tests/pytest/import_merge/importToCommit.py
View File

@ -18,6 +18,7 @@ from util.cases import *
from util.sql import *
from util.dnodes import *
class TDTestCase:
def init(self, conn):
tdLog.debug("start to execute %s" % __file__)
@ -38,7 +39,8 @@ class TDTestCase:
tdLog.info("================= step1")
tdLog.info("create 1 table")
tdSql.execute('create table tb1 (ts timestamp, i int)')
tdLog.info("one block can import 38 records and totally there are 40 blocks")
tdLog.info(
"one block can import 38 records and totally there are 40 blocks")
tdLog.info("================= step2")
tdLog.info('insert data until the first commit')
@ -47,7 +49,8 @@ class TDTestCase:
startTime = self.startTime
rid0 = 1
while (True):
sqlcmd = 'insert into tb1 values(%ld, %d)' %(startTime+rid0*2, rid0)
sqlcmd = 'insert into tb1 values(%ld, %d)' % (
startTime + rid0 * 2, rid0)
tdSql.execute(sqlcmd)
rid0 += 1
vnodes = os.listdir(dataDir)
@ -77,5 +80,6 @@ class TDTestCase:
tdSql.close()
tdLog.success("%s successfully executed" % __file__)
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())

15
tests/pytest/query/tbname.py
View File

@ -26,12 +26,14 @@ class TDTestCase:
def run(self):
tdSql.prepare()
tdSql.execute('create table cars (ts timestamp, speed int) tags(id int)')
tdSql.execute(
'create table cars (ts timestamp, speed int) tags(id int)')
tdSql.execute("create table carzero using cars tags(0)")
tdSql.execute("create table carone using cars tags(1)")
tdSql.execute("create table cartwo using cars tags(2)")
tdSql.execute("insert into carzero values(now, 100) carone values(now, 110)")
tdSql.execute(
"insert into carzero values(now, 100) carone values(now, 110)")
tdSql.query("select * from cars where tbname in ('carzero', 'carone')")
tdSql.checkRows(2)
@ -39,13 +41,16 @@ class TDTestCase:
tdSql.query("select * from cars where tbname in ('carzero', 'cartwo')")
tdSql.checkRows(1)
tdSql.query("select * from cars where id=1 or tbname in ('carzero', 'cartwo')")
tdSql.query(
"select * from cars where id=1 or tbname in ('carzero', 'cartwo')")
tdSql.checkRows(2)
tdSql.query("select * from cars where id=1 and tbname in ('carzero', 'cartwo')")
tdSql.query(
"select * from cars where id=1 and tbname in ('carzero', 'cartwo')")
tdSql.checkRows(0)
tdSql.query("select * from cars where id=0 and tbname in ('carzero', 'cartwo')")
tdSql.query(
"select * from cars where id=0 and tbname in ('carzero', 'cartwo')")
tdSql.checkRows(1)
"""