Add dump column in schema_migration and sync command line argument

README.md

@@ -119,6 +119,7 @@ dbmate drop      # drop the database
 dbmate migrate   # run any pending migrations
 dbmate rollback  # roll back the most recent migration
 dbmate down      # alias for rollback
+dbmate sync      # sync the database to most recent migration or downgrade the database in case the available file migrations are older
 dbmate status    # show the status of all migrations (supports --exit-code and --quiet)
 dbmate dump      # write the database schema.sql file
 dbmate load      # load schema.sql file to the database

main.go

@@ -67,6 +67,11 @@ func NewApp() *cli.App {
 			Value:   cli.NewStringSlice(defaultDB.MigrationsDir[0]),
 			Usage:   "specify the directory containing migration files",
 		},
+		&cli.StringFlag{
+			Name:    "migrations-url",
+			EnvVars: []string{"DBMATE_MIGRATIONS_URL"},
+			Usage:   "specify a database URL to read migrations from (sync only). If set, sync reads migrations from this DB instead of filesystem",
+		},
 		&cli.StringFlag{
 			Name:    "migrations-table",
 			EnvVars: []string{"DBMATE_MIGRATIONS_TABLE"},
@@ -183,6 +188,28 @@ func NewApp() *cli.App {
 				return db.Rollback()
 			}),
 		},
+		{
+			Name:  "sync",
+			Usage: "Strips eventual later migrations or migrate up in case the database is older. Uses filesystem migrations by default; if --migrations-url is set, reads migrations from that database.",
+			Flags: []cli.Flag{
+				&cli.BoolFlag{
+					Name:    "verbose",
+					Aliases: []string{"v"},
+					EnvVars: []string{"DBMATE_VERBOSE"},
+					Usage:   "print the result of each statement execution",
+				},
+			},
+			Action: action(func(db *dbmate.DB, c *cli.Context) error {
+				db.Verbose = c.Bool("verbose")
+
+				// check ambiguità
+				if db.MigrationsUrl != "" && c.IsSet("migrations-dir") {
+					return fmt.Errorf("cannot use both --migrations-url and --migrations-dir with sync: choose one source")
+				}
+
+				return db.Synchronize()
+			}),
+		},
 		{
 			Name:  "status",
 			Usage: "List applied and pending migrations",
@@ -298,10 +325,16 @@ func action(f func(*dbmate.DB, *cli.Context) error) cli.ActionFunc {
 		db.SchemaFile = c.String("schema-file")
 		db.WaitBefore = c.Bool("wait")
 		waitTimeout := c.Duration("wait-timeout")
+		db.MigrationsUrl = c.String("migrations-url") // ✅ AGGIUNTO
+
 		if waitTimeout != 0 {
 			db.WaitTimeout = waitTimeout
 		}
 
+		if c.String("migrations-url") != "" && c.Command.Name != "sync" {
+			return fmt.Errorf("--migrations-url is supported only for the sync command")
+		}
+
 		return f(db, c)
 	}
 }