Skip to content

Commit 542edc2

Browse files
authored
Some improvements for v156 (#13497)
1 parent beab1dd commit 542edc2

File tree

1 file changed

+12
-7
lines changed

1 file changed

+12
-7
lines changed

models/migrations/v156.go

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ func fixPublisherIDforTagReleases(x *xorm.Engine) error {
5555
var (
5656
repo *Repository
5757
gitRepo *git.Repository
58+
user *User
5859
)
5960
defer func() {
6061
if gitRepo != nil {
@@ -69,7 +70,7 @@ func fixPublisherIDforTagReleases(x *xorm.Engine) error {
6970
}
7071

7172
if err := sess.Limit(batchSize, start).
72-
Where("publisher_id = 0").
73+
Where("publisher_id = 0 OR publisher_id is null").
7374
Asc("repo_id", "id").Where("is_tag=?", true).
7475
Find(&releases); err != nil {
7576
return err
@@ -117,17 +118,21 @@ func fixPublisherIDforTagReleases(x *xorm.Engine) error {
117118
return fmt.Errorf("GetTagCommit: %v", err)
118119
}
119120

120-
u := new(User)
121-
exists, err := sess.Where("email=?", commit.Author.Email).Get(u)
122-
if err != nil {
123-
return err
121+
if user == nil || !strings.EqualFold(user.Email, commit.Author.Email) {
122+
user = new(User)
123+
_, err = sess.Where("email=?", commit.Author.Email).Get(user)
124+
if err != nil {
125+
return err
126+
}
127+
128+
user.Email = commit.Author.Email
124129
}
125130

126-
if !exists {
131+
if user.ID <= 0 {
127132
continue
128133
}
129134

130-
release.PublisherID = u.ID
135+
release.PublisherID = user.ID
131136
if _, err := sess.ID(release.ID).Cols("publisher_id").Update(release); err != nil {
132137
return err
133138
}

0 commit comments

Comments
 (0)