mysql数据导入sqlite

import mysql.connector
import sqlite3

# 连接MySQL数据库
mysql_conn = mysql.connector.connect(
    host="localhost",
    user="username",
    password="password",
    database="database_name"
)
mysql_cursor = mysql_conn.cursor()

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

# 获取MySQL表结构
mysql_cursor.execute("SHOW TABLES")
tables = mysql_cursor.fetchall()

for table in tables:
    table_name = table[0]
    # 创建SQLite表
    mysql_cursor.execute(f"SHOW CREATE TABLE {table_name}")
    create_table_sql = mysql_cursor.fetchone()[1]
    create_table_sql = create_table_sql.replace("`", "\"")
    sqlite_cursor.execute(create_table_sql)

    # 导入数据
    mysql_cursor.execute(f"SELECT * FROM {table_name}")
    rows = mysql_cursor.fetchall()
    sqlite_cursor.executemany(f"INSERT INTO {table_name} VALUES ({','.join(['?']*len(rows[0]))})", rows)

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