Go语言中将MySQL行数据映射到结构体：数据类型处理与扫描实践

CREATE TABLE products (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(255) NOT NULL,
    is_match TINYINT(1) NOT NULL,
    created DATETIME NOT NULL
);

package main

import (
    "database/sql"
    "fmt"
    "time" // 引入time包
    _ "github.com/go-sql-driver/mysql" // 引入MySQL驱动
)

type Product struct {
    Id      int64
    Name    string
    IsMatch bool      // tinyint(1) 映射为 bool
    Created time.Time // datetime 映射为 time.Time
}

// ... main 函数和数据库连接部分

type Product struct {
    Id      int64
    Name    string
    IsMatch sql.NullBool
    Created sql.NullTime
}

package main

import (
    "database/sql"
    "fmt"
    "log"
    "time"

    _ "github.com/go-sql-driver/mysql"
)

// Product 结构体定义
type Product struct {
    Id      int64
    Name    string
    IsMatch bool
    Created time.Time
}

func main() {
    // 数据库连接字符串，注意添加 parseTime=true
    // 假设数据库名为 product_development，用户名为 root，无密码
    dsn := "root:@tcp(127.0.0.1:3306)/product_development?parseTime=true"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    defer db.Close() // 确保数据库连接关闭

    // 尝试ping数据库以验证连接
    err = db.Ping()
    if err != nil {
        log.Fatalf("数据库连接失败: %v", err)
    }
    fmt.Println("成功连接到数据库！")

    // 假设 products 表中已有一条 id=1 的记录
    // 可执行以下SQL语句插入测试数据：
    // INSERT INTO products (id, name, is_match, created) VALUES (1, 'Sample Product', 1, NOW());
    rows, err := db.Query("SELECT id, name, is_match, created FROM products WHERE id=1")
    if err != nil {
        log.Fatalf("查询失败: %v", err)
    }
    defer rows.Close() // 确保结果集关闭

    var products []*Product // 用于存储查询结果的Product结构体切片

    for rows.Next() {
        p := new(Product) // 创建一个新的Product实例
        // 扫描当前行的数据到Product结构体字段的地址
        if err := rows.Scan(&p.Id, &p.Name, &p.IsMatch, &p.Created); err != nil {
            log.Printf("扫描行数据失败: %v", err)
            continue // 或者处理错误并退出
        }
        products = append(products, p) // 将填充好的结构体添加到切片
    }

    // 检查在遍历rows过程中是否发生其他错误
    if err = rows.Err(); err != nil {
        log.Fatalf("遍历rows时发生错误: %v", err)
    }

    // 打印查询到的产品信息
    if len(products) > 0 {
        for _, p := range products {
            fmt.Printf("产品ID: %d, 名称: %s, 是否匹配: %t, 创建时间: %s\n",
                p.Id, p.Name, p.IsMatch, p.Created.Format("2006-01-02 15:04:05"))
        }
    } else {
        fmt.