Golang数据库操作出错如何处理

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值，并根据场景决定日志记录、重试或向上层返回。

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()。

成新网络商城购物系统

使用模板与程序分离的方式构建，依靠专门设计的数据库操作类实现数据库存取，具有专有错误处理模块，通过 Email 实时报告数据库错误，除具有满足购物需要的全部功能外，成新商城购物系统还对购物系统体系做了丰富的扩展，全新设计的搜索功能，自定义成新商城购物系统代码功能代码已经全面优化，杜绝SQL注入漏洞前台测试用户名：admin密码：admin888后台管理员名：admin密码：admin888

下载

立即学习“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)
}