sqllite 转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='user',
    password='password',
    database='example_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]
    
    # 创建 MySQL 表
    sqlite_cursor.execute(f"PRAGMA table_info({table_name});")
    columns = sqlite_cursor.fetchall()
    column_defs = ', '.join([f"{col[1]} {map_sqlite_to_mysql(col[2])}" for col in columns])
    mysql_cursor.execute(f"CREATE TABLE {table_name} ({column_defs});")
    
    # 插入数据
    sqlite_cursor.execute(f"SELECT * FROM {table_name};")
    rows = sqlite_cursor.fetchall()
    for row in rows:
        placeholders = ', '.join(['%s'] * len(row))
        mysql_cursor.execute(f"INSERT INTO {table_name} VALUES ({placeholders});", row)

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

def map_sqlite_to_mysql(sqlite_type):
    if 'TEXT' in sqlite_type:
        return 'VARCHAR(255)'
    elif 'INTEGER' in sqlite_type:
        return 'INT'
    elif 'REAL' in sqlite_type:
        return 'FLOAT'
    else:
        return 'VARCHAR(255)'