# -*- coding: utf-8 -*- import sys from util.log import * from util.cases import * from util.sql import * class TDTestCase: def init(self, conn, logSql, replicaVar = 1): tdLog.debug("start to execute %s" % __file__) tdSql.init(conn.cursor(), logSql) def run(self): tdSql.prepare() # TSIM: system sh/stop_dnodes.sh # TSIM: # TSIM: system sh/ip.sh -i 1 -s up # TSIM: system sh/deploy.sh -n dnode1 -m 192.168.0.1 -i 192.168.0.1 # TSIM: system sh/cfg.sh -n dnode1 -c walLevel -v 0 # TSIM: system sh/exec.sh -n dnode1 -s start # TSIM: # TSIM: sleep 3000 # TSIM: sql connect # TSIM: # TSIM: $i = 0 # TSIM: $dbPrefix = lm_da_db # TSIM: $tbPrefix = lm_da_tb # TSIM: $db = $dbPrefix . $i # TSIM: $tb = $tbPrefix . $i # TSIM: # TSIM: print =============== step1 tdLog.info('=============== step1') # TSIM: sql create database $db # TSIM: sql use $db # TSIM: # TSIM: sql create table $tb (ts timestamp, speed int) tdLog.info("create table tb0 (ts timestamp, speed int)") tdSql.execute('create table tb0 (ts timestamp, speed int)') # TSIM: sql insert into $tb values ('2017-01-01 08:00:00.001', 1) tdLog.info("insert into tb0 values ('2017-01-01 08:00:00.001', 1)") tdSql.execute("insert into tb0 values ('2017-01-01 08:00:00.001', 1)") # TSIM: sql select ts from $tb tdLog.info('select ts from tb0') tdSql.query('select ts from tb0') # TSIM: if $rows != 1 then tdLog.info('tdSql.checkRow(1)') tdSql.checkRows(1) # TSIM: return -1 # TSIM: endi # TSIM: if $data00 != @17-01-01 08:00:00.001@ then tdLog.info("tdSql.checkData(0, 0, 17-01-01 08:00:00.001)") expectedData = datetime.datetime.strptime( "17-01-01 08:00:00.001", "%y-%m-%d %H:%M:%S.%f") tdSql.checkData(0, 0, expectedData) # TSIM: return -1 # TSIM: endi # TSIM: # TSIM: print =============== step2 tdLog.info('=============== step2') # TSIM: sql insert into $tb values ('2017-08-28 00:23:46.429+ 1a', 2) tdLog.info("insert into tb0 values ('2017-08-28 00:23:46.429+ 1a', 2)") tdSql.execute( "insert into tb0 values ('2017-08-28 00:23:46.429+ 1a', 2)") # TSIM: #sql insert into $tb values ('2017-08-28 00:23:46cd .429', 2) # TSIM: sql select ts from $tb tdLog.info('select ts from tb0') tdSql.query('select ts from tb0') # TSIM: if $rows != 2 then tdLog.info('tdSql.checkRow(2)') tdSql.checkRows(2) # TSIM: return -1 # TSIM: endi # TSIM: # TSIM: print =============== step3 tdLog.info('=============== step3') # TSIM: #sql insert into $tb values ('1970-01-01 08:00:00.000', 3) # TSIM: #sql insert into $tb values ('1970-01-01 08:00:00.000', 3) # TSIM: sql select ts from $tb tdLog.info('select ts from tb0') tdSql.query('select ts from tb0') # TSIM: if $rows != 2 then tdLog.info('tdSql.checkRow(2)') tdSql.checkRows(2) # TSIM: return -1 # TSIM: endi # TSIM: # TSIM: print =============== step4 tdLog.info('=============== step4') # TSIM: sql insert into $tb values(now, 4); tdLog.info("insert into tb0 values(now, 4);") tdSql.execute("insert into tb0 values(now, 4);") # TSIM: sql insert into $tb values(now+1a, 5); tdLog.info("insert into tb0 values(now+1a, 5);") tdSql.execute("insert into tb0 values(now+1a, 5);") # TSIM: sql insert into $tb values(now+1s, 6); tdLog.info("insert into tb0 values(now+1s, 6);") tdSql.execute("insert into tb0 values(now+1s, 6);") # TSIM: sql insert into $tb values(now+1m, 7); tdLog.info("insert into tb0 values(now+1m, 7);") tdSql.execute("insert into tb0 values(now+1m, 7);") # TSIM: sql insert into $tb values(now+1h, 8); tdLog.info("insert into tb0 values(now+1h, 8);") tdSql.execute("insert into tb0 values(now+1h, 8);") # TSIM: sql insert into $tb values(now+1d, 9); tdLog.info("insert into tb0 values(now+1d, 9);") tdSql.execute("insert into tb0 values(now+1d, 9);") # TSIM: sql_error insert into $tb values(now+3w, 10); tdLog.info("insert into tb0 values(now+3w, 10);") tdSql.error("insert into tb0 values(now+3w, 10);") # TSIM: sql_error insert into $tb values(now+1n, 11); tdLog.info("insert into tb0 values(now+1n, 11);") tdSql.error("insert into tb0 values(now+1n, 11);") # TSIM: sql_error insert into $tb values(now+1y, 12); tdLog.info("insert into tb0 values(now+1y, 12);") tdSql.error("insert into tb0 values(now+1y, 12);") # TSIM: # TSIM: print =============== step5 tdLog.info('=============== step5') # TSIM: sql_error insert into $tb values ('9999-12-31 213:59:59.999', # 13) tdLog.info("insert into tb0 values ('9999-12-31 213:59:59.999', 13)") tdSql.error("insert into tb0 values ('9999-12-31 213:59:59.999', 13)") # TSIM: sql select ts from $tb tdLog.info('select ts from tb0') tdSql.query('select ts from tb0') # TSIM: print $rows tdLog.info('$rows') # TSIM: if $rows != 8 then tdLog.info('tdSql.checkRow(8)') tdSql.checkRows(8) # TSIM: return -1 # TSIM: endi # TSIM: # TSIM: print =============== step6 tdLog.info('=============== step6') # TSIM: sql_error insert into $tb values ('9999-12-99 23:59:59.999', # 13) tdLog.info("insert into tb0 values ('9999-12-99 23:59:59.999', 13)") tdSql.error("insert into tb0 values ('9999-12-99 23:59:59.999', 13)") # TSIM: # TSIM: sql select ts from $tb tdLog.info('select ts from tb0') tdSql.query('select ts from tb0') # TSIM: if $rows != 8 then tdLog.info('tdSql.checkRow(8)') tdSql.checkRows(8) # TSIM: return -1 # TSIM: endi # TSIM: # TSIM: print =============== step7 tdLog.info('=============== step7') # TSIM: $i = 1 # TSIM: $tb = $tbPrefix . $i # TSIM: sql create table $tb (ts timestamp, ts2 timestamp) tdLog.info("create table tb1 (ts timestamp, ts2 timestamp)") tdSql.execute('create table tb1 (ts timestamp, ts2 timestamp)') # TSIM: # TSIM: print =============== step8 tdLog.info('=============== step8') # TSIM: sql insert into $tb values (now, now) tdLog.info("insert into tb1 values (now, now)") tdSql.execute("insert into tb1 values (now, now)") # TSIM: sql select * from $tb tdLog.info('select * from tb1') tdSql.query('select * from tb1') # TSIM: if $rows != 1 then tdLog.info('tdSql.checkRow(1)') tdSql.checkRows(1) # TSIM: return -1 # TSIM: endi # TSIM: # TSIM: sql drop database $db tdLog.info('drop database db') tdSql.execute('drop database db') # TSIM: sql select * from information_schema.ins_databases tdLog.info('select * from information_schema.ins_databases') tdSql.query('select * from information_schema.ins_databases') # TSIM: if $rows != 0 then tdLog.info('tdSql.checkRow(0)') tdSql.checkRows(0) # TSIM: return -1 # TSIM: endi # convert end def stop(self): tdSql.close() tdLog.success("%s successfully executed" % __file__) tdCases.addWindows(__file__, TDTestCase()) tdCases.addLinux(__file__, TDTestCase())