localhots
/
empact
1
0
Fork 0
Code Releases Activity

Make use of insert ignore statement

This commit is contained in:
Gregory Eremin 2015-03-21 21:16:09 +07:00
parent a87fecf1d3
commit 6a35467c1e
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
db/members.go
View File

@ -27,9 +27,8 @@ func SaveOrgMembers(orgID int, members []int) {
values = append(values, fmt.Sprintf("(%d, %d)", orgID, id)) values = append(values, fmt.Sprintf("(%d, %d)", orgID, id))
} }
tx.MustExec(` tx.MustExec(`
insert into org_members (org_id, user_id) insert ignore into org_members (org_id, user_id)
values ` + strings.Join(values, ", ") + ` values ` + strings.Join(values, ", ") + `
on duplicate key update org_id = org_id
`) `)
if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {
@ -58,9 +57,8 @@ func SaveTeamMembers(orgID, teamID int, members []int) {
values = append(values, fmt.Sprintf("(%d, %d, %d)", orgID, teamID, id)) values = append(values, fmt.Sprintf("(%d, %d, %d)", orgID, teamID, id))
} }
tx.MustExec(` tx.MustExec(`
insert into team_members (org_id, team_id, user_id) insert ignore into team_members (org_id, team_id, user_id)
values ` + strings.Join(values, ", ") + ` values ` + strings.Join(values, ", ") + `
on duplicate key update org_id = org_id
`) `)
if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {
@ -89,9 +87,8 @@ func SaveTeamRepos(orgID, teamID int, repos []int) {
values = append(values, fmt.Sprintf("(%d, %d, %d)", orgID, teamID, id)) values = append(values, fmt.Sprintf("(%d, %d, %d)", orgID, teamID, id))
} }
tx.MustExec(` tx.MustExec(`
insert into team_repos (org_id, team_id, repo_id) insert ignore into team_repos (org_id, team_id, repo_id)
values ` + strings.Join(values, ", ") + ` values ` + strings.Join(values, ", ") + `
on duplicate key update org_id = org_id
`) `)
if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {