如何在Go语言中高效地将二进制数据存储到MySQL的BINARY列

package main

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

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

func main() {
    // 1. 配置数据库连接
    // 请替换为您的实际数据库连接字符串
    // 格式: "user:password@tcp(127.0.0.1:3306)/database_name?charset=utf8mb4&parseTime=True&loc=Local"
    dsn := "root:password@tcp(127.0.0.1:3306)/testdb?charset=utf8mb4&parseTime=True&loc=Local"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        log.Fatalf("无法连接到数据库: %v", err)
    }
    defer db.Close()

    // 2. 确保数据库表结构正确
    // 假设您有一个名为 'AIPRangesBlocks' 的表，其中包含 BINARY(4) 类型的列
    // 示例DDL:
    // CREATE TABLE IF NOT EXISTS AIPRangesBlocks (
    //     IPGRID INT PRIMARY KEY AUTO_INCREMENT,
    //     BinRangeStart BINARY(4) NOT NULL,
    //     BinRangeEnd BINARY(4) NOT NULL
    // );
    // 为了演示，这里假设IPGRID=1的记录已存在，我们将更新它。
    // 如果是插入新记录，请使用 INSERT INTO ... VALUES (?, ?, ?)
    _, err = db.Exec(`
        CREATE TABLE IF NOT EXISTS AIPRangesBlocks (
            IPGRID INT PRIMARY KEY AUTO_INCREMENT,
            BinRangeStart BINARY(4) NOT NULL,
            BinRangeEnd BINARY(4) NOT NULL
        );
    `)
    if err != nil {
        log.Fatalf("创建表失败: %v", err)
    }

    // 确保有一条记录可以更新
    _, err = db.Exec("INSERT IGNORE INTO AIPRangesBlocks (IPGRID, BinRangeStart, BinRangeEnd) VALUES (?, ?, ?)", 1, string([]byte{0,0,0,0}), string([]byte{0,0,0,0}))
    if err != nil {
        log.Fatalf("插入初始记录失败: %v", err)
    }


    // 3. 准备IP地址数据
    rangeStartStr := "66.182.64.0"
    rangeEndStr := "66.182.64.255"
    ipGridID := 1 // 假设要更新的记录ID

    // 解析IP地址并转换为4字节切片
    startSlice := net.ParseIP(rangeStartStr).To4()
    if startSlice == nil {
        log.Fatalf("无效的起始IP地址: %s", rangeStartStr)
    }
    endSlice := net.ParseIP(rangeEndStr).To4()
    if endSlice == nil {
        log.Fatalf("无效的结束IP地址: %s", rangeEndStr)
    }

    fmt.Printf("原始起始IP: %s -> 字节: %v\n", rangeStartStr, startSlice) // [66 182 64 0]
    fmt.Printf("原始结束IP: %s -> 字节: %v\n", rangeEndStr, endSlice)   // [66 182 64 255]

    // 4. 存储二进制数据：将 []byte 转换为 string
    // 这是解决问题的关键步骤。MySQL驱动会正确处理这个字符串作为二进制数据。
    updateQuery := "UPDATE AIPRangesBlocks SET BinRangeStart = ?, BinRangeEnd = ? WHERE IPGRID = ?"
    result, err := db.Exec(updateQuery, string(startSlice), string(endSlice), ipGridID)
    if err != nil {
        log.Fatalf("执行更新失败: %v", err)
    }

    rowsAffected, _ := result.RowsAffected()
    fmt.Printf("成功更新 %d 行。\n", rowsAffected)

    // 5. 验证数据检索
    var retrievedStart, retrievedEnd []byte
    selectQuery := "SELECT BinRangeStart, BinRangeEnd FROM AIPRangesBlocks WHERE IPGRID = ?"
    err = db.QueryRow(selectQuery, ipGridID).Scan(&retrievedStart, &retrievedEnd)
    if err != nil {
        log.Fatalf("检索数据失败: %v", err)
    }

    fmt.Printf("检索到的起始IP字节: %v -> IP: %s\n", retrievedStart, net.IP(retrievedStart).String())
    fmt.Printf("检索到的结束IP字节: %v -> IP: %s\n", retrievedEnd, net.IP(retrievedEnd).String())

    // 验证数据是否一致
    if net.IP(retrievedStart).String() == rangeStartStr && net.IP(retrievedEnd).String() == rangeEndStr {
        fmt.Println("数据存储和检索成功，且数据一致。")
    } else {
        fmt.Println("数据存储或检索出现问题，数据不一致。")
    }
}