gorm高级使用
一、从数据库中随机返回一条数据
1、方式一直接写原生
sqSELECT*FROM`user`ORDERBYRAND()LIMIT12、方式二使用
clause.OrderBy来写函数查询varuserEntity model.UserEntity err:=dao.UserEntity.UnderlyingDB().WithContext(ctx).Clauses(clause.OrderBy{Expression:clause.Expr{SQL:"RAND()",WithoutParentheses:true},}).Take(&userEntity).Error3、使用随机函数
varmaxIDuintdao.UserEntity.WithContext(ctx).Select(dao.UserEntity.ID.Max()).Scan(&maxID)// 生成随机ID（假设ID从1开始连续）ifmaxID>0{randID:=rand.Intn(int(maxID))+1userEntity,err:=dao.UserEntity.WithContext(ctx).Where(dao.UserEntity.ID.Gte(int64(randID))).Take()iferr==nil{utils.Success(ctx,userEntity)return}}
二、 锁的使用
官网文档地址,链接地址，关于锁的使用必须是在事务中使用，否则无效，注意:如果没有使用索引的话会直接升级为表锁
1、关于
mysql中表里面锁的几种行锁，锁定一行数据
SELECT * FROM user WHERE id = 1 FOR UPDATE;共享锁，可读不可写
SELECT * FROM user WHERE id = 1 LOCK IN SHARE MODE;
2、行锁的具体的使用
u:=dao.UsersEntity user,err:=u.WithContext(ctx).Clauses(clause.Locking{Strength:"UPDATE"}).Where(u.ID.Eq(1)).First()// SELECT * FROM user WHERE id = 1 FOR UPDATE;3、共享锁的使用
u:=dao.UsersEntity user,err:=u.WithContext(ctx).Clauses(clause.Locking{Strength:"SHARE"}).Where(u.ID.Eq(1)).First()// SELECT * FROM user WHERE id = 1 LOCK IN SHARE MODE;4、常见使用(扣减库存的时候)
err:=db.Transaction(func(tx*gorm.DB)error{p:=query.Product.WithContext(ctx).UseDB(tx)product,err:=p.Clauses(clause.Locking{Strength:"UPDATE"}).Where(p.ID.Eq(productId)).First()iferr!=nil{returnerr}ifproduct.Stock<1{returnerrors.New("库存不足")}_,err=p.Where(p.ID.Eq(productId)).Update(p.Stock,product.Stock-1)returnerr})
三、其他高级使用
1、
Upsert操作,指定字段来创建或更新字段，使用场景防止重复数据dao.UserEntity.WithContext(ctx).Clauses(clause.OnConflict{Columns:[]clause.Column{{Name:"email"}},DoNothing:true,// 表示什么都不做，}).Create(&model.UserEntity{Email:"1@qq.com",Password:"123456",PassSalt:"123456",})2、存在的时候就更新指定的字段
dao.UserEntity.WithContext(ctx).Clauses(clause.OnConflict{Columns:[]clause.Column{{Name:"email"}},DoUpdates:clause.AssignmentColumns([]string{"updated_at"}),// 更新指定字段}).Create(&model.UserEntity{Email:"1@qq.com",Password:"123456",PassSalt:"123456",})3、存在的时候更新全部的字段
dao.UserEntity.WithContext(ctx).Clauses(clause.OnConflict{Columns:[]clause.Column{{Name:"email"}},UpdateAll:true,// 表示更新全部的字段}).Create(&model.UserEntity{Email:"1@qq.com",Password:"123456",PassSalt:"123456",})4、备注说明
其中根据指定的字段来创建或更新，这个字段必须是唯一索引，如果是多个字段，多个字段一起是唯一索引
四、在gorm-gen中使用普通的sql写法
这种情况是针对于
gorm-gen不能满足需求的时候才使用
1、直接使用聚合函数
varuserList=make([]model.UsersEntity,0)err:=dao.UsersEntity.WithContext(context.Background()).Select(dao.UsersEntity.ID,field.NewUnsafeFieldRaw("COALESCE(NULLIF(TRIM(name), ''), '默认名称') AS name"),field.NewUnsafeFieldRaw("COALESCE(name_id, 1) AS name_id"),).Scan(&userList)