Skip to content

Commit 31c4c40

Browse files
committed
fix migration
1 parent 6a0e3de commit 31c4c40

File tree

1 file changed

+13
-4
lines changed

1 file changed

+13
-4
lines changed

models/migrations/v46.go

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -27,8 +27,17 @@ func removeOrgnizationWatchRepo(x *xorm.Engine) error {
2727
UserTypeOrganization
2828
)
2929

30-
_, err := x.Join("INNER", "user", "watch.user_id = user.id").
31-
Where("user.`type` = ?", UserTypeOrganization).
32-
Delete(new(Watch))
33-
return err
30+
sess := x.NewSession()
31+
defer sess.Close()
32+
if err := sess.Begin(); err != nil {
33+
return err
34+
}
35+
if _, err := sess.Exec("DELETE FROM watch WHERE id IN (SELECT watch.id FROM watch INNER JOIN user ON watch.user_id = user.id WHERE `user`.`type` = ?)", UserTypeOrganization); err != nil {
36+
return err
37+
}
38+
if _, err := sess.Exec("UPDATE `repository` SET num_watches = (SELECT count(*) FROM watch WHERE `repository`.`id` = watch.repo_id)"); err != nil {
39+
return err
40+
}
41+
42+
return sess.Commit()
3443
}

0 commit comments

Comments
 (0)