sqlite 转mysql

import sqlite3
import mysql.connector

# 连接到 SQLite 数据库
sqlite_conn = sqlite3.connect('example.db')
sqlite_cursor = sqlite_conn.cursor()

# 连接到 MySQL 数据库
mysql_conn = mysql.connector.connect(
    host='localhost',
    user='your_user',
    password='your_password',
    database='your_database'
)
mysql_cursor = mysql_conn.cursor()

# 获取 SQLite 表结构
sqlite_cursor.execute("PRAGMA table_info(your_table)")
table_info = sqlite_cursor.fetchall()

# 创建 MySQL 表
create_table_sql = f"CREATE TABLE your_table ("
for column in table_info:
    create_table_sql += f"{column[1]} {column[2]}, "
create_table_sql = create_table_sql.rstrip(', ') + ")"
mysql_cursor.execute(create_table_sql)

# 迁移数据
sqlite_cursor.execute("SELECT * FROM your_table")
rows = sqlite_cursor.fetchall()
for row in rows:
    placeholders = ', '.join(['%s'] * len(row))
    insert_sql = f"INSERT INTO your_table VALUES ({placeholders})"
    mysql_cursor.execute(insert_sql, row)

# 提交事务并关闭连接
mysql_conn.commit()
sqlite_conn.close()
mysql_conn.close()