heimoshuiyu/gonic
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

auto migrate plays before migration

Browse Source
This commit is contained in:
sentriz
2023-06-30 16:12:42 +01:00
parent 2e879f6f16
commit c5cac5b987
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
db/migrations.go
View File

@@ -519,8 +519,15 @@ func migratePlaylistsToM3U(tx *gorm.DB, ctx MigrationContext) error {
} }
func migratePlayCountToLength(tx *gorm.DB, _ MigrationContext) error { func migratePlayCountToLength(tx *gorm.DB, _ MigrationContext) error {
step := tx.AutoMigrate(
Play{},
)
if err := step.Error; err != nil {
return fmt.Errorf("step auto migrate: %w", err)
}
// As a best guess, we set length played so far as length of album * current count / number of tracks in album // As a best guess, we set length played so far as length of album * current count / number of tracks in album
step := tx.Exec(` step = tx.Exec(`
UPDATE plays SET length= UPDATE plays SET length=
((SELECT SUM(length) FROM tracks WHERE tracks.album_id=plays.album_id)*plays.count/ ((SELECT SUM(length) FROM tracks WHERE tracks.album_id=plays.album_id)*plays.count/
(SELECT COUNT(*) FROM tracks WHERE tracks.album_id=plays.album_id)); (SELECT COUNT(*) FROM tracks WHERE tracks.album_id=plays.album_id));
@@ -528,8 +535,6 @@ func migratePlayCountToLength(tx *gorm.DB, _ MigrationContext) error {
if err := step.Error; err != nil { if err := step.Error; err != nil {
return fmt.Errorf("calculate length: %w", err) return fmt.Errorf("calculate length: %w", err)
} }
return nil return nil
} }