基于Gin+Gorm框架搭建MVC模式的Go语言企业级后端系统

文/朱季谦

环境准备:安装Gin与Gorm

本文搭建准备环境:Gin+Gorm+MySql。

Gin是Go语言的一套WEB框架,在学习一种陌生语言的陌生框架,最好的方式,就是用我们熟悉的思维去学。作为一名后端Java开发,在最初入门时,最熟悉的莫过于MVC分层结构,可以简单归纳成controller层,model层,dao层,而在SpringBoot框架里,大概也经常看到以下的分层结构——

image

这个结构分为java根目录与resources资源目录。

在学习Go语言的Gin框架时,是否也可以参照这样的分层结构来搭建一套简单的后端系统呢。

答案是,肯定的。

接下来,我们就按照这个MVC分层结构,搭建一套基于Gin+Gorm框架的Go语言后端。

搭建之前,先简单介绍一下Gin和Gorm分别是什么。

Gin是一个golang的WEB框架,很轻量,依赖到很少,有些类似Java的SpringMVC,通过路由设置,可以将请求转发到对应的处理器上。

Gorm是Go语言的ORM框架,提供一套对数据库进行增删改查的接口,使用它,就可以类似Java使用Hibernate框架一样,可对数据库进行相应操作。

若要用到这两套框架,就需要import依赖进来,依赖进来前,需要Go命令安装Gin和Gorm。

go get -u github.com/gin-gonic/gin
go get -u github.com/jinzhu/gorm

最好放在GOPATH目录下。

我的GOPATH目录在C:\Users\Administrator\go下:

image

通过Go命令安装的依赖包放在这个目录底下C:\Users\Administrator\go\src下:

image

现在,我们就参考SpringBoot的分层结构,搭建一套MVC分层结构系统。
 

一、搭建根目录与资源目录。

先创建一个Go项目,这里,我取名为go-admin,底下创建一个go目录,用于存放Go代码;一个resources资源目录,存放配置文件,结构如下——
 

image


go根目录底下,创建controller、service、dao、entity包,另外,还需要一个router包,用于存放路由文件,可能你对路由文件不是很理解,那么,你可以简单理解为,这个路由的作用,就类似SpringMVC的@RequestMapping("/user")和@GetMapping("/list")注解组合起到的作用,通过路由,就可以找到需要调用的后端方法。创建完这些包后,若在SpringBoot项目里,是否还缺少一个xxxxxApplication.java的启动类,没错,在Go里,同样需要一个启动类,该启动类文件可以直接命名为main.go。

创建以上包与类后,go根目录底下结构如下:

image

接下来,是在resources资源目录创建一个application.yaml配置文件,当然,这个配置文件可以随便命名,不用像SpringBoot那样需要考虑其命名背后所代表的优先级。
 

image


这个配置文件里,就存放需要用到的Mysql数据库连接信息:

url: 127.0.0.1
userName: root
password: root
dbname: example
post: 3306

这些基础工作做好后,就可以填充代码了。

二、dao层的搭建。

在dao层下,建立一个mysql.go文件,这个文件在dao的包下,最初的效果如下

image

按照以往jdbc连接数据库的步骤,首先需要加载jdbc驱动程序,然后再创建数据库的连接,其实,在Go连接数据库,同样需要类似这样的操作。

首先,需要导入数据库驱动程序。

Gorm已经包含了驱动程序,只需要将它导入进来即可:

import _ "github.com/jinzhu/gorm/dialects/mysql"

进入到这个依赖包的源码,根据命名就可以看到出,这是一个go语言的mysql驱动包——

image

除此之外,还提供了mssql、postgres、sqlite的驱动包。

底层使用到的是GORM 框架,自然也要把它依赖进来:

import  "github.com/jinzhu/gorm"

另外,还需要依赖以下几个包,用于读取yaml配置文件数据与拼接成url字符串:

import "io/ioutil"
import "gopkg.in/yaml.v2"
import "fmt"

当依赖的包过多时,我们可以统一放到一个()号里,例如这样:

import ("github.com/jinzhu/gorm"_ "github.com/jinzhu/gorm/dialects/mysql""io/ioutil""gopkg.in/yaml.v2""fmt"
)

到这一步,效果如下:

image

这里爆红色是正常的,Go语言与Java不同的一个地方是,若依赖进来的包,没有被用到话,会直接出现红色异常提示,后面写到用到它们的代码时,就正常了。

接下来,定义一个用于接收yaml配置参数的struct结构体,你可以简单将它理解为Java的类。

type conf struct {Url string `yaml:"url"`UserName string `yaml:"userName"`Password string `yaml:"password"`DbName string `yaml:"dbname"`Port string `yaml:"post"`
}

然后提供一个读取解析该yaml配置的方法,将读取到的配置参数数据转换成上边的结构体conf

func (c *conf) getConf() *conf {//读取resources/application.yaml文件yamlFile, err := ioutil.ReadFile("resources/application.yaml")//若出现错误,打印错误提示if err != nil {fmt.Println(err.Error())}//将读取的字符串转换成结构体conferr = yaml.Unmarshal(yamlFile, c)if err != nil {fmt.Println(err.Error())}return c
}

后面可以通过debug观察一下,这个返回的c变量,它就类似Java的对象,里边是key-value形式的值——

image

最后,就可以根据这些解析到的配置参数,用来驱动连接数据库了。

创建一个类似旧版mybatis全局的SqlSession变量,就取名为SqlSession即可,该变量起到作用于mybatis的SqlSession实例类似,在数据库驱动连接成功后,即可提供select/insert/update/delete方法。

var SqlSession *gorm.DB

然后定义一个初始化连接数据库的方法,该方法用于在启动项目时执行——

func InitMySql()(err error)  {var c conf//获取yaml配置参数conf:=c.getConf()//将yaml配置参数拼接成连接数据库的urldsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local",conf.UserName,conf.Password,conf.Url,conf.Port,conf.DbName,)//连接数据库SqlSession,err =gorm.Open("mysql",dsn)if err !=nil{panic(err)}//验证数据库连接是否成功,若成功,则无异常return SqlSession.DB().Ping()
}

最后,还需要提供一个可以关闭数据库连接的方法——

func Close()  {SqlSession.Close()
}

到这里,我们就完成了Dao层的搭建,该层里的代码主要负责连接数据库,创建一个取名为SqlSession全局的*gorm.DB变量,该变量作用类似SqlSession,提供了操作数据库的方法,最后,整块dao层的mysql.go代码就如下:

package daoimport ("github.com/jinzhu/gorm""io/ioutil"
)import ("github.com/jinzhu/gorm"_ "github.com/jinzhu/gorm/dialects/mysql""io/ioutil""gopkg.in/yaml.v2""fmt"
)
//指定驱动
const DRIVER = "mysql"var SqlSession *gorm.DB//配置参数映射结构体
type conf struct {Url string `yaml:"url"`UserName string `yaml:"userName"`Password string `yaml:"password"`DbName string `yaml:"dbname"`Port string `yaml:"post"`
}//获取配置参数数据
func (c *conf) getConf() *conf {//读取resources/application.yaml文件yamlFile, err := ioutil.ReadFile("resources/application.yaml")//若出现错误,打印错误提示if err != nil {fmt.Println(err.Error())}//将读取的字符串转换成结构体conferr = yaml.Unmarshal(yamlFile, c)if err != nil {fmt.Println(err.Error())}return c
}//初始化连接数据库,生成可操作基本增删改查结构的变量
func InitMySql()(err error)  {var c conf//获取yaml配置参数conf:=c.getConf()//将yaml配置参数拼接成连接数据库的urldsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local",conf.UserName,conf.Password,conf.Url,conf.Port,conf.DbName,)//连接数据库SqlSession,err =gorm.Open(DRIVER,dsn)if err !=nil{panic(err)}//验证数据库连接是否成功,若成功,则无异常return SqlSession.DB().Ping()
}
//关闭数据库连接
func Close()  {SqlSession.Close()
}

三、entity层定义模型。

Gorm是全特性的ORM框架,即对象关系映射,这样,就需要类似Java那样建立与数据库映射的类,在Go语言当中,我们称之为结构体。

首先,先创建一张用于验证的数据库表结构——

CREATE TABLE `sys_user` (`id` int(50) unsigned NOT NULL AUTO_INCREMENT,`name` varchar(50) NOT NULL COMMENT '用户名',`nick_name` varchar(150) DEFAULT NULL COMMENT '昵称',`avatar` varchar(150) DEFAULT NULL COMMENT '头像',`password` varchar(100) DEFAULT NULL COMMENT '密码',`email` varchar(100) DEFAULT NULL COMMENT '邮箱',`mobile` varchar(100) DEFAULT NULL COMMENT '手机号',`create_time` bigint(50) DEFAULT NULL COMMENT '更新时间',`del_status` tinyint(4) DEFAULT '0' COMMENT '是否删除 -1:已删除   0:正常',PRIMARY KEY (`id`),UNIQUE KEY `name` (`name`)
) ENGINE=InnoDB AUTO_INCREMENT=11 DEFAULT CHARSET=utf8 COMMENT='用户表';

然后创建一个User.go文件,里边定义一个User结构体——

type User struct {Id int `json:"id"`Name string `json:"name"`NickName string `json:"nickName"`Avatar string `json:"avatar"`Password string `json:"password"`Email string `json:"email"`Mobile string `json:"mobile"`DelStatus int `json:"delStatus"`CreateTime int64 `json:"createTime"`
}

注意一点,这里需要明确指出,其struct结构体映射到哪一张表,如果没有显示指出,它会默认生成一张命名为users的数据库表——

// 数据库表明自定义,默认为model的复数形式,比如这里默认为 users
func (User) TableName() string {return "sys_user"
}

到这一步,我们就完成了user模型关系建立。

package entity// 数据库表明自定义,默认为model的复数形式,比如这里默认为 users
func (User) TableName() string {return "sys_user"
}type User struct {Id int `json:"id"`Name string `json:"name"` NickName string `json:"nickName"`Avatar string `json:"avatar"`Password string `json:"password"`Email string `json:"email"`Mobile string `json:"mobile"`DelStatus int `json:"delStatus"`CreateTime int64 `json:"createTime"`
}

四、service层建立增删改查业务逻辑。

在service层建立一个User的service类,命名为UserService.go。

这里,需要引入两个依赖,一个是dao层创建的全局SqlSession,用于操作数据库;一个是User类,用于接收数据库对应表结构的数据。

import ("go-admin/go/dao""go-admin/go/entity"
)

接下来,就可以基于SqlSession获取到的API接口,对数据库进行简单的增删改查操作了。

1.添加User信息

/**
新建User信息*/
func CreateUser(user *entity.User)(err error)  {if err = dao.SqlSession.Create(user).Error;err!=nil{return err}return
}

2.查询所有的User记录

/**
获取user集合*/
func GetAllUser()(userList []*entity.User,err error)  {if err:=dao.SqlSession.Find(&userList).Error;err!=nil{return nil,err}return
}

3.根据id删除对应的User信息

/**
根据id删除user*/
func DeleteUserById(id string)(err error){err = dao.SqlSession.Where("id=?",id).Delete(&entity.User{}).Errorreturn
}

4.根据id查询用户User

/**
根据id查询用户User*/
func GetUserById(id string)(user *entity.User,err error)  {if err = dao.SqlSession.Where("id=?",id).First(user).Error;err!=nil{return nil,err}return
}

5.更新用户信息

/**
更新用户信息*/
func UpdateUser(user * entity.User)(err error)  {err = dao.SqlSession.Save(user).Errorreturn
}

UserService.go的完整代码如下:

package serviceimport ("go-admin/go/dao""go-admin/go/entity"
)/**
新建User信息*/
func CreateUser(user *entity.User)(err error)  {if err = dao.SqlSession.Create(user).Error;err!=nil{return err}return
}/**
获取user集合*/
func GetAllUser()(userList []*entity.User,err error)  {if err:=dao.SqlSession.Find(&userList).Error;err!=nil{return nil,err}return
}/**
根据id删除user*/
func DeleteUserById(id string)(err error){err = dao.SqlSession.Where("id=?",id).Delete(&entity.User{}).Errorreturn
}/**
根据id查询用户User*/
func GetUserById(id string)(user *entity.User,err error)  {if err = dao.SqlSession.Where("id=?",id).First(user).Error;err!=nil{return nil,err}return
}/**
更新用户信息*/
func UpdateUser(user * entity.User)(err error)  {err = dao.SqlSession.Save(user).Errorreturn
}

五、controller层建立User的controller类。

在controller层建立一个UserController.go类,类似Java的controller,主要用于根据url跳转执行到对应路径的方法。

首先,引入需要用到的依赖包,

import (//需要用到的结构体"go-admin/go/entity"//gin框架的依赖"github.com/gin-gonic/gin"//http连接包"net/http"//service层方法"go-admin/go/service"
)

接下来,可以实现增删改查的controller方法了。

1.实现新增User的方法

func CreateUser(c *gin.Context)  {//定义一个User变量var user entity.User//将调用后端的request请求中的body数据根据json格式解析到User结构变量中c.BindJSON(&user)//将被转换的user变量传给service层的CreateUser方法,进行User的新建err:=service.CreateUser(&user)//判断是否异常,无异常则返回包含200和更新数据的信息if err!=nil{c.JSON(http.StatusBadRequest,gin.H{"error":err.Error()})}else {c.JSON(http.StatusOK,gin.H{"code":200,"msg":"success","data":user,})}
}

2.查询User的方法

func GetUserList(c *gin.Context)  {todoList,err :=service.GetAllUser()if err!=nil{c.JSON(http.StatusBadRequest,gin.H{"error":err.Error()})}else {c.JSON(http.StatusOK,gin.H{"code":200,"msg":"success","data":todoList,})}
}

六、routes层增加路由文件,用于根据请求url进行转发。

routes层新建一个Routers.go文件。

首先,同样需要引入需要用到的依赖——

import (
"go-admin/go/controller"
"github.com/gin-gonic/gin"
)

然后搭建一个初始化路由的操作,将路由统一存放到数据user的group组里,这样可以比较方便区分这些路由数据哪个controller类的。

Routers.go文件完整代码如下:

package routesimport (
"go-admin/go/controller"
"github.com/gin-gonic/gin"
)func SetRouter() *gin.Engine  {r :=gin.Default()/**用户User路由组*/userGroup :=r.Group("user"){//增加用户UseruserGroup.POST("/users",controller.CreateUser)//查看所有的UseruserGroup.GET("/users",controller.GetUserList)//修改某个UseruserGroup.PUT("/users/:id",controller.UpdateUser)//删除某个UseruserGroup.DELETE("/users/:id",controller.DeleteUserById)}return r
}

七、main启动类。

最后一步,就是建立main的启动类了,需要注意一点是,go的启动类,必须命名在package main的包下,否则无法进行启动。

首先,还是需要先引入依赖,main启动类需要用到dao、entity、routers以及mysql驱动包。

import ("go-admin/go/dao""go-admin/go/entity""go-admin/go/routes"_ "github.com/jinzhu/gorm/dialects/mysql"
)

启动方法里的代码主要如下,即前边搭建的东西,这里都有用到了——

func main()  {//连接数据库err :=dao.InitMySql()if err !=nil{panic(err)}//程序退出关闭数据库连接defer dao.Close()//绑定模型dao.SqlSession.AutoMigrate(&entity.User{})//注册路由r :=routes.SetRouter()//启动端口为8085的项目r.Run(":8081")
}

到这一步,就可以启动项目了,正常情况下,启动成功会显示以下日志信息——

image

到这一步,基于Gin+Gorm框架搭建MVC模式的Go后端系统,就初步搭建完成了。

最后,代码已经上传到GitHub:GitHub - z924931408/go-admin: 这是个人Go语言基于Gin+gorm框架搭建的MVC结构的后端模块。

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

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

相关文章

【AI视野·今日NLP 自然语言处理论文速览 第六十五期】Mon, 30 Oct 2023

AI视野今日CS.NLP 自然语言处理论文速览 Mon, 30 Oct 2023 Totally 67 papers 👉上期速览✈更多精彩请移步主页 Daily Computation and Language Papers An Approach to Automatically generating Riddles aiding Concept Attainment Authors Niharika Sri Parasa,…

为什么esp8266刷入了固件,无法接受AT指令

我遇到的解决方法是:是串口调试助手出了问题。所以需要更换一个串口调试助手软件。 上面这个就是我换了的软件 在开发的时候,经常会遇到软件故障,导致正确的方法,但是没有效果,好比以前用盗版的8.7版本的Proteus模拟…

idea中git 移除对某个文件的跟踪

应用场景如下 某个log 文件,被同事用git 提交到了服务器,本地拉去之后我们的跟踪也会受影响 取消跟踪的方法如下: 删除本地缓存 git rm --cached "logs/test.log" 提交无效的log git commit -m "ignore log" 再将lo…

时间序列预测实战(十六)PyTorch实现GRU-FCN模型长期预测并可视化结果

往期回顾:时间序列预测专栏——包含上百种时间序列模型带你从入门到精通时间序列预测 一、本文介绍 本文讲解的实战内容是GRU-FCN(门控循环单元-全卷积网络),这是一种结合了GRU(用于处理时间序列数据)和FCN(全卷积网络…

【数据结构】单链表 | 详细讲解

线性表顺序存储结构的优缺点 顺序表优点 无须为了表示中间的元素之间的逻辑关系而增加额外的存储空间;因为以数组形式存储,可以快速地存取表中任一位置的元素。 顺序表缺点 插入和删除操作需要移动大量元素,时间复杂度为O(N);…

Android图形系统之X11、Weston、Wayland、Mesa3D、ANGLE、SwiftShader介绍(十五)

简介: CSDN博客专家,专注Android/Linux系统,分享多mic语音方案、音视频、编解码等技术,与大家一起成长! 优质专栏:Audio工程师进阶系列【原创干货持续更新中……】🚀 人生格言: 人生…

redis运维(七)基础通用命令

一 基础通用命令 备注: 与具体数据类型无关Tab键 自动补全补充: redis 命令是不区分大小写 通用不到 10 个提升逼格的 redis 命令 后续: slowlog、rename-command、monitor、set ① help command 需求: 显示有关redis命令的…

就近值 reduce用法 时间戳与时间点对比循环查找

后台接口返回的13为时间戳 需要与数据data的time做对比,查找出最近的值 data的数据结构如下: 将:改为空格,变成数字之间的对比 //查找最近的时间getNearestTime(timestamp, data) {let date new Date(timestamp)let h date.ge…

openGauss学习笔记-122 openGauss 数据库管理-设置密态等值查询-密态支持函数/存储过程

文章目录 openGauss学习笔记-122 openGauss 数据库管理-设置密态等值查询-密态支持函数/存储过程122.1 创建并执行涉及加密列的函数/存储过程 openGauss学习笔记-122 openGauss 数据库管理-设置密态等值查询-密态支持函数/存储过程 密态支持函数/存储过程当前版本只支持sql和P…

postgreSQL中的高速缓存

1. 高速缓存简介 ​如下图所示,当一个postgreSQL进程读取一个元组时,需要获取表的基本信息(例如:表的oid、索引信息和统计信息等)及元组的模式信息,这些信息被分别记录在多个系统表中。通常一个表的模式信…

报错资源不足,k8s使用containerd运行容器修改挂载点根目录换成/home

运行k8s一段时间发现存储不足报错 发现这里用的是根路径的挂载,修改一下

手撕无头单链表

💓 博客主页:江池俊的博客⏩ 收录专栏:数据结构探索👉专栏推荐:✅C语言初阶之路 ✅C语言进阶之路💻代码仓库:江池俊的代码仓库🔥编译环境:Visual Studio 2022&#x1f38…

【Python】jupyter notebook(学习笔记)

Jupyter Notebook初见 1、Jupyter Notebook介绍 web版的ipython 编程、写文档、记笔记、展示 格式.ipynb 2、为什么使用Jupyter Notebook? 画图方面的优势:图像的生成不会堵塞后面代码的执行数据展示方面的优势:生成的数据可以保存在文件中 3、J…

hive数仓-数据的质量管理

版本20231116 要理解数据的质量管理,应具备hive数据仓库的相关知识 文章目录 1.理解什么是数据的质量管理:2.数据质量管理的规划数据质量标准的分类 3.数据质量管理解决方案1.ods层的数据质量校验1)首先在hive上建立一个仓库,添加…

oracle初步学习

先了解几个登录的方式 1.直接在cmd输入 sqlplus scott/tiger //登陆普通用户scott 2.输入sqlplus sys as sysdba 之后 紧接着让你输入口令,直接输入sys就行了 3.先输入sqlplus/nolog 在输入conn system/managerorcl 先在cmd窗口输入sqlplus/nolog &#x…

Linux输入设备应用编程(键盘,触摸屏,按键,鼠标)

目录 一 输入设备编程介绍 1.1 什么是输入设备呢? 1.2 什么是输入设备的应用编程? 1.3 input子系统 1.4 数据读取流程 1.5 应用程序如何解析数据 1.5.1 按键类事件: 1.5.2 相对位移事件 1.5.3 绝对位移事件 二 读取 struct input_e…

Swift爬虫程序

以下是一个简单的Swift爬虫程序,用于从前程无忧深圳地区招聘财务、会计的数据爬取数据: import Foundation import SwiftSoup// 创建一个请求对象,指定代理信息 var request URLRequest(url: URL(string: "https://www.51job.com/zh/c…

【软件安装】Centos系统中安装docker容器(华为云HECS云耀服务器)

这篇文章,主要介绍Centos系统中安装docker容器(华为云HECS云耀服务器)。 目录 一、安装docker 1.1、卸载旧版本docker 1.2、更新repo镜像 1.3、安装依赖包 1.4、添加docker-ce镜像 1.5、安装docker-ce 1.6、查看docker安装版本 1.7、…

Maven介绍及仓库配置

目录 一.Maven 1.介绍 坐标 仓库 1)中央仓库 2)本地仓库 3)私服 配置国内源 配置过程 二.Maven功能 2.项目构建 3.依赖管理 Maven Help插件 安装 ​使用 一.Maven 1.介绍 坐标 唯一的,通过以下代码的三个键值对确…