Remove IF NOT EXISTS from influxdb output

sparrc · aurrelhebert · commit d84e7dbcdcf3 · 2016-08-09T15:01:15.000+02:00
diff --git a/plugins/outputs/influxdb/influxdb.go b/plugins/outputs/influxdb/influxdb.go
@@ -146,7 +146,7 @@ func (i *InfluxDB) Connect() error {
 func createDatabase(c client.Client, database string) error {
 	// Create Database if it doesn't exist
 	_, err := c.Query(client.Query{
-		Command: fmt.Sprintf("CREATE DATABASE IF NOT EXISTS \"%s\"", database),
+		Command: fmt.Sprintf("CREATE DATABASE \"%s\"", database),
 	})
 	return err
 }

Original file line number	Diff line number	Diff line change
`@@ -146,7 +146,7 @@ func (i *InfluxDB) Connect() error {`
`146`	`146`	`func createDatabase(c client.Client, database string) error {`
`147`	`147`	`// Create Database if it doesn't exist`
`148`	`148`	`_, err := c.Query(client.Query{`
`149`		`- Command: fmt.Sprintf("CREATE DATABASE IF NOT EXISTS \"%s\"", database),`
	`149`	`+ Command: fmt.Sprintf("CREATE DATABASE \"%s\"", database),`
`150`	`150`	`})`
`151`	`151`	`return err`
`152`	`152`	`}`