fix: add missing DATABASE

PostHog · Oct 17, 2024 · 790b871 · 790b871
1 parent 3589b84
commit 790b871
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/schemas.go b/schemas.go
@@ -240,7 +240,7 @@ func dbCreateStmt(db *sql.DB, dbName string) (string, error) {
 		return "", fmt.Errorf("getting database %s create statement: %v", dbName, err)
 	}
 
-	return strings.Replace(createStmt, "CREATE", "CREATE IF NOT EXISTS", 1), nil
+	return strings.Replace(createStmt, "CREATE DATABASE", "CREATE DATABASE IF NOT EXISTS", 1), nil
 }
 
 func fetchTableCreateStmt(db *sql.DB, dbName string, tableName string) (string, error) {