Go语言中MySQL数据与结构体的映射及行绑定实战

package main

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

// Product 结构体定义，映射 MySQL 的 PRODUCT 表
type Product struct {
    Id      int64
    Name    string
    IsMatch sql.NullBool // tinyint(1) 可以是 NULL，使用 sql.NullBool
    Created sql.NullTime // datetime 可以是 NULL，使用 sql.NullTime
}

func main() {
    // 数据库连接字符串，注意添加 parseTime=true
    // 格式：user:password@tcp(host:port)/dbname?charset=utf8mb4&parseTime=true&loc=Local
    dsn := "root:@tcp(127.0.0.1:3306)/product_development?charset=utf8mb4&parseTime=true&loc=Local"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    defer db.Close() // 确保数据库连接关闭

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

    // 执行查询
    rows, err := db.Query("SELECT id, name, IsMatch, created FROM products WHERE id=1")
    if err != nil {
        log.Fatalf("查询失败: %v", err)
    }
    defer rows.Close() // 确保结果集关闭

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

    // 遍历结果集
    for rows.Next() {
        p := &Product{} // 创建一个新的 Product 实例

        // 使用 rows.Scan 将当前行的数据扫描到结构体字段中
        // 注意字段顺序必须与 SELECT 语句中的列顺序一致
        if err := rows.Scan(&p.Id, &p.Name, &p.IsMatch, &p.Created); err != nil {
            log.Printf("扫描行数据失败: %v", err)
            continue // 可以选择跳过当前行或返回错误
        }
        products = append(products, p)
    }

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

    // 打印查询结果
    if len(products) > 0 {
        for _, p := range products {
            fmt.Printf("Product ID: %d, Name: %s\n", p.Id, p.Name)
            // 访问可空字段时，先检查 Valid
            if p.IsMatch.Valid {
                fmt.Printf("IsMatch: %t\n", p.IsMatch.Bool)
            } else {
                fmt.Println("IsMatch: NULL")
            }
            if p.Created.Valid {
                fmt.Printf("Created: %s\n", p.Created.Time.Format(time.RFC3339))
            } else {
                fmt.Println("Created: NULL")
            }
            fmt.Println("---")
        }
    } else {
        fmt.Println("未找到产品。")
    }
}

CREATE DATABASE IF NOT EXISTS product_development;
USE product_development;

CREATE TABLE IF NOT EXISTS products (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255) NOT NULL,
    IsMatch TINYINT(1) NULL, -- 允许为 NULL
    created DATETIME NULL     -- 允许为 NULL
);

-- 插入一些测试数据
INSERT INTO products (name, IsMatch, created) VALUES ('Product A', 1, NOW());
INSERT INTO products (name, IsMatch, created) VALUES ('Product B', 0, '2023-01-15 10:30:00');
INSERT INTO products (name, IsMatch, created) VALUES ('Product C', NULL, NULL);