AI 助理
备案控制台
开发者社区 彭世瑜的博客 文章 正文

Golang：gorm的常用CRUD操作

2023-04-15 215
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： Golang：gorm的常用CRUD操作

image.png

文档：

完整代码：https://github.com/mouday/gorm-demo

初始化项目

go mod init github.com/mouday/gorm-demo

安装依赖

go get -u gorm.io/gorm
go get -u gorm.io/driver/mysql

目录

连接数据库

package service
import (
    "gorm.io/driver/mysql"
    "gorm.io/gorm"
    "gorm.io/gorm/logger"
)
const DB_URL = "root:123456@tcp(127.0.0.1:3306)/data?charset=utf8mb4&parseTime=True&loc=Local"
// 连接数据库
func GetDb() (db *gorm.DB, err error) {
    return gorm.Open(mysql.Open(DB_URL), &gorm.Config{
        // 日志级别
        Logger: logger.Default.LogMode(logger.Info),
    })
}

定义模型

package models
import (
  "time"
  "gorm.io/gorm"
)
// 自定义模型基类
// https://gorm.io/zh_CN/docs/models.html
type BaseModel struct {
  ID         uint           `gorm:"primaryKey"`
  CreateTime time.Time      `gorm:"autoCreateTime"`
  UpdateTime time.Time      `gorm:"autoUpdateTime"`
  DeleteTime gorm.DeletedAt `gorm:"index"`
}

package models
import "time"
// 定义模型
type UserModel struct {
  BaseModel
  Name     string
  Age      uint8
  Birthday time.Time
}
// 自定义表名
func (UserModel) TableName() string {
  return "user"
}

表操作

package service
import (
  "fmt"
  "github.com/mouday/gorm-demo/models"
)
// 创建表
func CreateTable() {
  db, _ := GetDb()
  // 为 `User` 创建表
  db.Migrator().CreateTable(&models.UserModel{})
  // CREATE TABLE `user` (
  // `id` bigint unsigned AUTO_INCREMENT,
  //  `create_time` datetime(3) NULL,
  //  `update_time` datetime(3) NULL,
  //  `delete_time` datetime(3) NULL,
  //  `name` longtext,
  //  `age` tinyint unsigned,
  //  `birthday` datetime(3) NULL,
  //  PRIMARY KEY (`id`),
  //  INDEX `idx_user_delete_time` (`delete_time`)
  // )
}
// 存在检查
func HasTable() {
  db, _ := GetDb()
  // 检查 `User` 对应的表是否存在
  hasTable := db.Migrator().HasTable(&models.UserModel{})
  // SELECT DATABASE()
  // SELECT SCHEMA_NAME from Information_schema.SCHEMATA where SCHEMA_NAME LIKE 'data%' ORDER BY SCHEMA_NAME='data' DESC,SCHEMA_NAME limit 1
  // SELECT count(*) FROM information_schema.tables WHERE table_schema = 'data' AND table_name = 'user' AND table_type = 'BASE TABLE'
  fmt.Printf("hasTable: %v\n", hasTable)
  // hasTable: true
}
// 删除表
func DropTable() {
  db, _ := GetDb()
  db.Migrator().DropTable(&models.UserModel{})
  // SET FOREIGN_KEY_CHECKS = 0;
  // DROP TABLE IF EXISTS `user` CASCADE
  // SET FOREIGN_KEY_CHECKS = 1;
}

写入操作

package service
import (
  "fmt"
  "time"
  "github.com/mouday/gorm-demo/models"
)
// 创建记录
func CreateRow() {
  db, _ := GetDb()
  user := models.UserModel{
    Name:     "Tom",
    Age:      20,
    Birthday: time.Now(),
  }
  // 通过数据的指针来创建
  db.Create(&user)
  // INSERT INTO `user`
  // (`create_time`,`update_time`,`delete_time`,`name`,`age`,`birthday`)
  // VALUES
  // ('2022-10-28 14:02:50.256','2022-10-28 14:02:50.256',NULL,'Tom',20,'2022-10-28 14:02:50.254')
  // 返回插入数据的主键
  fmt.Printf("user.ID: %v\n", user.ID)
  // user.ID: 1
}
// 指定的字段创建记录
func SelectCreateRow() {
  db, _ := GetDb()
  user := models.UserModel{
    Name:     "Tom",
    Age:      20,
    Birthday: time.Now(),
  }
  // 通过数据的指针来创建
  // Omit 忽略
  db.Select("Name", "Age").Create(&user)
  // INSERT INTO `user`
  // (`create_time`,`update_time`,`name`,`age`)
  // VALUES
  // ('2022-10-28 14:07:21.884','2022-10-28 14:07:21.884','Tom',20)
}
// 批量创建
func CreateInBatches() {
  db, _ := GetDb()
  users := []models.UserModel{{
    Name:     "Tom",
    Age:      20,
    Birthday: time.Now(),
  }, {
    Name:     "Jack",
    Age:      21,
    Birthday: time.Now(),
  }}
  batchSize := 100
  db.CreateInBatches(users, batchSize)
  // INSERT INTO `user`
  // (`create_time`,`update_time`,`delete_time`,`name`,`age`,`birthday`)
  // VALUES
  // ('2022-10-28 14:11:20.253','2022-10-28 14:11:20.253',NULL,'Tom',20,'2022-10-28 14:11:20.252'),
  // ('2022-10-28 14:11:20.253','2022-10-28 14:11:20.253',NULL,'Jack',21,'2022-10-28 14:11:20.252')
}
// 通过map创建
func CreateByMap() {
  db, _ := GetDb()
  user := map[string]interface{}{
    "Name": "jinzhu",
    "Age":  23,
  }
  db.Model(&models.UserModel{}).Create(user)
  //  INSERT INTO `user` (`age`,`name`) VALUES (23,'jinzhu')
}

更新操作

package service
import (
  "github.com/mouday/gorm-demo/models"
)
func UpdateSingleColumn() {
  db, _ := GetDb()
  // 实例中有主键，可以不写where
  // db.Model(&user).Update("name", "Jack")
  db.Model(&models.UserModel{}).Where("id = ?", 1).Update("name", "Jack")
  // UPDATE `user` SET `name`='Jack',`update_time`='2022-10-28 15:35:00.109' WHERE id = 1 AND `user`.`delete_time` IS NULL
}
func UpdateMoreColumn() {
  db, _ := GetDb()
  // 根据主键更新
  // db.Model(&user).Updates(User{Name: "hello", Age: 18})
  db.Model(&models.UserModel{}).Where("id = ?", 1).Updates(
    models.UserModel{
      Name: "hello",
      Age:  18,
    })
  // UPDATE `user` SET `update_time`='2022-10-28 15:36:59.661',`name`='hello',`age`=18 WHERE id = 1 AND `user`.`delete_time` IS NULL
}

删除操作

package service
import (
  "github.com/mouday/gorm-demo/models"
)
// 软删除
func SoftDelete() {
  db, _ := GetDb()
  // 开启了
  // 实例中有主键，可以不写where
  // db.Delete(&user)
  // db.Delete(&User{}, 10)
  db.Where("id = ?", 1).Delete(&models.UserModel{})
  // UPDATE `user` SET `delete_time`='2022-10-28 15:45:38.108' WHERE id = 1 AND `user`.`delete_time` IS NULL
}
// 物理删除
func ForceDelete() {
  db, _ := GetDb()
  db.Unscoped().Delete(&models.UserModel{}, 10)
  // DELETE FROM `user` WHERE `user`.`id` = 10
}

查询操作

package service
import (
  "fmt"
  "github.com/mouday/gorm-demo/models"
  "github.com/mouday/gorm-demo/utils"
)
// 查询单条记录
// 没有找到记录时，它会返回 ErrRecordNotFound 错误
func GetFirst() {
  db, _ := GetDb()
  var user models.UserModel
  // （主键升序）
  db.First(&user)
  // SELECT * FROM `user` WHERE `user`.`delete_time` IS NULL ORDER BY `user`.`id` LIMIT 1
  fmt.Printf("user: %v\n", user)
}
// 查询记录
func GetTake() {
  db, _ := GetDb()
  var user models.UserModel
  // 获取一条记录，没有指定排序字段
  db.Take(&user)
  // SELECT * FROM `user` WHERE `user`.`delete_time` IS NULL LIMIT 1
  fmt.Printf("user: %v\n", user)
}
// 查询记录
func GetLast() {
  db, _ := GetDb()
  var user models.UserModel
  // 获取最后一条记录（主键降序）
  db.Last(&user)
  // SELECT * FROM `user` WHERE `user`.`delete_time` IS NULL ORDER BY `user`.`id` DESC LIMIT 1
  fmt.Printf("user: %v\n", user)
}
// 根据主键检索
func GetFirstByID() {
  db, _ := GetDb()
  var user models.UserModel
  // 根据主键检索
  db.First(&user, 1)
  // SELECT * FROM `user` WHERE `user`.`id` = 1 AND `user`.`delete_time` IS NULL ORDER BY `user`.`id` LIMIT 1
  fmt.Printf("user: %v\n", user)
}
// Find
func GetFind() {
  db, _ := GetDb()
  var users []models.UserModel
  // 根据主键检索
  db.Find(&users, []int{1, 2, 3})
  // SELECT * FROM `user` WHERE `user`.`id` IN (1,2,3) AND `user`.`delete_time` IS NULL
  fmt.Printf("user: %v\n", users)
}
// Where Find
func GetWhereFind() {
  db, _ := GetDb()
  var users []models.UserModel
  db.Where("name = ?", "Tom").Find(&users)
  // SELECT * FROM `user` WHERE name = 'Tom' AND `user`.`delete_time` IS NULL
  fmt.Printf("user: %v\n", users)
}
// Where First
func GetWhereFirst() {
  db, _ := GetDb()
  var user models.UserModel
  db.Where("name = ?", "Tom").First(&user)
  // SELECT * FROM `user` WHERE name = 'Tom' AND `user`.`delete_time` IS NULL ORDER BY `user`.`id` LIMIT 1
  fmt.Printf("user: %v\n", user)
}
// LIKE
func GetWhereLikeFind() {
  db, _ := GetDb()
  var users []models.UserModel
  db.Where("name LIKE ?", "%Tom%").Find(&users)
  // SELECT * FROM `user` WHERE name LIKE '%Tom%' AND `user`.`delete_time` IS NULL
  fmt.Printf("user: %v\n", users)
}
// Struct & Map 条件
func GetWhereStructFind() {
  db, _ := GetDb()
  var users []models.UserModel
  db.Where(&models.UserModel{Name: "jinzhu", Age: 20}).Find(&users)
  // SELECT * FROM `user` WHERE `user`.`name` = 'jinzhu' AND `user`.`age` = 20 AND `user`.`delete_time` IS NULL
  fmt.Printf("user: %v\n", users)
}
// 选择特定字段
func GetSelectFind() {
  db, _ := GetDb()
  var users []models.UserModel
  db.Select("name", "age").Find(&users)
  // SELECT `name`,`age` FROM `user` WHERE `user`.`delete_time` IS NULL
  fmt.Printf("user: %v\n", users)
}
// Order
func GetOrderFind() {
  db, _ := GetDb()
  var users []models.UserModel
  db.Order("age desc").Find(&users)
  // SELECT * FROM `user` WHERE `user`.`delete_time` IS NULL ORDER BY age desc
  fmt.Printf("user: %v\n", users)
}
// Limit & Offset
func GetLimitOffsetFind() {
  db, _ := GetDb()
  var users []models.UserModel
  db.Limit(1).Offset(2).Find(&users)
  // SELECT * FROM `user` WHERE `user`.`delete_time` IS NULL LIMIT 1 OFFSET 2
  fmt.Printf("user: %v\n", users)
}
// 分页 Paginate
func GetPaginateFind() {
  db, _ := GetDb()
  var users []models.UserModel
  db.Scopes(utils.Paginate(2, 10)).Find(&users)
  // SELECT * FROM `user` WHERE `user`.`delete_time` IS NULL LIMIT 10 OFFSET 10
  fmt.Printf("user: %v\n", users)
}
// Pluck
func GetPluckFind() {
  db, _ := GetDb()
  var ages []int64
  db.Model(&models.UserModel{}).Pluck("age", &ages)
  // SELECT `age` FROM `user` WHERE `user`.`delete_time` IS NULL
  fmt.Printf("user: %v\n", ages)
  // user: [20 20 20 20 21 23]
}
// Count
func GetCountFind() {
  db, _ := GetDb()
  var count int64
  db.Model(&models.UserModel{}).Count(&count)
  // SELECT count(*) FROM `user` WHERE `user`.`delete_time` IS NULL
  fmt.Printf("count: %v\n", count)
  // count: 6
}


文章标签：
Go
数据库
关键词：
Golang gorm
Golang操作
Golang gorm操作
Golang crud
编程达人
目录
相关文章
尹正杰
|
4月前
|
Go 数据库
golang编程语言操作GORM快速上手篇
使用Go语言的GORM库进行数据库操作的教程，涵盖了GORM的基本概念、基本使用、关联查询以及多对多关系处理等内容。
尹正杰
60 1
1529723250799936
|
8月前
|
关系型数据库 MySQL Go
golang使用gorm操作mysql1
golang使用gorm操作mysql1
1529723250799936
127 2
golang使用gorm操作mysql1
青玉白露
|
8月前
|
存储 Go 数据处理
Golang简单实现IO操作
Golang简单实现IO操作
青玉白露
62 1
1529723250799936
|
8月前
|
Go
golang使用gorm操作mysql3，数据查询
golang使用gorm操作mysql3，数据查询
1529723250799936
104 3
1529723250799936
|
8月前
|
JSON 前端开发 Java
golang使用gorm操作mysql2
golang使用gorm操作mysql2
1529723250799936
72 1
长梦
|
8月前
|
Go 索引
Golang深入浅出之-切片（Slices）入门：创建、操作与扩容机制
【4月更文挑战第20天】Go语言中的切片是动态数组，提供灵活的操作和自动扩容。本文介绍了切片的创建（通过`make()`、数组创建和切片字面量）、基本操作（索引访问、切片、赋值追加和遍历）以及扩容机制（首次和后续扩容策略）。此外，还强调了切片与底层数组的关系、切片越界问题、`append()`的使用以及理解切片的关键点，帮助提升Go编程效率和代码质量。
长梦
190 0
游客eg2mpb57glrj6
|
8月前
|
缓存 Cloud Native 测试技术
Golang 乐观锁实战：Gorm 乐观锁的优雅使用
在现代软件开发中，数据一致性是一个永恒的话题。随着系统规模的扩大和并发操作的增加，如何有效地处理并发冲突，确保数据的完整性，成为了开发者必须面对的挑战。本文将带你深入了解 Golang 中 Gorm ORM 库的乐观锁机制，并通过实际示例，展示如何在项目中优雅地使用乐观锁。
游客eg2mpb57glrj6
549 1
cheems~
|
8月前
|
Go
golang力扣leetcode 701. 二叉搜索树中的插入操作
golang力扣leetcode 701. 二叉搜索树中的插入操作
cheems~
43 0
cheems~
|
8月前
|
NoSQL Go API
Golang使用第三方库Go-Redis操作redis
Golang使用第三方库Go-Redis操作redis
cheems~
108 0
cheems~
|
8月前
|
Go
etcd部署以及Golang实现CRUD
etcd部署以及Golang实现CRUD
cheems~
72 0