【go语言开发】gorm库连接和操作mysql,实现一个简单的用户注册和登录

本文主要介绍使用gorm库连接和操作mysql,首先安装gorm和mysql依赖库;然后初始化mysql,配置连接池等基本信息;然后建表、完成dao、controller开发;最后在swagger中测试

文章目录

  • 前言
  • 安装依赖库
  • 数据库初始化
  • 账号注册和登录
    • 创建实体类User
    • dao
    • controller
    • router配置
  • 测试

欢迎大家访问个人博客网址:https://www.maogeshuo.com,博主努力更新中…

参考文档:

  • 【go语言开发】yaml文件配置和解析
  • 【go语言开发】loglus日志框架的使用
  • 【go语言开发】swagger安装和使用

前言

GORM 是一个强大的 ORM(对象关系映射)库,可以简化数据库操作并提供方便的查询方法。它提供了一种简单而强大的方式来处理数据库操作,包括连接到数据库、定义数据模型、执行查询、插入、更新和删除数据等功能。

以下是 GORM 库的一些主要特点和优点:

  • 支持多种数据库引擎:GORM 支持多种主流的数据库引擎,如 MySQL、PostgreSQL、SQLite、SQL Server 等。

  • 自动迁移:通过 GORM,你可以使用简单的代码就能自动创建、更新数据库表结构,而无需手动编写 SQL。

  • 链式方法:GORM 提供了丰富的链式方法,用于构建复杂的查询条件,并支持预加载相关数据,实现数据的懒加载。

  • 事务支持:GORM 提供了事务支持,确保在数据操作时的原子性和一致性。

  • 回调函数:你可以注册各种回调函数,以在特定事件发生时执行自定义逻辑,如在保存数据之前或之后执行某些操作。

  • 软删除:GORM 支持软删除功能,即标记删除数据而非真正从数据库中删除,方便数据恢复和数据保留。

  • 关系映射:GORM 可以轻松地定义模型之间的关系,如一对一、一对多、多对多等,并提供方便的方法来处理这些关系。

  • 性能优化:GORM 对数据库操作进行了优化,提供了缓存、批量插入等功能,以提高性能。

安装依赖库

当使用 GORM 时,首先需要安装 GORM 包和相应的数据库驱动。

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

数据库初始化

初始化mysql,我这里只配置了两张表,设置连接池相关参数

package coreimport ("code-go/model/do""fmt""gorm.io/driver/mysql""gorm.io/gorm""log""time"
)var DB *gorm.DB// InitMysql 初始化mysql
func InitMysql() (*gorm.DB, error) {mysqlConfig := Config.Database.Mysqldsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local",mysqlConfig.UserName,mysqlConfig.Password,mysqlConfig.Host,mysqlConfig.Port,mysqlConfig.Database)LOG.Println("dsn: ", dsn)dbMysql, err := gorm.Open(mysql.Open(dsn), &gorm.Config{})if err != nil {log.Println("open db_mysql error ", err)return nil, err}DB = dbMysql//迁移表autoMigrateTable()// 是否打开日志if mysqlConfig.LogMode {dbMysql.Debug()}db, _ := dbMysql.DB()//设置连接池的最大闲置连接数db.SetMaxIdleConns(10)//设置连接池中的最大连接数量db.SetMaxOpenConns(100)//设置连接的最大复用时间db.SetConnMaxLifetime(10 * time.Second)return dbMysql, nil
}// 自动迁移表
func autoMigrateTable() {err := DB.AutoMigrate(&do.User{}, &do.OperationLog{})if err != nil {LOG.Error("迁移表结构失败:", err)}
}

SetMaxIdleConns:设置最大空闲连接数,目前默认值为2,0<= n<=MaxIdleConns
SetMaxOpenConns: 设置最大连接数,默认为0
SetConnMaxLifetime:设置连接的最大存活时间,当d<=0,connections are not closed due to a connection’s age
至于其他的配置,查看源码和官方文档https://gorm.io/docs/

账号注册和登录

创建实体类User

package doimport ("gorm.io/gorm"
)type User struct {gorm.ModelUsername     string  `gorm:"type:varchar(20);not null;unique;index:idx_username" json:"username"`Password     string  `gorm:"size:255;not null" json:"password,omitempty"`Mobile       string  `gorm:"type:varchar(11);not null;unique" json:"mobile"`Avatar       string  `gorm:"type:varchar(255)" json:"avatar"`Nickname     *string `gorm:"type:varchar(20)" json:"nickname"`Introduction *string `gorm:"type:varchar(255)" json:"introduction"`Status       uint    `gorm:"type:tinyint(1);default:1;comment:'1正常, 2禁用'" json:"status"`Creator      string  `gorm:"type:varchar(20);" json:"creator"`Roles        []*Role `gorm:"many2many:user_roles" json:"roles"`
}

dao

package daoimport ("code-go/core""code-go/model/do"
)func InsertUser(user do.User) error {tx := core.DB.Create(&user)if tx.Error != nil {core.LOG.Println("insert user in do fail")return tx.Error}return nil
}func GetUserByUsername(userName string) *do.User {var user *do.Usertx := core.DB.Model(&do.User{}).Where("username=?", userName).Find(&user)if tx.Error != nil {core.LOG.Println("Query user by username fail")}return user
}

controller

package apiimport ("code-go/app/admin/dao""code-go/common""code-go/core""code-go/global""code-go/model/do""code-go/model/vo""code-go/util""fmt""github.com/gin-gonic/gin""net/http""strconv""time"
)// Register 用户注册
//
//	@Summary	用户注册
//	@Produce	json
//	@Router		/api/user/register [post]
//	@Param		username	query	string	true	"用户名"
//	@Param		password	query	string	true	"密码"
//	@Param		mobile		query	string	true	"电话"
func Register(c *gin.Context) {userName := c.Query("username")password := c.Query("password")mobile := c.Query("mobile")if userName == "" || password == "" {core.LOG.Println("输入的用户名和密码为空")c.JSON(http.StatusOK, common.FailWithCodeMsg(common.VALILD_FAIL, "输入的用户名或密码为空"))return}// 查询用户daoUser := dao.GetUserByUsername(userName)if daoUser.Username == userName {core.LOG.Printf("用户: %s 已存在\n", userName)c.JSON(http.StatusOK, common.OkWithData("输入的用户已存在"))return}// 生成用户genPasswd := util.GenPasswd(password)var user do.Useruser.Mobile = mobileuser.Username = userNameuser.Password = genPasswduser.Status = core.User_status_OKerr := dao.InsertUser(user)if err != nil {core.LOG.Println("插入用户失败 ", err)c.JSON(http.StatusOK, common.FailWithCodeMsg(common.INSERT_DB_FAIL, "插入用户失败"))return}c.JSON(http.StatusOK, common.Ok())}// Login 用户登录
//
//	@Summary	用户登录
//	@Produce	json
//	@Router		/api/user/login [post]
//	@Param		username	query	string	true	"用户名"
//	@Param		password	query	string	true	"密码"
func Login(c *gin.Context) {userLogin := vo.UserLoginReqVo{}err := c.ShouldBindQuery(&userLogin)if err != nil {core.LOG.Println("用户登录:参数绑定失败")c.JSON(http.StatusOK, common.FailWithMsg("参数绑定失败"))return}userName := userLogin.Usernamepassword := userLogin.Passwordif userName == "" || password == "" {core.LOG.Println("用户登录:输入的用户名和密码为空")c.JSON(http.StatusOK, common.FailWithCodeMsg(common.VALILD_FAIL, "输入的用户名和密码为空"))return}// 校验格式isMatched := util.ValidateUserName(userName)if !isMatched {core.LOG.Println("用户登录:用户名格式校验失败")c.JSON(http.StatusOK, common.FailWithCodeMsg(common.VALILD_FAIL, "用户名格式校验失败"))return}//isMatched = util.ValidatePassword(password)//if !isMatched {//	global.Log.Println("用户登录:密码格式校验失败")//	c.JSON(http.StatusOK, common.FailWithCodeMsg(common.VALILD_FAIL, "密码格式校验失败"))//	return//}// TODO: 生成验证码// 数据库查询user := dao.GetUserByUsername(userName)if user.Username == "" {core.LOG.Println("用户登录:未查询到用户")c.JSON(http.StatusOK, common.FailWithCodeMsg(common.USER_NOT_EXIST, common.GetMapInfo(common.USER_NOT_EXIST)))return}//校验登录密码是否和数据库一致isPasswordMatch := util.ComparePasswd(user.Password, password)if !isPasswordMatch {core.LOG.Println("用户登录:用户密码输入错误")c.JSON(http.StatusOK, common.FailWithCodeMsg(common.USER_PASSWORD_NOT_MATCHED,common.GetMapInfo(common.USER_PASSWORD_NOT_MATCHED)))return}// TODO:生成tokentoken, err := util.GenerateToken(strconv.Itoa(int(user.ID)), user.Username)if err != nil {core.LOG.Println("用户登录:生成token失败")c.JSON(http.StatusOK, common.FailWithCodeMsg(common.AUTHORIZATION_FAIL, "生成token失败"))return}c.Header(global.Authorization, token)// 写入redisredisToken := fmt.Sprintf("user-token-%s", userName)isOk := core.Redis.SetEX(redisToken, token, 7*24*time.Hour)if isOk == false {core.LOG.Println("用户登录:设置值到redis")c.JSON(http.StatusOK, common.FailWithCodeMsg(common.REDIS_SET_FAIL, "设置值到Redis失败"))return}userVo := vo.ConvertToUserResVo(user)c.Header(global.Authorization, token)c.JSON(http.StatusOK, gin.H{"token": token,"user":  userVo,})}// GetUserByUsername 根据用户名查询用户
//
//	@Summary	用户登录
//	@Produce	json
//	@Router		/api/user/getUserByName [get]
//	@Param		username	query	string	true	"用户名"	maxlength(20)
func GetUserByUsername(c *gin.Context) {userName := c.Query("username")user := dao.GetUserByUsername(userName)if user.Username == "" {c.JSON(http.StatusOK, common.FailWithMsg("未查询到该用户"))return}userVo := vo.ConvertToUserResVo(user)c.JSON(http.StatusOK, common.OkWithData(userVo))
}// GetAllUser 查询所有的用户
//
//	@Summary	查询所有的用户
//	@Produce	json
//	@Router		/api/user/getAllUser [get]
//	@Param		pagenum		query	int	true	"页数"
//	@Param		pagesize	query	int	true	"页面大小"
func GetAllUser(c *gin.Context) {pageNum, _ := strconv.Atoi(c.Query("pagenum"))pageSize, _ := strconv.Atoi(c.Query("pagesize"))core.LOG.Printf("pagenum: %d, pagesize: %d\n", pageNum, pageSize)if pageNum <= 0 {pageNum = 0}if pageSize <= 0 {pageSize = 1}users, total := dao.GetUser(pageNum, pageSize)c.JSON(http.StatusOK, common.OkWithData(common.NewPageRes(users, total)))
}

router配置

package middlewareimport ("code-go/app/admin/api"_ "code-go/docs""github.com/gin-gonic/gin"swaggerFiles "github.com/swaggo/files"     // swagger embed filesginSwagger "github.com/swaggo/gin-swagger" // gin-swagger middleware
)// InitRouter 初始化Router
func InitRouter() *gin.Engine {g := gin.New()g.Use(gin.Recovery())g.Use(Logger())g.Use(Cors())// 需授权auth := g.Group("/api"){auth.GET("/user/getAllUser", api.GetAllUser)auth.POST("/user/register", api.Register)auth.POST("/user/login", api.Login)auth.GET("/user/getUserByName", api.GetUserByUsername)}// 无需授权norm := g.Group("/"){norm.GET("/getIp", api.GetIp)norm.GET("/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))norm.GET("/captcha", api.GetCaptcha)norm.POST("/checkCaptcha", api.CheckCaptcha)}return g
}

测试

使用swagger测试如下,可以确认登录成功,且有token生成
在这里插入图片描述
在这里插入图片描述

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

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

相关文章

2403C++,C++20协程通道

原文 通道是一个可用来连接协程,实现不同协程间通信的并发安全队列. Test fun test know channel() runBlocking<Unit> {val channel Channel<Int>()//生产者val producer GlobalScope.launch {var i 0while (true) {delay(1000)channel.send(i)println("…

springBoot整合Redis(三、整合Spring Cache)

缓存的框架太多了&#xff0c;各有各的优势&#xff0c;比如Redis、Memcached、Guava、Caffeine等等。 如果我们的程序想要使用缓存&#xff0c;就要与这些框架耦合。聪明的架构师已经在利用接口来降低耦合了&#xff0c;利用面向对象的抽象和多态的特性&#xff0c;做到业务代…

上市公司财务报表精讲系列一:黄山旅游

上市公司财务报表精讲系列一&#xff1a;黄山旅游 一、主营业务分行业、分产品、分地区情况二、董事会报告三、净利润现金流四、净资产收益率五、权益乘数和总资产周转率六、负债结构图七、行业分析八、案例总结九、2023年度业绩 一、主营业务分行业、分产品、分地区情况 二、董…

为国产信创服务器提供LDAP统一身份认证方案

金融信创作为 8 大行业信创之首&#xff0c;早已成为其他行业信创建设的参考。金融行业有着极为复杂的业务场景&#xff0c;对系统有着极高的稳定可靠需求&#xff0c;因此&#xff0c;在寻找微软 AD 国产化替代方案时&#xff0c;常会涉及到更深层次的场景。例如&#xff0c;最…

哪些行业将有可能被ai替代

随着AI技术的不断发展&#xff0c;越来越多的行业开始受到其影响&#xff0c;一些工作可能会被AI替代。以下是一些可能被AI替代的行业和领域&#xff1a; 制造业&#xff1a;制造业中的许多重复性劳动&#xff0c;如装配线上的工作&#xff0c;可能首先被AI和自动化技术替代。…

【test】【linux perf】【Android simpleperf】 获取火焰图 使用示例

文章目录 火焰图perfperf listperf recordperf scriptperf statperf reportperf top 官方perf使用示例记录60s系统中发生的所有上下文切换事件监测整个系统的 CPU 使用情况抓取 CPU 事件数据统计 CPU 循环事件、指令数、缓存引用、缓存失效和总线周期等性能指标的命令以mysqld进…

unity学习(45)——选择角色菜单——客户端处理服务器的数据

1.已知客户端ReceiveCallBack中已经收到来自服务器返回的数据包。 2.问题是客户端MessageManager中的Update并没有拆解该数据包 &#xff0c;因该是因为脚本没有挂载。 挂在SelectMenu场景中的Camera上即可。 挂载后成功达到目地 其中Update中的List是一个起到全局效果的static…

构建 LLM 支持的应用程序

LangChain 教程&#xff1a;构建 LLM 支持的应用程序的指南 一、引言 在当前的科技浪潮中&#xff0c;大型语言模型&#xff08;LLM&#xff09;已经成为引领人工智能发展的重要力量。许多企业和开发者都渴望利用LLM构建出功能强大的应用程序。然而&#xff0c;对于初学者来说…

【七】【SQL】自连接

自连接初见 数据库中的自连接是一种特殊类型的SQL查询&#xff0c;它允许表与自身进行连接&#xff0c;以便查询表中与其他行相关联的行。自连接通常用于处理那些存储在同一个表中的但彼此之间具有层级或关系的数据。为了实现自连接&#xff0c;通常需要给表使用别名&#xff…

CVPR 2024 | Modular Blind Video Quality Assessment:模块化无参视频质量评估

无参视频质量评估 (Blind Video Quality Assessment&#xff0c;BVQA) 在评估和改善各种视频平台并服务用户的观看体验方面发挥着关键作用。当前基于深度学习的模型主要以下采样/局部块采样的形式分析视频内容&#xff0c;而忽视了实际空域分辨率和时域帧率对视频质量的影响&am…

学习 考证 帆软 FCP-FineBI V6.0 心得

学习背景&#xff1a; 自2024年1月起&#xff0c;大部分时间就在家里度过了&#xff0c;想着还是需要充实一下自己&#xff0c;我是一个充满热情的个体。由于之前公司也和帆软结缘&#xff0c;无论是 Fine-Report 和 Fine-BI 都有接触3年之久&#xff0c;但是主要做为管理者并…

多重验证及比特币脚本中的P2PK、P2PKH、P2SH机制

在数字货币的世界中&#xff0c;安全性和有效性是核心要素。其中&#xff0c;二重验证作为一种强化账户安全的重要手段&#xff0c;以及比特币赎回脚本系统中的P2PK、P2PKH、P2SH等交易类型&#xff0c;对于理解区块链技术的底层逻辑和实现方式至关重要。本文将对这些概念进行深…

使用rust实现九九乘法表

rust目前拥有接近c/c的运行速度以及更快的编码支持&#xff0c;所以是很值得学习得一门语言。rust的语法及设计理念与其他的语言也有许多的不同之处。比如其特有的所有权属性。可以让开发者快速的开发出高效的运行程序。对于内存的管理也有极好的管理方案。 在这里使用rust语言…

在Java中,Scanner类是用来获取用户输入的

在Java中&#xff0c;Scanner类是用来获取用户输入的。以下是一个简单的示例&#xff0c;展示如何使用Scanner类从控制台读取用户输入&#xff1a; java import java.util.Scanner; // 导入Scanner类 public class Main { public static void main(String[] args)…

基于jwt -用户离线检测的实现思路

其实思路很简单。就是,用户与系统交互的token。token的拦截时间 - token的创建时间 用户与系统交互的时间差值。只要这个时间差值为负数&#xff0c;就判定为离线。基于此,我们每次与系统交互,都需要重新创建token&#xff0c;从而不断刷新token的创建时间来给下次系统判定来使…

MyBatis复杂映射开发之多对多查询

多对多查询的模型 用户表和角色表的关系为&#xff0c;一个用户有多个角色&#xff0c;一个角色被多个用户使用。 多对多查询的需求&#xff1a;查询所有用户的同时查询出该用户对应的所有角色。 startuml !theme plain top to bottom direction skinparam linetype ortho cl…

C# 在exe中启动另外一个exe时的关闭方法

在C#中&#xff0c;如果你想要从一个exe程序中启动另一个exe程序&#xff0c;并希望在需要时能够关闭它。 一、启动外部exe程序&#xff1a; 使用System.Diagnostics.Process启动程序&#xff0c;代码如下&#xff1a; private void btnStart_Click(object sender, RoutedEve…

阿里云服务器使用教程_搭建网站教程_2024建站教程

使用阿里云服务器快速搭建网站教程&#xff0c;先为云服务器安装宝塔面板&#xff0c;然后在宝塔面板上新建站点&#xff0c;阿里云服务器网aliyunfuwuqi.com以搭建WordPress网站博客为例&#xff0c;来详细说下从阿里云服务器CPU内存配置选择、Web环境、域名解析到网站上线全流…

自然语言处理(NLP)—— 语言学、结构的主要任务

1. 计算语言学的任务 1.1 自然语言处理任务——句法分析任务 1.1.1 词法&#xff08;Syntatic tasks:Word level&#xff09; 在自然语言处理中&#xff0c;词法分析主要涉及到词汇层面的处理&#xff0c;包括形态划分、分词、切分以及词性标注等任务。 1.1.1.1 形态划分&am…

XUbuntu22.04之显示实时网速(二百一十八)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 优质专栏&#xff1a;多媒…