文/朱季谦
环境准备:安装Gin与Gorm本文搭建准备环境:Gin+Gorm+MysqL。
Gin是Go语言的一套WEB框架,在学习一种陌生语言的陌生框架,最好的方式,就是用我们熟悉的思维去学。作为一名后端Java开发,在最初入门时,最熟悉的莫过于MVC分层结构,可以简单归纳成controller层,model层,dao层,而在SpringBoot框架里,大概也经常看到以下的分层结构——
这个结构分为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/gingo get -u github.com/jinzhu/gorm
最好放在GOPATH目录下。
我的GOPATH目录在C:\Users\administrator\go下:
通过Go命令安装的依赖包放在这个目录底下C:\Users\administrator\go\src下:
现在,我们就参考SpringBoot的分层结构,搭建一套MVC分层结构系统。
先创建一个Go项目,这里,我取名为go-admin,底下创建一个go目录,用于存放Go代码;一个resources资源目录,存放配置文件,结构如下——
go根目录底下,创建controller、service、dao、entity包,另外,还需要一个router包,用于存放路由文件,可能你对路由文件不是很理解,那么,你可以简单理解为,这个路由的作用,就类似SpringMVC的@RequestMapPing("/user")和@GetMapPing("/List")注解组合起到的作用,通过路由,就可以找到需要调用的后端方法。创建完这些包后,若在SpringBoot项目里,是否还缺少一个xxxxxApplication.java的启动类,没错,在Go里,同样需要一个启动类,该启动类文件可以直接命名为main.go。
创建以上包与类后,go根目录底下结构如下:
接下来,是在resources资源目录创建一个application.yaml配置文件,当然,这个配置文件可以随便命名,不用像SpringBoot那样需要考虑其命名背后所代表的优先级。
这个配置文件里,就存放需要用到的MysqL数据库连接信息:
url: 127.0.0.1username: rootpassword: rootdbname: examplepost: 3306
这些基础工作做好后,就可以填充代码了。
二、dao层的搭建。
在dao层下,建立一个MysqL.go文件,这个文件在dao的包下,最初的效果如下
按照以往jdbc连接数据库的步骤,首先需要加载jdbc驱动程序,然后再创建数据库的连接,其实,在Go连接数据库,同样需要类似这样的 *** 作。
首先,需要导入数据库驱动程序。
Gorm已经包含了驱动程序,只需要将它导入进来即可:
import _ "github.com/jinzhu/gorm/dialects/MysqL"
进入到这个依赖包的源码,根据命名就可以看到出,这是一个go语言的MysqL驱动包——
除此之外,还提供了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")
到这一步,效果如下:
这里爆红色是正常的,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()) } //将读取的字符串转换成结构体conf err = yaml.Unmarshal(yamlfile,c) if err != nil { fmt.Println(err.Error()) } return c}
后面可以通过deBUG观察一下,这个返回的c变量,它就类似Java的对象,里边是key-value形式的值——
最后,就可以根据这些解析到的配置参数,用来驱动连接数据库了。
创建一个类似旧版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配置参数拼接成连接数据库的url dsn := 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,c) if err != nil { fmt.Println(err.Error()) } return c}//初始化连接数据库,生成可 *** 作基本增删改查结构的变量func InitMysqL()(err error) { var c conf //获取yaml配置参数 conf:=c.getConf() //将yaml配置参数拼接成连接数据库的url dsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local",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的复数形式,比如这里默认为 usersfunc (User) tablename() string { return "sys_user"}
到这一步,我们就完成了user模型关系建立。
package entity// 数据库表明自定义,默认为model的复数形式,比如这里默认为 usersfunc (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{}).Error return}
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).Error return}
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 } return}/**根据ID删除user */func DeleteUserByID(ID string)(err error){ err = dao.sqlSession.Where("ID=?",ID).Delete(&entity.User{}).Error return}/**根据ID查询用户User */func GetUserByID(ID string)(user *entity.User,err } return}/**更新用户信息 */func UpdateUser(user * entity.User)(err error) { err = dao.sqlSession.Save(user).Error return}
五、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,"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") { //增加用户User userGroup.POST("/users",controller.createuser) //查看所有的User userGroup.GET("/users",controller.GetUserList) //修改某个User userGroup.PUT("/users/:ID",controller.UpdateUser) //删除某个User userGroup.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")}
到这一步,就可以启动项目了,正常情况下,启动成功会显示以下日志信息——
到这一步,基于Gin+Gorm框架搭建MVC模式的Go后端系统,就初步搭建完成了。
最后,代码已经上传到GitHub:https://github.com/z924931408/go-admin.git
欢迎关注公众号,关于思考,关于文化,关于成长——
总结以上是内存溢出为你收集整理的基于Gin+Gorm框架搭建MVC模式的Go语言企业级后端系统全部内容,希望文章能够帮你解决基于Gin+Gorm框架搭建MVC模式的Go语言企业级后端系统所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)