dragonflyoss
/
dragonfly
mirror of https://github.com/dragonflyoss/dragonfly.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat: use unscoped delete for resource in manager (#2595) 

Signed-off-by: Gaius <gaius.qi@gmail.com>
This commit is contained in:
Gaius 2023-08-03 15:01:49 +08:00 committed by GitHub
parent a151be1cbb
commit a966c04f66
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
10 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
manager/service/application.go
View File

@ -51,7 +51,7 @@ func (s *service) DestroyApplication(ctx context.Context, id uint) error {
return err
}
if err := s.db.WithContext(ctx).Delete(&models.Application{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.Application{}, id).Error; err != nil {
return err
}

4
manager/service/cluster.go
View File

@ -141,7 +141,7 @@ func (s *service) DestroyCluster(ctx context.Context, id uint) error {
return errors.New("seed peer cluster exists seed peer")
}
if err := tx.WithContext(ctx).Delete(&models.SeedPeerCluster{}, seedPeerCluster.ID).Error; err != nil {
if err := tx.WithContext(ctx).Unscoped().Delete(&models.SeedPeerCluster{}, seedPeerCluster.ID).Error; err != nil {
tx.Rollback()
return err
}
@ -152,7 +152,7 @@ func (s *service) DestroyCluster(ctx context.Context, id uint) error {
return err
}
if err := tx.WithContext(ctx).Delete(&models.SchedulerCluster{}, id).Error; err != nil {
if err := tx.WithContext(ctx).Unscoped().Delete(&models.SchedulerCluster{}, id).Error; err != nil {
tx.Rollback()
return err
}

2
manager/service/config.go
View File

@ -44,7 +44,7 @@ func (s *service) DestroyConfig(ctx context.Context, id uint) error {
return err
}
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.Config{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Unscoped().Delete(&models.Config{}, id).Error; err != nil {
return err
}

2
manager/service/job.go
View File

@ -190,7 +190,7 @@ func (s *service) DestroyJob(ctx context.Context, id uint) error {
return err
}
if err := s.db.WithContext(ctx).Delete(&models.Job{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.Job{}, id).Error; err != nil {
return err
}

2
manager/service/oauth.go
View File

@ -45,7 +45,7 @@ func (s *service) DestroyOauth(ctx context.Context, id uint) error {
return err
}
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.Oauth{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Unscoped().Delete(&models.Oauth{}, id).Error; err != nil {
return err
}

2
manager/service/personal_access_token.go
View File

@ -55,7 +55,7 @@ func (s *service) DestroyPersonalAccessToken(ctx context.Context, id uint) error
return err
}
if err := s.db.WithContext(ctx).Delete(&models.PersonalAccessToken{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.PersonalAccessToken{}, id).Error; err != nil {
return err
}

2
manager/service/scheduler.go
View File

@ -52,7 +52,7 @@ func (s *service) DestroyScheduler(ctx context.Context, id uint) error {
return err
}
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.Scheduler{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Unscoped().Delete(&models.Scheduler{}, id).Error; err != nil {
return err
}

2
manager/service/scheduler_cluster.go
View File

@ -73,7 +73,7 @@ func (s *service) DestroySchedulerCluster(ctx context.Context, id uint) error {
return errors.New("scheduler cluster exists scheduler")
}
if err := s.db.WithContext(ctx).Delete(&models.SchedulerCluster{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.SchedulerCluster{}, id).Error; err != nil {
return err
}

2
manager/service/seed_peer.go
View File

@ -49,7 +49,7 @@ func (s *service) DestroySeedPeer(ctx context.Context, id uint) error {
return err
}
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.SeedPeer{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Unscoped().Delete(&models.SeedPeer{}, id).Error; err != nil {
return err
}

2
manager/service/seed_peer_cluster.go
View File

@ -54,7 +54,7 @@ func (s *service) DestroySeedPeerCluster(ctx context.Context, id uint) error {
return errors.New("seedPeer cluster exists seedPeer")
}
if err := s.db.WithContext(ctx).Delete(&models.SeedPeerCluster{}, id).Error; err != nil {
if err := s.db.WithContext(ctx).Unscoped().Delete(&models.SeedPeerCluster{}, id).Error; err != nil {
return err
}