sql/internal/sqlx: pass diff options to drivers

cmd/atlas/internal/cmdapi/cmdapi.go

@@ -105,6 +105,11 @@ type (
 	AbortError struct {
 		Err error
 	}
+	// Aborter allows errors to signal if the error is an abort error.
+	Aborter interface {
+		error
+		IsAbort()
+	}
 )
 
 func (e *FormattedError) Error() string { return e.Err.Error() }
@@ -129,10 +134,14 @@ func (e *AbortError) FormatError(cmd *cobra.Command) {
 
 // RunE wraps the command cobra.Command.RunE function with additional postrun logic.
 func RunE(f func(*cobra.Command, []string) error) func(*cobra.Command, []string) error {
-	return func(cmd *cobra.Command, args []string) error {
-		err := f(cmd, args)
-		if ef, ok := err.(ErrorFormatter); ok {
-			ef.FormatError(cmd)
+	return func(cmd *cobra.Command, args []string) (err error) {
+		if err = f(cmd, args); err != nil {
+			if err1 := (Aborter)(nil); errors.As(err, &err1) {
+				err = &AbortError{Err: err}
+			}
+			if ef, ok := err.(ErrorFormatter); ok {
+				ef.FormatError(cmd)
+			}
 		}
 		return err
 	}

sql/internal/sqlx/diff.go

@@ -37,7 +37,7 @@ type (
 
 		// SchemaObjectDiff returns a changeset for migrating schema objects from
 		// one state to the other. For example, changing schema custom types.
-		SchemaObjectDiff(from, to *schema.Schema) ([]schema.Change, error)
+		SchemaObjectDiff(from, to *schema.Schema, _ *schema.DiffOptions) ([]schema.Change, error)
 
 		// TableAttrDiff returns a changeset for migrating table attributes from
 		// one state to the other. For example, dropping or adding a `CHECK` constraint.
@@ -196,7 +196,7 @@ func (d *Diff) schemaDiff(from, to *schema.Schema, opts *schema.DiffOptions) ([]
 		})
 	}
 	// Add, drop or modify objects.
-	change, err := d.SchemaObjectDiff(from, to)
+	change, err := d.SchemaObjectDiff(from, to, opts)
 	if err != nil {
 		return nil, err
 	}

sql/mysql/diff.go

@@ -61,7 +61,7 @@ func (*diff) RealmObjectDiff(_, _ *schema.Realm) ([]schema.Change, error) {
 
 // SchemaObjectDiff returns a changeset for migrating schema objects from
 // one state to the other.
-func (*diff) SchemaObjectDiff(_, _ *schema.Schema) ([]schema.Change, error) {
+func (*diff) SchemaObjectDiff(_, _ *schema.Schema, _ *schema.DiffOptions) ([]schema.Change, error) {
 	return nil, nil
 }
 

sql/postgres/driver_oss.go

@@ -204,7 +204,7 @@ func (*diff) RealmObjectDiff(_, _ *schema.Realm) ([]schema.Change, error) {
 
 // SchemaObjectDiff returns a changeset for migrating schema objects from
 // one state to the other.
-func (*diff) SchemaObjectDiff(from, to *schema.Schema) ([]schema.Change, error) {
+func (*diff) SchemaObjectDiff(from, to *schema.Schema, _ *schema.DiffOptions) ([]schema.Change, error) {
 	var changes []schema.Change
 	// Drop or modify enums.
 	for _, o1 := range from.Objects {

sql/sqlite/diff.go

@@ -36,7 +36,7 @@ func (*diff) RealmObjectDiff(_, _ *schema.Realm) ([]schema.Change, error) {
 
 // SchemaObjectDiff returns a changeset for migrating schema objects from
 // one state to the other.
-func (*diff) SchemaObjectDiff(_, _ *schema.Schema) ([]schema.Change, error) {
+func (*diff) SchemaObjectDiff(_, _ *schema.Schema, _ *schema.DiffOptions) ([]schema.Change, error) {
 	return nil, nil
 }