Go新手求问：如何实现类似PHP框架的数据库对象自动CRUD？

你之前接触的PHP框架应该是类似Laravel Eloquent或者Yii ActiveRecord这类ORM（对象关系映射）工具，它们通过模型类封装数据库操作，无需手动编写SQL。在Go里要实现同样功能，有两种常见方式：用成熟的ORM库，或者手动通过反射实现简单的自动SQL生成。

一、用ORM库快速实现（生产环境推荐） #

Go生态里最流行的ORM是GORM，它能直接满足需求，代码简洁且处理了大部分数据库操作细节。

1. 定义带ORM标签的结构体 #

给Patients结构体添加GORM标签，指定主键和表名（GORM默认会把结构体名复数化作为表名，这里可显式指定）：

import "gorm.io/gorm"

type Patients struct {
    ID              int    `gorm:"primaryKey"` // 标记为主键
    Name            string 
    Image           string    
}

// 显式指定数据库表名
func (Patients) TableName() string {
    return "patients"
}

2. 实现Insert和Update方法 #

直接借助GORM内置方法，无需自己写SQL：

// Insert：插入一条患者记录
func (p *Patients) Insert(db *gorm.DB) error {
    return db.Create(p).Error
}

// Update：根据ID更新患者信息
func (p *Patients) Update(db *gorm.DB) error {
    // Model指定更新模型，Updates自动更新非零值字段
    return db.Model(p).Updates(p).Error
}

调用示例：

// 初始化GORM连接（提前完成）
db, err := gorm.Open(postgres.Open(dsn), &gorm.Config{})
if err != nil {
    panic(err)
}

// 插入操作
newPatient := Patients{Name: "张三", Image: "avatar.jpg"}
err = newPatient.Insert(db)

// 更新操作
updatePatient := Patients{ID: 1, Name: "李四", Image: "new_avatar.jpg"}
err = updatePatient.Update(db)

二、手动实现自动SQL生成（理解原理） #

如果不想依赖ORM库，可以通过Go的反射机制遍历结构体字段生成SQL语句，但这种方式需要自己处理很多边界情况（比如空值、字段类型适配等）。

1. 手动实现Insert方法 #

import (
    "context"
    "database/sql"
    "fmt"
    "reflect"
    "strings"
    "strconv"
)

// Insert：自动生成插入SQL并执行
func (p *Patients) Insert(ctx context.Context, db *sql.DB) error {
    t := reflect.TypeOf(*p)
    v := reflect.ValueOf(*p)

    var columns []string
    var placeholders []string
    var values []interface{}

    // 遍历结构体字段，跳过自增ID（假设ID为0时表示未生成）
    for i := 0; i < t.NumField(); i++ {
        field := t.Field(i)
        fieldVal := v.Field(i).Interface()

        if field.Name == "ID" && fieldVal == 0 {
            continue
        }

        columns = append(columns, strings.ToLower(field.Name))
        placeholders = append(placeholders, "$"+strconv.Itoa(len(placeholders)+1))
        values = append(values, fieldVal)
    }

    // 拼接SQL语句
    sqlStmt := fmt.Sprintf(
        "INSERT INTO patients (%s) VALUES (%s)",
        strings.Join(columns, ", "),
        strings.Join(placeholders, ", "),
    )

    _, err := db.ExecContext(ctx, sqlStmt, values...)
    return err
}

2. 手动实现Update方法 #

// Update：根据ID自动生成更新SQL并执行
func (p *Patients) Update(ctx context.Context, db *sql.DB) error {
    t := reflect.TypeOf(*p)
    v := reflect.ValueOf(*p)

    var setClauses []string
    var values []interface{}
    var idVal interface{}

    // 遍历字段生成SET子句，同时提取ID值
    for i := 0; i < t.NumField(); i++ {
        field := t.Field(i)
        fieldVal := v.Field(i).Interface()

        if field.Name == "ID" {
            idVal = fieldVal
            continue
        }

        setClauses = append(setClauses, fmt.Sprintf(
            "%s = $%d",
            strings.ToLower(field.Name),
            len(setClauses)+1,
        ))
        values = append(values, fieldVal)
    }

    // 把ID添加到参数列表末尾
    values = append(values, idVal)
    // 拼接SQL语句
    sqlStmt := fmt.Sprintf(
        "UPDATE patients SET %s WHERE id = $%d",
        strings.Join(setClauses, ", "),
        len(values),
    )

    _, err := db.ExecContext(ctx, sqlStmt, values...)
    return err
}

注意事项 #

手动实现方式虽然灵活，但需要处理字段类型转换、空值判断、不同数据库占位符差异等问题，适合学习原理，生产环境还是推荐用成熟ORM库避免重复造轮子。

内容的提问来源于stack exchange，提问作者mevoker659