pb txt导入数据库

import protobuf_module

# 读取PB文件
with open('data.pb', 'rb') as f:
    data = f.read()

# 解析PB文件
message = protobuf_module.MyMessage()
message.ParseFromString(data)

# 打印解析后的数据
print(message)

import sqlite3

# 连接数据库
conn = sqlite3.connect('database.db')
cursor = conn.cursor()

# 创建表
cursor.execute('''
CREATE TABLE IF NOT EXISTS my_table (
    id INTEGER PRIMARY KEY,
    name TEXT,
    age INTEGER
)
''')

# 插入数据
cursor.execute('INSERT INTO my_table (id, name, age) VALUES (?, ?, ?)', (message.id, message.name, message.age))

# 提交事务
conn.commit()

import mysql.connector

# 连接数据库
conn = mysql.connector.connect(
    host='localhost',
    user='username',
    password='password',
    database='mydatabase'
)
cursor = conn.cursor()

# 插入数据
cursor.execute('INSERT INTO my_table (id, name, age) VALUES (%s, %s, %s)', (message.id, message.name, message.age))

# 提交事务
conn.commit()