Go语言中MySQL数据类型与结构体映射及查询结果绑定实战教程

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

package main

import (
    "time"
    // "database/sql" // 如果需要处理NULL值，则引入
)

// Product 结构体定义，字段名通常与数据库列名大小写不敏感匹配
type Product struct {
    Id      int64     // MySQL int 映射为 Go int64
    Name    string    // MySQL varchar(255) 映射为 Go string
    IsMatch bool      // MySQL tinyint(1) 映射为 Go bool
    Created time.Time // MySQL datetime 映射为 Go time.Time
}

// 如果 IsMatch 和 Created 字段可能为 NULL，则结构体定义如下：
/*
type Product struct {
    Id      int64
    Name    string
    IsMatch sql.NullBool
    Created sql.NullTime
}
*/

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql" // 导入 MySQL 驱动，下划线表示只导入包进行初始化，不直接使用其导出成员
)

// DSN (Data Source Name) 示例
// "user:password@tcp(host:port)/dbname?charset=utf8mb4&parseTime=true&loc=Local"
// 注意：parseTime=true 是将 MySQL datetime/timestamp 转换为 Go time.Time 的关键
// loc=Local 可以确保时间以本地时区解析
dsn := "root:@tcp(127.0.0.1:3306)/product_development?parseTime=true&loc=Local"
db, err := sql.Open("mysql", dsn)
if err != nil {
    // 错误处理
    panic(err.Error())
}
defer db.Close() // 确保在函数结束时关闭数据库连接

// 验证数据库连接是否有效
err = db.Ping()
if err != nil {
    panic(err.Error())
}
fmt.Println("成功连接到MySQL数据库!")

package main

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

// Product 结构体定义，假设 IsMatch 和 Created 字段在数据库中为 NOT NULL
type Product struct {
    Id      int64
    Name    string
    IsMatch bool
    Created time.Time
}

func main() {
    // 1. 数据库连接配置
    // 注意：DSN中添加 parseTime=true 以便将 MySQL datetime/timestamp 自动解析为 Go time.Time
    // loc=Local 确保时间以本地时区解析
    dsn := "root:@tcp(127.0.0.1:3306)/product_development?parseTime=true&loc=Local"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err) // 使用 log.Fatalf 替代 panic
    }
    defer db.Close() // 确保在 main 函数结束时关闭数据库连接

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

    // 3. 查询数据并绑定到结构体
    // 假设查询 id 为 1 的产品
    products, err := getProducts(db, 1)
    if err != nil {
        log.Fatalf("查询产品失败: %v", err)
    }

    if len(products) > 0 {
        fmt.Printf("查询到产品信息 (ID: %d): %+v\n", products[0].Id, products[0])
    } else {
        fmt.Println("未查询到指定产品。")
    }

    // 4. 查询所有产品示例
    allProducts, err := getAllProducts(db)
    if err != nil {
        log.Fatalf("查询所有产品失败: %v", err)
    }
    fmt.Printf("\n所有产品数量: %d\n", len(allProducts))
    for _, p := range allProducts {
        fmt.Printf("产品: ID=%d, Name=%s, IsMatch=%t, Created=%s\n", p.Id, p.Name, p.IsMatch, p.Created.Format("2006-01-02 15:04:05"))
    }
}

// getProducts 函数封装查询单个产品的逻辑
func getProducts(db *sql.DB, id int64) ([]*Product, error) {
    // 明确指定要查询的列，以避免 SELECT * 带来的潜在问题
    query := "SELECT id, name, IsMatch, created FROM products WHERE id = ?"
    rows, err := db.Query(query, id)
    if err != nil {
        return nil, fmt.Errorf("执行查询失败: %w", err)
    }
    defer rows.Close() // 确保在函数退出时关闭行结果集

    var products []*Product
    for rows.Next() {
        p := &Product{} // 创建新的 Product 实例
        // 使用 rows.Scan 将查询结果绑定到结构体字段
        err := rows.Scan(&p.Id, &p.Name, &p.IsMatch, &p.Created)
        if err != nil {
            return nil, fmt.Errorf("扫描行数据失败: %w", err)
        }
        products = append(products, p)
    }

    // 检查迭代过程中是否出现错误
    if err = rows.Err(); err != nil {
        return nil, fmt.Errorf("遍历查询结果时发生错误: %w", err)
    }

    return products, nil
}

// getAllProducts 函数封装查询所有产品的逻辑
func getAllProducts(db *sql.DB) ([]*Product, error) {
    query := "SELECT id, name, IsMatch, created FROM products"
    rows, err := db.Query(query)
    if err != nil {
        return nil, fmt.Errorf("执行查询所有产品失败: %w", err)
    }
    defer rows.Close()

    var products []*Product
    for rows.Next() {
        p := &Product{}
        err := rows.Scan(&p.Id, &p.Name, &p.IsMatch, &p.Created)
        if err != nil {
            return nil, fmt.Errorf("扫描所有产品行数据失败: %w", err)
        }
        products = append(products, p)
    }

    if err = rows.Err(); err != nil {
        return nil, fmt.Errorf("遍历所有产品查询结果时发生错误: %w", err)
    }

    return products, nil
}

-- 创建数据库
CREATE DATABASE IF NOT EXISTS product_development;

-- 使用数据库
USE product_development;

-- 创建产品表
CREATE TABLE IF NOT EXISTS products (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(255) NOT NULL,
    IsMatch TINYINT(1) NOT NULL,
    created DATETIME NOT NULL
);

-- 插入一些示例数据
INSERT INTO products (name, IsMatch, created) VALUES ('Laptop Pro', 1, NOW());
INSERT INTO products (name, IsMatch, created) VALUES ('Keyboard X', 0, '2023-01-15 10:30:00');
INSERT INTO products (name, IsMatch, created) VALUES ('Mouse Z', 1, '2023-02-20 14:00:00');