tdLog.info("restart taosd to ensure that the data falls into the disk")
# tdDnodes.stop(1)
# tdDnodes.start(1)
...
...
@@ -94,18 +94,18 @@ class TDTestCase:
paraDict['vgroups']=self.vgroups
paraDict['ctbNum']=self.ctbNum
paraDict['rowsPerTbl']=self.rowsPerTbl
topicNameList=['topic1']
expectRowsList=[]
tmqCom.initConsumerTable()
tdLog.info("create topics from stb with filter")
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+9379)
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+9379)
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
...
...
@@ -174,7 +174,7 @@ class TDTestCase:
sqlString="create topic %s as %s"%(topicNameList[0],queryString)
tdLog.info("restart taosd to ensure that the data falls into the disk")
# tdDnodes.stop(1)
# tdDnodes.starttaosd(1)
...
...
@@ -94,11 +94,11 @@ class TDTestCase:
paraDict['vgroups']=self.vgroups
paraDict['ctbNum']=self.ctbNum
paraDict['rowsPerTbl']=self.rowsPerTbl
topicNameList=['topic1']
expectRowsList=[]
tmqCom.initConsumerTable()
tdLog.info("create topics from stb with filter")
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+math.ceil(self.rowsPerTbl/5))
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
...
...
@@ -106,7 +106,7 @@ class TDTestCase:
sqlString="create topic %s as %s"%(topicNameList[0],queryString)
tdLog.info("create topic sql: %s"%sqlString)
tdSql.execute(sqlString)
tdSql.query(queryString)
tdSql.query(queryString)
expectRowsList.append(tdSql.getRows())
# init consume info, and start tmq_sim, then check consume result
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+math.ceil(self.rowsPerTbl/5))
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
...
...
@@ -175,7 +175,7 @@ class TDTestCase:
sqlString="create topic %s as %s"%(topicNameList[0],queryString)
tdLog.info("create topic sql: %s"%sqlString)
tdSql.execute(sqlString)
tdSql.query(queryString)
tdSql.query(queryString)
expectRowsList.append(tdSql.getRows())
totalRowsInserted=expectRowsList[0]
tdLog.info("select result rows: %d"%totalRowsInserted)
tdLog.info("restart taosd to ensure that the data falls into the disk")
# tdDnodes.stop(1)
# tdDnodes.start(1)
...
...
@@ -93,11 +93,11 @@ class TDTestCase:
paraDict['vgroups']=self.vgroups
paraDict['ctbNum']=self.ctbNum
paraDict['rowsPerTbl']=self.rowsPerTbl
topicNameList=['topic1']
expectRowsList=[]
tmqCom.initConsumerTable()
tdLog.info("create topics from stb with filter")
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 == 0) and (ts >= %d) and (t4 like 'shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+math.ceil(self.rowsPerTbl/5))
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
...
...
@@ -105,7 +105,7 @@ class TDTestCase:
sqlString="create topic %s as %s"%(topicNameList[0],queryString)
tdLog.info("create topic sql: %s"%sqlString)
tdSql.execute(sqlString)
tdSql.query(queryString)
tdSql.query(queryString)
expectRowsList.append(tdSql.getRows())
totalRowsInserted=expectRowsList[0]
tdLog.info("select result rows: %d"%totalRowsInserted)
queryString="select ts, acos(c1), ceil(pow(c1,3)) from %s.%s where (sin(c2) >= 0) and (c1 %% 4 != 0) and (ts+1a >= %d) and (t4 like '%%shanghai')"%(paraDict['dbName'],paraDict['stbName'],paraDict["startTs"]+math.ceil(self.rowsPerTbl/10))
# queryString = "select * from %s.%s"%(paraDict['dbName'], paraDict['stbName'])
...
...
@@ -179,7 +179,7 @@ class TDTestCase:
sqlString="create topic %s as %s"%(topicNameList[0],queryString)
tdLog.info("create topic sql: %s"%sqlString)
tdSql.execute(sqlString)
tdSql.query(queryString)
tdSql.query(queryString)
expectRowsList.append(tdSql.getRows())
totalRowsInserted=expectRowsList[0]
tdLog.info("select result rows: %d"%totalRowsInserted)