Gin Example With Generic - Gin Example 的泛型实现

项目简介

• gin_example_with_generic是一个基于Gin开发的一个简单的API框架，并对controller、service、model层进行泛型化。
• 项目地址：tiancheng92/gin_example_with_generic

使用方法

必要组件

• mysql

安装

go get -u github.com/tiancheng92/gin_example_with_generic

配置

• 修改./config_file/local.yaml文件

## 数据库链接DSN
Mysql: "root:@tcp(127.0.0.1:3306)/gin_example?charset=utf8&parseTime=true&loc=Local"

## gin服务配置
Server:
  Mode: "debug"           ## 运行模式，test、debug或release
  ServicePort: "8080"     ## 服务端口
  ServiceHost: "0.0.0.0"  ## 服务器地址

## 日志级别，debug、info、warn、error
LogLevel: "debug"

## 国际化
I18n: "zh" # zh en ja

构建

• 模型内建了自己的json包，支持使用go_json 或json-iterator 进行json解析。

json解析方式	构建约束
encoding/json	go build ...
github.com/goccy/go-json	go build -tags=go_json ...
github.com/json-iterator/go	go build -tags=jsoniter ...
github.com/bytedance/sonic （仅支持amd64架构的主机）	go build -tags=sonic,avx,linux,amd64 ...

运行

cd $GOPATH/src/gin-example-with-generic
go run -tags=go_json -gcflags=-l=4 -ldflags=-s -w ./cmd/cmd.go

项目的运行信息

2022/06/18 12:51:24 maxprocs: Leaving GOMAXPROCS=8: CPU quota undefined
[GIN-debug] [WARNING] Running in "debug" mode. Switch to "release" mode in production.
 - using env:   export GIN_MODE=release
 - using code:  gin.SetMode(gin.ReleaseMode)

[GIN-debug] GET    /debug/pprof/             --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/cmdline      --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/profile      --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] POST   /debug/pprof/symbol       --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/symbol       --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/trace        --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/allocs       --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/block        --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/goroutine    --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/heap         --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/mutex        --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /debug/pprof/threadcreate --> github.com/gin-contrib/pprof.pprofHandler.func1 (2 handlers)
[GIN-debug] GET    /healthz                  --> gin_example_with_generic/controller/api/universal.HealthCheck (5 handlers)
[GIN-debug] GET    /metrics                  --> github.com/gin-gonic/gin.WrapH.func1 (5 handlers)
[GIN-debug] GET    /api/v1/country/:pk       --> gin_example_with_generic/controller/api/v1.CountryInterface.Get-fm (5 handlers)
[GIN-debug] GET    /api/v1/country           --> gin_example_with_generic/controller/api/v1.CountryInterface.List-fm (5 handlers)
[GIN-debug] POST   /api/v1/country           --> gin_example_with_generic/controller/api/v1.CountryInterface.Create-fm (5 handlers)
[GIN-debug] PUT    /api/v1/country/:pk       --> gin_example_with_generic/controller/api/v1.CountryInterface.Update-fm (5 handlers)
[GIN-debug] DELETE /api/v1/country/:pk       --> gin_example_with_generic/controller/api/v1.CountryInterface.Delete-fm (5 handlers)
[GIN-debug] GET    /api/v1/user/:pk          --> gin_example_with_generic/controller/api/v1.UserInterface.Get-fm (5 handlers)
[GIN-debug] GET    /api/v1/user              --> gin_example_with_generic/controller/api/v1.UserInterface.List-fm (5 handlers)
[GIN-debug] GET    /api/v1/user/name/:name   --> gin_example_with_generic/controller/api/v1.UserInterface.ListByName-fm (5 handlers)
[GIN-debug] POST   /api/v1/user              --> gin_example_with_generic/controller/api/v1.UserInterface.Create-fm (5 handlers)
[GIN-debug] PUT    /api/v1/user/:pk          --> gin_example_with_generic/controller/api/v1.UserInterface.Update-fm (5 handlers)
[GIN-debug] DELETE /api/v1/user/:pk          --> gin_example_with_generic/controller/api/v1.UserInterface.Delete-fm (5 handlers)

项目目录结构

├── cmd                             // 程序入口
├── config                          // 读取配置文件方法
├── config_file                     // 配置文件
├── controller                      // 控制器层
│   └── api                         // 控制器层的api
│       ├── universal               // 通用api（404、健康检测等接口）
│       └── v1                      // 具体的api
├── generic                         // 泛型实现
│   ├── controller.go               // 控制器层的泛型实现
│   ├── model.go                    // 重写gorm的Model结构体（为了实现特定方法）
│   ├── paginate.go                 // 分页器
│   ├── repository.go               // 数据库操作的泛型实现
│   ├── request.go                  // 请求体的接口
│   └── service.go                  // service层的泛型实现
├── pkg                             // 通用包
│   ├── ecode                       // 错误码
│   ├── errors                      // 重写pkg/errors包（结合错误码）
│   ├── http                        // 对Gin的一些方法的封装
│   │   ├── bind                    // 数据绑定
│   │   ├── middleware              // 中间件
│   │   │   ├── cross_domain        // 跨域
│   │   │   ├── handle_error        // 统一的错误处理
│   │   │   └── logging             // 日志（access log）
│   │   └── render                  // 数据渲染
│   ├── json                        // json序列化（fast）
│   ├── log                         // 日志（app log）
│   ├── mysql                       // mysql连接函数
│   └── validator                   // 参数校验
├── router                          // 路由
├── server                          // 服务
├── service                         // 服务层
├── store                           // 数据层
│   ├── db_engine.go                // 数据库引擎
│   ├── model                       // 模型
│   └── repository                  // 数据库操作
├── tools                           // 第三方工具（ecode生成）
└── types                           // 类型
    ├── config                      // 配置文件结构体
    ├── const.go                    // 常量 
    ├── paginate                    // 分页结构体
    ├── request                     // 入参结构体
    └── result                      // 返回结构体

各个模块说明

泛型实现

Model层

• 数据库模型需要实现ModelInterface 接口，自带的SoftDeleteModel与Model默认实现了GetPrimaryKeyName() string方法与GetPrimaryKey() any 方法，即用户若在模型结构体中嵌套了SoftDeleteModel或Model，模型结构体仅需实现GetFuzzySearchFieldList() []string即可。
• ModelInterface详解：

type ModelInterface interface {
GetPrimaryKeyName() string // 获取主键名称
GetPrimaryKey() any        // 获取主键值
GetFuzzySearchFieldList() []string // 获取允许模糊查询的字段列表
}

• Model层泛型结构体Repository[M ModelInterface]默认实现了 RepositoryInterface 接口，用户只需在自己的Repository层继承Repository[M ModelInterface]结构体，即可实现默认的对数据库增删改查操作。
• RepositoryInterface详解：

type RepositoryInterface[M ModelInterface] interface {
Get(ctx context.Context, pk any) (*M, error) // 查询指定主键的数据
Create(ctx context.Context, attributes M) (*M, error) // 创建数据
Update(ctx context.Context, pk any, attributes M) (*M, error) // 更新数据
Delete(ctx context.Context, pk any) error // 删除数据
List(ctx context.Context, pq *paginate.Query) (*Paginate[M], error) // 分页查询
}

• 用户可在自己的Repository层继承Repository[M ModelInterface]结构体后对Repository[M ModelInterface] 中的方法进行重写或新增，参考store/repository/user.go 。

Service层

• Service层泛型包含了俩个结构体模型：
  • ReadOnlyService[M ModelInterface] 只读服务层，实现了ReadOnlyServiceInterface 接口
  • Service[R RequestInterface, M ModelInterface] 默认服务层, 实现了ServiceInterface接口
• 用户只需在自己的Service层继承ReadOnlyService[M ModelInterface]或Service[R RequestInterface, M ModelInterface] 结构体，即可实现对Service层增删改查操作。
• 泛型Service仅仅实现了Controller层数据的拓传以及把请求数据格式化为数据库模型操作。
• 泛型Service接口详解：

type ServiceInterface[R RequestInterface, M ModelInterface] interface {
Get(ctx context.Context, pk any) (*M, error) // 查询指定主键的数据
List(ctx context.Context, pq *paginate.Query) (*Paginate[M], error) // 分页查询
Update(ctx context.Context, pk any, request *R) (*M, error)          // 更新数据
Create(ctx context.Context, request *R) (*M, error) // 创建数据
Delete(ctx context.Context, pk any) error                            // 删除数据
}

type ReadOnlyServiceInterface[M ModelInterface] interface {
Get(ctx context.Context, pk any) (*M, error) // 查询指定主键的数据
List(ctx context.Context, pq *paginate.Query) (*Paginate[M], error) // 分页查询
}

• 用户可在自己的Service层继承ReadOnlyService[M ModelInterface]或Service[R RequestInterface, M ModelInterface] 结构体后对接口中的方法进行重写或新增，参考store/service/user.go 。

Controller层

• 从API接口获取的数据模型需要实现 RequestInterface接口。
• RequestInterface详解：

type RequestInterface interface {
FormatToModel() ModelInterface // 将请求数据格式化为数据库模型
}

• Controller层泛型包含了俩个结构体模型：
  • ReadOnlyController[M ModelInterface] 只读Controller层，实现了ReadOnlyControllerInterface 接口
  • Controller[R RequestInterface, M ModelInterface] 默认Controller层, 实现了ControllerInterface 接口
• 用户只需在自己的Controller层继承ReadOnlyController[M ModelInterface] 或Controller[R RequestInterface, M ModelInterface] 结构体，即可实现对Controller层增删改查操作。
• 泛型Controller仅仅实现了默认的数据绑定以及向Service层传递数据的操作。
• 泛型Controller接口详解：

type ControllerInterface[R RequestInterface, M ModelInterface] interface {
Get(ctx *gin.Context) // 查询指定主键的数据
List(ctx *gin.Context) // 分页查询
Update(ctx *gin.Context) // 更新数据
Create(ctx *gin.Context) // 创建数据
Delete(ctx *gin.Context) // 删除数据
}

type ReadOnlyControllerInterface[M ModelInterface] interface {
Get(ctx *gin.Context) // 查询指定主键的数据
List(ctx *gin.Context) // 分页查询
}

• 用户可在自己的Controller层继承ReadOnlyController[M ModelInterface] 或Controller[R RequestInterface, M ModelInterface] 结构体后对接口中的方法进行重写或新增，参考controller/api/v1/user.go 。

参数绑定

函数签名	描述
func Body(ctx *gin.Context, ptr any) error	把Body数据绑定到结构体
func Query(ctx *gin.Context, ptr any) error	把Query数据绑定到结构体
func ParamsID(ctx *gin.Context, key string) (int, error)	获取Param中的ID
func PaginateQuery(ctx *gin.Context) *paginate.Query	获取分页数据

• 以上函数均是对gin.bind的二次分装，并对绑定过程中发生的错误进行了渲染返回，故用户在发生参数绑定错误后，无需手动渲染错误返回直接return即可。
• Code： pkg/http/bind/request.go

参数校验

• gin_example_with_generic模型使用validator进行参数校验，并对其进行了二次分装。
• 默认支持了中、英、日语言（仅需在配置文件的I18n字段中进行设置）
• 支持自定义翻译与自定义校验规则定义
• Code： pkg/validator/validator.go

数据渲染

• 任意数据均通过 Response(ctx *gin.Context, rawData ...any) 进行渲染，并自动根据请求的accept头进行格式化（针对rawData的不同类型会有不同的处理方式）。

普通数据

• 如果rawData类型既没有实现 PaginateInterface 接口也不是Error类型，则数据原样返回

{
  "data": {},
  "msg": "Success",
  "code": 100000
}

error数据

如果rawData类型为Error类型，且实现了Coder 接口，则返回对应的错误码和错误信息，否则返回默认错误码（500）和默认错误信息

• 如果http_code >= 500，则会在console中打印堆栈信息（需启用handle_error中间件）

{
  "data": "record not found",
  "msg": "数据未找到",
  "code": 100008
}

分页数据

• 如果rawData类型实现了 PaginateInterface 接口，则返回分页数据

{
  "data": {
    "items": [],
    "paginate": {
      "total": 0,
      "page": 1,
      "page_size": 20
    }
  },
  "msg": "Success",
  "code": 100000
}

分页

通用参数

Query参数名	描述
search	全文模糊搜索（后端需定义允许模糊搜索的字段）
page	页码（默认1）
page_size	每页大小（默认20）
order_by	排序对象（默认id）
order	排序参数（desc:倒序、asc：正序）（默认倒序）
all_data	为true时忽略分页参数（"", "false", "False", "FALSE", "0" 皆为false）（默认false）

指定字段搜索

Query参数名	描述	举例	SQL
字段名	等于	name=abc // name=a&name=b	where name = 'abc' // where name in ['a','b']
字段名__ne	不等于	name__ne=abc	where name != 'abc'
字段名__gt	大于	name__gt=abc	where name > 'abc'
字段名__gte	大于等于	name__gte=abc	where name >= 'abc'
字段名__lt	小于	name__lt=abc	where name < 'abc'
字段名__lte	小于等于	name__lte=abc	where name <= 'abc'
字段名__sw	以...开头	name__sw=abc	where name like 'abc%'
字段名__ew	以...结尾	name__ew=abc	where name like '%abc'
字段名__like	包含	name__like=abc	where name like '%abc%'

JSON字段搜索

Query参数名	描述	举例
字段名__json_contains	JSON列表字段包含指定值	name__json_contains=jack
字段名__json_extract	JSON字段中的指定字段等于指定值(json的key与value以//分隔)	name__json_extract=$."www.baidu.com"//1 or name__json_extract=[*]."www.baidu.com"//1

中间件

中间件	描述	路径
cross_domain	跨域	pkg/http/middleware/cross_domain/cross_domain.go
log	Gin日志	pkg/http/middleware/logging/log.go
handle_error	错误统一处理	pkg/http/middleware/handle_error/handle_error.go

Errors

• 本模型中的errors包是对pkg/errors的二次分装
• 在原本errors包的基础上添加了WithCode方法，用于设置错误码（多次调用记录最新的错误码，但堆栈信息只保留第一次调用时的）
• 错误码的定义在 pkg/ecode/base.go 中，用户只需按规则定义好错误码并执行codegen -type=int即可自动生成注册代码
• Code： pkg/errors 、pkg/ecode 、tools/codegen/main.go

AppLog

• 本模型使用zap包进行app日志处理
• Code： pkg/log/app_log.go