Fix MySQL drop database query.

dogmatiq · Dec 4, 2020 · fada933 · fada933
1 parent 1b45a45
commit fada933
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/open_test.go b/open_test.go
@@ -24,6 +24,9 @@ var _ = Describe("func Open()", func() {
 
 			err = db.PingContext(ctx)
 			Expect(err).ShouldNot(HaveOccurred())
+
+			err = close()
+			Expect(err).ShouldNot(HaveOccurred())
 		},
 		entry(MySQLDriver, MySQL),
 	)

diff --git a/productmysql.go b/productmysql.go
@@ -21,7 +21,7 @@ func (mysqlCompatable) DropDatabase(
 	db *sql.DB,
 	name string,
 ) error {
-	_, err := db.ExecContext(ctx, "CREATE DATABASE IF EXISTS `"+name+"`")
+	_, err := db.ExecContext(ctx, "DROP DATABASE IF EXISTS `"+name+"`")
 	return err
 }