在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 string
err := 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分析。
