Use 'CREATE DATABASE IF NOT EXISTS' syntax

closes #376
influxdata · Nov 18, 2015 · 03a6f28 · 03a6f28
1 parent 19e5d97
commit 03a6f28
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/outputs/influxdb/influxdb.go b/outputs/influxdb/influxdb.go
@@ -97,10 +97,10 @@ func (i *InfluxDB) Connect() error {
 
 			// Create Database if it doesn't exist
 			_, e := c.Query(client.Query{
-				Command: fmt.Sprintf("CREATE DATABASE %s", i.Database),
+				Command: fmt.Sprintf("CREATE DATABASE IF NOT EXISTS %s", i.Database),
 			})
 
-			if e != nil && !strings.Contains(e.Error(), "database already exists") {
+			if e != nil {
 				log.Println("Database creation failed: " + e.Error())
 			}