Golang多表场景下如何设计REST API减少重复代码

你现在的重复代码问题本质是把模板化流程按表硬编码，/tables/{tableName}形式的通用CRUD完全可以落地，按下面步骤改完，后续加新表只需要定义结构体+注册一行元数据就行，不用再写重复的handler和DB函数。

1. 先建表元数据注册表 #

第一步先把所有表的配置统一收敛到全局注册表，路由动态拿到表名后直接从注册表取配置，不用硬编码每张表的路由和逻辑。

import "net/http"

// TableMeta 单表元数据配置
type TableMeta struct {
    TableName    string                     // 数据库实际表名
    Model        interface{}                // 表对应结构体的空实例，比如&TableA{}
    Validator    func(interface{}) error    // 表专属自定义校验，无特殊逻辑留空走通用校验
    AllowMethods []string                   // 表允许的HTTP方法，比如配置只读表只开放GET
    // 后续扩展钩子、权限配置都往这加
}

// 全局表注册表，服务启动时初始化
var tableRegistry = map[string]TableMeta{}

// 注册表示例，后续加新表只需要加这一段
func init() {
    tableRegistry["table-a"] = TableMeta{
        TableName:    "table_a",
        Model:        &types.TableA{},
        AllowMethods: []string{http.MethodGet, http.MethodPost, http.MethodPatch, http.MethodDelete},
    }
    tableRegistry["table-b"] = TableMeta{
        TableName:    "table_b",
        Model:        &types.TableB{},
        AllowMethods: []string{http.MethodGet, http.MethodPost},
    }
}

2. 抽通用Handler层，消灭重复请求处理逻辑 #

你现在每个handler的流程完全固定：解析请求→校验→调DB→返回，一套通用逻辑就能覆盖所有单表场景，不用每张表写四个handler。

import (
    "net/http"
    "reflect"
    "slices"
    // 替换成你自己项目里的路由、工具包路径
)

// RegisterCommonCRUDRoutes 通用CRUD路由注册，全局只需要写一次
func RegisterCommonCRUDRoutes(router *yourRouter.Router) {
    router.Get("/tables/{tableName}", CommonListHandler)
    router.Post("/tables/{tableName}", CommonCreateHandler)
    router.Patch("/tables/{tableName}/{id}", CommonUpdateHandler)
    router.Delete("/tables/{tableName}/{id}", CommonDeleteHandler)
}

// CommonCreateHandler 通用创建接口，所有表POST都走这
func CommonCreateHandler(w http.ResponseWriter, r *http.Request) error {
    // 从路径取表名，替换成你用的路由框架获取路径参数的方法
    tableName := r.PathValue("tableName")
    meta, exist := tableRegistry[tableName]
    if !exist {
        w.WriteHeader(http.StatusNotFound)
        return nil
    }
    // 校验当前表是否允许POST方法
    if !slices.Contains(meta.AllowMethods, http.MethodPost) {
        w.WriteHeader(http.StatusMethodNotAllowed)
        return nil
    }

    // 动态初始化对应表的结构体实例，不用硬编码new(TableA)
    reqInstance := reflect.New(reflect.TypeOf(meta.Model).Elem()).Interface()
    if err := httputils.DecodeJsonBody(r, reqInstance); err != nil {
        return err
    }

    // 参数校验
    if meta.Validator != nil {
        if err := meta.Validator(reqInstance); err != nil {
            return err
        }
    } else {
        if err := validCheck(reqInstance); err != nil {
            return err
        }
    }

    // 调用通用DB插入逻辑
    if err := CommonDBInsert(r.Context(), meta.TableName, reqInstance); err != nil {
        return err
    }

    w.WriteHeader(http.StatusCreated)
    return nil
}
// 其余GET/PATCH/DELETE的handler逻辑和上面完全一致，只是调用对应的通用DB方法

反射的性能损耗在管理后台类CRUD场景下完全可以忽略，真要抠性能可以在注册TableMeta的时候提前把结构体反射类型缓存好，不用每次请求现算。

3. 重构DB层，用Gorm原生能力代替手写SQL #

你现在拿着Gorm手写单表CRUD属于把ORM用成了原生sql.DB，Gorm本身就支持动态传模型做增删改查，根本不用每张表写一套DB函数。

// 注意：DB连接别每次请求都Open！服务启动时初始化一次全局实例复用，Gorm自带连接池管理
var globalDB *gorm.DB

// CommonDBInsert 通用单表插入
func CommonDBInsert(ctx context.Context, tableName string, data interface{}) error {
    tx := globalDB.WithContext(ctx).Table(tableName).Begin()
    defer tx.Rollback()

    // Gorm自动映射结构体字段和表字段，不用自己拼INSERT SQL
    if err := tx.Create(data).Error; err != nil {
        return err
    }

    return tx.Commit().Error
}

// 其余通用DB方法同理：
// CommonDBList 支持分页、排序、条件过滤，从请求query里取参数动态拼Gorm条件即可
// CommonDBUpdate 按主键更新，自动忽略结构体零值字段
// CommonDBDelete 按主键删除，支持软删除
// CommonDBGetByID 按主键查单条

这里必须提一句：你之前代码里每次DB操作都Open连接再defer Close是严重错误写法，并发上来会直接把数据库连接打满，服务直接雪崩，赶紧改成全局连接复用。

4. 特殊逻辑扩展方案 #

抽通用层不代表不能处理个性化需求，遇到某张表有特殊逻辑（比如创建后发通知、操作前校验数据权限、多表关联），直接在TableMeta里加钩子函数就行，不用修改通用流程代码。

// 扩展TableMeta加钩子
type TableMeta struct {
    // 原有字段保留
    BeforeCreate func(ctx context.Context, data interface{}) error
    AfterCreate  func(ctx context.Context, data interface{}) error
    BeforeUpdate func(ctx context.Context, data interface{}) error
    // 其余钩子按需加
}

// 在通用Create逻辑里，插入DB前加钩子调用
if meta.BeforeCreate != nil {
    if err := meta.BeforeCreate(r.Context(), reqInstance); err != nil {
        return err
    }
}
// DB插入完成后调用AfterCreate即可

比如tableA创建后需要生成操作日志，直接在注册tableA元数据的时候写对应的AfterCreate逻辑，其他表不受影响。

落地注意事项 #

• 必须加权限校验：通用接口放开后越权风险很高，在元数据里加权限校验钩子，每个请求先校验当前用户有没有对应表的操作权限再往下走
• 敏感字段屏蔽：用json:"-"标签把结构体里的密码、内部备注这类不允许返回给前端的字段标记好，避免敏感数据泄露
• 别硬套通用逻辑：多表关联、统计聚合这类复杂查询单独写路由就行，通用层只需要覆盖80%的单表CRUD场景，剩下20%特殊需求单独写代码反而效率更高

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