diff --git a/sql-migrate/command_common.go b/sql-migrate/command_common.go index e5949c6a..e8c76606 100644 --- a/sql-migrate/command_common.go +++ b/sql-migrate/command_common.go @@ -16,6 +16,7 @@ func ApplyMigrations(dir migrate.MigrationDirection, dryrun bool, limit int) err if err != nil { return err } + defer db.Close() source := migrate.FileMigrationSource{ Dir: env.Dir, diff --git a/sql-migrate/command_redo.go b/sql-migrate/command_redo.go index c69ede84..1aae639d 100644 --- a/sql-migrate/command_redo.go +++ b/sql-migrate/command_redo.go @@ -54,6 +54,7 @@ func (c *RedoCommand) Run(args []string) int { ui.Error(err.Error()) return 1 } + defer db.Close() source := migrate.FileMigrationSource{ Dir: env.Dir, diff --git a/sql-migrate/command_skip.go b/sql-migrate/command_skip.go index cc0ea3d1..5a043eb7 100644 --- a/sql-migrate/command_skip.go +++ b/sql-migrate/command_skip.go @@ -63,6 +63,7 @@ func SkipMigrations(dir migrate.MigrationDirection, dryrun bool, limit int) erro if err != nil { return err } + defer db.Close() source := migrate.FileMigrationSource{ Dir: env.Dir, diff --git a/sql-migrate/command_status.go b/sql-migrate/command_status.go index e3c5d21e..1c1ba5e9 100644 --- a/sql-migrate/command_status.go +++ b/sql-migrate/command_status.go @@ -53,6 +53,7 @@ func (c *StatusCommand) Run(args []string) int { ui.Error(err.Error()) return 1 } + defer db.Close() source := migrate.FileMigrationSource{ Dir: env.Dir,