在Golang中进行数据库操作时，必须始终检查error以确保程序健壮性。1. 每次数据库调用如db.Query、db.Exec等都需判断返回的error，防止因连接失败、超时等问题导致程序崩溃。2. 区分错误类型：sql.ErrNoRows表示查询无结果，可特殊处理；driver.ErrBadConn表示连接损坏，应触发重试或重连。3. 对于唯一约束、外键冲突等数据库特定错误，需通过类型断言解析底层错误码，如MySQL的1062（重复键）、1452（外键失败）。4. 建议封装错误并添加上下文信息（SQL语句、参数），使用fmt.Errorf与%w保留错误链，便于日志记录和上层分析。关键在于养成主动查错习惯，并根据场景细化处理策略。
在Golang中进行数据库操作时，错误处理是确保程序健壮性的关键环节。Go语言没有异常机制，所有错误都通过返回的error类型显式暴露，因此必须主动检查和处理。特别是在使用database/sql包与MySQL、PostgreSQL等数据库交互时，正确捕获和判断错误类型至关重要。
1. 基本错误检查：每次操作后都要判断error
任何数据库调用都可能出错，比如连接失败、查询语法错误、超时等。最基础的做法是在每次操作后检查返回的error。
例如执行查询：
rows, err := db.Query("SELECT name FROM users WHERE id = ?", userID)if err != nil { log.Printf("查询失败: %v", err) return}defer rows.Close()
注意：db.Query、db.Exec、db.Prepare等方法都会返回error，必须检查。即使语句看似正确，也可能因网络、权限、连接池耗尽等问题失败。
立即学习“go语言免费学习笔记（深入）”；
2. 区分不同类型的数据库错误
不是所有错误都需要相同处理方式。常见需要区分的错误包括：
记录不存在（如NoRows） 连接错误或超时 唯一约束冲突（如重复主键） SQL语法错误
对于db.QueryRow().Scan()，当查询没有匹配行时，会返回sql.ErrNoRows，这是常见且可预期的错误，可以特殊处理：
var name stringerr := db.QueryRow("SELECT name FROM users WHERE id = ?", 999).Scan(&name)if err != nil { if err == sql.ErrNoRows { log.Println("用户不存在") } else { log.Printf("查询出错: %v", err) } return}
3. 使用driver.ErrBadConn触发重试逻辑
某些底层驱动错误（如连接中断）可以通过重试恢复。Go的database/sql接口允许你识别这类可恢复错误。
如果一个函数返回driver.ErrBadConn，则表示连接已损坏，应断开并重建连接或重试操作。
_, err := db.Exec("INSERT INTO ...")if err != nil { if errors.Is(err, driver.ErrBadConn) { log.Println("连接异常，建议重试") // 可在此触发重连或重试逻辑 }}
注意：实际项目中可结合重试库（如github.com/cenkalti/backoff）实现自动重试机制。
4. 判断唯一约束等数据库特定错误
像“重复键”、“外键约束”这类错误来自数据库底层，Go本身不提供统一枚举，需根据驱动解析错误信息。
以MySQL为例，插入重复主键通常返回类似ERROR 1062 (23000): Duplicate entry的错误：
_, err := db.Exec("INSERT INTO users(id, name) VALUES(?, ?)", 1, "Alice")if err != nil { if mysqlErr, ok := err.(*mysql.MySQLError); ok { switch mysqlErr.Number { case 1062: log.Println("该ID已存在") case 1452: log.Println("外键约束失败") default: log.Printf("MySQL错误: %v", mysqlErr) } }}
使用github.com/go-sql-driver/mysql时，可通过类型断言获取具体错误码。PostgreSQL可使用github.com/lib/pq中的pq.Error结构做类似判断。
5. 统一错误封装与日志记录
为了便于调试和监控，建议对数据库错误进行封装，加入上下文信息（如SQL语句、参数、时间戳）。
func queryUser(db *sql.DB, id int) (string, error) { const sql = "SELECT name FROM users WHERE id = ?" var name string err := db.QueryRow(sql, id).Scan(&name) if err != nil { if err == sql.ErrNoRows { return "", fmt.Errorf("用户未找到 (id=%d)", id) } return "", fmt.Errorf("执行SQL失败 [%s] 参数=%d: %w", sql, id, err) } return name, nil}
这样上层调用者既能知道发生了什么，也能通过%w保留原始错误链，方便后续用errors.Is或errors.As分析。
基本上就这些。关键是养成“每次操作必查error”的习惯，并根据场景细化处理策略。
以上就是如何在Golang中捕获数据库操作错误_Golang数据库操作错误处理方法汇总的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1418523.html
微信扫一扫 
支付宝扫一扫 
