Go语言微服务框架 - 8.Gormer迭代-定制专属的ORM代码生成工具

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS PostgreSQL,高可用系列 2核4GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: 我们对比一下GORM库提供的`gorm.Model`,它在新增、修改时,会自动修改对应的时间,这个可以帮我们减少很多重复性的代码编写。这里,我就针对现有的gormer工具做一个示例性的迭代。

在上一篇,我们写一个gormer工具库,支持了简单的CRUD。但是,在实际的开发场景中,这部分的功能仍显得非常单薄。

例如,我们对比一下GORM库提供的gorm.Model,它在新增、修改时,会自动修改对应的时间,这个可以帮我们减少很多重复性的代码编写。这里,我就针对现有的gormer工具做一个示例性的迭代。

v0.5.2:Gormer迭代-定制更智能的代码生成工具

项目链接 https://github.com/Junedayday/micro_web_service/tree/v0.5.2

目标

生成一套智能化的Dao层代码,兼容软删除和硬删除。

这里提一下软删除的概念,就是指在数据库中用某个字段标记为删除,但这行数据仍存在;而硬删除就是直接删除整条数据。

软删除虽然增加了一定的复杂度,但带来的收益很大。最直接的好处就是能保留记录,方便查原始记录。

关键技术点

  1. gormer.yaml的文件
  2. 模板文件的修改
  3. 核心结构体梳理
  4. API调用示例

目录构造

为了方便理解,我简化对应的目录结构

--- micro_web_service            项目目录
    |-- gen                            从idl文件夹中生成的文件,不可手动修改
       |-- idl                             对应idl文件夹
          |-- demo                             对应idl/demo服务,包括基础结构、HTTP接口、gRPC接口
            |-- order                            对应idl/order服务,同上
    |-- idl                            原始的idl定义
       |-- demo                            业务package定义,protobuffer的原始定义
       |-- order                           业务order定义,同时干
    |-- internal                       项目的内部代码,不对外暴露
       |-- config                          配置相关的文件夹,viper的相关加载逻辑
       |-- dao                             Data Access Object层,是model层的实现
       |-- gormer                          从pkg/gormer中生成的相关代码,不允许更改
       |-- model                           model层,定义对象的接口方法,具体实现在dao层
       |-- mysql                           MySQL连接
       |-- server                          服务器的实现,对idl中定义服务的具体实现
       |-- service                         service层,作为领域实现的核心部分
     |-- zlog                            封装zap日志的代码实现
  |-- pkg                            开放给第三方的工具库
     |-- gormer                          修改:gormer二进制工具,用于生成Gorm相关Dao层代码
    |-- buf.gen.yaml                   buf生成代码的定义,从v1beta升到v1
    |-- buf.yaml                       buf工具安装所需的工具,从v1beta升到v1
    |-- gen.sh                         生成代码的脚本:buf+gormer
    |-- go.mod                         Go Module文件
    |-- gormer.yaml                    新增:将gormer中的参数移动到这里
    |-- main.go                        项目启动的main函数

1.gormer.yaml的文件

这里先给出具体的建表语句,可以清晰地看到orders表6个字段的具体含义:

CREATE TABLE orders
(
id bigint PRIMARY KEY AUTO_INCREMENT COMMENT '主键',
name varchar(255) COMMENT '名称,建议唯一',
price decimal(15,3) COMMENT '订单价格',
create_time timestamp NULL DEFAULT NULL COMMENT '创建时间',
update_time timestamp NULL DEFAULT NULL COMMENT '更新时间',
delete_status tinyint(3) COMMENT '删除状态,1表示软删除'
) COMMENT='订单信息表';

我们回顾一下之前的gormer程序,它采用了flag参数解析的方式。但随着复杂度提升,命令行参数包含了大量的内容,很难维护。这时,就建议采用配置文件的方式,保证可读性、可维护性。

# 数据库相关的信息
database:
  # 数据库连接
  dsn: "root:123456@tcp(127.0.0.1:3306)/demo"
  # 所有要生成到Go结构体中的表
  tables:
    # name-表名
    # goStruct-Go中结构体名
    # createTime-创建时间的数据库字段,必须为时间格式
    # updateTime-更新时间的数据库字段,必须为时间格式
    # softDeleteKey-软删除的数据库字段,必须为整数型,不填则为硬删除
    # softDeleteValue-表示为软删除的对应值
    - name: "orders"
      goStruct: "Order"
      createTime: "create_time"
      updateTime: "update_time"
      softDeleteKey: "delete_status"
      softDeleteValue: 1

# 项目相关的信息
project:
  # 项目的路径
  base: "./"
  # gorm相关核心结构的代码路径
  gorm: "internal/gormer/"
  # dao层CRUD核心结构的代码路径
  dao: "internal/dao/"
  # 项目的go module信息
  go_mod: "github.com/Junedayday/micro_web_service"

2.模板文件的修改

这里以两个具有代表性的操作为例,一起来看看具体代码。

新增

利用了go template的特性,填充了create_time和update_time字段。这里包含两层if语句:

  • 第一层:在gormer.yaml里必须指定了createTime代码,否则不要生成这段代码
  • 第二层:如果外部传进来的字段里没有指定时间,才填充最新的时间;否则以外部传入为准
daoTmplAdd = `func (repo *{
   {.StructName}}Repo) Add{
   {.StructName}}({
   {.StructSmallCamelName}} *gormer.{
   {.StructName}}) (err error) {
{
   {if ne .FieldCreateTime "" }}
    if {
   {.StructSmallCamelName}}.{
   {.FieldCreateTime}}.IsZero() {
        {
   {.StructSmallCamelName}}.{
   {.FieldCreateTime}} = time.Now()
    }
{
   {end}}
{
   {if ne .FieldUpdateTime "" }}
    if {
   {.StructSmallCamelName}}.{
   {.FieldUpdateTime}}.IsZero() {
        {
   {.StructSmallCamelName}}.{
   {.FieldUpdateTime}} = time.Now()
    }
{
   {end}}
    err = repo.db.
        Table(gormer.{
   {.StructName}}TableName).
        Create({
   {.StructSmallCamelName}}).
        Error
    return
}
`

// 生成后
func (repo *OrderRepo) AddOrder(order *gormer.Order) (err error) {
   

    if order.CreateTime.IsZero() {
   
        order.CreateTime = time.Now()
    }

    if order.UpdateTime.IsZero() {
   
        order.UpdateTime = time.Now()
    }

    err = repo.db.
        Table(gormer.OrderTableName).
        Create(order).
        Error
    return
}

删除

删除的逻辑主要区分了一个字段,即是否在gormer.yaml里指定了软删除的字段。

  • 指定了软删除的字段,则将这个字段更新为设定的值、并且更新updateTime字段;
  • 未指定软删除的字段,则直接硬删除对应的记录;
daoTmplDelete = `func (repo *{
   {.StructName}}Repo) Delete{
   {.StructName}}(condition *gormer.{
   {.StructName}}Options) (err error) {
    if condition == nil {
        return errors.New("delete must include where condition")
    }

    err = repo.db.
        Table(gormer.{
   {.StructName}}TableName).
        Where(condition.{
   {.StructName}}, condition.Fields).
{
   {if eq .FieldSoftDeleteKey "" }} Delete(&gormer.{
   {.StructName}}{}).
{
   { else }}  {
   {if eq .FieldUpdateTime "" }}
                Select("{
   {.TableSoftDeleteKey}}").
                Updates(&gormer.{
   {.StructName}}{
                    {
   {.FieldSoftDeleteKey}}:{
   {.TableSoftDeleteValue}},
                }).
            {
   { else }}
                Select("{
   {.TableSoftDeleteKey}}","{
   {.TableUpdateTime}}").
                Updates(&gormer.{
   {.StructName}}{
                    {
   {.FieldSoftDeleteKey}}:{
   {.TableSoftDeleteValue}},
                    {
   {.FieldUpdateTime}} : time.Now(),
                }).
            {
   { end }}
{
   { end }}
        Error
    return
}
`

// 生成后
func (repo *OrderRepo) DeleteOrder(condition *gormer.OrderOptions) (err error) {
   
    if condition == nil {
   
        return errors.New("delete must include where condition")
    }

    err = repo.db.
        Table(gormer.OrderTableName).
        Where(condition.Order, condition.Fields).
        Select("delete_status", "update_time").
        Updates(&gormer.Order{
   
            DeleteStatus: 1,
            UpdateTime:   time.Now(),
        }).
        Error
    return
}

3.核心结构体梳理

我们再一起看看表结构对应到Go结构体的一个关键结构体,这里分成了4个重要的部分:

  1. 表名、结构体名
  2. 表中的列信息、结构体中的Field字段信息
  3. 创建时间、更新时间
  4. 软删除的字段

这个数据结构体,其实是将两个数据源进行了关联映射:

  • 原始信息:从MySQL表中查询
  • 自定义字段信息:从gormer.yaml查询
type StructLevel struct {
   
    // table -> struct
    TableName            string
    StructName           string
    StructSmallCamelName string

    // table column -> struct field
    Columns []FieldLevel

    // create time
    TableCreateTime string
    FieldCreateTime string
    // update time
    TableUpdateTime string
    FieldUpdateTime string

    // soft delete
    TableSoftDeleteKey   string
    TableSoftDeleteValue int
    FieldSoftDeleteKey   string
}

type FieldLevel struct {
   
    FieldName string
    FieldType string
    // gorm tag for field
    GormName string
    // comment from create table sql
    Comment string
}

4.API调用示例

从API调用的角度来看,程序对外接口如下。有兴趣的可以体验下:

// List
curl --location --request GET 'http://127.0.0.1:8081/v1/orders'

// Create
curl --location --request POST 'http://127.0.0.1:8081/v1/orders' \
--header 'Content-Type: application/json' \
--data-raw '{
    "name": "order4",
    "price": 100.3
}'

// Update
curl --location --request PATCH 'http://127.0.0.1:8081/v1/orders' \
--header 'Content-Type: application/json' \
--data-raw '{
    "order": {
        "id": "1",
        "name": "order1",
        "price": 110.8
    },
    "update_mask": "price"
}'

// Get
curl --location --request GET 'http://127.0.0.1:8081/v1/orders/order1'

// Delete
curl --location --request DELETE 'http://127.0.0.1:8081/v1/orders/order1'

延伸思考

修改到这个版本,gormer工具已经达到了基本可用的阶段。我们回顾一下重点功能:根据数据库表结构,自动化生成dao层的CRUD代码,并扩展了两特性:

  1. 支持创建时间、修改时间的字段,自动填充
  2. 支持软删除与硬删除

从更远的角度来看,还有许多MySQL的特性可以添加,尤其是对事务的支持,有兴趣的可以自行探索。限于篇幅与复杂度,目前就迭代到这个版本。

总结

Gormer是一个我们根据日常CRUD需求自行实现的工具,是框架实现高度自动化的重要环节。它的核心思想是 - 在重复的日常开发过程中找到可自动化的环节,实现Generate Code

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
目录
相关文章
|
30天前
|
数据采集 Go API
Go语言实战案例:多协程并发下载网页内容
本文是《Go语言100个实战案例 · 网络与并发篇》第6篇,讲解如何使用 Goroutine 和 Channel 实现多协程并发抓取网页内容,提升网络请求效率。通过实战掌握高并发编程技巧,构建爬虫、内容聚合器等工具,涵盖 WaitGroup、超时控制、错误处理等核心知识点。
|
1月前
|
数据采集 JSON Go
Go语言实战案例:实现HTTP客户端请求并解析响应
本文是 Go 网络与并发实战系列的第 2 篇,详细介绍如何使用 Go 构建 HTTP 客户端,涵盖请求发送、响应解析、错误处理、Header 与 Body 提取等流程,并通过实战代码演示如何并发请求多个 URL,适合希望掌握 Go 网络编程基础的开发者。
|
2月前
|
JSON 前端开发 Go
Go语言实战:创建一个简单的 HTTP 服务器
本篇是《Go语言101实战》系列之一,讲解如何使用Go构建基础HTTP服务器。涵盖Go语言并发优势、HTTP服务搭建、路由处理、日志记录及测试方法,助你掌握高性能Web服务开发核心技能。
|
2月前
|
Go
如何在Go语言的HTTP请求中设置使用代理服务器
当使用特定的代理时,在某些情况下可能需要认证信息,认证信息可以在代理URL中提供,格式通常是:
165 0
|
3月前
|
JSON 编解码 API
Go语言网络编程:使用 net/http 构建 RESTful API
本章介绍如何使用 Go 语言的 `net/http` 标准库构建 RESTful API。内容涵盖 RESTful API 的基本概念及规范,包括 GET、POST、PUT 和 DELETE 方法的实现。通过定义用户数据结构和模拟数据库,逐步实现获取用户列表、创建用户、更新用户、删除用户的 HTTP 路由处理函数。同时提供辅助函数用于路径参数解析,并展示如何设置路由器启动服务。最后通过 curl 或 Postman 测试接口功能。章节总结了路由分发、JSON 编解码、方法区分、并发安全管理和路径参数解析等关键点,为更复杂需求推荐第三方框架如 Gin、Echo 和 Chi。
|
10月前
|
设计模式 Java API
微服务架构演变与架构设计深度解析
【11月更文挑战第14天】在当今的IT行业中,微服务架构已经成为构建大型、复杂系统的重要范式。本文将从微服务架构的背景、业务场景、功能点、底层原理、实战、设计模式等多个方面进行深度解析,并结合京东电商的案例,探讨微服务架构在实际应用中的实施与效果。
499 6
|
10月前
|
设计模式 Java API
微服务架构演变与架构设计深度解析
【11月更文挑战第14天】在当今的IT行业中,微服务架构已经成为构建大型、复杂系统的重要范式。本文将从微服务架构的背景、业务场景、功能点、底层原理、实战、设计模式等多个方面进行深度解析,并结合京东电商的案例,探讨微服务架构在实际应用中的实施与效果。
232 1
|
9月前
|
Java 开发者 微服务
从单体到微服务:如何借助 Spring Cloud 实现架构转型
**Spring Cloud** 是一套基于 Spring 框架的**微服务架构解决方案**,它提供了一系列的工具和组件,帮助开发者快速构建分布式系统,尤其是微服务架构。
598 70
从单体到微服务:如何借助 Spring Cloud 实现架构转型
|
12月前
|
安全 应用服务中间件 API
微服务分布式系统架构之zookeeper与dubbo-2
微服务分布式系统架构之zookeeper与dubbo-2
|
12月前
|
负载均衡 Java 应用服务中间件
微服务分布式系统架构之zookeeper与dubbor-1
微服务分布式系统架构之zookeeper与dubbor-1