1.安装 gin 和 gorm
go get -u github.com/gin-gonic/gin go get -u gorm.io/gorm
新建项目,main 函数import 他们的包
"github.com/gin-gonic/gin" "gorm.io/driver/mysql" "gorm.io/gorm"
2.连接mysql
var db *gorm.db // 全局db,方便后续扩展其他包调用
func initmysql() (err error) {
dsn := "root:root@tcp(127.0.0.1:13306)/bubble?charset=utf8mb4&parsetime=true&loc=local"
db, err = gorm.open(mysql.open(dsn), &gorm.config{
namingstrategy: schema.namingstrategy{
singulartable: true,
},
})
if err != nil {
return
}
return nil
}
dsn 处换成自己的 mysql 配置信息。
高级配置:参考 https://gorm.io/zh_cn/docs/connecting_to_the_database.html
db, err := gorm.open(mysql.new(mysql.config{
dsn: "gorm:gorm@tcp(127.0.0.1:3306)/gorm?charset=utf8&parsetime=true&loc=local", // dsn data source name
defaultstringsize: 256, // string 类型字段的默认长度
disabledatetimeprecision: true, // 禁用 datetime 精度,mysql 5.6 之前的数据库不支持
dontsupportrenameindex: true, // 重命名索引时采用删除并新建的方式,mysql 5.7 之前的数据库和 mariadb 不支持重命名索引
dontsupportrenamecolumn: true, // 用 `change` 重命名列,mysql 8 之前的数据库和 mariadb 不支持重命名列
skipinitializewithversion: false, // 根据当前 mysql 版本自动配置
}), &gorm.config{})
3.声明模型并绑定
type todo struct {
id int `json:"id"`
title string `json:"title"`
status bool `json:"status"`
}
如想在数据库表中增加 createdat , updatedat 和 deletedat 字段,可在 todo 模型中引入 gorm.model 字段:
type todo struct {
gorm.model
id int `json:"id"`
title string `json:"title"`
status bool `json:"status"`
}
gorm.model 定义如下:
type model struct {
id uint `gorm:"primary_key"`//primary_key:设置主键
createdat time.time
updatedat time.time
deletedat *time.time
}
接下来最重要的一步,一定要绑定模型:
// 模型绑定
err = db.automigrate(&todo{})
if err != nil {
return
}
后续执行绑定模型后会在你的 mysql 数据库中生成一张 todo 表:

一般情况下表名会显示复数 todos,改为单数的话要在 &gorm.config 中指定启用单数 singulartable 为 true:
db, err = gorm.open(mysql.open(dsn), &gorm.config{
namingstrategy: schema.namingstrategy{
singulartable: true,
},
})
4.结合 gin 完成增删改查
流程主要分为三步:
- 从请求中取出数据
- 操作数据库
- 返回响应
完整代码:
package main
import (
"github.com/gin-gonic/gin"
"gorm.io/driver/mysql"
"gorm.io/gorm"
"gorm.io/gorm/schema"
"net/http"
)
var db *gorm.db
func initmysql() (err error) {
dsn := "root:root@tcp(127.0.0.1:13306)/bubble?charset=utf8mb4&parsetime=true&loc=local"
db, err = gorm.open(mysql.open(dsn), &gorm.config{
namingstrategy: schema.namingstrategy{
singulartable: true,
},
})
if err != nil {
return
}
return nil
}
type todo struct {
id int `json:"id"`
title string `json:"title"`
status bool `json:"status"`
}
func main() {
// 连接数据库
err := initmysql()
if err != nil {
panic(err)
}
// 模型绑定
err = db.automigrate(&todo{})
if err != nil {
return
}
r := gin.default()
v1group := r.group("/v1")
{
// 添加
v1group.post("/todo", func(c *gin.context) {
// 1.从请求中取出数据
var todo todo
if err = c.shouldbindjson(&todo); err != nil {
c.json(http.statusbadrequest, gin.h{"error": err.error()})
}
// 2.存入数据库
if err = db.create(&todo).error; err != nil {
c.json(http.statusok, gin.h{"error": err.error()})
return
} else {
// 3.返回响应
c.json(http.statusok, gin.h{"data": todo})
}
})
// 查看所有的待办事项
v1group.get("/todo", func(c *gin.context) {
var todolist []todo
if err = db.find(&todolist).error; err != nil {
c.json(http.statusok, gin.h{"error": err.error()})
return
} else {
c.json(http.statusok, gin.h{"data": todolist})
}
})
// 查看某个待办事项
v1group.get("/todo/:id", func(c *gin.context) {
var todo todo
if err = db.first(&todo, c.param("id")).error; err != nil {
c.json(http.statusok, gin.h{"error": err.error()})
return
} else {
c.json(http.statusok, gin.h{"data": todo})
}
})
// 更新某一个待办事项
v1group.put("/todo/:id", func(c *gin.context) {
id, ok := c.params.get("id")
if !ok {
c.json(http.statusok, gin.h{"error": "无效的id"})
}
var todo todo
if err = db.where("id = ?", id).first(&todo).error; err != nil {
c.json(http.statusok, gin.h{"error": err.error()})
return
}
c.shouldbindjson(&todo)
if err = db.save(&todo).error; err != nil {
c.json(http.statusok, gin.h{"error": err.error()})
return
} else {
c.json(http.statusok, gin.h{"data": todo})
}
})
// 删除某个待办事项
v1group.delete("/todo/:id", func(c *gin.context) {
var todo todo
id, ok := c.params.get("id")
if !ok {
c.json(http.statusok, gin.h{"error": "无效的id"})
}
if err = db.where("id = ?", id).delete(&todo{}).error; err != nil {
c.json(http.statusok, gin.h{"error": err.error()})
return
} else {
c.json(http.statusok, gin.h{"data": todo})
}
})
}
err = r.run(":8080")
if err != nil {
return
}
}
执行 go run main.go 项目启动在8080端口。
到此这篇关于gin+gorm实现增删改查的示例代码的文章就介绍到这了,更多相关gin gorm增删改查内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网!
发表评论