Fix metrics table migration (#29250)
Some checks failed
Some checks failed
This commit is contained in:
parent
b751090b03
commit
9138ef81f6
1 changed files with 17 additions and 16 deletions
|
|
@ -182,23 +182,24 @@ func SetupSchema() error {
|
|||
}
|
||||
}
|
||||
|
||||
rename := func(from, to string) error {
|
||||
if table := new(meter); m.HasColumn(table, from) && !m.HasColumn(table, to) {
|
||||
return m.RenameColumn(table, from, to)
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// meter: split energy direction
|
||||
if old := "val"; m.HasColumn(new(meter), old) {
|
||||
if err := m.RenameColumn(new(meter), old, "import"); err != nil {
|
||||
return err
|
||||
}
|
||||
} else {
|
||||
// meter: split energy direction #2
|
||||
if old := "pos"; m.HasColumn(new(meter), old) {
|
||||
if err := m.RenameColumn(new(meter), old, "import"); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
if old := "neg"; m.HasColumn(new(meter), old) {
|
||||
if err := m.RenameColumn(new(meter), old, "export"); err != nil {
|
||||
return err
|
||||
}
|
||||
}
|
||||
if err := rename("val", "import"); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
// meter: split energy direction #2
|
||||
if err := rename("pos", "import"); err != nil {
|
||||
return err
|
||||
}
|
||||
if err := rename("neg", "export"); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return db.Instance.AutoMigrate(new(meter))
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue