Fix unnecessary duplicated primary condition when using Save, close #3330

This commit is contained in:
Jinzhu 2020-08-29 23:02:19 +08:00
parent 677edf9d9e
commit 59586dcd31
2 changed files with 26 additions and 7 deletions

View File

@ -32,17 +32,12 @@ func (db *DB) Save(value interface{}) (tx *DB) {
tx.callbacks.Create().Execute(tx) tx.callbacks.Create().Execute(tx)
case reflect.Struct: case reflect.Struct:
if err := tx.Statement.Parse(value); err == nil && tx.Statement.Schema != nil { if err := tx.Statement.Parse(value); err == nil && tx.Statement.Schema != nil {
where := clause.Where{Exprs: make([]clause.Expression, len(tx.Statement.Schema.PrimaryFields))} for _, pf := range tx.Statement.Schema.PrimaryFields {
for idx, pf := range tx.Statement.Schema.PrimaryFields { if _, isZero := pf.ValueOf(reflectValue); isZero {
if pv, isZero := pf.ValueOf(reflectValue); isZero {
tx.callbacks.Create().Execute(tx) tx.callbacks.Create().Execute(tx)
return return
} else {
where.Exprs[idx] = clause.Eq{Column: pf.DBName, Value: pv}
} }
} }
tx.Statement.AddClause(where)
} }
fallthrough fallthrough

View File

@ -2,6 +2,7 @@ package tests_test
import ( import (
"errors" "errors"
"regexp"
"sort" "sort"
"strings" "strings"
"testing" "testing"
@ -586,3 +587,26 @@ func TestUpdateFromSubQuery(t *testing.T) {
t.Errorf("name should be %v, but got %v", user.Company.Name, result.Name) t.Errorf("name should be %v, but got %v", user.Company.Name, result.Name)
} }
} }
func TestSave(t *testing.T) {
user := *GetUser("save", Config{})
DB.Create(&user)
if err := DB.First(&User{}, "name = ?", "save").Error; err != nil {
t.Fatalf("failed to find created user")
}
user.Name = "save2"
DB.Save(&user)
var result User
if err := DB.First(&result, "name = ?", "save2").Error; err != nil || result.ID != user.ID {
t.Fatalf("failed to find updated user")
}
dryDB := DB.Session(&gorm.Session{DryRun: true})
stmt := dryDB.Save(&user).Statement
if !regexp.MustCompile("WHERE .id. = [^ ]+$").MatchString(stmt.SQL.String()) {
t.Fatalf("invalid updating SQL, got %v", stmt.SQL.String())
}
}