登录
推荐 文章 Go 技术 课程 下载 专题 AI
首页 >  Golang >  Go教程

Go SQLX 怎样把多个结果行扫描成字符串切片

来源:17golang原创

时间:2026-10-29 20:18:52 169浏览 收藏

用 Go SQLX 查询一列、多行结果时,最省事的写法是把目标变量声明为 []string,再交给 db.Select:它会把每一行的第一列扫描到切片元素中。这个方案适合结果集规模可控、只需要最终切片的场景;如果需要边读边处理,就改用 Queryx 手动遍历。

官方地址:https://github.com/jmoiron/sqlx

结论:单列多行用 Select(&names, query);需要流式处理、区分空值或控制资源时,用 Queryx 加 rows.Scan,最后检查 rows.Err()。

先确认查询列和 Go 目标类型

SQLX 建立在标准库 database/sql 之上,官方 README 将 Select 定义为从查询快速得到结构体或切片。要映射成字符串切片,查询最好只返回一个文本列,例如标签名、用户名或状态码。不要直接使用 SELECT *,因为列数一变,扫描目标就可能不再匹配。

-- 只返回需要映射到 []string 的一列,并固定顺序
SELECT name
FROM tags
WHERE enabled = TRUE
ORDER BY name;

如果数据库列允许 NULL,目标类型不应盲目写成 string,后文会给出 sql.NullString 的处理方式。

用 Select 直接得到字符串切片

结果量不大时,Select 能把查询和扫描合成一个清晰的调用。切片会按结果行顺序追加,查询中的 ORDER BY 决定最终顺序;查询失败时直接返回错误,不要把半成品切片当作成功结果。

package main

import (
    "context"
    "fmt"

    "github.com/jmoiron/sqlx"
)

func loadTagNames(ctx context.Context, db *sqlx.DB) ([]string, error) {
    var names []string

    // 只查询一列;Select 会把多行逐个扫描到 []string。
    const query = `
        SELECT name
        FROM tags
        WHERE enabled = TRUE
        ORDER BY name`

    // Context 让调用方可以取消查询,错误必须向上返回。
    if err := db.SelectContext(ctx, &names, query); err != nil {
        return nil, fmt.Errorf("load tag names: %w", err)
    }
    return names, nil
}

这个写法的关键是目标变量的形状:&names 是切片地址,SQLX 根据单列结果把每一行转换为一个字符串。零行时通常得到空切片或 nil 切片,业务层只要把它当作“没有匹配项”即可,不必把零行误判成数据库故障。

SQLX Select 将 SELECT name 的 Rows 通过 Scanner 映射到 []string 的静态结构说明图
图1:结构说明图,查看单列查询结果如何映射到字符串切片。

需要逐行处理时改用 Queryx

如果结果可能很大,或者每行还要做过滤、去重、写入下游,就不要强制一次性构造完整切片。Queryx 返回可遍历的结果集,循环中使用 Scan 读取当前行;退出后关闭 rows,并检查 rows.Err(),这样网络读取或驱动层错误不会被静默吞掉。

func streamTagNames(ctx context.Context, db *sqlx.DB, consume func(string) error) error {
    const query = `SELECT name FROM tags WHERE enabled = TRUE ORDER BY name`

    // QueryxContext 返回结果集;函数结束前必须释放数据库资源。
    rows, err := db.QueryxContext(ctx, query)
    if err != nil {
        return fmt.Errorf("query tag names: %w", err)
    }
    defer rows.Close()

    for rows.Next() {
        var name string
        // 单列结果只扫描到一个 string 变量。
        if err := rows.Scan(&name); err != nil {
            return fmt.Errorf("scan tag name: %w", err)
        }
        // 消费者的错误也要停止遍历并返回。
        if err := consume(name); err != nil {
            return fmt.Errorf("consume tag name: %w", err)
        }
    }
    // Next 返回 false 既可能是读完,也可能是中途发生了驱动错误。
    if err := rows.Err(); err != nil {
        return fmt.Errorf("iterate tag names: %w", err)
    }
    return nil
}

手动遍历的代价是代码更长,但内存峰值不再随着全部结果行一起增长。它适合导出、批量写入和长列表处理;如果业务最终仍然必须返回 []string,那就继续 append,并预留一个合理容量。

SQLX Queryx、Rows、Scan、Close 和 Err 的资源与错误边界静态结构说明图
图2:结构说明图,查看手动遍历时的资源释放与错误边界。

NULL、空结果和扫描错误要分开处理

数据库 NULL 不是空字符串。如果 name 可能为 NULL,直接扫描到 string 可能返回转换错误。此时用 sql.NullString 接住空值,再由业务决定跳过、替换还是保留。

func loadNullableNames(ctx context.Context, db *sqlx.DB) ([]string, error) {
    var result []string
    rows, err := db.QueryxContext(ctx, `SELECT name FROM tags ORDER BY id`)
    if err != nil {
        return nil, err
    }
    defer rows.Close()

    for rows.Next() {
        var value sql.NullString
        // NullString 同时保存字符串值和 Valid,避免把 NULL 假装成空文本。
        if err := rows.Scan(&value); err != nil {
            return nil, err
        }
        if value.Valid {
            result = append(result, value.String)
        }
    }
    if err := rows.Err(); err != nil {
        return nil, err
    }
    return result, nil
}

可以用三个问题快速判断结果:查询本身是否成功、结果是否为零行、每一行是否能转换成目标类型。它们分别对应查询返回的 error、遍历后切片为空,以及 Scan 或 rows.Err() 的错误,不要用“切片为空”代替全部故障判断。

常见问题

为什么不用 StructScan? 这篇场景只有一列字符串,直接使用 Select 或 Scan 更贴合目标;多列结果再定义结构体并使用 StructScan。

Select 还是 Queryx? 最终只要一个小切片就用 Select;需要流式消费、处理 NULL 或控制每行逻辑时用 Queryx。

只查询一行怎么办? 使用 GetContext 配合一个 string 变量,不必为单行结果建立切片。

小结

  • 单列、多行、结果量可控:SelectContext(ctx, &names, query)。
  • 长结果或需要逐行处理:QueryxContext、Scan、Close、Err 成套使用。
  • 允许 NULL:用 sql.NullString 显式处理空值语义。
声明:本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>