【Golang学习之旅】Go + MySQL 数据库操作详解

前言

✅ 适合人群：Go 后端开发者 | 数据库开发者 | 想掌握 GORM 的工程师
✅ 文章亮点：从 安装、基础操作、CRUD、事务、索引优化 到 进阶技巧，全面解析 GORM
✅ 目标：掌握 Go 语言 + MySQL（GORM），开发高效数据库应用！

1. GORM简介

GORM是Go语言最流行的ORM框架，它提供了一套强大且简介的数据库操作API，相比database/sql，它具备以下优势：
✅ 代码简洁：无需手写 SQL，使用链式调用
✅ 支持自动迁移：可自动创建和更新数据库表结构
✅ 支持事务、预加载、钩子函数
✅ 支持多种数据库（MySQL、PostgreSQL、SQLite、SQL Server）
✅ 支持软删除、乐观锁、索引管理

2. 安装GORM并连接MySQL

2.1 安装GORM和MySQL驱动

执行以下命令安装 GORM 和 MySQL 依赖：

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

2.2 连接MySQL

在main.go中编写数据库连接代码：

package mainimport ("fmt""gorm.io/driver/mysql""gorm.io/gorm"
)
var DB *gorm.DB  // 全局数据库实例func InitDB() {dsn := "root:password@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=True&loc=Local"var err errorDB, err = gorm.Open(mysql.Open(dsn), &gorm.Config{})if err != nil {panic("数据库连接失败：" + err.Error())}fmt.Println("数据库连接成功！")
}func main() {InitDB()
}

📌 替换 root:password 为你的 MySQL 账号密码，testdb 为数据库名称
📌 确保 MySQL 服务已开启，并且testdb数据库已存在

3. GORM数据模型（Model）

GORM的模型（Model）类似于数据库中的表，每个字段对应表的列。

3.1 定义User结构体

type User struct {ID uint `gorm:"primaryKey"`  // 主键Name string `gorm:"size:100"`  // 名字，最大100字符Age int  // 年龄Email string `gorm:"unique"`  // 邮箱，唯一约束CreateAt time.Time
}

3.2 自动迁移（AutoMigrate）

GORM支持自动迁移，可以自动创建表结构。

package mainimport ("fmt""time""gorm.io/driver/mysql""gorm.io/gorm"
)type User struct {ID       uint   `gorm:"primaryKey"` // 主键Name     string `gorm:"size:100"`   // 名字，最大100字符Age      int    // 年龄Email    string `gorm:"unique"` // 邮箱，唯一约束CreateAt time.Time
}var DB *gorm.DBfunc InitDB() {dsn := "root:password@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=True&loc=Local"var err errorDB, err = gorm.Open(mysql.Open(dsn), &gorm.Config{})if err != nil {panic("❌ 数据库连接失败：" + err.Error())}fmt.Println("✅ 数据库连接成功！")
}func Migrate() {err := DB.AutoMigrate(&User{}) // 自动迁移User表if err != nil {fmt.Println("数据库迁移失败：", err)}else {fmt.Println("数据库迁移成功！")}
}func main() {InitDB()Migrate()
}

📌 运行 go run main.go，会自动创建 users 表！ 🚀

4. GORM CRUD 操作

4.1 插入数据（Create）

package mainimport ("fmt""time""gorm.io/driver/mysql""gorm.io/gorm"
)type User struct {ID       uint   `gorm:"primaryKey"` // 主键Name     string `gorm:"size:100"`   // 名字，最大100字符Age      int    // 年龄Email    string `gorm:"unique"` // 邮箱，唯一约束CreateAt time.Time
}var DB *gorm.DBfunc InitDB() {dsn := "root:123456@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=True&loc=Local"var err errorDB, err = gorm.Open(mysql.Open(dsn), &gorm.Config{})if err != nil {panic("❌ 数据库连接失败：" + err.Error())}fmt.Println("✅ 数据库连接成功！")
}func Migrate() {err := DB.AutoMigrate(&User{}) // 自动迁移User表if err != nil {fmt.Println("数据库迁移失败：", err)} else {fmt.Println("数据库迁移成功！")}
}func CreateUser() {user := User{Name: "Zhangsan", Age: 18, Email: "[e-mail]",CreateAt: time.Now()}result := DB.Create(&user)if result.Error != nil {fmt.Println("数据插入失败", result.Error)} else {fmt.Println("数据插入成功：", user)}
}func main() {InitDB()// Migrate()CreateUser()}

4.2 查询数据（Read）

func GetUserByID(id int) {var user Userresult := DB.First(&user, id)if result.Error != nil {fmt.Println("查询失败：",result.Error)}else {fmt.Println("查询成功：",user)}
}

4.3 更新数据（Update）

func UpdateUser(id int,newAge int) {result :=DB.Model(&User{}).Where("id = ?",id).Update("age",newAge)if result.Error != nil {fmt.Println("数据更新失败：", result.Error)}else {fmt.Println("数据更新成功：", result.RowsAffected,"行")}
}

4.4 删除数据（Delete）

func DeleteUser(id uint) {result := DB.Delete(&User{}, id)if result.Error != nil {fmt.Println("❌ 删除失败:", result.Error)} else {fmt.Println("✅ 删除成功:", result.RowsAffected, "行")}
}

5. 进阶功能：事务 & 关联关系

5.1 事务操作

func TransferFunds(senderID, receiverID uint, amount int) {tx := DB.Begin()  // 开启事务defer func() {if r := recover(); r != nil {tx.Rollback()  // 事务回滚}}()sender := User{}receiver := User{}if err := tx.First(&sender, senderID).Error; err != nil {tx.Rollback()return}if err := tx.First(&receiver, receiverID).Error; err != nil {tx.Rollback()return}// 模拟扣款sender.Age -= amountreceiver.Age += amountif err := tx.Save(&sender).Error; err != nil {tx.Rollback()return}if err := tx.Save(&receiver).Error; err != nil {tx.Rollback()return}tx.Commit()  // 提交事务
}

6. GORM 性能优化

6.1 添加索引

type Product struct {ID       uint   `gorm:"primaryKey"`Name     string `gorm:"index"`  // 索引Price    float64
}

6.2 批量插入

func BatchInsertUsers(users []User) {DB.Create(&users)
}

🎯 总结

✅ 学习了 GORM 基础：安装、连接 MySQL、定义 Model
✅ 掌握了 CRUD 操作：插入、查询、更新、删除
✅ 实现了事务操作，防止数据不一致
✅ 了解了索引优化 & 性能优化

🔥 现在，你已经掌握了 Go + MySQL（GORM）的完整开发流程！ 🚀