################################################################### # 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 os from util.log import * from util.cases import * from util.sql import * from util.dnodes import * class TDTestCase: def caseDescription(self): ''' [TD-11510] taosBenchmark test cases ''' return def init(self, conn, logSql): tdLog.debug("start to execute %s" % __file__) tdSql.init(conn.cursor(), logSql) def run(self): cmd = "taosBenchmark -f ./5-taos-tools/taosbenchmark/json/sml_rest_telnet.json" tdLog.info("%s" % cmd) os.system("%s" % cmd) tdSql.execute("reset query cache") tdSql.query("select count(tbname) from db.stb1") tdSql.checkData(0, 0, 8) tdSql.query("select count(*) from db.stb1") tdSql.checkData(0, 0, 160) tdSql.query("select count(tbname) from db.stb2") tdSql.checkData(0, 0, 8) tdSql.query("select count(*) from db.stb2") tdSql.checkData(0, 0, 160) cmd = "taosBenchmark -f ./5-taos-tools/taosbenchmark/json/sml_rest_line.json" tdLog.info("%s" % cmd) os.system("%s" % cmd) tdSql.execute("reset query cache") tdSql.query("select count(tbname) from db2.stb1") tdSql.checkData(0, 0, 8) tdSql.query("select count(*) from db2.stb1") tdSql.checkData(0, 0, 160) tdSql.query("select count(tbname) from db2.stb2") tdSql.checkData(0, 0, 8) tdSql.query("select count(*) from db2.stb2") tdSql.checkData(0, 0, 160) cmd = "taosBenchmark -f ./5-taos-tools/taosbenchmark/json/sml_rest_json.json" tdLog.info("%s" % cmd) os.system("%s" % cmd) tdSql.execute("reset query cache") tdSql.query("select count(tbname) from db3.stb1") tdSql.checkData(0, 0, 8) tdSql.query("select count(*) from db3.stb1") tdSql.checkData(0, 0, 160) tdSql.query("select count(tbname) from db3.stb2") tdSql.checkData(0, 0, 8) tdSql.query("select count(*) from db3.stb2") tdSql.checkData(0, 0, 160) def stop(self): tdSql.close() tdLog.success("%s successfully executed" % __file__) tdCases.addWindows(__file__, TDTestCase()) tdCases.addLinux(__file__, TDTestCase())