sqlite数据库转mysql

import sqlite3
import mysql.connector

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

# 连接到MySQL数据库
mysql_conn = mysql.connector.connect(
    host='your_mysql_host',
    user='your_mysql_username',
    password='your_mysql_password',
    database='your_mysql_database'
)
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"PRAGMA table_info({table_name});")
    columns = sqlite_cursor.fetchall()
    
    # 构建MySQL表结构
    mysql_columns = []
    for column in columns:
        column_name = column[1]
        column_type = column[2]
        
        # 数据类型转换
        if column_type == 'INTEGER PRIMARY KEY':
            mysql_columns.append(f"{column_name} INT AUTO_INCREMENT PRIMARY KEY")
        elif column_type == 'TEXT':
            mysql_columns.append(f"{column_name} TEXT")
        elif column_type == 'REAL':
            mysql_columns.append(f"{column_name} FLOAT")
        else:
            mysql_columns.append(f"{column_name} VARCHAR(255)")
    
    # 创建MySQL表
    create_table_sql = f"CREATE TABLE {table_name} ({', '.join(mysql_columns)});"
    mysql_cursor.execute(create_table_sql)
    
    # 导入数据
    sqlite_cursor.execute(f"SELECT * FROM {table_name};")
    rows = sqlite_cursor.fetchall()
    
    for row in rows:
        placeholders = ', '.join(['%s'] * len(row))
        insert_sql = f"INSERT INTO {table_name} VALUES ({placeholders});"
        mysql_cursor.execute(insert_sql, row)
    
    # 提交事务
    mysql_conn.commit()

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