Go 扫描未知列数结果时怎么动态分配接收变量

我们用Go操作数据库执行查询时，如果返回的结果列数提前不确定、没法预先定义好固定的结构体字段来接收，完全可以通过database/sql包提供的原生接口动态生成接收变量，不需要提前硬编码适配不同的返回结构。

拿到结果集之后先调用Rows.Columns()方法获取当前结果的列名列表，就能得到总列数，动态创建对应数量的元素指针切片，把这个切片转成interface{}类型直接传给Scan方法，就能自动把所有列的数据读进去，不需要提前定义固定数量的接收变量。

当 SQL 是动态拼接的报表、插件查询或管理后台的自定义字段时，程序往往事先不知道返回多少列。此时不要为每一列预先声明变量，也不要把 ColumnTypes() 当成必须存在的类型系统。更稳妥的做法是先用 Columns() 取得列名，再按列数创建 *any 接收变量，交给 Rows.Scan；这样数据库返回的 NULL 仍可保留为 nil。

先用 Columns 确定动态接收槽位

Rows.Scan 不要求接收变量拥有固定的 Go 类型，但要求参数个数与当前结果集的列数相同。因此第一步只取列名并创建两个同长度切片：一个保存值，一个保存传给 Scan 的指针。每轮循环重新填充接收指针，避免把上一行的地址带到下一行。

func scanRows(rows *sql.Rows) ([]map[string]any, error) {
	// 列数来自结果集，不在代码里写死字段数量。
	columns, err := rows.Columns()
	if err != nil {
		return nil, err
	}

	result := make([]map[string]any, 0)
	for rows.Next() {
		values := make([]any, len(columns))
		receivers := make([]any, len(columns))
		for i := range values {
			// *any 能接住普通值和 NULL；Scan 会把结果写入 values[i]。
			receivers[i] = &values[i]
		}
		if err := rows.Scan(receivers...); err != nil {
			return nil, err
		}

		row := make(map[string]any, len(columns))
		for i, name := range columns {
			row[name] = values[i]
		}
		result = append(result, row)
	}
	// Next 返回 false 可能是读完，也可能是迭代途中出错。
	if err := rows.Err(); err != nil {
		return nil, err
	}
	return result, nil
}

这里的关键不是反射，而是把 receivers 构造成 []any 后展开传参。数据库驱动常见的基础值会被 database/sql 放进接口；如果源值是 NULL，对应的 values[i] 就是 nil，调用方可以据此区分“没有值”和空字符串。

ColumnTypes 适合做提示，不适合替代 Scan

如果需要生成表头、记录驱动类型或判断某列是否可能为 NULL，可以在进入循环前调用 ColumnTypes()。它会返回列名、数据库类型名、长度、可空性和适合扫描的 Go 类型等信息，但官方文档明确提示，部分信息取决于驱动实现。

types, err := rows.ColumnTypes()
if err != nil {
	return nil, err
}
for i, column := range types {
	// ScanType 可能只是 interface{}，不能据此强行转换所有值。
	nullable, known := column.Nullable()
	fmt.Printf("%s: %s nullable=%v known=%v\n",
		column.Name(), column.DatabaseTypeName(), nullable, known)
	_ = i // 这里可把元数据写入表头或审计记录。
}

通用结果读取建议仍然使用 *any。如果业务明确要求时间、金额或布尔值，就在得到列名后按列名做小范围转换；不要因为某个驱动返回了 *int64 就对所有数据库和所有 NULL 情况做硬编码。

动态扫描最容易漏掉的三个检查

实际调用函数时，查询成功后应立即关闭结果集：

rows, err := db.QueryContext(ctx, query, args...)
if err != nil {
	return err
}
defer rows.Close() // 及时释放连接相关资源。

records, err := scanRows(rows)
if err != nil {
	return err
}
fmt.Println(records)

相关问题

为什么不能直接把一个 map 传给 Scan？

Scan 需要每一列对应一个可写入的接收目标，map 本身既没有按列展开，也不提供指针位置；应先建切片，Scan 成功后再按列名组装 map。

ColumnTypes().ScanType 能不能直接生成所有接收变量？

可以在受控驱动环境中辅助生成，但它可能返回空接口类型，且类型信息不等于该行一定非 NULL。通用查询层优先使用 *any，强类型转换放到业务边界。

[]byte 结果能不能长期保存？

用 *any 接收时由 database/sql 按接口规则处理；若改用 sql.RawBytes，必须遵守其只在下一次 Scan 前有效的生命周期，长期保存要复制。