Go语言MySQL数据类型映射与数据行绑定实践指南

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

package main

import (
    "database/sql"
    "time"
)

// Product 结构体定义，用于映射products表
type Product struct {
    Id      int64         // 对应MySQL的id INT
    Name    string        // 对应MySQL的name VARCHAR(255)
    IsMatch sql.NullBool  // 对应MySQL的IsMatch TINYINT(1)，可为NULL
    Created sql.NullTime  // 对应MySQL的created DATETIME，可为NULL
}

package main

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

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

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

func main() {
    // 数据库连接字符串
    // 注意：需要替换为你的实际数据库信息
    // parseTime=true 是将MySQL的DATETIME/TIMESTAMP解析为Go的time.Time的关键
    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("成功连接到MySQL数据库！")

    // 假设products表中有数据，例如：
    // INSERT INTO products (name, IsMatch, created) VALUES ('Laptop', 1, NOW());
    // INSERT INTO products (name, IsMatch, created) VALUES ('Mouse', 0, NOW());
    // INSERT INTO products (name, IsMatch, created) VALUES ('Keyboard', NULL, NULL);

    // 执行查询
    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实例
        // 将当前行的数据扫描到Product结构体的字段中
        // 注意：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) // 将Product实例添加到切片中
    }

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

    // 打印查询结果
    if len(products) > 0 {
        fmt.Println("\n查询结果:")
        for _, p := range products {
            fmt.Printf("ID: %d, Name: %s", p.Id, p.Name)
            if p.IsMatch.Valid {
                fmt.Printf(", IsMatch: %t", p.IsMatch.Bool)
            } else {
                fmt.Printf(", IsMatch: NULL")
            }
            if p.Created.Valid {
                fmt.Printf(", Created: %s", p.Created.Time.Format(time.RFC3339))
            } else {
                fmt.Printf(", Created: NULL")
            }
            fmt.Println()
        }
    } else {
        fmt.Println("未找到匹配的产品。")
    }
}