mirror of
https://github.com/yunionio/cloudpods.git
synced 2026-09-21 14:19:49 +08:00
fix: 平滑迁移数据
This commit is contained in:
@@ -61,6 +61,7 @@ func InitDB() error {
|
||||
ScheduledTaskActivityManager,
|
||||
ExternalProjectManager,
|
||||
CachedimageManager,
|
||||
StoragecachedimageManager,
|
||||
} {
|
||||
err := manager.InitializeData()
|
||||
if err != nil {
|
||||
|
||||
@@ -545,3 +545,22 @@ func (manager *SStoragecachedimageManager) OrderByExtraFields(
|
||||
|
||||
return q, nil
|
||||
}
|
||||
|
||||
func (manager *SStoragecachedimageManager) InitializeData() error {
|
||||
images := []SStoragecachedimage{}
|
||||
q := manager.Query().Equals("status", "ready")
|
||||
err := db.FetchModelObjects(manager, q, &images)
|
||||
if err != nil {
|
||||
return errors.Wrapf(err, "db.FetchModelObjects")
|
||||
}
|
||||
for i := range images {
|
||||
_, err := db.Update(&images[i], func() error {
|
||||
images[i].Status = api.CACHED_IMAGE_STATUS_ACTIVE
|
||||
return nil
|
||||
})
|
||||
if err != nil {
|
||||
return errors.Wrapf(err, "db.Update(%d)", images[i].RowId)
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user