// 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)
}