pb怎么连接mysql

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/go-sql-driver/mysql"
    "github.com/golang/protobuf/proto"
    pb "path/to/your/protobuf/package"
)

func main() {
    // 连接MySQL数据库
    db, err := sql.Open("mysql", "user:password@tcp(localhost:3306)/dbname")
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // 创建PB消息实例
    pbMessage := &pb.YourMessage{
        Field1: "value1",
        Field2: 123,
    }

    // 序列化PB消息
    data, err := proto.Marshal(pbMessage)
    if err != nil {
        panic(err)
    }

    // 将序列化后的数据插入MySQL
    _, err = db.Exec("INSERT INTO your_table (data) VALUES (?)", data)
    if err != nil {
        panic(err)
    }

    // 从MySQL读取数据并反序列化为PB消息
    var result []byte
    err = db.QueryRow("SELECT data FROM your_table LIMIT 1").Scan(&result)
    if err != nil {
        panic(err)
    }

    pbMessage2 := &pb.YourMessage{}
    err = proto.Unmarshal(result, pbMessage2)
    if err != nil {
        panic(err)
    }

    fmt.Printf("Message: %+v\n", pbMessage2)
}