Skip to content

Commit 717add4

Browse files
Rollback session before returning error
1 parent d096b9b commit 717add4

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

models/migrations/v115.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ func renameExistingUserAvatarName(x *xorm.Engine) error {
3737
return fmt.Errorf("select users from id [%d]: %v", start, err)
3838
}
3939
if len(users) == 0 {
40+
_ = sess.Rollback()
4041
break
4142
}
4243

@@ -55,17 +56,20 @@ func renameExistingUserAvatarName(x *xorm.Engine) error {
5556
}
5657

5758
if err := copyAvatar(oldAvatar, newAvatar); err != nil {
59+
_ = sess.Rollback()
5860
return fmt.Errorf("[user: %s] %v", user.LowerName, err)
5961
}
6062

6163
user.Avatar = newAvatar
62-
if _, err := sess.ID(user.ID).Update(user); err != nil {
64+
if _, err := sess.ID(user.ID).Cols("avatar").Update(user); err != nil {
65+
_ = sess.Rollback()
6366
return fmt.Errorf("[user: %s] user table update: %v", user.LowerName, err)
6467
}
6568

6669
deleteList[filepath.Join(setting.AvatarUploadPath, oldAvatar)] = struct{}{}
6770
}
6871
if err := sess.Commit(); err != nil {
72+
_ = sess.Rollback()
6973
return fmt.Errorf("commit session: %v", err)
7074
}
7175
}

0 commit comments

Comments
 (0)