################################################################### # 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 taos from util.log import tdLog from util.cases import tdCases from util.sql import tdSql from util.dnodes import tdDnodes class TDTestCase: def init(self, conn, logSql): tdLog.debug("start to execute %s" % __file__) tdSql.init(conn.cursor(), logSql) self.tables = 10 self.rows = 20 self.columns = 100 self.perfix = 't' self.ts = 1601481600000 def insertData(self): print("==============step1") sql = "create table st(ts timestamp, " for i in range(self.columns - 1): sql += "c%d bigint, " % (i + 1) sql += "c100 bigint) tags(t1 int)" tdSql.execute(sql) for i in range(self.tables): tdSql.execute("create table %s%d using st tags(%d)" % (self.perfix, i, i)) for j in range(self.rows): tc = self.ts + j * 60000 tdSql.execute("insert into %s%d(ts, c1) values(%d, %d)" %(self.perfix, i, tc, j)) def executeQueries(self): print("==============step2") tdSql.query("select last_row(c1) from %s%d" % (self.perfix, 1)) tdSql.checkData(0, 0, 19) tdSql.query("select last_row(c1) from %s%d where ts <= %d" % (self.perfix, 1, self.ts + 4 * 60000)) tdSql.checkData(0, 0, 4) tdSql.query("select last_row(c1) as b from %s%d" % (self.perfix, 1)) tdSql.checkData(0, 0, 19) tdSql.query("select last_row(c1) from st") tdSql.checkData(0, 0, 19) tdSql.query("select last_row(c1) as c from st where ts <= %d" % (self.ts + 4 * 60000)) tdSql.checkData(0, 0, 4) tdSql.query("select last_row(c1) as c from st where t1 < 5") tdSql.checkData(0, 0, 19) tdSql.query("select last_row(c1) as c from st where t1 <= 5 and ts <= %d" % (self.ts + 4 * 60000)) tdSql.checkData(0, 0, 4) tdSql.query("select last_row(c1) as c from st group by t1") tdSql.checkRows(10) tdSql.checkData(0, 0, 19) tc = self.ts + 1 * 3600000 tdSql.execute("insert into %s%d(ts, c1) values(%d, %d)" %(self.perfix, 1, tc, 10)) tc = self.ts + 3 * 3600000 tdSql.execute("insert into %s%d(ts, c1) values(%d, null)" %(self.perfix, 1, tc)) tc = self.ts + 5 * 3600000 tdSql.execute("insert into %s%d(ts, c1) values(%d, %d)" %(self.perfix, 1, tc, -1)) tc = self.ts + 7 * 3600000 tdSql.execute("insert into %s%d(ts, c1) values(%d, null)" %(self.perfix, 1, tc)) def insertData2(self): tc = self.ts + 1 * 3600000 tdSql.execute("insert into %s%d(ts, c1) values(%d, %d)" %(self.perfix, 1, tc, 10)) tc = self.ts + 3 * 3600000 tdSql.execute("insert into %s%d(ts, c1) values(%d, null)" %(self.perfix, 1, tc)) tc = self.ts + 5 * 3600000 tdSql.execute("insert into %s%d(ts, c1) values(%d, %d)" %(self.perfix, 1, tc, -1)) tc = self.ts + 7 * 3600000 tdSql.execute("insert into %s%d(ts, c1) values(%d, null)" %(self.perfix, 1, tc)) def executeQueries2(self): # For stable tc = self.ts + 6 * 3600000 tdSql.query("select last_row(c1) from st where ts < %d " % tc) tdSql.checkData(0, 0, -1) tc = self.ts + 8 * 3600000 tdSql.query("select last_row(*) from st where ts < %d " % tc) tdSql.checkData(0, 1, None) tdSql.query("select last_row(*) from st") tdSql.checkData(0, 1, None) tc = self.ts + 4 * 3600000 tdSql.query("select last_row(*) from st where ts < %d " % tc) tdSql.checkData(0, 1, None) tc1 = self.ts + 1 * 3600000 tc2 = self.ts + 4 * 3600000 tdSql.query("select last_row(*) from st where ts > %d and ts <= %d" % (tc1, tc2)) tdSql.checkData(0, 1, None) # For table tc = self.ts + 6 * 3600000 tdSql.query("select last_row(*) from %s%d where ts <= %d" % (self.perfix, 1, tc)) tdSql.checkData(0, 1, -1) tc = self.ts + 8 * 3600000 tdSql.query("select last_row(*) from %s%d where ts <= %d" % (self.perfix, 1, tc)) tdSql.checkData(0, 1, None) tdSql.query("select last_row(*) from %s%d" % (self.perfix, 1)) tdSql.checkData(0, 1, None) tc = self.ts + 4 * 3600000 tdSql.query("select last_row(*) from %s%d where ts <= %d" % (self.perfix, 1, tc)) tdSql.checkData(0, 1, None) tc1 = self.ts + 1 * 3600000 tc2 = self.ts + 4 * 3600000 tdSql.query("select last_row(*) from st where ts > %d and ts <= %d" % (tc1, tc2)) tdSql.checkData(0, 1, None) def run(self): tdSql.prepare() print("============== Step1: last_row_cache_0.sim") tdSql.execute("create database test1 cachemodel 'none'") tdSql.execute("use test1") self.insertData() self.executeQueries() self.insertData2() self.executeQueries2() print("============== Step2: alter database test1 cachemodel 'last_row'") tdSql.execute("alter database test1 cachemodel 'last_row'") self.executeQueries2() print("============== Step3: alter database test1 cachemodel 'last_value'") tdSql.execute("alter database test1 cachemodel 'last_value'") self.executeQueries2() print("============== Step4: alter database test1 cachemodel 'both'") tdSql.execute("alter database test1 cachemodel 'both'") self.executeQueries2() print("============== Step5: alter database test1 cachemodel 'none' and restart taosd") tdSql.execute("alter database test1 cachemodel 'none'") self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step6: alter database test1 cachemodel 'last_row' and restart taosd") tdSql.execute("alter database test1 cachemodel 'last_row'") self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step7: alter database test1 cachemodel 'last_value' and restart taosd") tdSql.execute("alter database test1 cachemodel 'last_value'") self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step8: alter database test1 cachemodel 'both' and restart taosd") tdSql.execute("alter database test1 cachemodel 'both'") self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step9: create database test2 cachemodel 'last_row'") tdSql.execute("create database test2 cachemodel 'last_row'") tdSql.execute("use test2") self.insertData() self.executeQueries() self.insertData2() self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step8: alter database test2 cachemodel 'none'") tdSql.execute("alter database test2 cachemodel 'none'") self.executeQueries2() print("============== Step9: alter database test2 cachemodel 'last_row'") tdSql.execute("alter database test2 cachemodel 'last_row'") self.executeQueries2() print("============== Step10: alter database test2 cachemodel 'last_value'") tdSql.execute("alter database test2 cachemodel 'last_value'") self.executeQueries2() print("============== Step11: alter database test2 cachemodel 'both'") tdSql.execute("alter database test2 cachemodel 'both'") self.executeQueries2() print("============== Step12: alter database test2 cachemodel 'none' and restart taosd") tdSql.execute("alter database test2 cachemodel 'none'") self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step13: alter database test2 cachemodel 'last_row' and restart taosd") tdSql.execute("alter database test2 cachemodel 'last_row'") self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step14: alter database test2 cachemodel 'last_value' and restart taosd") tdSql.execute("alter database test2 cachemodel 'last_value'") self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step15: alter database test2 cachemodel 'both' and restart taosd") tdSql.execute("alter database test2 cachemodel 'both'") self.executeQueries2() tdDnodes.stop(1) tdDnodes.start(1) self.executeQueries2() print("============== Step16: select last_row(*) from st group by tbname") tdSql.query("select last_row(*) from st group by tbname") tdSql.checkRows(10) def stop(self): tdSql.close() tdLog.success("%s successfully executed" % __file__) tdCases.addWindows(__file__, TDTestCase()) tdCases.addLinux(__file__, TDTestCase())