taosdemoTestSupportNanoInsert.py 6.2 KB
Newer Older
W
wenzhouwww 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38
###################################################################
#           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 os
from util.log import *
from util.cases import *
from util.sql import *
from util.dnodes import *


class TDTestCase:
    def init(self, conn, logSql):
        tdLog.debug("start to execute %s" % __file__)
        tdSql.init(conn.cursor(), logSql)

    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):
39
                    buildPath = root[:len(root) - len("/build/bin")]
W
wenzhouwww 已提交
40 41 42 43 44 45 46 47 48
                    break
        return buildPath

    def run(self):
        buildPath = self.getBuildPath()
        if (buildPath == ""):
            tdLog.exit("taosd not found!")
        else:
            tdLog.info("taosd found in %s" % buildPath)
49
        binPath = buildPath + "/build/bin/"
W
wenzhouwww 已提交
50 51 52 53 54

        # insert: create one  or mutiple tables per sql and insert multiple rows per sql
        # insert data from a special timestamp
        # check stable stb0

55 56 57
        os.system(
            "%staosdemo -f tools/taosdemoAllTest/NanoTestCase/taosdemoTestNanoDatabase.json -y " %
            binPath)
W
wenzhouwww 已提交
58 59 60 61 62 63 64 65 66 67
        tdSql.execute("use nsdb")
        tdSql.query("show stables")
        tdSql.checkData(0, 4, 100)
        tdSql.query("select count (tbname) from stb0")
        tdSql.checkData(0, 0, 100)
        tdSql.query("select count(*) from tb0_0")
        tdSql.checkData(0, 0, 100)
        tdSql.query("select count(*) from stb0")
        tdSql.checkData(0, 0, 10000)
        tdSql.query("describe stb0")
68
        tdSql.checkDataType(9, 1, "TIMESTAMP")
W
wenzhouwww 已提交
69
        tdSql.query("select last(ts) from stb0")
70
        tdSql.checkData(0, 0, "2021-07-01 00:00:00.990000000")
W
wenzhouwww 已提交
71 72 73 74 75 76 77 78 79 80 81

        # check stable stb1 which is insert with disord

        tdSql.query("select count (tbname) from stb1")
        tdSql.checkData(0, 0, 100)
        tdSql.query("select count(*) from tb1_0")
        tdSql.checkData(0, 0, 100)
        tdSql.query("select count(*) from stb1")
        tdSql.checkData(0, 0, 10000)
        # check c8 is an nano timestamp
        tdSql.query("describe stb1")
82
        tdSql.checkDataType(9, 1, "TIMESTAMP")
W
wenzhouwww 已提交
83 84
        # check insert timestamp_step is nano_second
        tdSql.query("select last(ts) from stb1")
85 86
        tdSql.checkData(0, 0, "2021-07-01 00:00:00.990000000")

W
wenzhouwww 已提交
87 88 89
        # insert data from now time

        # check stable stb0
90 91 92 93
        os.system(
            "%staosdemo -f tools/taosdemoAllTest/NanoTestCase/taosdemoTestNanoDatabaseNow.json -y " %
            binPath)

W
wenzhouwww 已提交
94 95 96 97 98 99 100 101 102 103 104
        tdSql.execute("use nsdb2")
        tdSql.query("show stables")
        tdSql.checkData(0, 4, 100)
        tdSql.query("select count (tbname) from stb0")
        tdSql.checkData(0, 0, 100)
        tdSql.query("select count(*) from tb0_0")
        tdSql.checkData(0, 0, 100)
        tdSql.query("select count(*) from stb0")
        tdSql.checkData(0, 0, 10000)
        # check c8 is an nano timestamp
        tdSql.query("describe stb0")
105 106 107 108
        tdSql.checkDataType(9, 1, "TIMESTAMP")

        # insert by csv files and timetamp is long int , strings  in ts and
        # cols
W
wenzhouwww 已提交
109

110 111 112
        os.system(
            "%staosdemo -f tools/taosdemoAllTest/NanoTestCase/taosdemoTestNanoDatabasecsv.json  -y " %
            binPath)
W
wenzhouwww 已提交
113 114 115 116 117 118 119
        tdSql.execute("use nsdbcsv")
        tdSql.query("show stables")
        tdSql.checkData(0, 4, 100)
        tdSql.query("select count(*) from stb0")
        tdSql.checkData(0, 0, 10000)
        tdSql.query("describe stb0")
        tdSql.checkDataType(3, 1, "TIMESTAMP")
120 121
        tdSql.query(
            "select count(*) from stb0 where ts > \"2021-07-01 00:00:00.490000000\"")
W
wenzhouwww 已提交
122 123 124 125
        tdSql.checkData(0, 0, 5000)
        tdSql.query("select count(*) from stb0 where ts < 1626918583000000000")
        tdSql.checkData(0, 0, 10000)

126 127 128 129 130 131 132 133 134
        os.system("rm -rf ./insert_res.txt")
        os.system(
            "rm -rf tools/taosdemoAllTest/NanoTestCase/taosdemoTestSupportNano*.py.sql")

        # taosdemo test insert with command and parameter , detals show
        # taosdemo --help
        os.system(
            "%staosdemo  -u root -ptaosdata -P 6030  -a 1  -m pre -n 10 -T 20 -t 60 -o res.txt -y " %
            binPath)
W
wenzhouwww 已提交
135 136 137 138
        tdSql.query("select count(*) from test.meters")
        tdSql.checkData(0, 0, 600)
        # check taosdemo -s

139 140 141 142 143 144 145 146
        sqls_ls = [
            'drop database  if exists nsdbsql;',
            'create database nsdbsql precision "ns" keep 3600 days 6 update 1;',
            'use nsdbsql;',
            'CREATE STABLE meters (ts timestamp, current float, voltage int, phase float) TAGS (location binary(64), groupdId int);',
            'CREATE TABLE d1001 USING meters TAGS ("Beijing.Chaoyang", 2);',
            'INSERT INTO d1001 USING METERS TAGS ("Beijng.Chaoyang", 2) VALUES (now, 10.2, 219, 0.32);',
            'INSERT INTO d1001 USING METERS TAGS ("Beijng.Chaoyang", 2) VALUES (now, 85, 32, 0.76);']
W
wenzhouwww 已提交
147

148
        with open("./taosdemoTestNanoCreateDB.sql", mode="a") as sql_files:
W
wenzhouwww 已提交
149
            for sql in sqls_ls:
150
                sql_files.write(sql + "\n")
W
wenzhouwww 已提交
151 152 153 154 155 156 157
            sql_files.close()

        sleep(10)

        os.system("%staosdemo  -s taosdemoTestNanoCreateDB.sql  -y " % binPath)
        tdSql.query("select count(*) from nsdbsql.meters")
        tdSql.checkData(0, 0, 2)
158

W
wenzhouwww 已提交
159 160 161 162 163 164 165 166 167 168 169
        os.system("rm -rf ./res.txt")
        os.system("rm -rf ./*.py.sql")
        os.system("rm -rf ./taosdemoTestNanoCreateDB.sql")

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


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