coder
diff --git a/‎coderd/coderdtest/coderdtest.go
Lines changed: 1 addition & 1 deletion b/‎coderd/coderdtest/coderdtest.go
Lines changed: 1 addition & 1 deletion
diff --git a/‎database/dump.sql
Lines changed: 95 additions & 95 deletions b/‎database/dump.sql
Lines changed: 95 additions & 95 deletions
diff --git a/‎database/dump/main.go
Lines changed: 1 addition & 1 deletion b/‎database/dump/main.go
Lines changed: 1 addition & 1 deletion
diff --git a/‎database/migrate.go
Lines changed: 39 additions & 5 deletions b/‎database/migrate.go
Lines changed: 39 additions & 5 deletions
@@ -61,7 +61,7 @@ func New(t *testing.T, options *Options) *codersdk.Client {
 		t.Cleanup(func() {
 			_ = sqlDB.Close()
 		})
-		err = database.Migrate(sqlDB)
+		err = database.MigrateUp(sqlDB)
 		require.NoError(t, err)
 		db = database.New(sqlDB)
 
 
@@ -24,7 +24,7 @@ func main() {
 	if err != nil {
 		panic(err)
 	}
-	err = database.Migrate(db)
+	err = database.MigrateUp(db)
 	if err != nil {
 		panic(err)
 	}
 
@@ -14,27 +14,61 @@ import (
 //go:embed migrations/*.sql
 var migrations embed.FS
 
-// Migrate runs SQL migrations to ensure the database schema is up-to-date.
-func Migrate(db *sql.DB) error {
+func migrateSetup(db *sql.DB) (*migrate.Migrate, error) {
 	sourceDriver, err := iofs.New(migrations, "migrations")
 	if err != nil {
-		return xerrors.Errorf("create iofs: %w", err)
+		return nil, xerrors.Errorf("create iofs: %w", err)
 	}
+
 	dbDriver, err := postgres.WithInstance(db, &postgres.Config{})
 	if err != nil {
-		return xerrors.Errorf("wrap postgres connection: %w", err)
+		return nil, xerrors.Errorf("wrap postgres connection: %w", err)
 	}
+
 	m, err := migrate.NewWithInstance("", sourceDriver, "", dbDriver)
 	if err != nil {
-		return xerrors.Errorf("migrate: %w", err)
+		return nil, xerrors.Errorf("new migrate instance: %w", err)
+	}
+
+	return m, nil
+}
+
+// Migrate runs SQL migrations to ensure the database schema is up-to-date.
+func MigrateUp(db *sql.DB) error {
+	m, err := migrateSetup(db)
+	if err != nil {
+		return xerrors.Errorf("migrate setup: %w", err)
 	}
+
 	err = m.Up()
 	if err != nil {
 		if errors.Is(err, migrate.ErrNoChange) {
 			// It's OK if no changes happened!
 			return nil
 		}
+
 		return xerrors.Errorf("up: %w", err)
 	}
+
+	return nil
+}
+
+// Migrate runs SQL migrations to ensure the database schema is up-to-date.
+func MigrateDown(db *sql.DB) error {
+	m, err := migrateSetup(db)
+	if err != nil {
+		return xerrors.Errorf("migrate setup: %w", err)
+	}
+
+	err = m.Down()
+	if err != nil {
+		if errors.Is(err, migrate.ErrNoChange) {
+			// It's OK if no changes happened!
+			return nil
+		}
+
+		return xerrors.Errorf("down: %w", err)
+	}
+
 	return nil
 }
Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,7 @@ func main() {`
`24`	`24`	`if err != nil {`
`25`	`25`	`panic(err)`
`26`	`26`	`}`
`27`		`- err = database.Migrate(db)`
	`27`	`+ err = database.MigrateUp(db)`
`28`	`28`	`if err != nil {`
`29`	`29`	`panic(err)`
`30`	`30`	`}`