go语言mysql框架_超级详细:Go语言框架Gin和Gorm实现一个完整的待办事项微服务...

前言

本文通过一步一步的设计,最终实现一个完善的todo应用。

我们使用GO框架Gin用户路由控制和返回数据。使用Gorm用于操作数据库。

读者可根据本教程操作,最终实现列出的各项功能。

技术清单

本文中所涉及的技术内容主要有以下几种:Gin:轻量高效性能爆棚的WEB框架

Gorm:一个关系型数据库的ORM工具包,避免直接SQL语句操作

MySQL:数据库

curl工具,用于API接口数据测试

另外,使用的GO版本是go version go1.13.5 windows/amd64

对于第2,3条内容,可使用以下指令安装

对于工具curl,我们使用的是 git bash内自带的指令。如果是linux下用户,开箱即用。

创建数据库

本文使用MySQL数据库装载数据。本节我们仅需创建一个空的数据库,就可以了。表结构在下一节使用gorm迁移功能创建。

使用Navicat工具新建界面如下图。

需要特别留意数据库字符集编码使用 utf8mb4,这个是MySQL真正的utf8,用于中文字符支持。

创建表模型

gorm中的Automigrate()操作,用于刷新数据库中的表,使其保持最新。即让数据库之前存储的记录的表字段和程序中最新使用的表字段保持一致(只增不减)。

我们先建一个todos表模型。

type (

todoModel struct {

gorm.Model

Title string `json:"title"`

Completed int `json:"completed`

}

fmtTodo struct {

ID uint `json:"id"`

Title string `json:"title"`

Completed bool `json:"completed"`

}

)

其中 todoModel用于数据库todos表。我们默认继承使用了gorm.Model的字段,主要包括以下几个:

// gorm.Model 定义

type Model struct {

ID uint `gorm:"primary_key"`

CreatedAt time.Time

UpdatedAt time.Time

DeletedAt *time.Time

}

数据库表会自动生成上述4个字段,并追加 title,completed两个字段。模型名与表名不一致,我们手动指定表名:

// 指定表名

func (todoModel) TableName() string {

return "todos"

}

然后在代码初始化过程中执行迁移。

var db *gorm.DB

// 初始化

func init() {

var err error

var constr string

constr = fmt.Sprintf("%s:%s@(%s:%d)/%s?charset=utf8mb4&parseTime=True&loc=Local", "root", "111213", "localhost", 3306, "05-gin-gorm-todo")

db, err = gorm.Open("mysql", constr)

if err != nil {

panic("数据库连接失败")

}

db.AutoMigrate(&todoModel{})

}

首先声明一个 gorm.DB,用于数据库操作。

在使用gorm包之前,需要导入。

import (

"github.com/jinzhu/gorm"

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

)

第二项我们仅导入而不使用。这个导入操作,gorm执行了下述操作

import _ "github.com/go-sql-driver/mysql"

这样我们无需重新手动处理包依赖关系。

MySQL的连接字符串是有特定格式的,这也是由底层 go-sql-driver/mysql 决定的参数配置项。其含义如下:

user:password@(hostname:port)/database_name?charset=utf8mb4&parseTime=True&loc=Local

此处我们使用的本地数据库3306端口,root用户,和 05-gin-gorm-todo 数据库。

在执行完整的程序之后,todos表会被自动迁移创建,其详细参数如下图。

这张表也是我们本文所操作的数据基础。

规划路由

依照restful风格的API设计标准,我们规划了5个路由,涵盖了一个todo列表清单的增删改查功能。

func main() {

r := gin.Default()

v1 := r.Group("/api/v1/todo")

{

v1.POST("/", add) // 添加新条目

v1.GET("/", all) // 查询所有条目

v1.GET("/:id", take) // 获取单个条目

v1.PUT("/:id", update) // 更新单个条目

v1.DELETE("/:id", del) // 删除单个条目

}

r.Run(":9089")

}

这个是最终会使用到的main函数,使用了gin提供的路由功能。为了扩展方便,我们使用了gin路由的Group功能,将版本v1的所有路由集中处理。

其中,访问的方法跟别使用 POST表示添加,GET表示查询,PUT表是更新,DELETE表示删除,这是restful API设计的一般性方法。

API功能

上一节规划的路由中,我们声明了5个函数,本节逐一实现这5个函数。注意API返回数据都是JSON格式。

为了统一返回状态码,对于正确响应的,返回HTTP CODE = 200。JSON数据的正常与否,使用两个常量表示,如下:

const (

JSON_SUCCESS int = 1

JSON_ERROR int = 0

)

成功返回1,失败返回0。

1 - 添加条目 add

主要的功能,是拿到POST表单提交的数据,并写入数据库,成功则返回信息通知,失败则给出相应提示。

// 创建TODO条目func add(c *gin.Context) {

completed, _ := strconv.Atoi(c.PostForm("completed"))

todo := todoModel{Title: c.PostForm("title"), Completed: completed}

db.Save(&todo)

c.JSON(http.StatusOK, gin.H{

"status": JSON_SUCCESS,

"message": "创建成功",

"resourceId": todo.ID,

})

}

注意我们对于POST提供的字段 completed 进行了转换,因为表单数据默认都是字符串类型,而todoModel内Completed是int类型,所以需要进行转换。

2 - 获取所有条目

不接受任何参数,默认给出所有的条目内容。

// 获取所有条目func all(c *gin.Context) {

var todos []todoModel

var _todos []fmtTodo

db.Find(&todos)

// 没有数据if len(todos) <= 0 {

c.JSON(http.StatusOK, gin.H{

"status": JSON_ERROR,

"message": "没有数据",

})

return

}

// 格式化for _, item := range todos {

completed := false

if item.Completed == 1 {

completed = true

} else {

completed = false

}

_todos = append(_todos, fmtTodo{

ID: item.ID,

Title: item.Title,

Completed: completed,

})

}

c.JSON(http.StatusOK, gin.H{

"status": JSON_SUCCESS,

"message": "ok",

"data": _todos,

})

}

为了API返回数据的便于使用,我们使用了一个结构体 fmtTodo 用于将结构体 todoModel 的数据进行格式化。如果没有查询到任何数据,返回状态码 status = 0。

3 - 获取单个条目

在路由中附加的id,可以调用此路由,用于返回单条数据。

// 根据id获取一个条目func take(c *gin.Context) {

var todo todoModel

todoID := c.Param("id")

db.First(&todo, todoID)

if todo.ID == 0 {

c.JSON(http.StatusNotFound, gin.H{

"status": JSON_ERROR,

"message": "条目不存在",

})

return

}

completed := false

if todo.Completed == 1 {

completed = true

} else {

completed = false

}

_todo := fmtTodo{

ID: todo.ID,

Title: todo.Title,

Completed: completed,

}

c.JSON(http.StatusOK, gin.H{

"status": JSON_SUCCESS,

"message": "ok",

"data": _todo,

})

}

根据ID查询数据,如果存在就返回,并使用fmtTodo进行格式化;如果不存在,状态码等于0。

4 - 更新单个条目

已经存在的数据,根据ID对其内容进行修改。如果ID不存在,返回错误信息。

// 更新一个条目func update(c *gin.Context) {

var todo todoModel

todoID := c.Param("id")

db.First(&todo, todoID)

if todo.ID == 0 {

c.JSON(http.StatusNotFound, gin.H{

"status": JSON_ERROR,

"message": "条目不存在",

})

return

}

db.Model(&todo).Update("title", c.PostForm("title"))

completed, _ := strconv.Atoi(c.PostForm("completed"))

db.Model(&todo).Update("completed", completed)

c.JSON(http.StatusOK, gin.H{

"status": JSON_SUCCESS,

"message": "更新成功",

})

}

5 - 删除单个条目

根据ID查询是否存在,如果存在就进行删除。

// 删除条目func del(c *gin.Context) {

var todo todoModel

todoID := c.Param("id")

db.First(&todo, todoID)

if todo.ID == 0 {

c.JSON(http.StatusOK, gin.H{

"status": JSON_ERROR,

"message": "条目不存在",

})

return

}

db.Delete(&todo)

c.JSON(http.StatusOK, gin.H{

"status": JSON_SUCCESS,

"message": "删除成功!",

})

}

以上就是5个方法的具体实现,只能用作demo,而不能用于生产。因为表单数据的有效性检测,我们在代码中并没有实现。这在线上是绝对不允许的。

还有一些数据的鉴权,用户身份权限鉴定,本示例中都没有。

使用curl测试

完成以上步骤,该todo清单功能基本完善,我们使用

go build main.go

进行编译,如果不出错,编译通过后,会生成 main.exe 文件。我们在命令行直接运行该文件,结果如下图。

下面我们对五个url分别进行测试。

首先是获取所有的条目,

curl -s -X GET http://localhost:9089/api/v1/todo/

这会命中第二条路由规则,返回值如下:

{"message":"没有数据","status":0}

暂时没有数据。接着添加一个条目:

curl -s -X POST -d "title=Talk is cheap, show me the code." -d "completed=0" http://localhost:9089/api/v1/todo/

执行成功返回数据

{"message":"创建成功","resourceId":8,"status":1}

接着我们再查询所有的条目,看看能否找到。返回结果如下:

{"data":[{"id":8,"title":"Talk is cheap, show me the code.","completed":false}],"message":"ok","status":1}

为了演示方便,我们再随机写入几条数据,然后测试单条数据查询,修改,和删除。

curl -s -X POST -d "title=Life is short, I use python." -d "completed=0" http://localhost:9089/api/v1/todo/

curl -s -X POST -d "title=Zen of Golang." -d "completed=0" http://localhost:9089/api/v1/todo/

curl -s -X POST -d "title=Do not repeat yourself." -d "completed=0" http://localhost:9089/api/v1/todo/

然后获取所有的条目

curl -s -X GET http://localhost:9089/api/v1/todo/

结果JSON数组格式化输出如下:

测试获取单条数据,这里使用id=10这一条,执行如下指令

curl -s -X GET http://localhost:9089/api/v1/todo/10

返回结果如下:

{"data":{"id":10,"title":"Zen of Golang.","completed":false},"message":"ok","status":1}

测试修改该条数据,设置completed=1,为已完成状态。

curl -s -X PUT -d "title=Zen of Golang." -d "completed=1" http://localhost:9089/api/v1/todo/10

执行成功返回:

{"message":"更新成功!","status":1}

注意更新操作使用的method = PUT。会命中第4条路由规则。

下面删除id=10的条目,使用以下指令:

curl -s -X DELETE http://localhost:9089/api/v1/todo/10

执行成功后返回结果:

{"message":"删除成功!","status":1}

OK,上面所有的路由都已经测试完毕,看服务器端的访问历史,大致如下图:

注意到有一条是数据库连接的自动释放,这是由MySQL设置的连接超时时间决定的,超期闲置则释放。如果有新的连接请求,重新建立。这可以节约资源。

关键点总结

在测试上述功能的时候,列出一些初学者可能会犯的错。

1 - 数据库连接失败

一定要确保连接字符串书写正确,账号密码书写正确,数据库IP地址和端口号正确,还有数据库名称对应。如果始终不能连接成长,可以尝试单独拿出来数据库连接进行测试,直到通过。

2 - 路由地址

根据设定的路由规则,正确地书写路由地址,还有传送参数方法,这样才能在程序中获取到提交的数据。

比如使用POST,传送的表单数据使用 c.PostForm 可以获取到。而 c.Param 则用于获取路由中 “/:id” id 这个位置参数。

3 - curl测试工具使用

注意使用请求方式 -X 参数,还有POST中使用的 -d 参数选项。

结语

以上内容使用两个成熟的包,快速地创建了一个待办清单的微服务。可以看到Go语言生态日臻完善,优秀的框架频出,给开发带来了很高的效率。

另外,GO语言的易于书写特性,接近与脚本语言的表达力,还有严格的数据类型检测,将不少低级的错误排除在编译阶段。

Happy coding :-)

【本文由 @程序员小助手 发布,持续分享编程与程序员成长相关的内容,欢迎关注】

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

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

相关文章

ef mysql 外键 一对一_MySQL 外键 一对一 一对多 多对多 复制

#外键## 1,学习外键首先要明白表与表之间的关系​ 首先要换位思考 在考虑了这边 还要考虑另一边​ 然后在下定论### 判断表关系的语法#### 图书与出版社​ 一本书可不可以有多个出版社 不可以​ 一个出版社可不可以出版多本书 可以​ 这就是一对多关系#### 图书与作者​ 一本书…

Mysql中Drop删除用户的名字_mysql5.5 使用drop删除用户

在说这个问题之前我们先讨论下关于在mysql中删除用户的方法和问题&#xff1a;其实在以前我删除mysql中的账号的时候用delete&#xff0c;一直没注意其实用这个命令删除账号会有一个问题就是使用delete删除账号后&#xff0c;只会清除user表的&#xff0c;在其它表中的信息还是…

docker建多个mysql_《容器化系列二》利用Docker容器化技术安装多个mysql

前提说明安装的Linux系统版本为Centos7.x一、安装docker并测试1、安装yum相关工具包///安装yum相关工具包yum install -y yum-utils device-mapper-persistent-data lvm2//发些报错&#xff0c;关闭刚刚睡眠中的进程kill -9 13312//再次执行yum install -y yum-utils device-ma…

mysql 元数据获取_[MySQL] 获取元数据的步骤

[MySQL] 获取元数据的方法 MySQL提供了以下三种方法用于获取数据库对象的元数据&#xff1a; 1)show语句 2)从INFORMATION_SCHEMA数据库里查询相关表 3)命令行程序&#xff0c;如mysqlshow, mysqldump 用SHOW语句获取元数据 MySQL用show语句获取元数据是最常用的方法&#xff0…

ai如何置入_ai图片(ai怎么把图片嵌入到图形里)

怎样将Ai格式的图片转换成常用的jpg&#xff0c;用什么软件转换&#xff1f;ai后缀的图片是指通过Illustrator(简称ai )软件储存得到的图片格式 这种格式的图片是矢量的&#xff0c;也就是说像freehand,Coredraw那样子的图片可以随意放大但不失真的那种 .在AI中&#xff0c;插入…

在模糊查询中怎样事先加载页面_8种信息类型,中后台产品功能自查清单

产品经理在梳理产品需求文档时需要把每一个功能的逻辑关系、交互方式都整理全面&#xff0c;为了避免疏漏&#xff0c;与开发评审前&#xff0c;建议每位产品都 Check 几遍文档。本文整理了一份中后台产品功能自查清单&#xff0c;供大家参考&#xff0c;如有不全欢迎提建议~中…

mysql 8.0 手动安装教程_mysql 8.0.13手动安装教程

本文为大家分享了mysql 8.0.13手动安装教程&#xff0c;供大家参考&#xff0c;具体内容如下一、步骤解读1.下载MySQL下载地址选择 Downloads-->Community-->MySQL Community Server&#xff0c;然后拉到页面的最低端&#xff0c;点击“下载”。此时一般会提示登陆&#…

gff3转mysql_科学网-把GFF3文件导入MySQL数据库-闫双勇的博文

什么是GFF3?这个一种序列注释文件的格式&#xff0c;基因组注释数据常常会用这种格式来记录序列注释信息&#xff0c;关于这种格式的更多信息&#xff0c;可以在这里学习&#xff1a;http://www.sequenceontology.org/gff3.shtml这里简单说下&#xff0c;怎样把GFF3文件导入My…

mysql时间字段不走索引_MySQL使用=或=范围查询时不走索引

2020-02-27最近一个日志页面查询很慢&#xff0c;然后去跟踪了查询sql&#xff0c;发现日期字段上即使建了索引&#xff0c;查询还是很慢&#xff0c;执行语句还是使用了全表扫描&#xff0c;于是继续分析下去。查询语句类似:select * from logs where createtime > 2020-01…

php mysql关键技术_中高级PHP开发者应该掌握哪些技术?

1.Linux能够流畅的使用Shell脚本来完成很多自动化的工作&#xff1b;awk/sed/perl 也操作的不错&#xff0c;能够完成很多文本处理和数据统计等工作&#xff1b;基本能够安装大 部分非特殊的Linux程序(包括各种库、包、第三方依赖等等&#xff0c;比如MongoDB/Redis/Sphinx/Lun…

python 简单socket_Python 简单socket

OSI七层模型(Open System Interconnection&#xff0c;开放式系统互联)应用层表示层回话层传输层 tcp,udp网络层 ip,icmp数据链路层 mac地址物理层 物理网卡服务端&#xff1a;import socket#实例化&#xff0c;绑定&#xff0c;监听&#xff0c;等待&#xff0c;解构(标识,ip-…

wxpython有哪些基本功能_用Python中的wxPython实现最基本的浏览器功能

通常&#xff0c;大多数应用程序通过保持 HTML 简单来解决大多数浏览器问题 ― 或者说&#xff0c;根据最低共同特性来编写。然而&#xff0c;即便如此&#xff0c;也仍然存在字体和布局的问题&#xff0c;发行新浏览器和升级现有浏览器时&#xff0c;也免不了测试应用程序的痛…

python增删改查mysql_python对数据库mysql的操作(增删改查)

#codingutf-8import pymysql# #查询# def connMySQL():# try:# connpymysql.connect(‘localhost‘,‘root‘,‘admin‘)# conn.select_db(‘five‘)# except Exception as e:# return e.args# else:# curconn.cursor()# cur.execute("select * from users")# datacu…

指数函数中x的取值范围_指数函数x的取值范围是

1、指数函数x的取值范围是a>0且a不1&#xff1b;2、指数函数是重要的基本初等函数之一。一般地&#xff0c;yax函数(a为常数且以a>0&#xff0c;a≠1)叫做指数函数&#xff0c;函数的定义域是 R &#xff1b;3、&#xff0c;在指数函数的定义表达式中&#xff0c;在ax前的…

java创建response对象_创建一个HttpResponse对象

创建一个HttpResponse对象HttpResponse类实现了javax.servlet.http.HttpServletResponse。跟随它的是一个叫做 HttpResponseFacade的faade类。Figure 3.3显示了HttpResponse类和它的相关类的UML图。在第2章中&#xff0c;你使用的是一个部分实现的HttpResponse类。例如&#xf…

java编译机制_java的编译机制

我们通常写的文件都是java文件,最后要在JVM上运行则需要将java文件编译成class(二进制文件).各厂商在实现JDK时通常会符合java语言规范的源码编译为class文件的编译器.编译器的好坏很大程度上决定了最后程序在机器上执行效率.通常使用Sun JDK(javac).javac将java源码编译成clas…

java excutorthread_JAVA 线程池ThreadPoolExcutor原理探究

概论线程池(英语&#xff1a;thread pool)&#xff1a;一种线程使用模式。线程过多会带来调度开销&#xff0c;进而影响缓存局部性和整体性能。而线程池维护着多个线程&#xff0c;等待着监督管理者分配可并发执行的任务。这避免了在处理短时间任务时创建与销毁线程的代价。线程…

java 继承作用_java三大特性之继承

继承(extends)&#xff1a;让类与类之间产生关系&#xff0c;子父类的关系继承的好处与弊端&#xff1a;好处&#xff1a;提高代码的复用性提高了代码的维护性让类与类之间产生关系&#xff0c;是多态的前提弊端&#xff1a;类的耦合性增加开发的原则是&#xff1a;1、高内聚&a…

java gui 单选_java GUI编程(swing)之三swing单选框复选框组件

swing复选框(JCheckBox) 单选框(JRadioButton)特别说明&#xff1a;同一组单选按钮&#xff0c;必须先创建一个ButtonGroup&#xff0c;然后把单选按钮放到ButtonGroup中package gui;import javax.swing.JButton;import javax.swing.JFrame;import javax.swing.JPanel;import j…

websocket连接mysql_websocket 使用 spring 的service层 ,进而调用里面的 dao层 来操作数据库 ,包括redis、mysql等通用...

1.前言描述一下今天用websocket踩得坑 ---》空指针异常&#xff01;我想在websocket里面使用service 层的接口&#xff0c;从中获取数据库的一些信息 &#xff0c;使用 Autowired 注解 接口 &#xff0c;报错 空指针异常 &#xff01;&#xff01;&#xff01;查过资料才发…