悠悠楠杉
网站页面
从零开始用Go操作MySQL：新手实战指南
08/11
一、为什么选择Go操作MySQL？
在Web开发领域，Go语言凭借其高性能和简洁语法，成为后端服务开发的热门选择。而MySQL作为最流行的关系型数据库之一，与Go的搭配堪称黄金组合。通过database/sql标准库，我们可以用不到20行代码实现安全的数据库连接和基本CRUD操作。
go
import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
)
这个看似简单的导入，背后却隐藏着Go的设计哲学——通过接口抽象和驱动分离实现扩展性。
二、实战四步曲
2.1 建立数据库连接
创建连接时需要注意三个关键点：
1. 使用格式正确的DSN（数据源名称）
2. 务必处理连接错误
3. 设置合理的连接池参数
go
db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/dbname?charset=utf8mb4&parseTime=True")
if err != nil {
log.Fatal(err)
}
// 重要配置
db.SetMaxOpenConns(25)
db.SetMaxIdleConns(5)
db.SetConnMaxLifetime(5 * time.Minute)
特别提醒：生产环境一定要配置连接池！默认设置可能导致连接泄漏。
2.2 基础CRUD操作
查询数据时的三个层级：
- 单行查询：
QueryRow() - 多行查询：
Query() - 预编译语句：
Prepare()
go
// 预编译示例
stmt, err := db.Prepare("SELECT name FROM users WHERE id = ?")
if err != nil {
log.Fatal(err)
}
defer stmt.Close()
var name string
err = stmt.QueryRow(5).Scan(&name)
插入操作时务必使用参数化查询，防止SQL注入：
go
result, err := db.Exec(
"INSERT INTO users (name, email) VALUES (?, ?)",
"张三",
"zhangsan@example.com"
)
2.3 事务处理
Go的事务模型非常直观：
go
tx, err := db.Begin()
if err != nil {
log.Fatal(err)
}
// 在事务中执行操作
_, err = tx.Exec("UPDATE accounts SET balance = balance - ? WHERE id = ?", 100, 1)
if err != nil {
tx.Rollback()
return
}
_, err = tx.Exec("UPDATE accounts SET balance = balance + ? WHERE id = ?", 100, 2)
if err != nil {
tx.Rollback()
return
}
err = tx.Commit()
关键点：一定要处理Rollback和错误，否则可能导致连接泄漏。
2.4 使用ORM简化操作
对于复杂业务场景，推荐使用GORM：
go
type Product struct {
gorm.Model
Code string
Price uint
}
// 自动迁移
db.AutoMigrate(&Product{})
// 创建记录
db.Create(&Product{Code: "D42", Price: 100})
// 查询
var product Product
db.First(&product, "code = ?", "D42")
GORM的优势在于：
- 结构体自动映射
- 链式调用
- 关联查询
- 钩子函数
三、性能优化要点
- 连接复用：避免频繁Open/Close
- 批量操作：使用
IN语句替代循环查询 - 索引优化：EXPLAIN分析慢查询
- 连接监控：定期检查
SHOW STATUS LIKE 'Threads%'
go
// 批量插入最佳实践
valueStrings := make([]string, 0, len(users))
valueArgs := make([]interface{}, 0, len(users)*3)
for _, u := range users {
valueStrings = append(valueStrings, "(?, ?, ?)")
valueArgs = append(valueArgs, u.Name, u.Email, u.Age)
}
stmt := fmt.Sprintf("INSERT INTO users (name, email, age) VALUES %s",
strings.Join(valueStrings, ","))
db.Exec(stmt, valueArgs...)
四、常见坑与解决方案
- 时区问题：在DSN中添加
loc=Local - NULL值处理：使用
sql.NullString等类型 - 长连接超时：设置
interpolateParams=true - 字符集乱码：统一使用
utf8mb4
结语：Go与MySQL的组合既保留了SQL的灵活性，又通过标准库提供了类型安全。建议从原生SQL开始理解底层机制，再逐步过渡到ORM。记住，好的数据库操作不仅要正确，更要考虑连接管理和查询性能。
