Go语言针对MySQL数据查询的错误处理方式

// Go语言针对MySQL数据查询的错误处理方式
package main
import (
 "database/sql"
 "fmt"
 "runtime"
)
// go run test.go
func main() {
 // mysql扩展 https://github.com/go-sql-driver/mysql
 db, err := sql.Open("mysql", "root:@tcp(127.0.0.1:3306)/test?charset=utf8")
 if err != nil {
 fmt.Println(err)
 }
 // db连接一般不主动关闭, 除非确认确实不再需要该连接了, go会进行回收
 defer db.Close()
 
 // 用户模型, 表结构, 需要一个结构来接收查询结果集
 type User struct {
 Id int32
 Name string
 Age int8
 }
 
 // 保存用户信息列表
 var user User
 
 // 1、查询一系列值
 // Query结果集需要调用Next()方法进行逐条遍历
 rows, err := db.Query(`
 SELECT id,name,age FROM user
 `)
 if err != nil {
 fmt.Println(err)
 }
 defer rows.Close()
 for rows.Next() {
 // 对于遍历, 只需要判断每次是否有错误产生即可
 // 参数绑定需要数量和位置一一对应
 if err := rows.Scan(&user.Id, &user.Name, &user.Age); err != nil {
 fmt.Println(err)
 continue
 }
 fmt.Println(user.Id, user.Name, user.Age)
 }
 // 处理完毕后, 需要在判断一次遍历过程中是否有错误产生
 if err := rows.Err(); err != nil {
 fmt.Println(err)
 }
 
 // 2、查询一条记录
 // 查询一条记录时, 不能使用类似if err := db.QueryRow().Scan(&...); err != nil {}的处理方式
 // 因为查询单条数据时, 可能返回var ErrNoRows = errors.New("sql: no rows in result set")该种错误信息
 // 而这属于正常错误
 err = db.QueryRow(`
 SELECT id,name,age WHERE id = ?
 `, 2).Scan(
 &user.Id, &user.Name, &user.Age,
 )
 switch {
 case err == sql.ErrNoRows:
 case err != nil:
 // 使用该方式可以打印出运行时的错误信息, 该种错误是编译时无法确定的
 if _, file, line, ok := runtime.Caller(0); ok {
 fmt.Println(err, file, line)
 }
 }
 fmt.Println(user.Id, user.Name, user.Age)
 
 // 3、关于NULL
 // 所有查询出来的字段都不允许有NULL, 避免该方式最好的办法就是建表字段时, 不要设置类似DEFAULT NULL属性
 // 还有一些无法避免的情况, 比如下面这个查询
 // 该种查询, 如果不存在, 返回值为NULL, 而非0, 针对该种简单的查询, 直接使用HAVING子句即可
 // 具体的查询, 需要在编码的过程中自行处理
 var age int32
 err = db.QueryRow(`
 SELECT
 SUM(age) age
 FROM user
 WHERE id = ?
 HAVING age <> NULL
 `, 10).Scan(&age)
 switch {
 case err == sql.ErrNoRows:
 case err != nil:
 fmt.Println(err)
 }
 fmt.Println(age)
}

本文来自:Segmentfault

感谢作者:广训

查看原文:Go语言针对MySQL数据查询的错误处理方式

• 编辑
• 预览