// 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 // 一、查询一系列值 // 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) } // 二、查询一条记录 // 查询一条记录时, 不能使用相似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) // 三、关于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) }