Golang操作MySQL实现增删改查教程

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《Golang操作MySQL实现CRUD教程》，文章讲解的知识点主要包括，如果你对Golang方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

本文介绍了使用 Go 的 database/sql 包操作 MySQL 实现 CRUD 的方法。1. 安装 go-sql-driver/mysql 驱动并正确导入；2. 使用 sql.Open 初始化连接池并通过 db.Ping 检测连接，合理设置连接数限制；3. 查询时使用 db.Query 或 db.QueryRow，并注意资源释放和字段匹配；4. 插入数据使用 db.Exec 并获取插入 ID，建议用结构体管理参数；5. 更新和删除同样使用 db.Exec，注意 WHERE 条件避免误删；6. 严格处理错误、防止 SQL 注入、并发控制及日志记录是关键保障措施。

刚开始学 Golang 的时候，操作数据库是个绕不开的环节。MySQL 是一个很常见的选择，而 Go 标准库中的 database/sql 提供了很好的支持。虽然它本身不包含具体的驱动实现，但配合像 go-sql-driver/mysql 这样的第三方驱动，可以很好地完成 CRUD 操作。

下面我们就一步步来看看怎么用 database/sql 实现对 MySQL 的增删改查。

安装依赖和连接数据库

要使用 MySQL，首先得安装对应的驱动：

go get -u github.com/go-sql-driver/mysql

然后在代码中导入：

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
)

连接数据库时需要构造 DSN（Data Source Name），格式大致如下：

dsn := "user:password@tcp(127.0.0.1:3306)/dbname"
db, err := sql.Open("mysql", dsn)
if err != nil {
    log.Fatal(err)
}

这里需要注意几点：

• sql.Open 并不会立即建立连接，只是初始化了一个连接池
• 真正测试连接是否正常可以用 db.Ping() 方法
• 建议设置最大打开连接数和最大空闲连接数，比如：

db.SetMaxOpenConns(20)
db.SetMaxIdleConns(10)

查询数据（Read）

查询是最常见的操作之一。基本流程是准备 SQL、执行查询、遍历结果：

rows, err := db.Query("SELECT id, name FROM users WHERE age > ?", 18)
if err != nil {
    log.Fatal(err)
}
defer rows.Close()

for rows.Next() {
    var id int
    var name string
    if err := rows.Scan(&id, &name); err != nil {
        log.Fatal(err)
    }
    fmt.Println(id, name)
}

几点建议：

• 记得调用 rows.Close() 避免资源泄露
• 使用 rows.Scan 时要注意字段顺序和类型匹配
• 如果只期望一行结果，可以用 db.QueryRow 更简洁

插入数据（Create）

插入操作通常使用 Exec 方法，返回的是 sql.Result，里面包含最后插入 ID 和受影响行数：

result, err := db.Exec("INSERT INTO users (name, email) VALUES (?, ?)", "Tom", "tom@example.com")
if err != nil {
    log.Fatal(err)
}

lastID, _ := result.LastInsertId()
fmt.Println("Last inserted ID:", lastID)

注意事项：

• 字段多的时候建议使用结构体绑定参数，避免写错顺序
• 可以使用命名参数库（如 sqlx）来提升可读性，但原生库不支持

更新和删除（Update & Delete）

更新和删除本质上都是“写”操作，使用方式类似：

res, err := db.Exec("UPDATE users SET name = ? WHERE id = ?", "Jerry", 1)
if err != nil {
    log.Fatal(err)
}

rowsAffected, _ := res.RowsAffected()
fmt.Println("Rows affected:", rowsAffected)

删除操作同理：

res, err := db.Exec("DELETE FROM users WHERE id = ?", 1)

注意点：

• 一定要小心 WHERE 条件，尤其是 DELETE 操作
• 测试环境建议加事务或备份机制，防止误删

处理错误和常见问题

Go 中处理数据库错误非常重要。例如：

• 查询时如果字段名拼错了，Scan 会报错
• 如果传参类型不匹配，也可能导致执行失败

建议的做法：

• 每次调用都检查 error
• 使用 log.Fatal 或自定义日志记录来定位问题
• 开启慢查询日志，排查性能瓶颈

另外一些容易出错的地方：

• 忘记关闭 rows
• 没有正确使用占位符导致 SQL 注入风险
• 多个 goroutine 共享连接池时没有合理控制并发

基本上就这些内容了。刚上手的时候可能觉得有点繁琐，但熟悉之后你会发现 database/sql 虽然不提供 ORM 功能，但它足够灵活，也更容易掌控底层行为。只要注意好错误处理和连接管理，CRUD 操作其实并不复杂。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~