Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Allow integration tests to specify query

pull/1547/head
Philip O'Toole 2015-02-09 19:45:46 -08:00
parent cdeab14201
commit 87bd21d204
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
cmd/influxd/server_integration_test.go
View File

@ -225,13 +225,13 @@ func write(t *testing.T, testname string, nodes cluster, data string) {
// simpleQuery creates a simple database, retention policy, and replicates // simpleQuery creates a simple database, retention policy, and replicates
// the data across all nodes. It then ensures a series of writes and queries are OK. // the data across all nodes. It then ensures a series of writes and queries are OK.
func simpleQuery(t *testing.T, testname string, nodes cluster, expected client.Results) { func simpleQuery(t *testing.T, testname string, nodes cluster, query string, expected client.Results) {
serverURL := nodes[0].url serverURL := nodes[0].url
var results client.Results var results client.Results
// Query the data exists // Query the data exists
t.Log("Query data") t.Log("Query data")
u := urlFor(serverURL, "query", url.Values{"q": []string{`select value from "foo"."bar".cpu`}, "db": []string{"foo"}}) u := urlFor(serverURL, "query", url.Values{"q": []string{query}, "db": []string{"foo"}})
resp, err := http.Get(u.String()) resp, err := http.Get(u.String())
if err != nil { if err != nil {
t.Fatalf("Couldn't query databases: %s", err) t.Fatalf("Couldn't query databases: %s", err)
@ -309,7 +309,7 @@ func Test_ServerSingleIntegration(t *testing.T) {
}, },
} }
simpleQuery(t, testName, nodes, expectedResults) simpleQuery(t, testName, nodes, `select value from "foo"."bar".cpu`, expectedResults)
} }
func Test_Server3NodeIntegration(t *testing.T) { func Test_Server3NodeIntegration(t *testing.T) {
@ -358,7 +358,7 @@ func Test_Server3NodeIntegration(t *testing.T) {
}, },
} }
simpleQuery(t, testName, nodes, expectedResults) simpleQuery(t, testName, nodes, `select value from "foo"."bar".cpu`, expectedResults)
} }
func Test_Server5NodeIntegration(t *testing.T) { func Test_Server5NodeIntegration(t *testing.T) {
@ -408,7 +408,7 @@ func Test_Server5NodeIntegration(t *testing.T) {
}, },
} }
simpleQuery(t, testName, nodes, expectedResults) simpleQuery(t, testName, nodes, `select value from "foo"."bar".cpu`, expectedResults)
} }
func urlFor(u *url.URL, path string, params url.Values) *url.URL { func urlFor(u *url.URL, path string, params url.Values) *url.URL {