pb创建mysql数据库连接

syntax = "proto3";

package example;

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

protoc --python_out=. user.proto

import mysql.connector
from user_pb2 import User

# 创建MySQL连接
db = mysql.connector.connect(
    host="localhost",
    user="your_username",
    password="your_password",
    database="your_database"
)

cursor = db.cursor()

# 创建表
cursor.execute("CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)")

# 创建PB对象并插入数据
user = User()
user.id = 1
user.name = "Alice"
user.age = 30

# 序列化PB对象
user_data = user.SerializeToString()

# 插入数据到MySQL
cursor.execute("INSERT INTO users (name, age) VALUES (%s, %s)", (user.name, user.age))
db.commit()

# 关闭连接
cursor.close()
db.close()