Fix the test as a result of 25cc979
parent
76eac23343
commit
6df047f855
|
@ -660,7 +660,7 @@ func (self *ServerSuite) TestContinuousQueryManagement(c *C) {
|
|||
series = collection.GetSeries("continuous queries", c)
|
||||
c.Assert(series.Points, HasLen, 1)
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "id", c), Equals, 1.0)
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "query", c), Equals, "select * from foo into bar")
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "query", c), Equals, `select * from "foo" into bar`)
|
||||
|
||||
// wait for the continuous query to run
|
||||
time.Sleep(time.Second)
|
||||
|
@ -670,9 +670,9 @@ func (self *ServerSuite) TestContinuousQueryManagement(c *C) {
|
|||
series = collection.GetSeries("continuous queries", c)
|
||||
c.Assert(series.Points, HasLen, 2)
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "id", c), Equals, 1.0)
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "query", c), Equals, "select * from foo into bar")
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "query", c), Equals, `select * from "foo" into bar`)
|
||||
c.Assert(series.GetValueForPointAndColumn(1, "id", c), Equals, 2.0)
|
||||
c.Assert(series.GetValueForPointAndColumn(1, "query", c), Equals, "select * from quu into qux")
|
||||
c.Assert(series.GetValueForPointAndColumn(1, "query", c), Equals, `select * from "quu" into qux`)
|
||||
|
||||
self.serverProcesses[0].QueryAsRoot("test_cq", "drop continuous query 1;", false, c)
|
||||
// wait for the continuous query to be dropped
|
||||
|
@ -682,7 +682,7 @@ func (self *ServerSuite) TestContinuousQueryManagement(c *C) {
|
|||
series = collection.GetSeries("continuous queries", c)
|
||||
c.Assert(series.Points, HasLen, 1)
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "id", c), Equals, 2.0)
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "query", c), Equals, "select * from quu into qux")
|
||||
c.Assert(series.GetValueForPointAndColumn(0, "query", c), Equals, `select * from "quu" into qux`)
|
||||
|
||||
self.serverProcesses[0].QueryAsRoot("test_cq", "drop continuous query 2;", false, c)
|
||||
}
|
||||
|
|
|
@ -962,8 +962,8 @@ func (self *SingleServerSuite) TestLoadDatabaseConfig(c *C) {
|
|||
c.Assert(err, IsNil)
|
||||
queries := series[0].Points
|
||||
c.Assert(queries, HasLen, 2)
|
||||
c.Assert(queries[0][2], Equals, "select * from events into events.[id]")
|
||||
c.Assert(queries[1][2], Equals, "select count(value) from events group by time(5m) into 5m.count.events")
|
||||
c.Assert(queries[0][2], Equals, `select * from "events" into events.[id]`)
|
||||
c.Assert(queries[1][2], Equals, `select count(value) from "events" group by time(5m) into 5m.count.events`)
|
||||
}
|
||||
|
||||
func (self *SingleServerSuite) TestSeriesShouldReturnSorted(c *C) {
|
||||
|
|
Loading…
Reference in New Issue