在Go语言的后端开发中，使用标准库的database/sql包操作关系型数据库时，查询多个数据库字段并正确处理返回结果是高频需求。无论是查询用户信息、订单数据还是业务配置，都需要将数据库返回的多个字段准确映射到程序的结构体中，同时处理可能出现的空值、类型不匹配等问题。
前期准备
首先需要导入对应的数据库驱动，以MySQL为例，需要导入database/sql和对应的驱动包，这里使用github.com/go-sql-driver/mysql作为驱动，注意驱动包只需要匿名导入即可。
import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql"
)
建立数据库连接
使用sql.Open函数创建数据库连接池，第一个参数是驱动名称，第二个是连接字符串，连接字符串需要包含用户名、密码、数据库地址、数据库名等信息。
func initDB() (*sql.DB, error) {
// 连接字符串格式：用户名:密码@tcp(地址:端口)/数据库名
dsn := "root:123456@tcp(127.0.0.1:3306)/test_db"
db, err := sql.Open("mysql", dsn)
if err != nil {
return nil, err
}
// 验证连接是否正常
err = db.Ping()
if err != nil {
return nil, err
}
return db, nil
}
定义对应结构体
查询多个字段时，建议先定义和数据库表字段对应的结构体，结构体的字段类型需要和数据库字段类型匹配，同时可以通过db标签指定字段对应的数据库列名，如果列名和结构体字段名一致（忽略大小写），标签可以省略。
假设我们有一个用户表user，包含id、username、age、email四个字段，对应的结构体定义如下：
type User struct {
ID int `db:"id"`
Username string `db:"username"`
Age int `db:"age"`
Email *string `db:"email"` // 邮箱可能为空，使用指针类型处理空值
}
执行多字段查询并处理结果
查询单条记录
如果只需要查询一条记录，可以使用QueryRow方法，然后通过Scan方法将字段值依次赋值给变量或者结构体字段，Scan的参数顺序需要和查询的字段顺序完全一致。
func querySingleUser(db *sql.DB, userId int) (*User, error) {
var user User
// 查询id、username、age、email四个字段
sqlStr := "SELECT id, username, age, email FROM user WHERE id = ?"
// QueryRow执行查询，Scan接收字段值
err := db.QueryRow(sqlStr, userId).Scan(&user.ID, &user.Username, &user.Age, &user.Email)
if err != nil {
return nil, err
}
return &user, nil
}
查询多条记录
如果需要查询多条记录，使用Query方法，返回*sql.Rows结果集，然后通过Next方法遍历每一行，每一行同样使用Scan方法获取字段值，遍历结束后需要关闭结果集。
func queryMultiUser(db *sql.DB) ([]User, error) {
var userList []User
sqlStr := "SELECT id, username, age, email FROM user WHERE age > ?"
// 执行查询
rows, err := db.Query(sqlStr, 18)
if err != nil {
return nil, err
}
// 函数结束前关闭结果集，避免资源泄漏
defer rows.Close()
// 遍历结果集
for rows.Next() {
var user User
// 扫描当前行的字段值
err := rows.Scan(&user.ID, &user.Username, &user.Age, &user.Email)
if err != nil {
return nil, err
}
userList = append(userList, user)
}
// 检查遍历过程中是否有错误
if err := rows.Err(); err != nil {
return nil, err
}
return userList, nil
}
注意事项
- 字段类型匹配：数据库字段类型和Go变量类型需要兼容，比如数据库的INT类型对应Go的int，VARCHAR对应string，如果类型不匹配会导致
Scan报错。 - 空值处理：数据库字段如果允许为空，对应的Go变量需要使用指针类型或者
sql.NullXXX类型，比如sql.NullString、sql.NullInt64，否则空值会导致扫描错误。 - 字段顺序：
Scan方法的参数顺序必须和查询SQL中的字段顺序完全一致，否则会出现字段值错乱的问题。 - 结果集关闭：使用
Query查询后，必须调用rows.Close()关闭结果集，建议使用defer语句确保关闭操作执行。
示例：使用sql.NullString处理空值
如果不想使用指针类型处理空值，也可以使用sql包提供的NullXXX类型，以下是使用sql.NullString处理邮箱空值的示例：
type User2 struct {
ID int
Username string
Age int
Email sql.NullString // 对应可空的VARCHAR字段
}
func queryUserWithNull(db *sql.DB, userId int) (*User2, error) {
var user User2
sqlStr := "SELECT id, username, age, email FROM user WHERE id = ?"
err := db.QueryRow(sqlStr, userId).Scan(&user.ID, &user.Username, &user.Age, &user.Email)
if err != nil {
return nil, err
}
// 判断邮箱是否有效
if user.Email.Valid {
fmt.Printf("用户邮箱：%sn", user.Email.String)
} else {
fmt.Println("用户邮箱为空")
}
return &user, nil
}
database/sqlGoSQL查询多字段处理数据库操作修改时间：2026-06-24 00:09:30