pb连mysql jdbc

syntax = "proto3";

message User {
  int32 id = 1;
  string name = 2;
  int32 age = 3;
}

protoc --java_out=./src ./example.proto

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class PBToMySQLExample {
    public static void main(String[] args) {
        try {
            // 加载JDBC驱动
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 连接数据库
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "user", "password");

            // 创建PreparedStatement
            String sql = "INSERT INTO users (id, name, age) VALUES (?, ?, ?)";
            PreparedStatement pstmt = conn.prepareStatement(sql);

            // 创建PB对象并序列化
            User user = User.newBuilder()
                    .setId(1)
                    .setName("Alice")
                    .setAge(30)
                    .build();

            // 假设我们已经将PB对象序列化为byte数组
            byte[] serializedUser = user.toByteArray();

            // 将byte数组转换为数据库支持的类型（如BLOB）
            pstmt.setBytes(1, serializedUser);
            pstmt.setString(2, user.getName());
            pstmt.setInt(3, user.getAge());

            // 执行SQL
            pstmt.executeUpdate();

            // 关闭连接
            pstmt.close();
            conn.close();
        } catch (ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }
    }
}