Method autoMigrateTable

plugins/destination/mysql/client/migrate.go:76–90

(ctx context.Context, table *schema.Table, changes []schema.TableColumnChange)

	return true
}
func (c *Client) autoMigrateTable(ctx context.Context, table *schema.Table, changes []schema.TableColumnChange) error {
	for _, change := range changes {
		switch change.Type {
		case schema.TableColumnChangeTypeAdd:
			if err := c.addColumn(ctx, table, table.Columns.Get(change.ColumnName)); err != nil {
				return err
			}
		case schema.TableColumnChangeTypeRemoveUniqueConstraint:
			if err := c.dropIndex(ctx, table, table.Columns.Get(change.ColumnName)); err != nil {
				return err
			}
		}
	}
	return nil
}

func getTables(msgs message.WriteMigrateTables) schema.Tables {
	tables := make(schema.Tables, len(msgs))