把数据库转换为mysql

import sqlite3
import mysql.connector

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

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

# 获取SQLite数据库中的所有表名
sqlite_cursor.execute("SELECT name FROM sqlite_master WHERE type='table';")
tables = sqlite_cursor.fetchall()

# 迁移每个表的结构和数据
for table in tables:
    table_name = table[0]
    
    # 获取表结构
    sqlite_cursor.execute(f"SELECT sql FROM sqlite_master WHERE type='table' AND name='{table_name}';")
    create_table_sql = sqlite_cursor.fetchone()[0]
    
    # 创建MySQL表
    mysql_cursor.execute(create_table_sql)
    
    # 获取表数据
    sqlite_cursor.execute(f"SELECT * FROM {table_name};")
    rows = sqlite_cursor.fetchall()
    
    # 插入数据到MySQL表
    for row in rows:
        placeholders = ', '.join(['%s'] * len(row))
        columns = ', '.join(row.keys())
        insert_sql = f"INSERT INTO {table_name} ({columns}) VALUES ({placeholders});"
        mysql_cursor.execute(insert_sql, row)
    
    # 提交事务
    mysql_conn.commit()

# 关闭连接
sqlite_conn.close()
mysql_conn.close()