更新有效载荷中包含的列

Question

我有一个到 mysql 表的结构映射，如下所示，并且想要更新在 PUT 请求有效负载中发送的字段

type Notification struct {
 Id                 int64     `json:"id"`
 Type               NotificationType
 Subject            string    `json:"confidence"`
 Body               string    `json:"body"`
 CreatedDate        time.Time `json:"created_dt"`
 CreatedBy          int64     `json:"created_by"`
 ParentNotification int64     `json:"parent_id"`
 IsExpired          bool      `json:"expired"`
}

目前我要求所有字段都包含在有效负载中，即使数据没有更改，并使用带有 db.Exec(query) 语句的查询更新所有列。

有什么方法可以让客户只包含在有效负载中更改的字段并仅更新这些字段？

{
 "body" : "new body"
 "subject" : "new subject"
}

我正在数据库端使用以下包。

"database/sql"
_ "github.com/go-sql-driver/mysql"

Answer 1

一种做你想做的事情的方法，即让客户端只发送他们想要更改的数据，是每个“db table”类型都有一个额外的“param”类型。因此，例如，给定您的 Notification 类型，您将有一个 NotificationParams 类型，如下所示：

type NotificationParams struct {
    Id      int64 `json:"id"`
    // use pointers so that a field that is not present in the json
    // will result in a nil pointer value, which tells you that no
    // update is needed for that column, it also allows the client
    // to send an empty string if they want to delete the content of
    // some column, e.g. Body.
    Type    *NotificationType
    Subject *string `json:"confidence"`
    Body    *string `json:"body"`
    // and other fields that you want to allow the client change
}

然后在您的处理程序或任何您可以按照以下方式执行操作的地方：

params := &NotificationParams{} // unmarshal from json
notif := &Notification{} // read from db using params.Id

// change only those fields that were provided
if params.Type != nil {
    notif.Type = *params.Type
}
if params.Subject != nil {
    notif.Subject = *params.Subject
}
if params.Body != nil {
    notif.Body = *params.Body
}

// do some validation...

// if ok save notif using mysql UPDATE

---

更新

如果您想避免编写大量 if 语句，您可以编写几个“setter”或“apply”函数（您更喜欢哪个名称）来为您执行此操作，每种类型一个你想支持的，例如一种用于string，一种用于time.Time，等等。

以这个函数为例：

// The variadic list of functions can be used to transform (think
// sanitization, normalization, etc.) the value before setting
// it to the dst pointer.
func ApplyStr(dst, src *string, fns ...func(string) string) {
    if src != nil {
        s := *src
        for _, fn := range fns {
            s = fn(s)
        }

        *dst = s
    }
}

然后你会使用像this playground example 这样的函数。

Answer 2

以下方法使用GORM库在接收到payload后持久化你的数据：

package main

import (
    "github.com/jinzhu/gorm"
    _ "github.com/jinzhu/gorm/dialects/mysql"
    "time"
)


type NotificationType struct {
    gorm.Model

}

type Notification struct {
    gorm.Model
    Id                 int64     `json:"id"`
    Type               NotificationType
    Subject            string    `json:"confidence"`
    Body               string    `json:"body"`
    CreatedDate        time.Time `json:"created_dt"`
    CreatedBy          int64     `json:"created_by"`
    ParentNotification int64     `json:"parent_id"`
    IsExpired          bool      `json:"expired"`
}

func main() {
    //your handler code to receive and decode payload from client


    //save data to database
    db, err := gorm.Open("mysql", "user:password@/dbname?charset=utf8&parseTime=True&loc=Local")
    if err != nil {
        panic("failed to connect database")
    }
    defer db.Close()

    // Migrate the schema
    db.AutoMigrate(&Notification{})

    // Read
    var Notification notification
    db.First(&notification, 1) // find notification with id 1 , the id from your payload

    // Update the table from notification object
    db.Save(&notification)
}