Golang GORM系列：GORM无缝集成web框架

高效的数据管理是每个成功的web应用程序的支柱。GORM是通用的Go对象关系映射库，它与流行的Go web框架搭配得非常好，提供了无缝集成，简化了数据交互。本指南将带你探索GORM和web框架（如Gin， Echo和Beego）之间的共生关系。最终你将具备轻松将GORM与这些框架集成在一起的技能，优化数据管理并推动Go项目的高效开发。

在这里插入图片描述

Gin Web框架集成

GORM与流行的web框架的兼容性增强了应用程序的功能。Gin是一个闪电般的web框架，可以毫不费力地与GORM集成。

步骤1：导入依赖项

在应用程序中导入GORM和Gin：

import ("github.com/gin-gonic/gin""gorm.io/gorm"
)

步骤2：建立GORM连接

在Gin应用程序中初始化GORM连接：

func setupDB() (*gorm.DB, error) {db, err := gorm.Open(sqlite.Open("mydb.db"), &gorm.Config{})if err != nil {return nil, err}// 配置连接池sqlDB, err := db.DB()if err != nil {return nil, err}sqlDB.SetMaxIdleConns(10)  // 设置最大空闲连接数sqlDB.SetMaxOpenConns(100) // 设置最大打开连接数sqlDB.SetConnMaxLifetime(time.Hour) // 设置连接的最大生命周期return db, nil
}

步骤3：在处理程序中使用GORM

在Gin处理程序中使用GORM进行数据库操作：

func getProductHandler(c *gin.Context) {db, err := setupDB()if err != nil {c.JSON(http.StatusInternalServerError, gin.H{"error": "Database connection error"})return}defer db.Close()var product Productdb.First(&product, c.Param("id"))c.JSON(http.StatusOK, product)
}

Gin集成实战

在实际项目中，直接将 db 作为全局变量，或者每次直接调用获取连接方法，可能会导致以下问题：

  1. 代码耦合性高：所有模块都依赖全局变量，难以维护和测试。
  2. 并发安全问题：全局变量在并发场景下可能会被意外修改。
  3. 难以扩展：随着项目规模增大，全局变量的管理会变得复杂。

为了解决这些问题，我们可以采用 依赖注入（Dependency Injection） 的方式，将数据库连接传递给需要它的模块或服务。以下是分步骤的解决方案：

1. 项目结构设计

假设项目结构如下：

复制

myapp/
├── main.go
├── config/
│   └── config.go
├── models/
│   ├── user.go
│   └── product.go
├── services/
│   ├── user_service.go
│   └── product_service.go
├── repositories/
│   ├── user_repository.go
│   └── product_repository.go
└── database/└── database.go

2. 分步骤实现

步骤 1：初始化数据库连接

在 database/database.go 中封装数据库连接的初始化逻辑：

package databaseimport ("gorm.io/driver/mysql""gorm.io/gorm""log""time"
)// DB 是全局数据库连接
var DB *gorm.DB// InitDB 初始化数据库连接
func InitDB(dsn string) {var err errorDB, err = gorm.Open(mysql.Open(dsn), &gorm.Config{})if err != nil {log.Fatalf("Failed to connect to database: %v", err)}// 配置连接池sqlDB, err := DB.DB()if err != nil {log.Fatalf("Failed to get database instance: %v", err)}sqlDB.SetMaxIdleConns(10)sqlDB.SetMaxOpenConns(100)sqlDB.SetConnMaxLifetime(time.Hour)log.Println("Database connection established")
}
步骤 2：定义模型

在 models/ 目录下定义用户和产品模型：

  • models/user.go:
package modelsimport "gorm.io/gorm"type User struct {gorm.ModelName  stringEmail string
}
  • models/product.go:
package modelsimport "gorm.io/gorm"type Product struct {gorm.ModelName  stringPrice float64
}
步骤 3：实现数据访问层（Repository）

在 repositories/ 目录下定义用户和产品的数据访问逻辑：

  • repositories/user_repository.go:
package repositoriesimport ("myapp/models""gorm.io/gorm"
)type UserRepository struct {db *gorm.DB
}// NewUserRepository 创建 UserRepository 实例
func NewUserRepository(db *gorm.DB) *UserRepository {return &UserRepository{db: db}
}// FindAll 获取所有用户
func (r *UserRepository) FindAll() ([]models.User, error) {var users []models.Userif err := r.db.Find(&users).Error; err != nil {return nil, err}return users, nil
}
  • repositories/product_repository.go:
package repositoriesimport ("myapp/models""gorm.io/gorm"
)type ProductRepository struct {db *gorm.DB
}// NewProductRepository 创建 ProductRepository 实例
func NewProductRepository(db *gorm.DB) *ProductRepository {return &ProductRepository{db: db}
}// FindAll 获取所有产品
func (r *ProductRepository) FindAll() ([]models.Product, error) {var products []models.Productif err := r.db.Find(&products).Error; err != nil {return nil, err}return products, nil
}
步骤 4：实现服务层（Service）

在 services/ 目录下定义用户和产品的业务逻辑：

  • services/user_service.go:
package servicesimport ("myapp/models""myapp/repositories"
)type UserService struct {userRepo *repositories.UserRepository
}// NewUserService 创建 UserService 实例
func NewUserService(userRepo *repositories.UserRepository) *UserService {return &UserService{userRepo: userRepo}
}// GetAllUsers 获取所有用户
func (s *UserService) GetAllUsers() ([]models.User, error) {return s.userRepo.FindAll()
}
  • services/product_service.go:
package servicesimport ("myapp/models""myapp/repositories"
)type ProductService struct {productRepo *repositories.ProductRepository
}// NewProductService 创建 ProductService 实例
func NewProductService(productRepo *repositories.ProductRepository) *ProductService {return &ProductService{productRepo: productRepo}
}// GetAllProducts 获取所有产品
func (s *ProductService) GetAllProducts() ([]models.Product, error) {return s.productRepo.FindAll()
}
步骤 5：在 main.go 中整合所有模块
package mainimport ("github.com/gin-gonic/gin""myapp/config""myapp/database""myapp/repositories""myapp/services"
)func main() {// 初始化数据库连接database.InitDB(config.GetDSN())// 初始化 Ginr := gin.Default()// 初始化 Repository 和 ServiceuserRepo := repositories.NewUserRepository(database.DB)userService := services.NewUserService(userRepo)productRepo := repositories.NewProductRepository(database.DB)productService := services.NewProductService(productRepo)// 定义路由r.GET("/users", func(c *gin.Context) {users, err := userService.GetAllUsers()if err != nil {c.JSON(500, gin.H{"error": err.Error()})return}c.JSON(200, users)})r.GET("/products", func(c *gin.Context) {products, err := productService.GetAllProducts()if err != nil {c.JSON(500, gin.H{"error": err.Error()})return}c.JSON(200, products)})// 启动服务r.Run(":8080")
}

3. 总结

通过以上步骤，我们实现了以下目标：

  1. 解耦：将数据库连接、数据访问逻辑和业务逻辑分离，降低模块之间的耦合性。
  2. 依赖注入：通过构造函数将数据库连接传递给 Repository 和 Service，避免全局变量的使用。
  3. 可扩展性：每个模块（用户、产品等）可以独立开发和测试，便于扩展和维护。

这种设计模式非常适合中大型项目，能够有效提升代码的可维护性和可测试性。如果有更多问题，欢迎继续讨论！

自动依赖注入

手动实现依赖注入（DI）虽然可行，但在大型项目中可能会变得繁琐且容易出错。为了简化依赖注入的过程，可以使用 Go 的第三方依赖注入库，例如：

  1. Google Wire: 一个编译时依赖注入工具，通过代码生成实现依赖注入。
  2. Dig: 一个运行时依赖注入库，基于反射实现。

下面我将以 Google Wire 为例，展示如何利用第三方库实现依赖注入。

1. 安装 Google Wire

首先，安装 Google Wire：

bash

复制

go install github.com/google/wire/cmd/wire@latest

2. 项目结构调整

假设项目结构如下：

myapp/
├── main.go
├── config/
│   └── config.go
├── models/
│   ├── user.go
│   └── product.go
├── services/
│   ├── user_service.go
│   └── product_service.go
├── repositories/
│   ├── user_repository.go
│   └── product_repository.go
├── database/
│   └── database.go
└── wire/└── wire.go

3. 使用 Google Wire 实现依赖注入

步骤 1：定义 Provider

在 wire/wire.go 中定义 Provider 函数，用于提供依赖项：

// wire/wire.go
package wireimport ("myapp/config""myapp/database""myapp/repositories""myapp/services""github.com/google/wire"
)// 初始化数据库连接
func InitDB() *gorm.DB {return database.InitDB(config.GetDSN())
}// 提供 UserRepository
func ProvideUserRepository(db *gorm.DB) *repositories.UserRepository {return repositories.NewUserRepository(db)
}// 提供 ProductRepository
func ProvideProductRepository(db *gorm.DB) *repositories.ProductRepository {return repositories.NewProductRepository(db)
}// 提供 UserService
func ProvideUserService(userRepo *repositories.UserRepository) *services.UserService {return services.NewUserService(userRepo)
}// 提供 ProductService
func ProvideProductService(productRepo *repositories.ProductRepository) *services.ProductService {return services.NewProductService(productRepo)
}// 定义依赖注入的集合
var SuperSet = wire.NewSet(InitDB,ProvideUserRepository,ProvideProductRepository,ProvideUserService,ProvideProductService,
)
步骤 2：生成依赖注入代码

在 wire/wire.go 中添加以下代码，用于生成依赖注入的初始化函数：

// wire/wire.go
// +build wireinjectpackage wireimport "github.com/google/wire"// 生成初始化函数
func InitializeApp() (*services.UserService, *services.ProductService, error) {wire.Build(SuperSet)return &services.UserService{}, &services.ProductService{}, nil
}

运行以下命令生成代码：

wire ./wire

Wire 会自动生成一个 wire_gen.go 文件，其中包含依赖注入的初始化逻辑。

步骤 3：在 main.go 中使用生成的代码

在 main.go 中使用生成的依赖注入代码：

package mainimport ("github.com/gin-gonic/gin""myapp/wire"
)func main() {// 使用 Wire 生成的初始化函数userService, productService, err := wire.InitializeApp()if err != nil {panic(err)}// 初始化 Ginr := gin.Default()// 定义路由r.GET("/users", func(c *gin.Context) {users, err := userService.GetAllUsers()if err != nil {c.JSON(500, gin.H{"error": err.Error()})return}c.JSON(200, users)})r.GET("/products", func(c *gin.Context) {products, err := productService.GetAllProducts()if err != nil {c.JSON(500, gin.H{"error": err.Error()})return}c.JSON(200, products)})// 启动服务r.Run(":8080")
}

4. 总结

通过使用 Google Wire，我们可以：

  1. 自动化依赖注入：无需手动管理依赖关系，Wire 会自动生成初始化代码。
  2. 减少错误：依赖关系在编译时确定，避免了运行时错误。
  3. 提升可维护性：代码结构更清晰，易于扩展和维护。

相比手动依赖注入，使用 Wire 可以显著简化依赖管理的过程，特别适合中大型项目。如果你更喜欢运行时依赖注入，可以考虑使用 Dig，它的原理类似，但基于反射实现。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/70375.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

SAM C++ TensorRT（实时图像分割）

SAM C++ TensorRT（实时图像分割）

SPEED SAM C TENSORRT 🌐 1、概述 用于SAM（segment anything model分割一切模型）的TensorRT和CUDA优化的高表现C实现，特别适用于实时图像分割任务。 📢 更新 模型转换：从ONNX模型构建TensorRT引擎以加速…
阅读更多...
【LLAMA】羊驼从LLAMA1到LLAMA3梳理

【LLAMA】羊驼从LLAMA1到LLAMA3梳理

every blog every motto: Although the world is full of suffering， it is full also of the overcoming of it 0. 前言 LLAMA 1到3梳理 1. LLAMA 1 论文： LLaMA: Open and Efficient Foundation Language Models 时间： 2023.02 1.1 前言…
阅读更多...
什么是网络安全？网络安全防范技术包括哪些？

什么是网络安全？网络安全防范技术包括哪些？

伴随着互联网的发展，它已经成为我们生活中不可或缺的存在，无论是个人还是企业，都离不开互联网。正因为互联网得到了重视，网络安全问题也随之加剧，给我们的信息安全造成严重威胁，而想要有效规避这些风险&…
阅读更多...
【从0做项目】Java搜索引擎（7） web模块

【从0做项目】Java搜索引擎（7） web模块

阿华代码，不是逆风，就是我疯 你们的点赞收藏是我前进最大的动力！！ 希望本文内容能够帮助到你！！ 目录 文章导读 零：项目结果展示 一：后端web模块 1：思路 2&#xff1a…
阅读更多...
Visual Studio Code 集成 Baidu Comate

Visual Studio Code 集成 Baidu Comate

文章目录 安装Baidu Comate插件 安装Baidu Comate插件 从左主侧栏中 点击 【扩展】这个图标，然后在上方输入栏中输入 baidu comate —>选中列出的Bai Comate —>点击 【安装】按钮，等待安装完毕…
阅读更多...
WeMos D1+PIR+Android 的小场景制作

WeMos D1+PIR+Android 的小场景制作

最近在做一个有趣的小场景功能，其实已经有成熟产品，但是考虑到没法实现场景扩展，所以自己开始动手做。 场景描述：玄关人体感应，有人进门，致欢迎词，有人离开，致欢送词。 硬件设备&a…
阅读更多...
Android ListPreference使用

Android ListPreference使用

Android ListPreference使用 参考 添加链接描述 导入 androidx.preference.ListPreferenceListPreference是Android中的一个Preference子类，用于显示一个可选择的列表，并且可以保存用户所选择的值。它继承自DialogPreference，可以在用户点击时弹出一个对话框，显示可选择的…
阅读更多...
Spring Security实现记住我功能的实战指南

Spring Security实现记住我功能的实战指南

在现代Web应用中，"记住我"功能是提升用户体验的重要特性之一。用户无需在每次访问时重新登录，这不仅方便，还能增强用户对应用的粘性。今天，我们将通过一个具体的实例，详细探讨如何在Spring Security中实现&q…
阅读更多...
用命令模式设计一个JSBridge用于JavaScript与Android交互通信

用命令模式设计一个JSBridge用于JavaScript与Android交互通信

用命令模式设计一个JSBridge用于JavaScript与Android交互通信 在开发APP的过程中，通常会遇到Android需要与H5页面互相传递数据的情况，而Android与H5交互的容器就是WebView。 因此要想设计一个高可用的 J S B r i d g e JSBridge JSBridge，不…
阅读更多...
ModuleNotFoundError: No module named ‘timm.optim.novogr两种解决方法

ModuleNotFoundError: No module named ‘timm.optim.novogr两种解决方法

运行报错 from timm.optim.novograd import NovoGradModuleNotFoundError: No module named ‘timm.optim.novograd’。 问题原因 timm版本过高，novograd函数已被抛弃。 解决办法 方法1：安装更低版本的timm pip install timm0.4.12方法2&#xff1a…
阅读更多...
DeepSeek 本地部署指南：从零开始搭建 AI 搜索工具

DeepSeek 本地部署指南：从零开始搭建 AI 搜索工具

1. 引言 背景介绍 DeepSeek 是一款基于 AI 的搜索工具，能够高效处理海量数据，提供精准的搜索结果。它结合了 Ollama 的模型管理能力，使得部署更加便捷。 为什么选择本地部署 本地部署可以确保数据隐私，避免云端传输的风险&…
阅读更多...
昇腾DeepSeek模型部署优秀实践及FAQ

昇腾DeepSeek模型部署优秀实践及FAQ

2024年12月26日，DeepSeek-V3横空出世，以其卓越性能备受瞩目。该模型发布即支持昇腾，用户可在昇腾硬件和MindIE推理引擎上实现高效推理，但在实际操作中，部署流程与常见问题困扰着不少开发者。本文将为你详细阐述昇腾 De…
阅读更多...
vscode复制到下一行

vscode复制到下一行

linux中默认快捷键是ctrl shift alt down/up 但是在vscode中无法使用，应该是被其他的东西绑定了，经测试，可以使用windows下的快捷键shift alt down/up { “key”: “shiftaltdown”, “command”: “editor.action.copyLinesDownAction”…
阅读更多...
网络爬虫学习：借助DeepSeek完善爬虫软件，实现模拟鼠标右键点击，将链接另存为本地文件

网络爬虫学习：借助DeepSeek完善爬虫软件，实现模拟鼠标右键点击，将链接另存为本地文件

一、前言 最近几个月里，我一直在学习网络爬虫方面的知识，每有收获都会将所得整理成文发布，不知不觉已经发了7篇日志了： 网络爬虫学习：从百度搜索结果抓取标题、链接、内容，并保存到xlsx文件中 网络爬虫学…
阅读更多...
Arduino 第十六章：pir红外人体传感器练习

Arduino 第十六章：pir红外人体传感器练习

Arduino 第十六章：PIR 传感器练习 一、引言 在 Arduino 的众多有趣项目中，传感器的应用是非常重要的一部分。今天我们要学习的主角是 PIR（被动红外）传感器。PIR 传感器能够检测人体发出的红外线，常用于安防系统、自动…
阅读更多...
CV -- YOLOv8 图像分割（GPU环境）

CV -- YOLOv8 图像分割（GPU环境）

目录 参考视频： 标注 JSON转为TXT 训练 验证 参考视频： 使用 Yolov8 自定义数据集进行图像分割_哔哩哔哩_bilibili 标注 数据集： 我使用的是一些苹果数据集，可以在我的csdn资源中下载： https://download.csdn.net/do…
阅读更多...
深入理解 lua_KFunction 和 lua_CFunction

深入理解 lua_KFunction 和 lua_CFunction

在 Lua C API 中，lua_KFunction 和 lua_CFunction 是两个核心概念，尤其在处理协程和 C 函数扩展时扮演着至关重要的角色。lua_CFunction 作为一种 C 函数类型，允许开发者将 C 函数注册到 Lua 环境中，使得这些 C 函数可以在 Lua 脚本中被调用，进而实现 Lua 的功能扩展。而 …
阅读更多...
基于微信小程序的电影院订票选座系统的设计与实现，SSM+Vue+毕业论文+开题报告+任务书+指导搭建视频

基于微信小程序的电影院订票选座系统的设计与实现，SSM+Vue+毕业论文+开题报告+任务书+指导搭建视频

本系统包含用户、管理员两个角色。 用户角色：注册登录、查看首页电影信息推荐、查看电影详情并进行收藏预定、查看电影资讯、在线客服、管理个人订单等。 管理员角色：登录后台、管理电影类型、管理放映厅信息、管理电影信息、管理用户信息、管理订单等。…
阅读更多...
【Linux网络编程】应用层协议HTTP（请求方法，状态码，重定向，cookie，session）

【Linux网络编程】应用层协议HTTP（请求方法，状态码，重定向，cookie，session）

🎁个人主页：我们的五年 🔍系列专栏：Linux网络编程 🌷追光的人，终会万丈光芒 🎉欢迎大家点赞👍评论📝收藏⭐文章 ​ Linux网络编程笔记： https://blog.cs…
阅读更多...
Vue3 打造 Windows 桌面个性高效组件工具

Vue3 打造 Windows 桌面个性高效组件工具

软件介绍 Widgets 这款基于 Vue3 构建的开源 Windows 桌面小部件工具超实用。 其多样化组件库涵盖超 20 种，从倒计时、打工进度等实用工具，到抖音热榜等实时资讯组件应有尽有，各组件独立运行，满足多场景需求。 高度自定义布局支持…
阅读更多...
最新文章

Copyright @ 2022~2023