Go语言微服务框架 - 12.ORM层的自动抽象与自定义方法的扩展

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
日志服务 SLS,月写入数据量 50GB 1个月
简介: 随着接口参数校验功能的完善,我们能快速定位到接口层面的参数问题;而应用服务的分层代码,也可以通过log的trace-id发现常见的业务逻辑问题。但在最底层与数据库的操作,也就是对GORM的使用,经常会因为我们不了解ORM的一些细节,导致对数据的CRUD失败,或者没有达到预期效果。这时,我们希望能在ORM这一层也有一个通用的解决方案,来加速问题的排查。

随着接口参数校验功能的完善,我们能快速定位到接口层面的参数问题;而应用服务的分层代码,也可以通过log的trace-id发现常见的业务逻辑问题。

但在最底层与数据库的操作,也就是对GORM的使用,经常会因为我们不了解ORM的一些细节,导致对数据的CRUD失败,或者没有达到预期效果。这时,我们希望能在ORM这一层也有一个通用的解决方案,来加速问题的排查。

趁这个机会,我们也对gormer这个工具再做一次迭代,添加新的功能。

v0.7.2:ORM层的自动抽象与自定义方法的扩展

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

目标

gormer工具支持interface的抽象与自定义方法的扩展,并具备日志打印功能。

关键技术点

  1. model层的自动抽象方案
  2. dao层的代码实现
  3. MySQL的SQL打印
  4. 关于gormer工具的迭代

目录构造

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

1.model层的自动抽象方案

之前,我们在dao层已经实现了基本的CRUD相关代码,所以实现一个model层的定义很简单。但考虑到扩展性,也就是这个model层不仅仅需要简单的CRUD代码,还可能需要一些类似于group by等复杂sql,甚至包括子查询。

这时候,如果考虑全部用gormer工具自动生成的方案,那成本会很高,所以更建议分开维护的方案:简单的CRUD用自动代码生成的方式,而复杂SQL调用GORM库自行实现。我们来阅读代码:

// *.go 自动生成的代码,标准方法
type OrderModel interface {
   
    AddOrder(ctx context.Context, order *gormer.Order) (err error)
    QueryOrders(ctx context.Context, pageNumber, pageSize int, condition *gormer.OrderOptions) (orders []gormer.Order, err error)
    CountOrders(ctx context.Context, condition *gormer.OrderOptions) (count int64, err error)
    UpdateOrder(ctx context.Context, updated, condition *gormer.OrderOptions) (err error)
    DeleteOrder(ctx context.Context, condition *gormer.OrderOptions) (err error)

    // Implement Your Method in ext model
    OrderExtModel
}

// *_ext.go 扩展方法
type OrderExtModel interface {
   
}

为了保证自定义的ext代码不被覆盖,在gormer的代码里添加如下代码:

// 如果extFile已经存在,则不要覆盖
if _, err = os.Stat(extFile); err != nil {
   
  // 创建ext文件的代码
}

2.dao层的代码实现

dao层的代码基本同model层,分为*.go*_ext.go两个。

为了保证dao层实现了model层的代码,我们也增加了一行代码,方便我们在编译期保证实现。

var _ model.OrderModel = NewOrderRepo(nil)

3.MySQL的SQL打印

在GORM工具中,提供了一个callback的方式,让用户添加自定义的插件。具体可以参考 https://gorm.io/zh_CN/docs/write_plugins.html。主要实现分下面两步:

// 1 - 操作SQL时,将ctx传入其中,用来传递一些通用参数,如traceid
func (repo *OrderRepo) AddOrder(ctx context.Context, order *gormer.Order) (err error) {
   
    repo.db.WithContext(ctx).
        Table(gormer.OrderTableName).
        Create(order)
    err = repo.db.Error
    return
}

// 2 - 在操作数据库后,注册对应的插件afterLog,用来打印SQL日志
func InitGorm(user, password, addr string, dbname string) (err error) {
   
    dsn := fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8mb4&parseTime=True&loc=Local",
        user, password, addr, dbname)
    GormDB, err = gorm.Open(mysql.Open(dsn), &gorm.Config{
   })

    // 结束后
    _ = GormDB.Callback().Create().After("gorm:after_create").Register(callBackLogName, afterLog)
    _ = GormDB.Callback().Query().After("gorm:after_query").Register(callBackLogName, afterLog)
    _ = GormDB.Callback().Delete().After("gorm:after_delete").Register(callBackLogName, afterLog)
    _ = GormDB.Callback().Update().After("gorm:after_update").Register(callBackLogName, afterLog)
    _ = GormDB.Callback().Row().After("gorm:row").Register(callBackLogName, afterLog)
    _ = GormDB.Callback().Raw().After("gorm:raw").Register(callBackLogName, afterLog)
    return
}

const callBackLogName = "zlog"

func afterLog(db *gorm.DB) {
   
    err := db.Error
    ctx := db.Statement.Context

    sql := db.Dialector.Explain(db.Statement.SQL.String(), db.Statement.Vars...)
    if err != nil {
   
        zlog.WithTrace(ctx).Errorf("sql=%s || error=%v", sql, err)
        return
    }
    zlog.WithTrace(ctx).Infof("sql=%s", sql)
}

afterLog这里,我们引用了插件,实现了自定义日志组件的打印。

4.关于gormer工具的迭代

在这个小版本中,我们又对gormer工具做了一次迭代。从整个框架的维度来看,我们不仅仅是把它作为一种代码生成的工具,而是一种模块化的抽象能力,关注分层能力的建设。从SQL的log打印来看,我们可以区分出前后的差异:

原先 - 通过调用一个公共函数来打印,需要侵入到每个dao层的具体代码

修改后 - 通过插件注册到组件中,无需侵入到具体实现的代码

无侵入地实现自定义功能,这个特性对每个工具组件都非常重要,GORM这里就提供了一个很好的实现思路 - 注册插件,自定义hook。

总结

本次迭代的意义很大 - 标志着gormer这个组件实现了自定义方法的可扩展(ext文件)。

接下来,我们还会持续地对gormer等low code工具持续优化,实现更多的功能。

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
13天前
|
运维 监控 算法
监控局域网其他电脑:Go 语言迪杰斯特拉算法的高效应用
在信息化时代,监控局域网成为网络管理与安全防护的关键需求。本文探讨了迪杰斯特拉(Dijkstra)算法在监控局域网中的应用,通过计算最短路径优化数据传输和故障检测。文中提供了使用Go语言实现的代码例程,展示了如何高效地进行网络监控,确保局域网的稳定运行和数据安全。迪杰斯特拉算法能减少传输延迟和带宽消耗,及时发现并处理网络故障,适用于复杂网络环境下的管理和维护。
|
15天前
|
编译器 Go
揭秘 Go 语言中空结构体的强大用法
Go 语言中的空结构体 `struct{}` 不包含任何字段,不占用内存空间。它在实际编程中有多种典型用法:1) 结合 map 实现集合(set)类型;2) 与 channel 搭配用于信号通知;3) 申请超大容量的 Slice 和 Array 以节省内存;4) 作为接口实现时明确表示不关注值。此外,需要注意的是,空结构体作为字段时可能会因内存对齐原因占用额外空间。建议将空结构体放在外层结构体的第一个字段以优化内存使用。
|
15天前
|
Shell Go 开发工具
【环境】Rocky8使用gvm配置Go多版本管理的微服务开发环境(go-zero)
通过本文的介绍,我们详细讲解了如何在Rocky8上使用gvm来管理多个Go版本,并配置go-zero框架的开发环境。通过gvm的灵活管理,开发者可以轻松切换不同的Go版本,以适应不同项目的需求。同时,go-zero框架的使用进一步提升了微服务开发的效率和质量。希望本文能帮助开发者构建高效的Go语言开发环境,提高项目开发的灵活性和稳定性。
99 63
|
19天前
|
存储 Go
Go 语言入门指南:切片
Golang中的切片(Slice)是基于数组的动态序列,支持变长操作。它由指针、长度和容量三部分组成,底层引用一个连续的数组片段。切片提供灵活的增减元素功能,语法形式为`[]T`,其中T为元素类型。相比固定长度的数组,切片更常用,允许动态调整大小,并且多个切片可以共享同一底层数组。通过内置的`make`函数可创建指定长度和容量的切片。需要注意的是,切片不能直接比较,只能与`nil`比较,且空切片的长度为0。
Go 语言入门指南:切片
|
18天前
|
开发框架 前端开发 Go
eino — 基于go语言的大模型应用开发框架(二)
本文介绍了如何使用Eino框架实现一个基本的LLM(大语言模型)应用。Eino中的`ChatModel`接口提供了与不同大模型服务(如OpenAI、Ollama等)交互的统一方式,支持生成完整响应、流式响应和绑定工具等功能。`Generate`方法用于生成完整的模型响应,`Stream`方法以流式方式返回结果,`BindTools`方法为模型绑定工具。此外,还介绍了通过`Option`模式配置模型参数及模板功能,支持基于前端和用户自定义的角色及Prompt。目前主要聚焦于`ChatModel`的`Generate`方法,后续将继续深入学习。
156 7
|
15天前
|
存储 缓存 监控
企业监控软件中 Go 语言哈希表算法的应用研究与分析
在数字化时代,企业监控软件对企业的稳定运营至关重要。哈希表(散列表)作为高效的数据结构,广泛应用于企业监控中,如设备状态管理、数据分类和缓存机制。Go 语言中的 map 实现了哈希表,能快速处理海量监控数据,确保实时准确反映设备状态,提升系统性能,助力企业实现智能化管理。
28 3
|
15天前
|
存储 缓存 安全
Go 语言中的 Sync.Map 详解:并发安全的 Map 实现
`sync.Map` 是 Go 语言中用于并发安全操作的 Map 实现,适用于读多写少的场景。它通过两个底层 Map(`read` 和 `dirty`)实现读写分离,提供高效的读性能。主要方法包括 `Store`、`Load`、`Delete` 等。在大量写入时性能可能下降,需谨慎选择使用场景。
|
19天前
|
存储 开发框架 Devops
eino — 基于go语言的大模型应用开发框架(一)
Eino 是一个受开源社区优秀LLM应用开发框架(如LangChain和LlamaIndex)启发的Go语言框架,强调简洁性、可扩展性和可靠性。它提供了易于复用的组件、强大的编排框架、简洁明了的API、最佳实践集合及实用的DevOps工具,支持快速构建和部署LLM应用。Eino不仅兼容多种模型库(如OpenAI、Ollama、Ark),还提供详细的官方文档和活跃的社区支持,便于开发者上手使用。
121 8
|
19天前
|
存储 算法 Go
Go语言实战:错误处理和panic_recover之自定义错误类型
本文深入探讨了Go语言中的错误处理和panic/recover机制,涵盖错误处理的基本概念、自定义错误类型的定义、panic和recover的工作原理及应用场景。通过具体代码示例介绍了如何定义自定义错误类型、检查和处理错误值,并使用panic和recover处理运行时错误。文章还讨论了错误处理在实际开发中的应用,如网络编程、文件操作和并发编程,并推荐了一些学习资源。最后展望了未来Go语言在错误处理方面的优化方向。
|
16天前
|
SQL 安全 Java
阿里双十一背后的Go语言实践:百万QPS网关的设计与实现
解析阿里核心网关如何利用Go协程池、RingBuffer、零拷贝技术支撑亿级流量。 重点分享: ① 如何用gRPC拦截器实现熔断限流; ② Sync.Map在高并发读写中的取舍。

热门文章

最新文章