Go语言中将IP地址等二进制数据存储到MySQL的BINARY类型字段

import (
    "database/sql"
    "fmt"
    "net"
    _ "github.com/go-sql-driver/mysql"
)

// ... 假设db已初始化并连接

rangeStart := "66.182.64.0"
rangeEnd := "66.182.64.255"
id := 123

startSlice := net.ParseIP(rangeStart).To4() // 返回 []byte
endSlice := net.ParseIP(rangeEnd).To4()     // 返回 []byte

// 尝试1: 直接传递 []byte
// r, e := db.Exec("UPDATE AIPRangesBlocks SET BinRangeStart = ?, BinRangeEnd = ? WHERE IPGRID = ?", startSlice, endSlice, id)
// 错误信息: sql: converting Exec argument #0's type: unsupported type net.IP, a slice

// 尝试2: 转换为固定大小的 [4]byte 数组
// var startBytes [4]byte
// copy(startBytes[:], startSlice)
// var endBytes [4]byte
// copy(endBytes[:], endSlice)
// r, e := db.Exec("UPDATE AIPRangesBlocks SET BinRangeStart = ?, BinRangeEnd = ? WHERE IPGRID = ?", startBytes, endBytes, id)
// 错误信息: sql: converting Exec argument #0's type: unsupported type [4]uint8, a array

import (
    "encoding/hex"
    // ...
)

// ...
startSlice := net.ParseIP("66.182.64.0").To4() // []byte{66, 182, 64, 0}
hexString := hex.EncodeToString(startSlice) // "42b64000"

// 尝试将 "42b64000" 存入 BINARY(4)
// db.Exec("UPDATE AIPRangesBlocks SET BinRangeStart = ? WHERE IPGRID = ?", hexString, id)
// 结果：数据库中存储的是 '42b6' 的ASCII码对应的二进制值，而不是原始的 {66, 182, 64, 0}
// 取回时可能得到 52 50 98 54 (ASCII for '4','2','b','6')

// 尝试将 "0x42b64000" 存入 BINARY(4)
// db.Exec("UPDATE AIPRangesBlocks SET BinRangeStart = ? WHERE IPGRID = ?", "0x" + hexString, id)
// 结果：数据库中存储的是 '0x42' 的ASCII码对应的二进制值
// 取回时可能得到 48 120 52 50 (ASCII for '0','x','4','2')

package main

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

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

func main() {
    // 假设的数据库连接信息
    // 替换为您的实际连接字符串
    db, err := sql.Open("mysql", "user:password@tcp(127.0.0.1:3306)/database_name")
    if err != nil {
        log.Fatalf("Error opening database: %v", err)
    }
    defer db.Close()

    // 确保连接有效
    err = db.Ping()
    if err != nil {
        log.Fatalf("Error connecting to database: %v", err)
    }
    fmt.Println("Successfully connected to MySQL!")

    // 假设的IP地址和ID
    rangeStartIPStr := "66.182.64.0"
    rangeEndIPStr := "66.182.64.255"
    id := 123 // 假设的IPGRID

    // 解析IP地址并转换为IPv4的[]byte格式
    startSlice := net.ParseIP(rangeStartIPStr).To4()
    endSlice := net.ParseIP(rangeEndIPStr).To4()

    if startSlice == nil || endSlice == nil {
        log.Fatalf("Invalid IP address provided.")
    }

    // 核心解决方案：将 []byte 转换为 string
    // Go语言中的 string 本质上是只读的 []byte 序列。
    // go-sql-driver/mysql 驱动在接收 string 类型的参数时，
    // 如果目标列是 BINARY/VARBINARY，它会将其作为二进制字节流处理，
    // 并正确地将这些字节存储到数据库中，包括处理其中的NUL字节。
    r, e := db.Exec("UPDATE AIPRangesBlocks SET BinRangeStart = ?, BinRangeEnd = ? WHERE IPGRID = ?", string(startSlice), string(endSlice), id)
    if e != nil {
        log.Fatalf("Error updating data: %v", e)
    }

    rowsAffected, _ := r.RowsAffected()
    fmt.Printf("Update successful, rows affected: %d\n", rowsAffected)

    // 验证存储结果 (可选)
    // 当从 BINARY(4) 字段检索数据时，通常会得到 []byte 类型。
    var retrievedStartBytes []byte
    var retrievedEndBytes []byte
    err = db.QueryRow("SELECT BinRangeStart, BinRangeEnd FROM AIPRangesBlocks WHERE IPGRID = ?", id).Scan(&retrievedStartBytes, &retrievedEndBytes)
    if err != nil {
        log.Fatalf("Error retrieving data: %v", err)
    }

    retrievedStartIP := net.IP(retrievedStartBytes)
    retrievedEndIP := net.IP(retrievedEndBytes)
    fmt.Printf("Retrieved Start IP: %s (Raw: %v), End IP: %s (Raw: %v)\n",
        retrievedStartIP.String(), retrievedStartBytes,
        retrievedEndIP.String(), retrievedEndBytes)

    // 确认检索到的数据与原始数据一致
    if retrievedStartIP.Equal(net.ParseIP(rangeStartIPStr)) && retrievedEndIP.Equal(net.ParseIP(rangeEndIPStr)) {
        fmt.Println("Data integrity verified: Retrieved IPs match original IPs.")
    } else {
        fmt.Println("Warning: Retrieved IPs do NOT match original IPs.")
    }
}

/*
假设的MySQL表结构 (用于测试):
CREATE TABLE AIPRangesBlocks (
    IPGRID INT PRIMARY KEY,
    BinRangeStart BINARY(4),
    BinRangeEnd BINARY(4)
);
*/