Golang后端学习笔记—Gorm CRUD

Gorm新手入门教程

安装

go get -u gorm.io/gorm
# mysql驱动 本文以mysql驱动为例
go get -u gorm.io/driver/mysql
# sqlite 驱动
go get -u gorm.io/driver/sqlite
# PostgreSQL 驱动
go get -u gorm.io/driver/postgres
复制代码

mysql数据库连接

dsn := "用户名:密码@tcp(ip:port)/dbName?charset=utf8mb4&parseTime=True&loc=Local"
// 这个db就是我们想要的*gorm.db实例了,后续就可以在这个基础上进行增删改查
db, err = gorm.Open(mysql.Open(dsn), &gorm.Config{})
if err!=nil{
    fmt.Println("mysql  conn err:",err)
}
复制代码

MySQl 驱动程序提供了一些高级配置可以在初始化过程中使用，例如：


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{})
复制代码

MySql 模型迁移

type Model struct {
	ID        uint `gorm:"primarykey"`
	CreatedAt time.Time
	UpdatedAt time.Time
	DeletedAt DeletedAt `gorm:"index"`
}

type  Product struct {
	gorm.Model // 模型嵌套 自动生成以上字段
	Code  string
	Price uint
	Name  string
}

// AutoMigrate 用于自动迁移您的 schema，保持您的 schema 是最新的
err := db.AutoMigrate(Product{})
if err != nil {
    return nil, err
}

复制代码

AutoMigrate 会自动创建数据库外键约束，您可以在初始化时禁用此功能

 gorm.Open(mysql.Open(dsn), &gorm.Config{
      DisableForeignKeyConstraintWhenMigrating: true,
 })
复制代码

GORM 提供了 Migrator 接口，该接口为每个数据库提供了统一的 API 接口

type Migrator interface {
  // 自动迁移
  AutoMigrate(dst ...interface{}) error

  // 数据库
  CurrentDatabase() string
  FullDataTypeOf(*schema.Field) clause.Expr

  // 数据库表的操作
  CreateTable(dst ...interface{}) error
  DropTable(dst ...interface{}) error
  HasTable(dst interface{}) bool
  RenameTable(oldName, newName interface{}) error

  // 表的字段相关操作
  AddColumn(dst interface{}, field string) error
  DropColumn(dst interface{}, field string) error
  AlterColumn(dst interface{}, field string) error
  HasColumn(dst interface{}, field string) bool
  RenameColumn(dst interface{}, oldName, field string) error
  MigrateColumn(dst interface{}, field *schema.Field, columnType *sql.ColumnType) error
  ColumnTypes(dst interface{}) ([]*sql.ColumnType, error)

  // 约束相关操作
  CreateConstraint(dst interface{}, name string) error
  DropConstraint(dst interface{}, name string) error
  HasConstraint(dst interface{}, name string) bool

  //索引相关操作
  CreateIndex(dst interface{}, name string) error
  DropIndex(dst interface{}, name string) error
  HasIndex(dst interface{}, name string) bool
  RenameIndex(dst interface{}, oldName, newName string) error
}
复制代码

gorm增删改查

增的相关操作

// gorm.model中的字段会在创建记录的时候自动插入对应数据，我们只需关心我们定义的字段数据即可
product := Product1{Code: "1024",Price: 128,Name:"测试"}
// 新增一条
// 通过数据的指针来创建，
//对应sql语句 "insert into product values('xx','xx')"
result:=db.Create(&product)
//out
product.ID             // 返回插入数据的主键
result.Error           // 返回 error
result.RowsAffected    // 返回插入记录的条数
复制代码

用指定的字段插入数据

db.Select("Code", "Name").Create(&product) //指定字段
db.Omit("Code", "Name").Create(&product1) //排除字段
复制代码

批量插入

func BatchCreate(db *gorm.DB) {
   var products []model.Product
   for x := 0; x < 10; x++ {
      pro := model.Product{
         Name:  "测试" + strconv.Itoa(x),
         Code:  strconv.Itoa(x),
         Price: 500 * (x + 1),
      }
      products = append(products, pro)
   }
   db.Create(&products)
}
复制代码

查的相关操作

单条查询

var pro Product
// 查询第一个
// SELECT * FROM users ORDER BY id LIMIT 1;
db.First(&pro)
// 查询最后一条
// SELECT * FROM users ORDER BY id DESC LIMIT 1;
db.Last(&pro)
// SELECT * FROM users LIMIT 1; 
db.Take(&pro)

result := db.First(&user)
result.RowsAffected // returns count of records found
result.Error        // returns error or nil

// check error ErrRecordNotFound
errors.Is(result.Error, gorm.ErrRecordNotFound)
// 以上单挑查询当表中没有数据的时候会报一个gorm.ErrRecordNotFound的错误
复制代码

ErrRecordNotFoundFinddb.Limit(1).Find(&user)FindFind

通过主键进行查询

var p1 model.Product
db.First(&p1,10)  //一个id
fmt.Println(p1)
var p2 []model.Product1
db.Find(&p2,[]int{1,2,3}) //多个id
fmt.Println(p2)
复制代码

String条件查询

func QueryByStringCondition(db *gorm.DB) {
	// 获取第一条匹配的记录
    var p1 model.Product
    // select * from product where name = "测试" order by id Limit 1;
    db.Where("name =?", "测试0").First(&p1)
    // 获取所有的匹配记录
    var p2 []model.Product
    db.Where("name =?", "测试").Find(&p2)
    // IN
    db.Where("name in", []string{"ceshi", "admin"}).Find(&p2)
    //Like
    db.Where("name Like ?", "%测%").Find(&p2)
    // And
    db.Where("name =? And code>=?", "测试", "1020")
    //Time 获取当前时间之前的记录
    db.Where("updated_at<?",time.Now()).Find(&p2)
    //Between
    db.Where("code between ? and ?", 2, 6).Find(&p2)
    for _, value := range p2 {
        fmt.Println(value)
    }
}
复制代码

struct 和map 条件查询

这种查询可以理解位String查询的升级版 QueryByStructAndMap struct 和map 条件查询区别:struct中查询字段为0,"",false或其他零值的会被过滤不会被用于构建查询条件 map会将所有查询的字段当做条件进行查询

func QueryByStructAndMap(db *gorm.DB) {
	var p1 model.Product
	//SELECT * FROM users WHERE name = "测试1"  ;
	db.Where(&model.Product{Name: "测试1", Code: "0",}).Find(&p1)
	//SELECT * FROM users WHERE name = "测试1 and code =0"
	db.Where(map[string]interface{}{"name":"测试1","code":"0"})
	// 主键切片条件
	//SELECT * FROM product WHERE id IN (1,3,5,6)
	db.Where([]int{1, 3, 5, 6}).Find(&p1)
	var p2 []model.Product
	db.Where(&model.Product{Name: "测试1"}, "name").Find(&p2)
	for _, value := range p2 {
		fmt.Println(value)
	}
}
复制代码

选择特定字段进行查询

func  QueryBySpecialFiled(db * gorm.DB)  {
	var  p1 []model.Product
	db.Select("name","price").Find(&p1)
	for _,value:=range p1{
		//fmt.Println(value.ID)
		fmt.Println(value.Name)
	}
	//效果同上
	db.Select([]string{"name","price"}).Find(&p1)
}
复制代码

排序方式的查询

func  QueryByOrder(db *gorm.DB)  {
	var  p1 []model.Product
	//SELECT * FROM product ORDER BY code desc, name;
	db.Order("code desc,name").Find(&p1)
	for _,value:=range p1{
		//fmt.Println(value.ID)
		fmt.Println(value)
	}

}
复制代码

limit && offset

Limit 指定获取记录的最大数量 Offset 指定在开始返回记录之前要跳过的记录数量

func  QueryLimitAndOffset(db *gorm.DB)  {
	var  p1 []model.Product
	//select * from product limit 3;
	db.Limit(3).Find(&p1)
	var  p2 []model.Product
	// SELECT * FROM product LIMIT 6; (product)
	// SELECT * FROM product; (product)
	db.Limit(6).Find(&p2).Limit(-1).Find(&p1)
	for _,value:=range p1{
		//fmt.Println(value.ID)
		fmt.Println("表1：",value)
	}
	for _,value:=range p2{
		//fmt.Println(value.ID)
		fmt.Println("表2：",value)
	}
	// select * from product offset 3 limit 6;
	// 同 limit语法一样 offset(-1)也可以消除offset条件
	db.Offset(3).Limit(6).Find(&p1)
	for _,value:=range p1{
		//fmt.Println(value.ID)
		fmt.Println(value)
	}
}
复制代码

更新的相关操作

// Update
func Update(db *gorm.DB) {
	var p1 model.Product
	db.First(&p1)
	p1.Price = 123455
	db.Save(&p1)
}

//UpdateRow 更新单列 就是更新某个字段的值
func UpdateRow(db *gorm.DB) {
	var p1 model.Product
	db.Model(&p1).Where("id=?", 20).Update("price", 5666)
}

//UpdateRows 更新多列
func UpdateRows(db *gorm.DB) {
	var p1 model.Product
	db.Model(&p1).Where("name like ?", "%测试%").Updates(model.Product{Name: "hq", Price: 123, Code: "10000"})
}
复制代码

删除的相关操作

单条删除需要指定主键否则则会触发批量删除 gorm 中的删除都是逻辑删除

func Delete(db *gorm.DB) {
	var p1 model.Product
	db.Delete(&p1, 22)
}

//批量删除
func DeleteBulk(db *gorm.DB) {
	var p1 model.Product
	db.Where("name =?", "hq").Delete(&p1)
}

复制代码

软删除

如果您的模型包含了一个 gorm.deletedat 字段（gorm.Model 已经包含了该字段)，它将自动获得软删除的能力

拥有软删除能力的模型调用 Delete 时，记录不会从数据库中被真正删除。但 GORM 会将 DeletedAt 置为当前时间，并且你不能再通过普通的查询方法找到该记录

// user 的 ID 是 `111` db.Delete(&user) // UPDATE users SET deleted_at="2013-10-29 10:23" WHERE id = 111; 
// 批量删除 
db.Where("age = ?", 20).Delete(&User{}) 
// UPDATE users SET deleted_at="2013-10-29 10:23" WHERE age = 20;
// 在查询时会忽略被软删除的记录 
db.Where("age = 20").Find(&user) // SELECT * FROM users WHERE age = 20 AND deleted_at IS NULL;
复制代码

查找被软删除的记录：您可以使用 Unscoped 找到被软删除的记录

db.Unscoped().Where("age = 20").Find(&users) 
// SELECT * FROM users WHERE age = 20;
复制代码

永久删除：您也可以使用 Unscoped 永久删除匹配的记录

db.Unscoped().Delete(&order) 
// DELETE FROM orders WHERE id=10;
复制代码