本文介绍了使用 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语言免费学习笔记（深入）”；
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初学者如何操作MySQL 使用database/sql实现CRUD功能的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1395701.html
微信扫一扫 
支付宝扫一扫 
