Go语言中数据库操作需显式处理错误，确保程序健壮性。1. 连接错误发生在sql.Open或db.Ping()时，如服务未启动或凭证错误；2. 执行错误需检查Query、Exec等返回的error；3. 结果处理时遍历*sql.Rows后必须调用rows.Err()确认迭代无误；4. 正确做法包括每次调用后判断error，根据场景记录日志或返回；5. 使用defer rows.Close()释放资源，并在循环后检查rows.Err()；6. 事务中出错应立即Rollback，且Commit也可能失败需检查。关键是在每步操作后检查错误、及时释放资源，并区分sql.ErrNoRows等特定错误进行处理。
Go语言中进行数据库操作时，错误处理是确保程序健壮性的关键环节。使用database/sql包与数据库交互时，每一步都可能出错，必须显式检查并处理错误。
理解常见错误来源
数据库操作中的典型错误包括连接失败、SQL语法错误、查询无结果、数据类型不匹配、超时和事务冲突等。
-
连接错误：在调用
sql.Open或db.Ping()时可能发生，比如数据库服务未启动或凭证错误。 -
执行错误：执行
Query、Exec等方法返回的error需立即检查。 -
结果处理错误：遍历
*sql.Rows后必须调用rows.Err()确认迭代过程是否出错。
正确检查和处理错误
每次数据库调用后都应判断error值，并根据场景决定日志记录、重试或向上层返回。
MySQL8 CRM Schema Design Expert
下载
面向 CRM 系统的 MySQL 8 数据库模式设计。当用户需要为客户关系管理（CRM）系统设计、评审、优化或生成数据库模式时，应使用此项技能。
db, err := sql.Open("mysql", dsn)
if err != nil {
log.Fatal("无法打开数据库:", err)
}
defer db.Close()
err = db.Ping()
if err != nil {
log.Fatal("无法连接数据库:", err)
}
var name string
err = db.QueryRow("SELECT name FROM users WHERE id = ?", 1).Scan(&name)
if err != nil {
if err == sql.ErrNoRows {
log.Println("用户不存在")
} else {
log.Printf("查询出错: %v", err)
}
return
}
资源清理与延迟检查
使用rows对象时，务必通过defer rows.Close()释放资源，并在循环结束后检查rows.Err()。
立即学习“go语言免费学习笔记（深入）”；
正确做法：rows, err := db.Query("SELECT name FROM users")
if err != nil {
log.Printf("查询失败: %v", err)
return
}
defer rows.Close()
for rows.Next() {
var name string
if err := rows.Scan(&name); err != nil {
log.Printf("扫描数据失败: %v", err)
continue
}
// 处理 name
}
// 检查迭代过程中是否有错误
if err = rows.Err(); err != nil {
log.Printf("遍历结果出错: %v", err)
}
事务中的错误处理
事务操作中一旦出错，应立即Rollback。注意Commit也可能返回错误。
tx, err := db.Begin()
if err != nil {
log.Printf("开启事务失败: %v", err)
return
}
defer func() {
if p := recover(); p != nil {
tx.Rollback()
panic(p)
} else if err != nil {
tx.Rollback()
}
}()
_, err = tx.Exec("INSERT INTO users(name) VALUES(?)", "alice")
if err != nil {
log.Printf("插入失败: %v", err)
return
}
err = tx.Commit()
if err != nil {
log.Printf("提交事务失败: %v", err)
}
基本上就这些。关键是每次操作后检查错误，合理释放资源，并区分不同类型的错误做相应处理。 
