Go语言database/sql：动态获取SQL查询结果的列类型信息

package main

import (
    "database/sql"
    "fmt"
    "log"
    "reflect" // 用于获取ScanType的实际类型

    _ "github.com/go-sql-driver/mysql" // 示例使用MySQL驱动，请根据您的数据库选择合适的驱动
)

func main() {
    // 假设您已经有了一个数据库连接。
    // 请替换为您的数据库连接字符串。
    // 例如： "user:password@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=true"
    db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/testdb")
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    defer db.Close()

    // 尝试ping数据库以确保连接有效
    err = db.Ping()
    if err != nil {
        log.Fatalf("无法ping数据库: %v", err)
    }
    fmt.Println("成功连接到数据库！")

    // 准备一个示例表和数据
    // 请确保您的testdb中存在一个名为'users'的表，或根据需要修改SQL
    // 示例表结构：
    // CREATE TABLE users (
    //     id INT AUTO_INCREMENT PRIMARY KEY,
    //     name VARCHAR(255) NOT NULL,
    //     age INT,
    //     email VARCHAR(255) UNIQUE,
    //     created_at DATETIME DEFAULT CURRENT_TIMESTAMP
    // );
    // INSERT INTO users (name, age, email) VALUES ('Alice', 30, 'alice@example.com'), ('Bob', 25, 'bob@example.com'), ('Charlie', 35, NULL);

    // 示例查询
    query := "SELECT id, name, age, email, created_at FROM users WHERE age > ?"
    rows, err := db.Query(query, 20)
    if err != nil {
        log.Fatalf("查询失败: %v", err)
    }
    defer rows.Close()

    // 获取列类型信息
    columnTypes, err := rows.ColumnTypes()
    if err != nil {
        log.Fatalf("获取列类型失败: %v", err)
    }

    fmt.Println("\n--- 列类型信息 ---")
    for _, ct := range columnTypes {
        fmt.Printf("列名: %s\n", ct.Name())
        fmt.Printf("数据库原生类型: %s\n", ct.DatabaseTypeName())
        fmt.Printf("Go语言扫描类型: %v\n", ct.ScanType()) // reflect.Type
        if ct.ScanType() != nil {
            fmt.Printf("Go语言扫描类型名称: %s\n", ct.ScanType().Name())
            fmt.Printf("Go语言扫描类型包路径: %s\n", ct.ScanType().PkgPath())
        }

        nullable, ok := ct.Nullable()
        if ok {
            fmt.Printf("可为空: %t\n", nullable)
        }
        length, ok := ct.Length()
        if ok {
            fmt.Printf("最大长度: %d\n", length)
        }
        precision, scale, ok := ct.DecimalSize()
        if ok {
            fmt.Printf("精度: %d, 小数位数: %d\n", precision, scale)
        }
        fmt.Println("--------------------")
    }

    // 动态扫描数据
    // 1. 获取列名，用于构建map的键
    columns, err := rows.Columns()
    if err != nil {
        log.Fatalf("获取列名失败: %v", err)
    }

    // 2. 创建一个切片来存储每一行的值
    // 每个元素是一个interface{}的指针，用于Scan方法接收数据
    values := make([]interface{}, len(columns))
    scanArgs := make([]interface{}, len(columns))
    for i := range values {
        scanArgs[i] = &values[i] // 将每个interface{}的地址存入scanArgs
    }

    fmt.Println("\n--- 查询结果数据 ---")
    var results []map[string]interface{}
    for rows.Next() {
        err = rows.Scan(scanArgs...)
        if err != nil {
            log.Fatalf("扫描行数据失败: %v", err)
        }

        rowMap := make(map[string]interface{})
        for i, colName := range columns {
            val := values[i] // 获取扫描到的原始值

            // 处理 NULL 值和类型转换
            // database/sql会将NULL值扫描为nil
            // 非nil值可能是[]byte、string、int64、time.Time等
            // 根据ScanType()或DatabaseTypeName()进行更精细的类型断言和转换
            if val == nil {
                rowMap[colName] = nil
            } else {
                // 示例：将可能的[]byte转换为string
                if b, ok := val.([]byte); ok {
                    rowMap[colName] = string(b)
                } else {
                    rowMap[colName] = val
                }
            }
        }
        results = append(results, rowMap)
        fmt.Printf("行数据: %v\n", rowMap)
    }

    if err = rows.Err(); err != nil {
        log.Fatalf("遍历行时发生错误: %v", err)
    }

    fmt.Printf("\n所有结果: %v\n", results)
}