importCacheFileSub.py 2.8 KB
Newer Older
1
###################################################################
2 3 4 5 6 7 8 9
#       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
#
10 11
###################################################################

12
# -*- coding: utf-8 -*-
13 14 15 16 17 18 19 20

import sys
import taos
from util.log import *
from util.cases import *
from util.sql import *
from util.dnodes import *

21

22
class TDTestCase:
S
Shuduo Sang 已提交
23
    def init(self, conn, logSql):
24
        tdLog.debug("start to execute %s" % __file__)
S
Shuduo Sang 已提交
25
        tdSql.init(conn.cursor(), logSql)
26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57

    def run(self):
        self.ntables = 1
        self.startTime = 1520000010000

        tdDnodes.stop(1)
        tdDnodes.deploy(1)
        tdDnodes.start(1)

        tdSql.execute('reset query cache')
        tdSql.execute('drop database if exists db')
        tdSql.execute('create database db')
        tdSql.execute('use db')

        tdLog.info("================= step1")
        tdLog.info("create 1 table")
        tdSql.execute('create table tb1 (ts timestamp, speed int)')

        tdLog.info("================= step2")
        tdLog.info("import 10 sequential data")
        startTime = self.startTime
        sqlcmd = ['import into tb1 values']
        for rid in range(1, 11):
            sqlcmd.append('(%ld, %d)' % (startTime + rid, rid))
        tdSql.execute(" ".join(sqlcmd))

        tdLog.info("================= step3")
        tdSql.query('select * from tb1')
        tdSql.checkRows(10)

        tdLog.info("================= step4")
        tdDnodes.stop(1)
L
liuyq-617 已提交
58
        #tdLog.sleep(5)
59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89
        tdDnodes.start(1)

        tdLog.info("================= step5")
        tdLog.info("import 10 data again")
        startTime = self.startTime + 10
        sqlcmd = ['import into tb1 values']
        for rid in range(1, 11):
            sqlcmd.append('(%ld, %d)' % (startTime + rid, rid))
        tdSql.execute(" ".join(sqlcmd))

        tdLog.info("================= step6")
        tdSql.query('select * from tb1')
        tdSql.checkRows(20)

        tdLog.info("================= step7")
        tdLog.info("import 10 data totally repetitive")
        startTime = self.startTime + 5
        sqlcmd = ['import into tb1 values']
        for rid in range(1, 11):
            sqlcmd.append('(%ld, %d)' % (startTime + rid, rid))
        tdSql.execute(" ".join(sqlcmd))

        tdLog.info("================= step8")
        tdSql.query('select * from tb1')
        tdSql.checkRows(20)

    def stop(self):
        tdSql.close()
        tdLog.success("%s successfully executed" % __file__)


90 91
tdCases.addWindows(__file__, TDTestCase())
tdCases.addLinux(__file__, TDTestCase())