go/go-clickhouse
1
0
Fork 0
mirror of https://github.com/uptrace/go-clickhouse.git synced 2025-06-10 23:27:25 +02:00
Code Issues Releases Activity

chore: cleanup

Browse Source
This commit is contained in:
Vladimir Mihailenco 2022-06-27 10:01:23 +03:00
parent d652c12de2
commit 1f1c73b38e
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
chmigrate/migrator.go
View File

@ -29,9 +29,9 @@ func WithLocksTableName(table string) MigratorOption {
// WithMarkAppliedOnSuccess sets the migrator to only mark migrations as applied/unapplied // WithMarkAppliedOnSuccess sets the migrator to only mark migrations as applied/unapplied
// when their up/down is successful // when their up/down is successful
func WithMarkAppliedOnSuccess() MigratorOption { func WithMarkAppliedOnSuccess(enabled bool) MigratorOption {
return func(m *Migrator) { return func(m *Migrator) {
m.markAppliedOnSuccess = true m.markAppliedOnSuccess = enabled
} }
} }
@ -145,10 +145,9 @@ func (m *Migrator) Migrate(ctx context.Context, opts ...MigrationOption) (*Migra
if err != nil { if err != nil {
return nil, err return nil, err
} }
migrations = migrations.Unapplied()
group := &MigrationGroup{ group := new(MigrationGroup)
Migrations: migrations.Unapplied(),
}
if len(group.Migrations) == 0 { if len(group.Migrations) == 0 {
return group, nil return group, nil
} }
@ -164,6 +163,8 @@ func (m *Migrator) Migrate(ctx context.Context, opts ...MigrationOption) (*Migra
} }
} }
group.Migrations = migrations[:i+1]
if !cfg.nop && migration.Up != nil { if !cfg.nop && migration.Up != nil {
if err := migration.Up(ctx, m.db); err != nil { if err := migration.Up(ctx, m.db); err != nil {
return group, err return group, err