gorm update传入struct对象,零值字段不更新的解决方案
作者：qauzy
这篇文章主要介绍了gorm update传入struct对象,零值字段不更新的解决方案，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
使用gorm的update接口，出现如果字段为零值
则不会生成字段的更新语句
// Update update attributes with callbacks, refer: https://jinzhu.github.io/gorm/crud.html#update
// WARNING when update with struct, GORM will not update fields that with zero value
func (s *DB) Update(attrs ...interface{}) *DB {
return s.Updates(toSearchableMap(attrs...), true)
}
如：
type AA struct {
ID int `gorm:"primary_key" json:" - "` //主键id
Code1 string
Code2 string
}
如果
a :=AA{
ID:1,
Code1:1,
Code2:0
}
则产生的SQL语句将不包含Code2更新语句，
update aa set Code1 =1 where id =1;
出现该问题的原因在于
使用stuct类型对象作为参数时，struct会首先转化为map对象，然后再生成SQL语句，但是转化为map的过程中，对于零值字段是忽略的
// assignUpdatingAttributesCallback assign updating attributes to model
func assignUpdatingAttributesCallback(scope *Scope) {
if attrs, ok := scope.InstanceGet("gorm:update_interface"); ok {
if updateMaps, hasUpdate := scope.updatedAttrsWithValues(attrs); hasUpdate {
scope.InstanceSet("gorm:update_attrs", updateMaps)
} else {
scope.SkipLeft()
}
}
}
func (scope *Scope) updatedAttrsWithValues(value interface{}) (results map[string]interface{}, hasUpdate bool) {
if scope.IndirectValue().Kind() != reflect.Struct {
return convertInterfaceToMap(value, false, scope.db), true
}
results = map[string]interface{}{}
for key, value := range convertInterfaceToMap(value, true, scope.db) {
if field, ok := scope.FieldByName(key); ok && scope.changeableField(field) {
if _, ok := value.(*SqlExpr); ok {
hasUpdate = true
results[field.DBName] = value
} else {
err := field.Set(value)
if field.IsNormal && !field.IsIgnored {
hasUpdate = true
if err == ErrUnaddressable {
results[field.DBName] = value
} else {
results[field.DBName] = field.Field.Interface()
}
}
}
}
}
return
}
func convertInterfaceToMap(values interface{}, withIgnoredField bool, db *DB) map[string]interface{} {
var attrs = map[string]interface{}{}
switch value := values.(type) {
case map[string]interface{}:
return value
case []interface{}:
for _, v := range value {
for key, value := range convertInterfaceToMap(v, withIgnoredField, db) {
attrs[key] = value
}
}
case interface{}:
reflectValue := reflect.ValueOf(values)
switch reflectValue.Kind() {
case reflect.Map:
for _, key := range reflectValue.MapKeys() {
attrs[ToColumnName(key.Interface().(string))] = reflectValue.MapIndex(key).Interface()
}
default:
for _, field := range (&Scope{Value: values, db: db}).Fields() {
if !field.IsBlank && (withIgnoredField || !field.IsIgnored) {
//只有非零值才更新
attrs[field.DBName] = field.Field.Interface()
}
}
}
}
return attrs
}
为了更新零值字段，则需要修改gorm库，我们这里添加一个FORCE标识字段必须更新
type AA struct {
ID int `gorm:"primary_key" json:" - "` //主键id
Code1 string `gorm:"force"`
Code2 string `gorm:"force"`
}
修改Sope的Fields函数，对于有FORCE标签的字段，IsBlank直接设置为fasle
// Fields get value's fields
//通过反射获取field的值
func (scope *Scope) Fields() []*Field {
if scope.fields == nil {
var (
fields []*Field
indirectScopeValue = scope.IndirectValue()
isStruct = indirectScopeValue.Kind() == reflect.Struct
)
// 解析结构体
for _, structField := range scope.GetModelStruct().StructFields {
if isStruct {
fieldValue := indirectScopeValue
// 一般只有一个字段名吧？？？？？
for _, name := range structField.Names {
if fieldValue.Kind() == reflect.Ptr && fieldValue.IsNil() {
// 处理数组
fieldValue.Set(reflect.New(fieldValue.Type().Elem()))
}
//
fieldValue = reflect.Indirect(fieldValue).FieldByName(name)
}
//有force代表强制更新
_, ok := structField.TagSettingsGet("FORCE")
fields = append(fields, &Field{StructField: structField, Field: fieldValue, IsBlank: isBlank(fieldValue) && !ok})
//如果不是struct，则返回空，因为原生没有字段这个说法
} else {
fields = append(fields, &Field{StructField: structField, IsBlank: true})
}
}
scope.fields = &fields
}
return *scope.fields
}
补充：Gorm 自动update操作自动过滤0和 “ “
gorm会自动过滤结构体的0 和" "
type CrmUserTableColumns struct {
Id int64 `gorm:"column:ids"`
Name string `gorm:"column:xxx"`
Account string `gorm:"column:xxx"`
Password string `gorm:"column:xxx"`
State int64 `gorm:"column:state"`
BusinessId int64 `gorm:"column:business_id"`
DepartmentId int64 `gorm:"column:department_id"`
...
}
func (u *CrmUserTableColumns) TableName() string {
return "crm_user"
}
field := map[string]interface{}{
"business_id": data.BusinessId,
"state": data.State,
"department_id": data.DepartmentId,
}
whereSql = "account = ?"
updates := dbMasterClient.
//Debug().
Model(&CrmUserTableColumns{}).
Where(whereSql, whereCase).
Updates(field)
RowsAffected = updates.RowsAffected
return
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。如有错误或未考虑完全的地方，望不吝赐教。